js_subscriber

Documentation

Index

• type JetStreamSubscriber
  • func NewJetstreamSubscriber(configuration *env.Configuration, logger *zap.SugaredLogger, ...) *JetStreamSubscriber
  • func (s *JetStreamSubscriber) Subscribe()
• type Subscriber

Types

type JetStreamSubscriber

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

func NewJetstreamSubscriber

func NewJetstreamSubscriber(configuration *env.Configuration, logger *zap.SugaredLogger, js jetstream.JetStream) *JetStreamSubscriber

func (*JetStreamSubscriber) Subscribe

func (s *JetStreamSubscriber) Subscribe()

type Subscriber

type Subscriber interface {
	Subscribe()
}