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, fromConsumer string) error
  • func (r *Runner) SequenceCallback(ctx context.Context, sequenceId string, msgBundle nats.MessageBundle) error
• type Schedule
  • func NewSchedule(config dsl.ScheduleAST, natsClient NatsClient, logger zerolog.Logger) (*Schedule, error)
  • func (s *Schedule) Run()

Types

type NatsClient

type NatsClient interface {
	ConsumeSequences(context.Context, string, 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)
	PublishResult(context.Context, time.Time, interface{}, error, ...string) (error, bool)
	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, fromConsumer string) error

func (*Runner) SequenceCallback

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

type Schedule

type Schedule struct {
	Config       dsl.ScheduleAST
	CronSchedule cron.Schedule
	// contains filtered or unexported fields
}

func NewSchedule

func NewSchedule(config dsl.ScheduleAST, natsClient NatsClient, logger zerolog.Logger) (*Schedule, error)

func (*Schedule) Run

func (s *Schedule) Run()