mesos

Documentation

Index

• type MesosManager
  • func NewMesosManager(d *yarpc.Dispatcher, frameworkInfoProvider hostmgrmesos.FrameworkInfoProvider, ...) *MesosManager
  • func (m *MesosManager) AckPodEvent(event *scalar.PodEvent)
  • func (m *MesosManager) KillPod(ctx context.Context, podID string) error
  • func (m *MesosManager) LaunchPods(ctx context.Context, pods []*models.LaunchablePod, hostname string) ([]*models.LaunchablePod, 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() error
  • func (m *MesosManager) Stop()
  • func (m *MesosManager) Update(ctx context.Context, body *sched.Event) error

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,
	frameworkInfoProvider hostmgrmesos.FrameworkInfoProvider,
	schedulerClient mpb.SchedulerClient,
	operatorClient mpb.MasterOperatorClient,
	agentInfoRefreshInterval time.Duration,
	offerHoldTime time.Duration,
	scope tally.Scope,
	podEventCh chan<- *scalar.PodEvent,
	hostEventCh chan<- *scalar.HostEvent,
) *MesosManager

func (*MesosManager) AckPodEvent

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

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

func (*MesosManager) KillPod

func (m *MesosManager) KillPod(ctx context.Context, podID string) error

KillPod kills a pod on a host.

func (*MesosManager) LaunchPods

func (m *MesosManager) LaunchPods(
	ctx context.Context,
	pods []*models.LaunchablePod,
	hostname string,
) ([]*models.LaunchablePod, error)

LaunchPods launch a list of pods 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() error

Start the plugin.

func (*MesosManager) Stop

func (m *MesosManager) Stop()

Stop the plugin.

func (*MesosManager) Update

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

Update is the Mesos callback on mesos task status updates