consumer

Documentation

Index

• func SinkConsumerFunc(cons jetstream.Consumer, sinkPath string)
• type MessageData
• type SinkConsumer
  • func NewSinkCunsumer(nc *nats.Conn, sinkPath string) *SinkConsumer
  • func (c *SinkConsumer) PeriodSched(js jetstream.JetStream)
  • func (c *SinkConsumer) Start()

Functions

func SinkConsumerFunc

func SinkConsumerFunc(cons jetstream.Consumer, sinkPath string)

Types

type MessageData

type MessageData struct {
	Data []byte
	Msg  jetstream.Msg
}

type SinkConsumer

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

func NewSinkCunsumer

func NewSinkCunsumer(nc *nats.Conn, sinkPath string) *SinkConsumer

func (*SinkConsumer) PeriodSched

func (c *SinkConsumer) PeriodSched(js jetstream.JetStream)

func (*SinkConsumer) Start

func (c *SinkConsumer) Start()

Consume from EventStream, sink event into json file (time-slice algo)