Documentation ¶
Index ¶
- func FakeDeclineOffersCall(frameworkId string, offerIds ...string) *scheduler.Call
- func FakeFramework() *mesosproto.FrameworkInfo
- func FakeKillTaskCall(frameworkId, taskId string) *scheduler.Call
- func FakeKillTaskMessage(frameworkId string, taskId string) *mesosproto.KillTaskMessage
- func FakeLaunchTasksCall(frameworkId string, offerIds []string, taskInfos ...*mesosproto.TaskInfo) *scheduler.Call
- func FakeLaunchTasksMessage(frameworkId string) *mesosproto.LaunchTasksMessage
- func FakeMesosTask(taskId string) *mesosproto.TaskInfo
- func FakeReconcileTasksCall(frameworkId string, taskIds ...string) *scheduler.Call
- func FakeReconcileTasksMessage(frameworkId string, statuses []*mesosproto.TaskStatus) *mesosproto.ReconcileTasksMessage
- func FakeRegisterFrameworkMessage() *mesosproto.RegisterFrameworkMessage
- func FakeReregisterFrameworkMessage() *mesosproto.ReregisterFrameworkMessage
- func FakeResources() []*mesosproto.Resource
- func FakeReviveOffersCall(frameworkId string) *scheduler.Call
- func FakeReviveOffersMessage(frameworkId string) *mesosproto.ReviveOffersMessage
- func FakeStatusUpdateAcknowledgementMessage(frameworkId string, taskId string, slaveId string, uuid []byte) *mesosproto.StatusUpdateAcknowledgementMessage
- func FakeSubscribeCall() *scheduler.Call
- func FakeTaskStatus(taskId string, fakeState mesosproto.TaskState) *mesosproto.TaskStatus
- func FakeUnregisterFrameworkMessage() *mesosproto.UnregisterFrameworkMessage
- func RunFakeFrameworkServer(frameworkid string, port int)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FakeDeclineOffersCall ¶
func FakeFramework ¶
func FakeFramework() *mesosproto.FrameworkInfo
func FakeKillTaskCall ¶
func FakeKillTaskMessage ¶
func FakeKillTaskMessage(frameworkId string, taskId string) *mesosproto.KillTaskMessage
func FakeLaunchTasksCall ¶
func FakeLaunchTasksMessage ¶
func FakeLaunchTasksMessage(frameworkId string) *mesosproto.LaunchTasksMessage
func FakeMesosTask ¶
func FakeMesosTask(taskId string) *mesosproto.TaskInfo
func FakeReconcileTasksCall ¶
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 FakeReviveOffersMessage ¶
func FakeReviveOffersMessage(frameworkId string) *mesosproto.ReviveOffersMessage
func FakeStatusUpdateAcknowledgementMessage ¶
func FakeStatusUpdateAcknowledgementMessage(frameworkId string, taskId string, slaveId string, uuid []byte) *mesosproto.StatusUpdateAcknowledgementMessage
func FakeSubscribeCall ¶
func FakeTaskStatus ¶
func FakeTaskStatus(taskId string, fakeState mesosproto.TaskState) *mesosproto.TaskStatus
func FakeUnregisterFrameworkMessage ¶
func FakeUnregisterFrameworkMessage() *mesosproto.UnregisterFrameworkMessage
func RunFakeFrameworkServer ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.