sub

Documentation

Index

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

Types

type Sub

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

func NewSub

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

func (*Sub) Close

func (s *Sub) Close()

func (*Sub) Process

func (s *Sub) Process() error

type SubOpts

type SubOpts struct {
	JsCtx        nats.JetStreamContext
	Logg         logf.Logger
	NatsConn     *nats.Conn
	TaskerClient *tasker.TaskerClient
}