scheduler

Documentation

Index

• type Manager
  • func New(opts Options) (*Manager, error)
  • func (m *Manager) Run(ctx context.Context) error
  • func (m *Manager) SetClients(clients *clients.Clients)
  • func (m *Manager) Start(actors actors.ActorRuntime)
  • func (m *Manager) Stop()
• type Options

Types

type Manager

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

Manager manages connections to multiple schedulers.

func New

func New(opts Options) (*Manager, error)

func (*Manager) Run

func (m *Manager) Run(ctx context.Context) error

Run starts watching for job triggers from all scheduler clients.

func (*Manager) SetClients

func (m *Manager) SetClients(clients *clients.Clients)

func (*Manager) Start

func (m *Manager) Start(actors actors.ActorRuntime)

Start starts the scheduler manager with the given actors runtime, if it is enabled, to begin receiving job triggers.

func (*Manager) Stop

func (m *Manager) Stop()

Stop stops the scheduler manager, which stops watching for job triggers.

type Options

type Options struct {
	Namespace string
	AppID     string
	Clients   *clients.Clients
	Channels  *channels.Channels
}