sender

Documentation

Index

• func NewSender(cfg *api.SenderConfig) api.Sender
• type Sender
  • func (s *Sender) Boot(ctx context.Context)
  • func (s *Sender) InputDataChannel(partition int) chan<- *event.OutputEventContext
  • func (s *Sender) Prepare() error
  • func (s *Sender) SetGatherer(m module.Module) error
  • func (s *Sender) Shutdown()
  • func (s *Sender) SyncInvoke(d *v1.SniffData) (*v1.SniffData, error)

Functions

func NewSender

func NewSender(cfg *api.SenderConfig) api.Sender

NewSender crate a Sender.

Types

type Sender

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

Sender is the forward module in Satellite.

func (*Sender) Boot

func (s *Sender) Boot(ctx context.Context)

Boot fetches the downstream partitioned input data and forward to external services, such as Kafka and OAP receiver.

func (*Sender) InputDataChannel

func (s *Sender) InputDataChannel(partition int) chan<- *event.OutputEventContext

func (*Sender) Prepare

func (s *Sender) Prepare() error

Prepare register the client status listener to the client manager and open partitioned input channel.

func (*Sender) SetGatherer

func (s *Sender) SetGatherer(m module.Module) error

func (*Sender) Shutdown

func (s *Sender) Shutdown()

Shutdown closes the channels and tries to force forward the events in the buffer.

func (*Sender) SyncInvoke

func (s *Sender) SyncInvoke(d *v1.SniffData) (*v1.SniffData, error)