sub

Documentation

Index

• type Sub
  • func NewSub(o SubObts) (*Sub, error)
  • func (s *Sub) Close()
  • func (s *Sub) Process()
• type SubObts

Types

type Sub

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

func NewSub

func NewSub(o SubObts) (*Sub, error)

func (*Sub) Close

func (s *Sub) Close()

func (*Sub) Process

func (s *Sub) Process()

type SubObts

type SubObts struct {
	Store      store.Store
	JS         jetstream.JetStream
	ConsumerID string
	Pub        *pub.Pub
	Logg       *slog.Logger
}