Struct protos::sp_pipeline::PipelineStep

pub struct PipelineStep {
    pub name: String,
    pub on_success: Vec<EnumOrUnknown<PipelineStepCondition>>,
    pub on_failure: Vec<EnumOrUnknown<PipelineStepCondition>>,
    pub _wasm_id: Option<String>,
    pub _wasm_bytes: Option<Vec<u8>>,
    pub _wasm_function: Option<String>,
    pub step: Option<Step>,
    pub special_fields: SpecialFields,
}

A pipeline step is a single step in a pipeline.

Fields

name: String

Friendly name for the step

on_success: Vec<EnumOrUnknown<PipelineStepCondition>>

SDKs should read this when WASM returns success to determine what to do next

on_failure: Vec<EnumOrUnknown<PipelineStepCondition>>

SDKs should read this when WASM returns failure to determine what to do next

_wasm_id: Option<String>

ID is a uuid(sha256(_wasm_bytes)) that is set by snitch-server

_wasm_bytes: Option<Vec<u8>>

WASM module bytes (set by snitch-server)

_wasm_function: Option<String>

WASM function name to execute (set by snitch-server)

step: Option<Step>

special_fields: SpecialFields

Implementations

impl PipelineStep

pub fn new() -> PipelineStep

pub fn detective(&self) -> &DetectiveStep

pub fn clear_detective(&mut self)

pub fn has_detective(&self) -> bool

pub fn set_detective(&mut self, v: DetectiveStep)

pub fn mut_detective(&mut self) -> &mut DetectiveStep

pub fn take_detective(&mut self) -> DetectiveStep

pub fn transform(&self) -> &TransformStep

pub fn clear_transform(&mut self)

pub fn has_transform(&self) -> bool

pub fn set_transform(&mut self, v: TransformStep)

pub fn mut_transform(&mut self) -> &mut TransformStep

pub fn take_transform(&mut self) -> TransformStep

pub fn encode(&self) -> &EncodeStep

pub fn clear_encode(&mut self)

pub fn has_encode(&self) -> bool

pub fn set_encode(&mut self, v: EncodeStep)

pub fn mut_encode(&mut self) -> &mut EncodeStep

pub fn take_encode(&mut self) -> EncodeStep

pub fn decode(&self) -> &DecodeStep

pub fn clear_decode(&mut self)

pub fn has_decode(&self) -> bool

pub fn set_decode(&mut self, v: DecodeStep)

pub fn mut_decode(&mut self) -> &mut DecodeStep

pub fn take_decode(&mut self) -> DecodeStep

pub fn custom(&self) -> &CustomStep

pub fn clear_custom(&mut self)

pub fn has_custom(&self) -> bool

pub fn set_custom(&mut self, v: CustomStep)

pub fn mut_custom(&mut self) -> &mut CustomStep

pub fn take_custom(&mut self) -> CustomStep

pub fn http_request(&self) -> &HttpRequestStep

pub fn clear_http_request(&mut self)

pub fn has_http_request(&self) -> bool

pub fn set_http_request(&mut self, v: HttpRequestStep)

pub fn mut_http_request(&mut self) -> &mut HttpRequestStep

pub fn take_http_request(&mut self) -> HttpRequestStep

pub fn kv(&self) -> &KVStep

pub fn clear_kv(&mut self)

pub fn has_kv(&self) -> bool

pub fn set_kv(&mut self, v: KVStep)

pub fn mut_kv(&mut self) -> &mut KVStep

pub fn take_kv(&mut self) -> KVStep

pub fn infer_schema(&self) -> &InferSchemaStep

pub fn clear_infer_schema(&mut self)

pub fn has_infer_schema(&self) -> bool

pub fn set_infer_schema(&mut self, v: InferSchemaStep)

pub fn mut_infer_schema(&mut self) -> &mut InferSchemaStep

pub fn take_infer_schema(&mut self) -> InferSchemaStep

Trait Implementations

impl Clone for PipelineStep

fn clone(&self) -> PipelineStep

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PipelineStep

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a> Default for &'a PipelineStep

fn default() -> &'a PipelineStep

Returns the “default value” for a type.

impl Default for PipelineStep

fn default() -> PipelineStep

Returns the “default value” for a type.

impl Display for PipelineStep

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Message for PipelineStep

const NAME: &'static str = "PipelineStep"

Message name as specified in .proto file.

fn is_initialized(&self) -> bool

True iff all required fields are initialized. Always returns true for protobuf 3.

fn merge_from(&mut self, is: &mut CodedInputStream<'_>) -> Result<()>

Update this message object with fields read from given stream.

fn compute_size(&self) -> u64

Compute and cache size of this message and all nested messages.

fn write_to_with_cached_sizes( &self, os: &mut CodedOutputStream<'_> ) -> Result<()>

Write message to the stream.

fn special_fields(&self) -> &SpecialFields

Special fields (unknown fields and cached size).

fn mut_special_fields(&mut self) -> &mut SpecialFields

Special fields (unknown fields and cached size).

fn new() -> PipelineStep

Create an empty message object.

fn clear(&mut self)

Reset all fields.

fn default_instance() -> &'static PipelineStep

Return a pointer to default immutable message with static lifetime.

fn parse_from(is: &mut CodedInputStream<'_>) -> Result<Self, Error>

Parse message from stream.

fn cached_size(&self) -> u32

Get size previously computed by compute_size.

fn write_to(&self, os: &mut CodedOutputStream<'_>) -> Result<(), Error>

Write the message to the stream.

fn write_length_delimited_to( &self, os: &mut CodedOutputStream<'_> ) -> Result<(), Error>

Write the message to the stream prepending the message with message length encoded as varint.

fn write_length_delimited_to_vec(&self, vec: &mut Vec<u8>) -> Result<(), Error>

Write the message to the vec, prepend the message with message length encoded as varint.

fn merge_from_bytes(&mut self, bytes: &[u8]) -> Result<(), Error>

Update this message object with fields read from given stream.

fn parse_from_reader(reader: &mut dyn Read) -> Result<Self, Error>

Parse message from reader. Parse stops on EOF or when error encountered.

fn parse_from_bytes(bytes: &[u8]) -> Result<Self, Error>

Parse message from byte array.

fn check_initialized(&self) -> Result<(), Error>

Check if all required fields of this object are initialized.

fn write_to_writer(&self, w: &mut dyn Write) -> Result<(), Error>

Write the message to the writer.

fn write_to_vec(&self, v: &mut Vec<u8>) -> Result<(), Error>

Write the message to bytes vec.

fn write_to_bytes(&self) -> Result<Vec<u8>, Error>

Write the message to bytes vec.

fn write_length_delimited_to_writer( &self, w: &mut dyn Write ) -> Result<(), Error>

Write the message to the writer, prepend the message with message length encoded as varint.

fn write_length_delimited_to_bytes(&self) -> Result<Vec<u8>, Error>

Write the message to the bytes vec, prepend the message with message length encoded as varint.

fn unknown_fields(&self) -> &UnknownFields

Get a reference to unknown fields.

fn mut_unknown_fields(&mut self) -> &mut UnknownFields

Get a mutable reference to unknown fields.

impl MessageFull for PipelineStep

fn descriptor() -> MessageDescriptor

Get message descriptor for message type.

fn reflect_eq(&self, other: &Self, mode: &ReflectEqMode) -> bool

Reflective equality.

impl PartialEq for PipelineStep

fn eq(&self, other: &PipelineStep) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl ProtobufValue for PipelineStep

type RuntimeType = RuntimeTypeMessage<PipelineStep>

Actual implementation of type properties.

impl StructuralPartialEq for PipelineStep