test

Documentation

Index

• type MockBrokenScheduler
  • func (m MockBrokenScheduler) Accept(offerIds []*mesos_v1.OfferID, tasks []*mesos_v1.Offer_Operation, ...) (*http.Response, error)
  • func (m MockBrokenScheduler) Acknowledge(agentId *mesos_v1.AgentID, taskId *mesos_v1.TaskID, uuid []byte) (*http.Response, error)
  • func (m MockBrokenScheduler) Decline(offerIds []*mesos_v1.OfferID, filters *mesos_v1.Filters) (*http.Response, error)
  • func (m MockBrokenScheduler) FrameworkInfo() *mesos_v1.FrameworkInfo
  • func (m MockBrokenScheduler) Kill(taskId *mesos_v1.TaskID, agentid *mesos_v1.AgentID) (*http.Response, error)
  • func (m MockBrokenScheduler) Message(agentId *mesos_v1.AgentID, executorId *mesos_v1.ExecutorID, data []byte) (*http.Response, error)
  • func (m MockBrokenScheduler) Reconcile(tasks []*mesos_v1.TaskInfo) (*http.Response, error)
  • func (m MockBrokenScheduler) Revive() (*http.Response, error)
  • func (m MockBrokenScheduler) SchedRequest(resources []*mesos_v1.Request) (*http.Response, error)
  • func (m MockBrokenScheduler) Shutdown(execId *mesos_v1.ExecutorID, agentId *mesos_v1.AgentID) (*http.Response, error)
  • func (m MockBrokenScheduler) Subscribe(chan *mesos_v1_scheduler.Event) (*http.Response, error)
  • func (m MockBrokenScheduler) Suppress() (*http.Response, error)
  • func (m MockBrokenScheduler) Teardown() (*http.Response, error)
• type MockScheduler
  • func NewMockScheduler() *MockScheduler
  • func (m MockScheduler) Accept(offerIds []*mesos_v1.OfferID, tasks []*mesos_v1.Offer_Operation, ...) (*http.Response, error)
  • func (m MockScheduler) Acknowledge(agentId *mesos_v1.AgentID, taskId *mesos_v1.TaskID, uuid []byte) (*http.Response, error)
  • func (m MockScheduler) Decline(offerIds []*mesos_v1.OfferID, filters *mesos_v1.Filters) (*http.Response, error)
  • func (m MockScheduler) FrameworkInfo() *mesos_v1.FrameworkInfo
  • func (m MockScheduler) Kill(taskId *mesos_v1.TaskID, agentid *mesos_v1.AgentID) (*http.Response, error)
  • func (m MockScheduler) Message(agentId *mesos_v1.AgentID, executorId *mesos_v1.ExecutorID, data []byte) (*http.Response, error)
  • func (m MockScheduler) Reconcile(tasks []*mesos_v1.TaskInfo) (*http.Response, error)
  • func (m MockScheduler) Revive() (*http.Response, error)
  • func (m MockScheduler) SchedRequest(resources []*mesos_v1.Request) (*http.Response, error)
  • func (m MockScheduler) Shutdown(execId *mesos_v1.ExecutorID, agentId *mesos_v1.AgentID) (*http.Response, error)
  • func (m MockScheduler) Subscribe(chan *mesos_v1_scheduler.Event) (*http.Response, error)
  • func (m MockScheduler) Suppress() (*http.Response, error)
  • func (m MockScheduler) Teardown() (*http.Response, error)

Types

type MockBrokenScheduler

type MockBrokenScheduler struct{}

func (MockBrokenScheduler) Accept

func (m MockBrokenScheduler) Accept(offerIds []*mesos_v1.OfferID, tasks []*mesos_v1.Offer_Operation, filters *mesos_v1.Filters) (*http.Response, error)

func (MockBrokenScheduler) Acknowledge

func (m MockBrokenScheduler) Acknowledge(agentId *mesos_v1.AgentID, taskId *mesos_v1.TaskID, uuid []byte) (*http.Response, error)

func (MockBrokenScheduler) Decline

func (m MockBrokenScheduler) Decline(offerIds []*mesos_v1.OfferID, filters *mesos_v1.Filters) (*http.Response, error)

func (MockBrokenScheduler) FrameworkInfo

func (m MockBrokenScheduler) FrameworkInfo() *mesos_v1.FrameworkInfo

func (MockBrokenScheduler) Kill

func (m MockBrokenScheduler) Kill(taskId *mesos_v1.TaskID, agentid *mesos_v1.AgentID) (*http.Response, error)

func (MockBrokenScheduler) Message

func (m MockBrokenScheduler) Message(agentId *mesos_v1.AgentID, executorId *mesos_v1.ExecutorID, data []byte) (*http.Response, error)

func (MockBrokenScheduler) Reconcile

func (m MockBrokenScheduler) Reconcile(tasks []*mesos_v1.TaskInfo) (*http.Response, error)

func (MockBrokenScheduler) Revive

func (m MockBrokenScheduler) Revive() (*http.Response, error)

func (MockBrokenScheduler) SchedRequest

func (m MockBrokenScheduler) SchedRequest(resources []*mesos_v1.Request) (*http.Response, error)

func (MockBrokenScheduler) Shutdown

func (m MockBrokenScheduler) Shutdown(execId *mesos_v1.ExecutorID, agentId *mesos_v1.AgentID) (*http.Response, error)

func (MockBrokenScheduler) Subscribe

func (m MockBrokenScheduler) Subscribe(chan *mesos_v1_scheduler.Event) (*http.Response, error)

func (MockBrokenScheduler) Suppress

func (m MockBrokenScheduler) Suppress() (*http.Response, error)

func (MockBrokenScheduler) Teardown

func (m MockBrokenScheduler) Teardown() (*http.Response, error)

type MockScheduler

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

func NewMockScheduler

func NewMockScheduler() *MockScheduler

func (MockScheduler) Accept

func (m MockScheduler) Accept(offerIds []*mesos_v1.OfferID, tasks []*mesos_v1.Offer_Operation, filters *mesos_v1.Filters) (*http.Response, error)

func (MockScheduler) Acknowledge

func (m MockScheduler) Acknowledge(agentId *mesos_v1.AgentID, taskId *mesos_v1.TaskID, uuid []byte) (*http.Response, error)

func (MockScheduler) Decline

func (m MockScheduler) Decline(offerIds []*mesos_v1.OfferID, filters *mesos_v1.Filters) (*http.Response, error)

func (MockScheduler) FrameworkInfo

func (m MockScheduler) FrameworkInfo() *mesos_v1.FrameworkInfo

func (MockScheduler) Kill

func (m MockScheduler) Kill(taskId *mesos_v1.TaskID, agentid *mesos_v1.AgentID) (*http.Response, error)

func (MockScheduler) Message

func (m MockScheduler) Message(agentId *mesos_v1.AgentID, executorId *mesos_v1.ExecutorID, data []byte) (*http.Response, error)

func (MockScheduler) Reconcile

func (m MockScheduler) Reconcile(tasks []*mesos_v1.TaskInfo) (*http.Response, error)

func (MockScheduler) Revive

func (m MockScheduler) Revive() (*http.Response, error)

func (MockScheduler) SchedRequest

func (m MockScheduler) SchedRequest(resources []*mesos_v1.Request) (*http.Response, error)

func (MockScheduler) Shutdown

func (m MockScheduler) Shutdown(execId *mesos_v1.ExecutorID, agentId *mesos_v1.AgentID) (*http.Response, error)

func (MockScheduler) Subscribe

func (m MockScheduler) Subscribe(chan *mesos_v1_scheduler.Event) (*http.Response, error)

func (MockScheduler) Suppress

func (m MockScheduler) Suppress() (*http.Response, error)

func (MockScheduler) Teardown

func (m MockScheduler) Teardown() (*http.Response, error)