producer

Documentation

Index

• type ProduceArgs
• type ProducerInterface
• type ProducerMessage

Types

type ProduceArgs

type ProduceArgs struct {
	Src            netip.AddrPort
	Dst            netip.AddrPort
	SamplerAddress netip.Addr
	TimeReceived   time.Time
}

type ProducerInterface

type ProducerInterface interface {
	// Converts a message into a list of flow samples
	Produce(msg interface{}, args *ProduceArgs) ([]ProducerMessage, error)
	// Indicates to the producer the messages returned were processed
	Commit([]ProducerMessage)
	Close()
}

type ProducerMessage

type ProducerMessage interface{}

Interface of the messages