cluster

Documentation

Index

• type Cluster
  • func New(opts Options) *Cluster
  • func (c *Cluster) RunClients(ctx context.Context, clients *clients.Clients) error
  • func (c *Cluster) StartApp()
  • func (c *Cluster) StopApp()
• type Options

Types

type Cluster

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

Cluster manages connections to multiple schedulers.

func New

func New(opts Options) *Cluster

func (*Cluster) RunClients

func (c *Cluster) RunClients(ctx context.Context, clients *clients.Clients) error

Run starts watching for job triggers from all scheduler clients.

func (*Cluster) StartApp

func (c *Cluster) StartApp()

func (*Cluster) StopApp

func (c *Cluster) StopApp()

type Options

type Options struct {
	Namespace string
	AppID     string
	Actors    actors.Interface
	Channels  *channels.Channels
	WFEngine  wfengine.Interface
}