mesos

Documentation

Index

• type MesosManager
  • func NewMesosManager(d *yarpc.Dispatcher, podEventCh chan<- *scalar.PodEvent, ...) *MesosManager
  • func (m *MesosManager) AckPodEvent(ctx context.Context, event *scalar.PodEvent)
  • func (m *MesosManager) KillPod(podID string) error
  • func (m *MesosManager) LaunchPod(podSpec *pbpod.PodSpec, podID, hostname string) error
  • func (m *MesosManager) Offers(ctx context.Context, body *sched.Event) error
  • func (m *MesosManager) ReconcileHosts() ([]*scalar.HostInfo, error)
  • func (m *MesosManager) Rescind(ctx context.Context, body *sched.Event) error
  • func (m *MesosManager) Start()
  • func (m *MesosManager) Stop()

Types

type MesosManager

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

MesosManager implements the plugin for the Mesos cluster manager.

func NewMesosManager

func NewMesosManager(
	d *yarpc.Dispatcher,
	podEventCh chan<- *scalar.PodEvent,
	hostEventCh chan<- *scalar.HostEvent,
) *MesosManager

func (*MesosManager) AckPodEvent

func (m *MesosManager) AckPodEvent(ctx context.Context, event *scalar.PodEvent)

AckPodEvent is only implemented by mesos plugin. For K8s this is a noop.

func (*MesosManager) KillPod

func (m *MesosManager) KillPod(podID string) error

KillPod kills a pod on a host.

func (*MesosManager) LaunchPod

func (m *MesosManager) LaunchPod(
	podSpec *pbpod.PodSpec,
	podID,
	hostname string,
) error

LaunchPod launches a pod on a host.

func (*MesosManager) Offers

func (m *MesosManager) Offers(ctx context.Context, body *sched.Event) error

Offers is the mesos callback that sends the offers from master TODO: add metrics similar to what offerpool has

func (*MesosManager) ReconcileHosts

func (m *MesosManager) ReconcileHosts() ([]*scalar.HostInfo, error)

ReconcileHosts will return the current state of hosts in the cluster.

func (*MesosManager) Rescind

func (m *MesosManager) Rescind(ctx context.Context, body *sched.Event) error

Rescind offers

func (*MesosManager) Start

func (m *MesosManager) Start()

Start the plugin.

func (*MesosManager) Stop

func (m *MesosManager) Stop()

Stop the plugin.