scheduler

Documentation

Index

• type JobDefinition
• type JobStatus
• type Scheduler
  • func New(nc *nats.Conn, js nats.JetStreamContext, kv nats.KeyValue, logger *zap.Logger) *Scheduler
  • func (s *Scheduler) GetActiveJobs() map[string]interface{}
  • func (s *Scheduler) Run(ctx context.Context) error
  • func (s *Scheduler) ScheduleJobFromData(data []byte)

Types

type JobDefinition

type JobDefinition struct {
	Subject  string `json:"subject"`
	Schedule struct {
		Every string `json:"every,omitempty"`
		Cron  string `json:"cron,omitempty"`
	} `json:"schedule"`
}

type JobStatus

type JobStatus struct {
	Subject string `json:"subject"`
}

type Scheduler

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

func New

func New(nc *nats.Conn, js nats.JetStreamContext, kv nats.KeyValue, logger *zap.Logger) *Scheduler

func (*Scheduler) GetActiveJobs

func (s *Scheduler) GetActiveJobs() map[string]interface{}

func (*Scheduler) Run

func (s *Scheduler) Run(ctx context.Context) error

func (*Scheduler) ScheduleJobFromData

func (s *Scheduler) ScheduleJobFromData(data []byte)