compute

Documentation

Index

• type CallbackStore
  • func (m *CallbackStore) Close(ctx context.Context) error
  • func (m *CallbackStore) CreateExecution(ctx context.Context, execution store.LocalExecutionState) error
  • func (m *CallbackStore) DeleteExecution(ctx context.Context, id string) error
  • func (m *CallbackStore) GetEventStore() watcher.EventStore
  • func (m *CallbackStore) GetExecution(ctx context.Context, id string) (store.LocalExecutionState, error)
  • func (m *CallbackStore) GetExecutionCount(ctx context.Context, state store.LocalExecutionStateType) (uint64, error)
  • func (m *CallbackStore) GetExecutionHistory(ctx context.Context, id string) ([]store.LocalStateHistory, error)
  • func (m *CallbackStore) GetExecutions(ctx context.Context, jobID string) ([]store.LocalExecutionState, error)
  • func (m *CallbackStore) GetLiveExecutions(ctx context.Context) ([]store.LocalExecutionState, error)
  • func (m *CallbackStore) UpdateExecutionState(ctx context.Context, request store.UpdateExecutionStateRequest) error
• type HeartbeatClientMock
  • func (h HeartbeatClientMock) Close(ctx context.Context) error
  • func (h HeartbeatClientMock) SendHeartbeat(ctx context.Context, sequence uint64) error
• type ManagementEndpointMock
  • func (m ManagementEndpointMock) Register(ctx context.Context, request requests.RegisterRequest) (*requests.RegisterResponse, error)
  • func (m ManagementEndpointMock) UpdateInfo(ctx context.Context, request requests.UpdateInfoRequest) (*requests.UpdateInfoResponse, error)
  • func (m ManagementEndpointMock) UpdateResources(ctx context.Context, request requests.UpdateResourcesRequest) (*requests.UpdateResourcesResponse, error)

Types

type CallbackStore

type CallbackStore struct {
	GetExecutionFn         func(ctx context.Context, id string) (store.LocalExecutionState, error)
	GetExecutionsFn        func(ctx context.Context, id string) ([]store.LocalExecutionState, error)
	GetLiveExecutionsFn    func(ctx context.Context) ([]store.LocalExecutionState, error)
	GetExecutionHistoryFn  func(ctx context.Context, id string) ([]store.LocalStateHistory, error)
	CreateExecutionFn      func(ctx context.Context, execution store.LocalExecutionState) error
	UpdateExecutionStateFn func(ctx context.Context, request store.UpdateExecutionStateRequest) error
	DeleteExecutionFn      func(ctx context.Context, id string) error
	GetExecutionCountFn    func(ctx context.Context, state store.LocalExecutionStateType) (uint64, error)
	GetEventStoreFn        func() watcher.EventStore
	CloseFn                func(ctx context.Context) error
}

func (*CallbackStore) Close

func (m *CallbackStore) Close(ctx context.Context) error

func (*CallbackStore) CreateExecution

func (m *CallbackStore) CreateExecution(ctx context.Context, execution store.LocalExecutionState) error

func (*CallbackStore) DeleteExecution

func (m *CallbackStore) DeleteExecution(ctx context.Context, id string) error

func (*CallbackStore) GetEventStore

func (m *CallbackStore) GetEventStore() watcher.EventStore

func (*CallbackStore) GetExecution

func (m *CallbackStore) GetExecution(ctx context.Context, id string) (store.LocalExecutionState, error)

func (*CallbackStore) GetExecutionCount

func (m *CallbackStore) GetExecutionCount(ctx context.Context, state store.LocalExecutionStateType) (uint64, error)

func (*CallbackStore) GetExecutionHistory

func (m *CallbackStore) GetExecutionHistory(ctx context.Context, id string) ([]store.LocalStateHistory, error)

func (*CallbackStore) GetExecutions

func (m *CallbackStore) GetExecutions(ctx context.Context, jobID string) ([]store.LocalExecutionState, error)

func (*CallbackStore) GetLiveExecutions

func (m *CallbackStore) GetLiveExecutions(ctx context.Context) ([]store.LocalExecutionState, error)

func (*CallbackStore) UpdateExecutionState

func (m *CallbackStore) UpdateExecutionState(ctx context.Context, request store.UpdateExecutionStateRequest) error

type HeartbeatClientMock

type HeartbeatClientMock struct {
	SendHeartbeatHandler func(ctx context.Context, sequence uint64) error
}

HeartbeatClientMock is a mock implementation of the HeartbeatClient interface

func (HeartbeatClientMock) Close

func (h HeartbeatClientMock) Close(ctx context.Context) error

func (HeartbeatClientMock) SendHeartbeat

func (h HeartbeatClientMock) SendHeartbeat(ctx context.Context, sequence uint64) error

type ManagementEndpointMock

type ManagementEndpointMock struct {
	RegisterHandler        func(ctx context.Context, request requests.RegisterRequest) (*requests.RegisterResponse, error)
	UpdateInfoHandler      func(ctx context.Context, request requests.UpdateInfoRequest) (*requests.UpdateInfoResponse, error)
	UpdateResourcesHandler func(ctx context.Context, request requests.UpdateResourcesRequest) (*requests.UpdateResourcesResponse, error)
}

func (ManagementEndpointMock) Register

func (m ManagementEndpointMock) Register(ctx context.Context, request requests.RegisterRequest) (*requests.RegisterResponse, error)

func (ManagementEndpointMock) UpdateInfo

func (m ManagementEndpointMock) UpdateInfo(ctx context.Context, request requests.UpdateInfoRequest) (*requests.UpdateInfoResponse, error)

func (ManagementEndpointMock) UpdateResources

func (m ManagementEndpointMock) UpdateResources(
	ctx context.Context, request requests.UpdateResourcesRequest) (*requests.UpdateResourcesResponse, error)