Trait device_connector::element::ElementBuildable

pub trait ElementBuildable: Sized + Send + 'static {
    type Config: DeserializeOwned;

    const NAME: &'static str;
    const RECV_PORTS: Port = 0u8;
    const SEND_PORTS: Port = 0u8;

    fn new(conf: Self::Config) -> Result<Self, Error>;
    fn next(
        &mut self,
        pipeline: &mut Pipeline,
        receiver: &mut MsgReceiver
    ) -> ElementResult;

    fn acceptable_msg_types() -> Vec<Vec<MsgType>> { ... }
    fn finalizer(&mut self) -> Result<Option<ElementFinalizer>, Error> { ... }
}

Buildable element from config.

Required Associated Types

type Config: DeserializeOwned

Configuration type for this element

Required Associated Constants

const NAME: &'static str

Name of this element. Must be unique in elements

Provided Associated Constants

const RECV_PORTS: Port = 0u8

The number of receiving ports

const SEND_PORTS: Port = 0u8

The number of sending ports

Required Methods

fn new(conf: Self::Config) -> Result<Self, Error>

Create element from config

fn next(
    &mut self,
    pipeline: &mut Pipeline,
    receiver: &mut MsgReceiver
) -> ElementResult

Get message from receiver and returns the result of this element.

Provided Methods

fn acceptable_msg_types() -> Vec<Vec<MsgType>>

Returns acceptable message type of this element

fn finalizer(&mut self) -> Result<Option<ElementFinalizer>, Error>

Returns the finalizer of this element

Implementors

impl ElementBuildable for FileSinkElement

type Config = FileSinkElementConf

const NAME: &'static str = "file-sink"

const RECV_PORTS: Port = 1u8

impl ElementBuildable for FileSrcElement

type Config = FileSrcElementConf

const NAME: &'static str = "file-src"

const SEND_PORTS: Port = 1u8

impl ElementBuildable for JsonSplitFilterElement

type Config = JsonSplitFilterElementConfig

const NAME: &'static str = "json-split-filter"

const RECV_PORTS: Port = 1u8

const SEND_PORTS: Port = 1u8

impl ElementBuildable for NullSinkElement

type Config = EmptyElementConf

const NAME: &'static str = "null-sink"

const RECV_PORTS: Port = 32u8

impl ElementBuildable for PrintLogFilterElement

type Config = PrintLogFilterElementConf

const NAME: &'static str = "print-log-filter"

const RECV_PORTS: Port = 1u8

const SEND_PORTS: Port = 1u8

impl ElementBuildable for ProcessSrcElement

type Config = ProcessSrcElementConf

const NAME: &'static str = "process-src"

const SEND_PORTS: Port = 1u8

impl ElementBuildable for RepeatProcessSrcElement

type Config = RepeatProcessSrcElementConf

const NAME: &'static str = "repeat-process-src"

const SEND_PORTS: Port = 1u8

impl ElementBuildable for SplitByDelimiterFilterElement

type Config = SplitByDelimiterFilterElementConfig

const NAME: &'static str = "split-by-delimiter-filter"

const RECV_PORTS: Port = 1u8

const SEND_PORTS: Port = 1u8

impl ElementBuildable for SplitByFixedSizeFilterElement

type Config = SplitByFixedSizeFilterElementConfig

const NAME: &'static str = "split-by-fixed-size-filter"

const RECV_PORTS: Port = 1u8

const SEND_PORTS: Port = 1u8

impl ElementBuildable for StatFilterElement

type Config = StatFilterElementConf

const NAME: &'static str = "stat-filter"

const RECV_PORTS: Port = 1u8

const SEND_PORTS: Port = 1u8

impl ElementBuildable for StdoutSinkElement

type Config = StdoutSinkElementConf

const NAME: &'static str = "stdout-sink"

const RECV_PORTS: Port = 1u8

impl ElementBuildable for TeeFilterElement

type Config = TeeFilterElementConf

const NAME: &'static str = "tee-filter"

const SEND_PORTS: Port = 1u8

const RECV_PORTS: Port = 1u8

impl ElementBuildable for TeeSrcElement

type Config = TeeSrcElementConf

const NAME: &'static str = "tee-src"

const SEND_PORTS: Port = 1u8

impl ElementBuildable for TextSrcElement

type Config = TextSrcElementConf

const NAME: &'static str = "text-src"

const SEND_PORTS: Port = 1u8