fakes

package
v0.0.0-...-c76ca94 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 2, 2017 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FakeDeclineOffersCall

func FakeDeclineOffersCall(frameworkId string, offerIds ...string) *scheduler.Call

func FakeFramework

func FakeFramework() *mesosproto.FrameworkInfo

func FakeKillTaskCall

func FakeKillTaskCall(frameworkId, taskId string) *scheduler.Call

func FakeKillTaskMessage

func FakeKillTaskMessage(frameworkId string, taskId string) *mesosproto.KillTaskMessage

func FakeLaunchTasksCall

func FakeLaunchTasksCall(frameworkId string, offerIds []string, taskInfos ...*mesosproto.TaskInfo) *scheduler.Call

func FakeLaunchTasksMessage

func FakeLaunchTasksMessage(frameworkId string) *mesosproto.LaunchTasksMessage

func FakeMesosTask

func FakeMesosTask(taskId string) *mesosproto.TaskInfo

func FakeReconcileTasksCall

func FakeReconcileTasksCall(frameworkId string, taskIds ...string) *scheduler.Call

func FakeReconcileTasksMessage

func FakeReconcileTasksMessage(frameworkId string, statuses []*mesosproto.TaskStatus) *mesosproto.ReconcileTasksMessage

func FakeRegisterFrameworkMessage

func FakeRegisterFrameworkMessage() *mesosproto.RegisterFrameworkMessage

func FakeReregisterFrameworkMessage

func FakeReregisterFrameworkMessage() *mesosproto.ReregisterFrameworkMessage

func FakeResources

func FakeResources() []*mesosproto.Resource

func FakeReviveOffersCall

func FakeReviveOffersCall(frameworkId string) *scheduler.Call

func FakeReviveOffersMessage

func FakeReviveOffersMessage(frameworkId string) *mesosproto.ReviveOffersMessage

func FakeStatusUpdateAcknowledgementMessage

func FakeStatusUpdateAcknowledgementMessage(frameworkId string, taskId string, slaveId string, uuid []byte) *mesosproto.StatusUpdateAcknowledgementMessage

func FakeSubscribeCall

func FakeSubscribeCall() *scheduler.Call

func FakeTaskStatus

func FakeTaskStatus(taskId string, fakeState mesosproto.TaskState) *mesosproto.TaskStatus

func FakeUnregisterFrameworkMessage

func FakeUnregisterFrameworkMessage() *mesosproto.UnregisterFrameworkMessage

func RunFakeFrameworkServer

func RunFakeFrameworkServer(frameworkid string, port int)

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL