embedded

Documentation

Index

• type CallbackFunc
• type EmbeddedOptionFunc
  • func WithCallbackFunc(callbackFunc CallbackFunc) EmbeddedOptionFunc
  • func WithOutputChan(outputChan chan event.Event) EmbeddedOptionFunc
• type EmbeddedOutput
  • func New(options ...EmbeddedOptionFunc) *EmbeddedOutput
  • func (e *EmbeddedOutput) ErrorChan() chan error
  • func (e *EmbeddedOutput) InputChan() chan<- event.Event
  • func (e *EmbeddedOutput) OutputChan() <-chan event.Event
  • func (e *EmbeddedOutput) Start() error
  • func (e *EmbeddedOutput) Stop() error

Types

type CallbackFunc

type CallbackFunc func(event.Event) error

type EmbeddedOptionFunc

type EmbeddedOptionFunc func(*EmbeddedOutput)

func WithCallbackFunc

func WithCallbackFunc(callbackFunc CallbackFunc) EmbeddedOptionFunc

WithCallbackFunc specifies a callback function for events

func WithOutputChan

func WithOutputChan(outputChan chan event.Event) EmbeddedOptionFunc

WithOutputChan specifies an event.Event channel to use for events

type EmbeddedOutput

type EmbeddedOutput struct {
	// contains filtered or unexported fields
}

func New

func New(options ...EmbeddedOptionFunc) *EmbeddedOutput

func (*EmbeddedOutput) ErrorChan

func (e *EmbeddedOutput) ErrorChan() chan error

ErrorChan returns the input error channel

func (*EmbeddedOutput) InputChan

func (e *EmbeddedOutput) InputChan() chan<- event.Event

InputChan returns the input event channel

func (*EmbeddedOutput) OutputChan

func (e *EmbeddedOutput) OutputChan() <-chan event.Event

OutputChan always returns nil

func (*EmbeddedOutput) Start

func (e *EmbeddedOutput) Start() error

Start the embedded output

func (*EmbeddedOutput) Stop

func (e *EmbeddedOutput) Stop() error

Stop the embedded output