sdk

Documentation

Index

• Variables
• type Worker
  • func NewWorker(logger *zap.Logger, ctx context.Context) (*Worker, error)
  • func (w *Worker) ProcessMessage(ctx context.Context, msg jetstream.Msg) error
  • func (w *Worker) Run(ctx context.Context) error

Variables

var (
	ManualTriggers = os.Getenv("MANUAL_TRIGGERS")
)

Types

type Worker

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

func NewWorker

func NewWorker(

	logger *zap.Logger,
	ctx context.Context,
) (*Worker, error)

func (*Worker) ProcessMessage

func (w *Worker) ProcessMessage(ctx context.Context, msg jetstream.Msg) error

func (*Worker) Run

func (w *Worker) Run(ctx context.Context) error