api

package
v0.13.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 16, 2019 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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 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) (*types.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) (*types.Instance, error)

Get retrives instance.

func (*InstanceServer) List 

func (s *InstanceServer) List(ctx context.Context, request *protobuf_api.ListInstancesRequest) (*protobuf_api.ListInstancesResponse, error)

List instances.

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) (*types.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.

type WorkflowServer added in v0.13.0 

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

WorkflowServer is the type to aggregate all Service APIs.

func NewWorkflowServer added in v0.13.0 

func NewWorkflowServer(sdk *sdk.SDK) *WorkflowServer

NewWorkflowServer creates a new WorkflowServer.

func (*WorkflowServer) Create added in v0.13.0 

func (s *WorkflowServer) Create(ctx context.Context, req *api.CreateWorkflowRequest) (*api.CreateWorkflowResponse, error)

Create creates a new service from definition.

func (*WorkflowServer) Delete added in v0.13.0 

func (s *WorkflowServer) Delete(ctx context.Context, request *api.DeleteWorkflowRequest) (*api.DeleteWorkflowResponse, error)

Delete deletes service by hash or sid.

func (*WorkflowServer) Get added in v0.13.0 

func (s *WorkflowServer) Get(ctx context.Context, req *api.GetWorkflowRequest) (*types.Workflow, error)

Get returns service from given hash.

func (*WorkflowServer) List added in v0.13.0 

func (s *WorkflowServer) List(ctx context.Context, req *api.ListWorkflowRequest) (*api.ListWorkflowResponse, error)

List returns all workflows.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.