runner

Documentation

Index

• type NatsClient
• type Runner
  • func NewRunner(natsClient NatsClient, hops *dsl.HopsFiles, logger zerolog.Logger) (*Runner, error)
  • func (r *Runner) Run(ctx context.Context) error
  • func (r *Runner) SequenceCallback(ctx context.Context, sequenceId string, msgBundle nats.MessageBundle) error

Types

type NatsClient

type NatsClient interface {
	ConsumeSequences(context.Context, nats.SequenceHandler) error
	GetMsg(ctx context.Context, subjTokens ...string) (*jetstream.RawStreamMsg, error)
	GetSysObject(key string) ([]byte, error)
	Publish(context.Context, []byte, ...string) (*jetstream.PubAck, bool, error)
	PutSysObject(string, []byte) (*natsgo.ObjectInfo, error)
}

type Runner

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

func NewRunner

func NewRunner(natsClient NatsClient, hops *dsl.HopsFiles, logger zerolog.Logger) (*Runner, error)

func (*Runner) Run

func (r *Runner) Run(ctx context.Context) error

func (*Runner) SequenceCallback

func (r *Runner) SequenceCallback(
	ctx context.Context,
	sequenceId string,
	msgBundle nats.MessageBundle,
) error