Documentation ¶
Index ¶
- Variables
- type AccountServer
- func (s *AccountServer) Create(ctx context.Context, request *protobuf_api.CreateAccountRequest) (*protobuf_api.CreateAccountResponse, error)
- func (s *AccountServer) Delete(ctx context.Context, request *protobuf_api.DeleteAccountRequest) (*protobuf_api.DeleteAccountResponse, error)
- func (s *AccountServer) Get(ctx context.Context, request *protobuf_api.GetAccountRequest) (*account.Account, error)
- func (s *AccountServer) List(ctx context.Context, request *protobuf_api.ListAccountRequest) (*protobuf_api.ListAccountResponse, error)
- type EventServer
- type ExecutionServer
- func (s *ExecutionServer) Create(ctx context.Context, req *api.CreateExecutionRequest) (*api.CreateExecutionResponse, error)
- func (s *ExecutionServer) Get(ctx context.Context, req *api.GetExecutionRequest) (*execution.Execution, error)
- func (s *ExecutionServer) Stream(req *api.StreamExecutionRequest, resp api.Execution_StreamServer) error
- func (s *ExecutionServer) Update(ctx context.Context, req *api.UpdateExecutionRequest) (*api.UpdateExecutionResponse, error)
- type InstanceServer
- func (s *InstanceServer) Create(ctx context.Context, request *protobuf_api.CreateInstanceRequest) (*protobuf_api.CreateInstanceResponse, error)
- func (s *InstanceServer) Delete(ctx context.Context, request *protobuf_api.DeleteInstanceRequest) (*protobuf_api.DeleteInstanceResponse, error)
- func (s *InstanceServer) Get(ctx context.Context, request *protobuf_api.GetInstanceRequest) (*instance.Instance, error)
- func (s *InstanceServer) List(ctx context.Context, request *protobuf_api.ListInstanceRequest) (*protobuf_api.ListInstanceResponse, error)
- type ProcessServer
- func (s *ProcessServer) Create(ctx context.Context, req *api.CreateProcessRequest) (*api.CreateProcessResponse, error)
- func (s *ProcessServer) Delete(ctx context.Context, request *api.DeleteProcessRequest) (*api.DeleteProcessResponse, error)
- func (s *ProcessServer) Get(ctx context.Context, req *api.GetProcessRequest) (*process.Process, error)
- func (s *ProcessServer) List(ctx context.Context, req *api.ListProcessRequest) (*api.ListProcessResponse, error)
- type ServiceServer
- func (s *ServiceServer) Create(ctx context.Context, req *protobuf_api.CreateServiceRequest) (*protobuf_api.CreateServiceResponse, error)
- func (s *ServiceServer) Delete(ctx context.Context, request *protobuf_api.DeleteServiceRequest) (*protobuf_api.DeleteServiceResponse, error)
- func (s *ServiceServer) Get(ctx context.Context, req *protobuf_api.GetServiceRequest) (*service.Service, error)
- func (s *ServiceServer) List(ctx context.Context, req *protobuf_api.ListServiceRequest) (*protobuf_api.ListServiceResponse, error)
Constants ¶
This section is empty.
Variables ¶
var ErrNoOutput = errors.New("output not supplied")
ErrNoOutput is an error when there is no output for updating execution.
Functions ¶
This section is empty.
Types ¶
type AccountServer ¶ added in v0.15.0
type AccountServer struct {
// contains filtered or unexported fields
}
AccountServer is the type to aggregate all Account APIs.
func NewAccountServer ¶ added in v0.15.0
func NewAccountServer(sdk *sdk.SDK) *AccountServer
NewAccountServer creates a new ServiceServer.
func (*AccountServer) Create ¶ added in v0.15.0
func (s *AccountServer) Create(ctx context.Context, request *protobuf_api.CreateAccountRequest) (*protobuf_api.CreateAccountResponse, error)
Create creates a new account from service.
func (*AccountServer) Delete ¶ added in v0.15.0
func (s *AccountServer) Delete(ctx context.Context, request *protobuf_api.DeleteAccountRequest) (*protobuf_api.DeleteAccountResponse, error)
Delete an account
func (*AccountServer) Get ¶ added in v0.15.0
func (s *AccountServer) Get(ctx context.Context, request *protobuf_api.GetAccountRequest) (*account.Account, error)
Get retrives account.
func (*AccountServer) List ¶ added in v0.15.0
func (s *AccountServer) List(ctx context.Context, request *protobuf_api.ListAccountRequest) (*protobuf_api.ListAccountResponse, error)
List accounts.
type EventServer ¶
type EventServer struct {
// contains filtered or unexported fields
}
EventServer serve event functions.
func NewEventServer ¶
func NewEventServer(sdk *sdk.SDK) *EventServer
NewEventServer creates a new EventServer.
func (*EventServer) Create ¶
func (s *EventServer) Create(ctx context.Context, req *api.CreateEventRequest) (*api.CreateEventResponse, error)
Create creates a new event.
func (*EventServer) Stream ¶
func (s *EventServer) Stream(req *api.StreamEventRequest, resp api.Event_StreamServer) error
Stream returns stream of events.
type ExecutionServer ¶
type ExecutionServer struct {
// contains filtered or unexported fields
}
ExecutionServer serve execution functions.
func NewExecutionServer ¶
func NewExecutionServer(sdk *sdk.SDK) *ExecutionServer
NewExecutionServer creates a new ExecutionServer.
func (*ExecutionServer) Create ¶
func (s *ExecutionServer) Create(ctx context.Context, req *api.CreateExecutionRequest) (*api.CreateExecutionResponse, error)
Create creates an execution.
func (*ExecutionServer) Get ¶
func (s *ExecutionServer) Get(ctx context.Context, req *api.GetExecutionRequest) (*execution.Execution, error)
Get returns execution from given hash.
func (*ExecutionServer) Stream ¶
func (s *ExecutionServer) Stream(req *api.StreamExecutionRequest, resp api.Execution_StreamServer) error
Stream returns stream of executions.
func (*ExecutionServer) Update ¶
func (s *ExecutionServer) Update(ctx context.Context, req *api.UpdateExecutionRequest) (*api.UpdateExecutionResponse, error)
Update updates execution from given hash.
type InstanceServer ¶
type InstanceServer struct {
// contains filtered or unexported fields
}
InstanceServer is the type to aggregate all Instance APIs.
func NewInstanceServer ¶
func NewInstanceServer(sdk *sdk.SDK) *InstanceServer
NewInstanceServer creates a new ServiceServer.
func (*InstanceServer) Create ¶
func (s *InstanceServer) Create(ctx context.Context, request *protobuf_api.CreateInstanceRequest) (*protobuf_api.CreateInstanceResponse, error)
Create creates a new instance from service.
func (*InstanceServer) Delete ¶
func (s *InstanceServer) Delete(ctx context.Context, request *protobuf_api.DeleteInstanceRequest) (*protobuf_api.DeleteInstanceResponse, error)
Delete an instance
func (*InstanceServer) Get ¶
func (s *InstanceServer) Get(ctx context.Context, request *protobuf_api.GetInstanceRequest) (*instance.Instance, error)
Get retrives instance.
func (*InstanceServer) List ¶
func (s *InstanceServer) List(ctx context.Context, request *protobuf_api.ListInstanceRequest) (*protobuf_api.ListInstanceResponse, error)
List instances.
type ProcessServer ¶ added in v0.14.0
type ProcessServer struct {
// contains filtered or unexported fields
}
ProcessServer is the type to aggregate all Service APIs.
func NewProcessServer ¶ added in v0.14.0
func NewProcessServer(sdk *sdk.SDK) *ProcessServer
NewProcessServer creates a new ProcessServer.
func (*ProcessServer) Create ¶ added in v0.14.0
func (s *ProcessServer) Create(ctx context.Context, req *api.CreateProcessRequest) (*api.CreateProcessResponse, error)
Create creates a new service from definition.
func (*ProcessServer) Delete ¶ added in v0.14.0
func (s *ProcessServer) Delete(ctx context.Context, request *api.DeleteProcessRequest) (*api.DeleteProcessResponse, error)
Delete deletes service by hash or sid.
func (*ProcessServer) Get ¶ added in v0.14.0
func (s *ProcessServer) Get(ctx context.Context, req *api.GetProcessRequest) (*process.Process, error)
Get returns service from given hash.
func (*ProcessServer) List ¶ added in v0.14.0
func (s *ProcessServer) List(ctx context.Context, req *api.ListProcessRequest) (*api.ListProcessResponse, error)
List returns all processes.
type ServiceServer ¶
type ServiceServer struct {
// contains filtered or unexported fields
}
ServiceServer is the type to aggregate all Service APIs.
func NewServiceServer ¶
func NewServiceServer(sdk *sdk.SDK) *ServiceServer
NewServiceServer creates a new ServiceServer.
func (*ServiceServer) Create ¶
func (s *ServiceServer) Create(ctx context.Context, req *protobuf_api.CreateServiceRequest) (*protobuf_api.CreateServiceResponse, error)
Create creates a new service from definition.
func (*ServiceServer) Delete ¶
func (s *ServiceServer) Delete(ctx context.Context, request *protobuf_api.DeleteServiceRequest) (*protobuf_api.DeleteServiceResponse, error)
Delete deletes service by hash or sid.
func (*ServiceServer) Get ¶
func (s *ServiceServer) Get(ctx context.Context, req *protobuf_api.GetServiceRequest) (*service.Service, error)
Get returns service from given hash.
func (*ServiceServer) List ¶
func (s *ServiceServer) List(ctx context.Context, req *protobuf_api.ListServiceRequest) (*protobuf_api.ListServiceResponse, error)
List returns all services.