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) 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 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)

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)
	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) 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 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)
}

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)