executor

Documentation

Index

• type PinkClient
  • func NewPinkClient(name, path string) *PinkClient
• type PinkExecutor
  • func NewPinkExecutor(etcdCli *etcd.Cli, eventBus *bus.EventBus, groupManaged *PinkGroupManaged, ...) *PinkExecutor
  • func (pe *PinkExecutor) PushExecutePlan(snapshot *protocol.SchedulePlanSnapshot)
• type PinkGroup
  • func NewPinkGroup(name, path string, cli *etcd.Cli) *PinkGroup
• type PinkGroupManaged
  • func NewPinkGroupManaged(cli *etcd.Cli) *PinkGroupManaged
  • func (managed *PinkGroupManaged) UnParkPinkClient(name string) (string, error)

Types

type PinkClient

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

func NewPinkClient

func NewPinkClient(name, path string) *PinkClient

type PinkExecutor

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

func NewPinkExecutor

func NewPinkExecutor(etcdCli *etcd.Cli, eventBus *bus.EventBus, groupManaged *PinkGroupManaged, collector *collector.PinkCollector) *PinkExecutor

func (*PinkExecutor) PushExecutePlan

func (pe *PinkExecutor) PushExecutePlan(snapshot *protocol.SchedulePlanSnapshot)

type PinkGroup

type PinkGroup struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewPinkGroup

func NewPinkGroup(name, path string, cli *etcd.Cli) *PinkGroup

new a pink group

type PinkGroupManaged

type PinkGroupManaged struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewPinkGroupManaged

func NewPinkGroupManaged(cli *etcd.Cli) *PinkGroupManaged

func (*PinkGroupManaged) UnParkPinkClient

func (managed *PinkGroupManaged) UnParkPinkClient(name string) (string, error)