api

package
v0.20.0 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventServer 

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

EventServer serve event functions.

func NewEventServer 

func NewEventServer(ep *publisher.EventPublisher) *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(mc *cosmos.ModuleClient, execPrice string) *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) List added in v0.17.0 

func (s *ExecutionServer) List(ctx context.Context, req *api.ListExecutionRequest) (*api.ListExecutionResponse, error)

List returns all executions.

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(mc *cosmos.ModuleClient) *InstanceServer

NewInstanceServer creates a new ServiceServer.

func (*InstanceServer) Get 

func (s *InstanceServer) Get(ctx context.Context, req *protobuf_api.GetInstanceRequest) (*instancepb.Instance, error)

Get retrives instance.

func (*InstanceServer) List 

func (s *InstanceServer) List(ctx context.Context, req *protobuf_api.ListInstanceRequest) (*protobuf_api.ListInstanceResponse, error)

List instances.

type OwnershipServer added in v0.16.0 

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

OwnershipServer is the type to aggregate all Ownership APIs.

func NewOwnershipServer added in v0.16.0 

func NewOwnershipServer(mc *cosmos.ModuleClient) *OwnershipServer

NewOwnershipServer creates a new OwnershipServer.

func (*OwnershipServer) List added in v0.16.0 

func (s *OwnershipServer) List(ctx context.Context, req *api.ListOwnershipRequest) (*api.ListOwnershipResponse, error)

List returns all ownerships.

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(mc *cosmos.ModuleClient) *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 process.

func (*ProcessServer) Delete added in v0.14.0 

func (s *ProcessServer) Delete(ctx context.Context, req *api.DeleteProcessRequest) (*api.DeleteProcessResponse, error)

Delete deletes process 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 process 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 RunnerServer added in v0.17.0 

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

RunnerServer is the type to aggregate all Runner APIs.

func NewRunnerServer added in v0.17.0 

func NewRunnerServer(mc *cosmos.ModuleClient, b *builder.Builder) *RunnerServer

NewRunnerServer creates a new RunnerServer.

func (*RunnerServer) Create added in v0.17.0 

func (s *RunnerServer) Create(ctx context.Context, req *api.CreateRunnerRequest) (*api.CreateRunnerResponse, error)

Create creates a new runner.

func (*RunnerServer) Delete added in v0.17.0 

func (s *RunnerServer) Delete(ctx context.Context, req *api.DeleteRunnerRequest) (*api.DeleteRunnerResponse, error)

Delete deletes a runner.

func (*RunnerServer) Get added in v0.17.0 

func (s *RunnerServer) Get(ctx context.Context, req *api.GetRunnerRequest) (*runner.Runner, error)

Get returns runner from given hash.

func (*RunnerServer) List added in v0.17.0 

func (s *RunnerServer) List(ctx context.Context, req *api.ListRunnerRequest) (*api.ListRunnerResponse, error)

List returns all runners.

type ServiceServer 

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

ServiceServer is the type to aggregate all Service APIs.

func NewServiceServer 

func NewServiceServer(mc *cosmos.ModuleClient) *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) Exists added in v0.16.0 

func (s *ServiceServer) Exists(ctx context.Context, req *protobuf_api.ExistsServiceRequest) (*protobuf_api.ExistsServiceResponse, error)

Exists returns if a service already exists.

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) Hash added in v0.16.0 

func (s *ServiceServer) Hash(ctx context.Context, req *protobuf_api.CreateServiceRequest) (*protobuf_api.HashServiceResponse, error)

Hash returns the calculated hash of a service request.

func (*ServiceServer) List 

func (s *ServiceServer) List(ctx context.Context, req *protobuf_api.ListServiceRequest) (*protobuf_api.ListServiceResponse, error)

List returns all services.

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.