sub

Documentation

Index

• type JetStreamOpts
• type JetStreamSub
  • func NewJetStreamSub(o JetStreamOpts) (*JetStreamSub, error)
  • func (s *JetStreamSub) Close()
  • func (s *JetStreamSub) Process() error

Types

type JetStreamOpts

type JetStreamOpts struct {
	Endpoint        string
	JetStreamID     string
	Store           store.Store
	Logg            *slog.Logger
	WorkerContainer *worker.WorkerContainer
}

type JetStreamSub

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

func NewJetStreamSub

func NewJetStreamSub(o JetStreamOpts) (*JetStreamSub, error)

func (*JetStreamSub) Close

func (s *JetStreamSub) Close()

func (*JetStreamSub) Process

func (s *JetStreamSub) Process() error