jetstream

Documentation

Index

• type JetStreamSink
  • func New(name string, v *viper.Viper) (s *JetStreamSink, err error)
  • func (s *JetStreamSink) Close() error
  • func (s *JetStreamSink) Name() string
  • func (s *JetStreamSink) ProcessEventsBatch(events []event.Event) error
  • func (s *JetStreamSink) SetLogger(l *common.Logger)
  • func (s *JetStreamSink) Stats() string
  • func (s *JetStreamSink) Status() error
  • func (s *JetStreamSink) Type() string

Types

type JetStreamSink

type JetStreamSink struct {
	*common.Logger
	// contains filtered or unexported fields
}

stub: s *JetStreamSink sink.Sink JetStreamSink ...

func New

func New(name string, v *viper.Viper) (s *JetStreamSink, err error)

New creates a new JetStream sink

func (*JetStreamSink) Close

func (s *JetStreamSink) Close() error

func (*JetStreamSink) Name

func (s *JetStreamSink) Name() string

func (*JetStreamSink) ProcessEventsBatch

func (s *JetStreamSink) ProcessEventsBatch(events []event.Event) error

func (*JetStreamSink) SetLogger

func (s *JetStreamSink) SetLogger(l *common.Logger)

SetLogger sets a logger

func (*JetStreamSink) Stats

func (s *JetStreamSink) Stats() string

func (*JetStreamSink) Status

func (s *JetStreamSink) Status() error

func (*JetStreamSink) Type

func (s *JetStreamSink) Type() string