api

package
v0.18.2 Latest Latest
Warning

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

 Go to latest Published: Jan 15, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterEventServer 

func RegisterEventServer(s *grpc.Server, srv EventServer)

func RegisterExecutionServer 

func RegisterExecutionServer(s *grpc.Server, srv ExecutionServer)

func RegisterInstanceServer 

func RegisterInstanceServer(s *grpc.Server, srv InstanceServer)

func RegisterOwnershipServer added in v0.16.0 

func RegisterOwnershipServer(s *grpc.Server, srv OwnershipServer)

func RegisterProcessServer added in v0.14.0 

func RegisterProcessServer(s *grpc.Server, srv ProcessServer)

func RegisterRunnerServer added in v0.17.0 

func RegisterRunnerServer(s *grpc.Server, srv RunnerServer)

func RegisterServiceServer 

func RegisterServiceServer(s *grpc.Server, srv ServiceServer)

Types

type CreateEventRequest 

type CreateEventRequest struct {
	// instanceHash is hash of instance that can proceed an execution.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 147-byte string literal not displayed */
	// key is the key of the event.
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty" validate:"required,printascii"`
	// data is the data for the event.
	Data                 *types.Struct `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

CreateEventRequest defines request for execution update.

func (*CreateEventRequest) Descriptor 

func (*CreateEventRequest) Descriptor() ([]byte, []int)

func (*CreateEventRequest) GetData 

func (m *CreateEventRequest) GetData() *types.Struct

func (*CreateEventRequest) GetKey 

func (m *CreateEventRequest) GetKey() string

func (*CreateEventRequest) ProtoMessage 

func (*CreateEventRequest) ProtoMessage()

func (*CreateEventRequest) Reset 

func (m *CreateEventRequest) Reset()

func (*CreateEventRequest) String 

func (m *CreateEventRequest) String() string

func (*CreateEventRequest) XXX_DiscardUnknown 

func (m *CreateEventRequest) XXX_DiscardUnknown()

func (*CreateEventRequest) XXX_Marshal 

func (m *CreateEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateEventRequest) XXX_Merge 

func (m *CreateEventRequest) XXX_Merge(src proto.Message)

func (*CreateEventRequest) XXX_Size 

func (m *CreateEventRequest) XXX_Size() int

func (*CreateEventRequest) XXX_Unmarshal 

func (m *CreateEventRequest) XXX_Unmarshal(b []byte) error

type CreateEventResponse 

type CreateEventResponse struct {
	// Hash represents event.
	Hash                 github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,1,opt,name=hash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"hash"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

CreateEventResponse defines response for execution update.

func (*CreateEventResponse) Descriptor 

func (*CreateEventResponse) Descriptor() ([]byte, []int)

func (*CreateEventResponse) ProtoMessage 

func (*CreateEventResponse) ProtoMessage()

func (*CreateEventResponse) Reset 

func (m *CreateEventResponse) Reset()

func (*CreateEventResponse) String 

func (m *CreateEventResponse) String() string

func (*CreateEventResponse) XXX_DiscardUnknown 

func (m *CreateEventResponse) XXX_DiscardUnknown()

func (*CreateEventResponse) XXX_Marshal 

func (m *CreateEventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateEventResponse) XXX_Merge 

func (m *CreateEventResponse) XXX_Merge(src proto.Message)

func (*CreateEventResponse) XXX_Size 

func (m *CreateEventResponse) XXX_Size() int

func (*CreateEventResponse) XXX_Unmarshal 

func (m *CreateEventResponse) XXX_Unmarshal(b []byte) error

type CreateExecutionRequest 

type CreateExecutionRequest struct {
	// taskKey to filter executions.
	TaskKey string        `protobuf:"bytes,2,opt,name=taskKey,proto3" json:"taskKey,omitempty" validate:"required,printascii"`
	Inputs  *types.Struct `protobuf:"bytes,3,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// tags the execution.
	Tags                 []string                                    `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty" validate:"dive,printascii"`
	ParentHash           github_com_mesg_foundation_engine_hash.Hash `` /* 144-byte string literal not displayed */
	EventHash            github_com_mesg_foundation_engine_hash.Hash `` /* 142-byte string literal not displayed */
	ProcessHash          github_com_mesg_foundation_engine_hash.Hash `` /* 146-byte string literal not displayed */
	NodeKey              string                                      `protobuf:"bytes,8,opt,name=nodeKey,proto3" json:"nodeKey,omitempty"`
	ExecutorHash         github_com_mesg_foundation_engine_hash.Hash `` /* 148-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

CreateExecutionRequest defines request to create a single execution.

func (*CreateExecutionRequest) Descriptor 

func (*CreateExecutionRequest) Descriptor() ([]byte, []int)

func (*CreateExecutionRequest) GetInputs 

func (m *CreateExecutionRequest) GetInputs() *types.Struct

func (*CreateExecutionRequest) GetNodeKey added in v0.18.0 

func (m *CreateExecutionRequest) GetNodeKey() string

func (*CreateExecutionRequest) GetTags 

func (m *CreateExecutionRequest) GetTags() []string

func (*CreateExecutionRequest) GetTaskKey 

func (m *CreateExecutionRequest) GetTaskKey() string

func (*CreateExecutionRequest) ProtoMessage 

func (*CreateExecutionRequest) ProtoMessage()

func (*CreateExecutionRequest) Reset 

func (m *CreateExecutionRequest) Reset()

func (*CreateExecutionRequest) String 

func (m *CreateExecutionRequest) String() string

func (*CreateExecutionRequest) XXX_DiscardUnknown 

func (m *CreateExecutionRequest) XXX_DiscardUnknown()

func (*CreateExecutionRequest) XXX_Marshal 

func (m *CreateExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateExecutionRequest) XXX_Merge 

func (m *CreateExecutionRequest) XXX_Merge(src proto.Message)

func (*CreateExecutionRequest) XXX_Size 

func (m *CreateExecutionRequest) XXX_Size() int

func (*CreateExecutionRequest) XXX_Unmarshal 

func (m *CreateExecutionRequest) XXX_Unmarshal(b []byte) error

type CreateExecutionResponse 

type CreateExecutionResponse struct {
	// Execution's hash.
	Hash                 github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,1,opt,name=hash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"hash"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

CreateExecutionResponse defines response for execution creation.

func (*CreateExecutionResponse) Descriptor 

func (*CreateExecutionResponse) Descriptor() ([]byte, []int)

func (*CreateExecutionResponse) ProtoMessage 

func (*CreateExecutionResponse) ProtoMessage()

func (*CreateExecutionResponse) Reset 

func (m *CreateExecutionResponse) Reset()

func (*CreateExecutionResponse) String 

func (m *CreateExecutionResponse) String() string

func (*CreateExecutionResponse) XXX_DiscardUnknown 

func (m *CreateExecutionResponse) XXX_DiscardUnknown()

func (*CreateExecutionResponse) XXX_Marshal 

func (m *CreateExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateExecutionResponse) XXX_Merge 

func (m *CreateExecutionResponse) XXX_Merge(src proto.Message)

func (*CreateExecutionResponse) XXX_Size 

func (m *CreateExecutionResponse) XXX_Size() int

func (*CreateExecutionResponse) XXX_Unmarshal 

func (m *CreateExecutionResponse) XXX_Unmarshal(b []byte) error

type CreateProcessRequest added in v0.14.0 

type CreateProcessRequest struct {
	// Process's name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" validate:"required,printascii"`
	// List of nodes of the process.
	Nodes []*process.Process_Node `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// List of edges of the process.
	Edges                []*process.Process_Edge `protobuf:"bytes,5,rep,name=edges,proto3" json:"edges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

The request's data for the `Create` API.

func (*CreateProcessRequest) Descriptor added in v0.14.0 

func (*CreateProcessRequest) Descriptor() ([]byte, []int)

func (*CreateProcessRequest) GetEdges added in v0.14.0 

func (m *CreateProcessRequest) GetEdges() []*process.Process_Edge

func (*CreateProcessRequest) GetName added in v0.18.0 

func (m *CreateProcessRequest) GetName() string

func (*CreateProcessRequest) GetNodes added in v0.14.0 

func (m *CreateProcessRequest) GetNodes() []*process.Process_Node

func (*CreateProcessRequest) ProtoMessage added in v0.14.0 

func (*CreateProcessRequest) ProtoMessage()

func (*CreateProcessRequest) Reset added in v0.14.0 

func (m *CreateProcessRequest) Reset()

func (*CreateProcessRequest) String added in v0.14.0 

func (m *CreateProcessRequest) String() string

func (*CreateProcessRequest) XXX_DiscardUnknown added in v0.14.0 

func (m *CreateProcessRequest) XXX_DiscardUnknown()

func (*CreateProcessRequest) XXX_Marshal added in v0.14.0 

func (m *CreateProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateProcessRequest) XXX_Merge added in v0.14.0 

func (m *CreateProcessRequest) XXX_Merge(src proto.Message)

func (*CreateProcessRequest) XXX_Size added in v0.14.0 

func (m *CreateProcessRequest) XXX_Size() int

func (*CreateProcessRequest) XXX_Unmarshal added in v0.14.0 

func (m *CreateProcessRequest) XXX_Unmarshal(b []byte) error

type CreateProcessResponse added in v0.14.0 

type CreateProcessResponse struct {
	// The process's hash created.
	Hash                 github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,1,opt,name=hash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"hash"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

The response's data for the `Create` API.

func (*CreateProcessResponse) Descriptor added in v0.14.0 

func (*CreateProcessResponse) Descriptor() ([]byte, []int)

func (*CreateProcessResponse) ProtoMessage added in v0.14.0 

func (*CreateProcessResponse) ProtoMessage()

func (*CreateProcessResponse) Reset added in v0.14.0 

func (m *CreateProcessResponse) Reset()

func (*CreateProcessResponse) String added in v0.14.0 

func (m *CreateProcessResponse) String() string

func (*CreateProcessResponse) XXX_DiscardUnknown added in v0.14.0 

func (m *CreateProcessResponse) XXX_DiscardUnknown()

func (*CreateProcessResponse) XXX_Marshal added in v0.14.0 

func (m *CreateProcessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateProcessResponse) XXX_Merge added in v0.14.0 

func (m *CreateProcessResponse) XXX_Merge(src proto.Message)

func (*CreateProcessResponse) XXX_Size added in v0.14.0 

func (m *CreateProcessResponse) XXX_Size() int

func (*CreateProcessResponse) XXX_Unmarshal added in v0.14.0 

func (m *CreateProcessResponse) XXX_Unmarshal(b []byte) error

type CreateRunnerRequest added in v0.17.0 

type CreateRunnerRequest struct {
	// Service's hash to start the runner with.
	ServiceHash github_com_mesg_foundation_engine_hash.Hash `` /* 136-byte string literal not displayed */
	// Environmental variables to start the runner with.
	Env                  []string `protobuf:"bytes,2,rep,name=env,proto3" json:"env,omitempty" validate:"unique,dive,env"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `Create` API.

func (*CreateRunnerRequest) Descriptor added in v0.17.0 

func (*CreateRunnerRequest) Descriptor() ([]byte, []int)

func (*CreateRunnerRequest) GetEnv added in v0.17.0 

func (m *CreateRunnerRequest) GetEnv() []string

func (*CreateRunnerRequest) ProtoMessage added in v0.17.0 

func (*CreateRunnerRequest) ProtoMessage()

func (*CreateRunnerRequest) Reset added in v0.17.0 

func (m *CreateRunnerRequest) Reset()

func (*CreateRunnerRequest) String added in v0.17.0 

func (m *CreateRunnerRequest) String() string

func (*CreateRunnerRequest) XXX_DiscardUnknown added in v0.17.0 

func (m *CreateRunnerRequest) XXX_DiscardUnknown()

func (*CreateRunnerRequest) XXX_Marshal added in v0.17.0 

func (m *CreateRunnerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateRunnerRequest) XXX_Merge added in v0.17.0 

func (m *CreateRunnerRequest) XXX_Merge(src proto.Message)

func (*CreateRunnerRequest) XXX_Size added in v0.17.0 

func (m *CreateRunnerRequest) XXX_Size() int

func (*CreateRunnerRequest) XXX_Unmarshal added in v0.17.0 

func (m *CreateRunnerRequest) XXX_Unmarshal(b []byte) error

type CreateRunnerResponse added in v0.17.0 

type CreateRunnerResponse struct {
	// The runner's hash created.
	Hash                 github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,1,opt,name=hash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"hash"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

The response's data for the `Create` API.

func (*CreateRunnerResponse) Descriptor added in v0.17.0 

func (*CreateRunnerResponse) Descriptor() ([]byte, []int)

func (*CreateRunnerResponse) ProtoMessage added in v0.17.0 

func (*CreateRunnerResponse) ProtoMessage()

func (*CreateRunnerResponse) Reset added in v0.17.0 

func (m *CreateRunnerResponse) Reset()

func (*CreateRunnerResponse) String added in v0.17.0 

func (m *CreateRunnerResponse) String() string

func (*CreateRunnerResponse) XXX_DiscardUnknown added in v0.17.0 

func (m *CreateRunnerResponse) XXX_DiscardUnknown()

func (*CreateRunnerResponse) XXX_Marshal added in v0.17.0 

func (m *CreateRunnerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateRunnerResponse) XXX_Merge added in v0.17.0 

func (m *CreateRunnerResponse) XXX_Merge(src proto.Message)

func (*CreateRunnerResponse) XXX_Size added in v0.17.0 

func (m *CreateRunnerResponse) XXX_Size() int

func (*CreateRunnerResponse) XXX_Unmarshal added in v0.17.0 

func (m *CreateRunnerResponse) XXX_Unmarshal(b []byte) error

type CreateServiceRequest 

type CreateServiceRequest struct {
	// Service's sid.
	Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty" validate:"printascii,max=63,domain"`
	// Service's name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" validate:"required,printascii"`
	// Service's description.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty" validate:"printascii"`
	// Configurations related to the service
	Configuration service.Service_Configuration `protobuf:"bytes,4,opt,name=configuration,proto3" json:"configuration" validate:"required"`
	// The list of tasks this service can execute.
	Tasks []*service.Service_Task `protobuf:"bytes,5,rep,name=tasks,proto3" json:"tasks,omitempty" validate:"dive,required"`
	// The list of events this service can emit.
	Events []*service.Service_Event `protobuf:"bytes,6,rep,name=events,proto3" json:"events,omitempty" validate:"dive,required"`
	// The container dependencies this service requires.
	Dependencies []*service.Service_Dependency `protobuf:"bytes,7,rep,name=dependencies,proto3" json:"dependencies,omitempty" validate:"dive,required"`
	// Service's repository url.
	Repository string `protobuf:"bytes,8,opt,name=repository,proto3" json:"repository,omitempty" validate:"omitempty,uri"`
	// The hash id of service's source code on IPFS.
	Source               string   `protobuf:"bytes,9,opt,name=source,proto3" json:"source,omitempty" validate:"required,printascii"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `Create` API.

func (*CreateServiceRequest) Descriptor 

func (*CreateServiceRequest) Descriptor() ([]byte, []int)

func (*CreateServiceRequest) GetConfiguration 

func (m *CreateServiceRequest) GetConfiguration() service.Service_Configuration

func (*CreateServiceRequest) GetDependencies 

func (m *CreateServiceRequest) GetDependencies() []*service.Service_Dependency

func (*CreateServiceRequest) GetDescription 

func (m *CreateServiceRequest) GetDescription() string

func (*CreateServiceRequest) GetEvents 

func (m *CreateServiceRequest) GetEvents() []*service.Service_Event

func (*CreateServiceRequest) GetName 

func (m *CreateServiceRequest) GetName() string

func (*CreateServiceRequest) GetRepository 

func (m *CreateServiceRequest) GetRepository() string

func (*CreateServiceRequest) GetSid 

func (m *CreateServiceRequest) GetSid() string

func (*CreateServiceRequest) GetSource 

func (m *CreateServiceRequest) GetSource() string

func (*CreateServiceRequest) GetTasks 

func (m *CreateServiceRequest) GetTasks() []*service.Service_Task

func (*CreateServiceRequest) ProtoMessage 

func (*CreateServiceRequest) ProtoMessage()

func (*CreateServiceRequest) Reset 

func (m *CreateServiceRequest) Reset()

func (*CreateServiceRequest) String 

func (m *CreateServiceRequest) String() string

func (*CreateServiceRequest) XXX_DiscardUnknown 

func (m *CreateServiceRequest) XXX_DiscardUnknown()

func (*CreateServiceRequest) XXX_Marshal 

func (m *CreateServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateServiceRequest) XXX_Merge 

func (m *CreateServiceRequest) XXX_Merge(src proto.Message)

func (*CreateServiceRequest) XXX_Size 

func (m *CreateServiceRequest) XXX_Size() int

func (*CreateServiceRequest) XXX_Unmarshal 

func (m *CreateServiceRequest) XXX_Unmarshal(b []byte) error

type CreateServiceResponse 

type CreateServiceResponse struct {
	// The service's hash created.
	Hash                 github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,1,opt,name=hash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"hash"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

The response's data for the `Create` API.

func (*CreateServiceResponse) Descriptor 

func (*CreateServiceResponse) Descriptor() ([]byte, []int)

func (*CreateServiceResponse) ProtoMessage 

func (*CreateServiceResponse) ProtoMessage()

func (*CreateServiceResponse) Reset 

func (m *CreateServiceResponse) Reset()

func (*CreateServiceResponse) String 

func (m *CreateServiceResponse) String() string

func (*CreateServiceResponse) XXX_DiscardUnknown 

func (m *CreateServiceResponse) XXX_DiscardUnknown()

func (*CreateServiceResponse) XXX_Marshal 

func (m *CreateServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateServiceResponse) XXX_Merge 

func (m *CreateServiceResponse) XXX_Merge(src proto.Message)

func (*CreateServiceResponse) XXX_Size 

func (m *CreateServiceResponse) XXX_Size() int

func (*CreateServiceResponse) XXX_Unmarshal 

func (m *CreateServiceResponse) XXX_Unmarshal(b []byte) error

type DeleteProcessRequest added in v0.14.0 

type DeleteProcessRequest struct {
	// The process's hash to delete.
	Hash                 github_com_mesg_foundation_engine_hash.Hash `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

The request's data for the `Delete` API.

func (*DeleteProcessRequest) Descriptor added in v0.14.0 

func (*DeleteProcessRequest) Descriptor() ([]byte, []int)

func (*DeleteProcessRequest) ProtoMessage added in v0.14.0 

func (*DeleteProcessRequest) ProtoMessage()

func (*DeleteProcessRequest) Reset added in v0.14.0 

func (m *DeleteProcessRequest) Reset()

func (*DeleteProcessRequest) String added in v0.14.0 

func (m *DeleteProcessRequest) String() string

func (*DeleteProcessRequest) XXX_DiscardUnknown added in v0.14.0 

func (m *DeleteProcessRequest) XXX_DiscardUnknown()

func (*DeleteProcessRequest) XXX_Marshal added in v0.14.0 

func (m *DeleteProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteProcessRequest) XXX_Merge added in v0.14.0 

func (m *DeleteProcessRequest) XXX_Merge(src proto.Message)

func (*DeleteProcessRequest) XXX_Size added in v0.14.0 

func (m *DeleteProcessRequest) XXX_Size() int

func (*DeleteProcessRequest) XXX_Unmarshal added in v0.14.0 

func (m *DeleteProcessRequest) XXX_Unmarshal(b []byte) error

type DeleteProcessResponse added in v0.14.0 

type DeleteProcessResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response's data for the `Delete` API, doesn't contain anything.

func (*DeleteProcessResponse) Descriptor added in v0.14.0 

func (*DeleteProcessResponse) Descriptor() ([]byte, []int)

func (*DeleteProcessResponse) ProtoMessage added in v0.14.0 

func (*DeleteProcessResponse) ProtoMessage()

func (*DeleteProcessResponse) Reset added in v0.14.0 

func (m *DeleteProcessResponse) Reset()

func (*DeleteProcessResponse) String added in v0.14.0 

func (m *DeleteProcessResponse) String() string

func (*DeleteProcessResponse) XXX_DiscardUnknown added in v0.14.0 

func (m *DeleteProcessResponse) XXX_DiscardUnknown()

func (*DeleteProcessResponse) XXX_Marshal added in v0.14.0 

func (m *DeleteProcessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteProcessResponse) XXX_Merge added in v0.14.0 

func (m *DeleteProcessResponse) XXX_Merge(src proto.Message)

func (*DeleteProcessResponse) XXX_Size added in v0.14.0 

func (m *DeleteProcessResponse) XXX_Size() int

func (*DeleteProcessResponse) XXX_Unmarshal added in v0.14.0 

func (m *DeleteProcessResponse) XXX_Unmarshal(b []byte) error

type DeleteRunnerRequest added in v0.17.0 

type DeleteRunnerRequest struct {
	// Runner's hash
	Hash github_com_mesg_foundation_engine_hash.Hash `` /* 131-byte string literal not displayed */
	// If true, any persistent data (volumes) that belongs to the runner's container and its dependencies will also be deleted.
	DeleteData           bool     `protobuf:"varint,2,opt,name=deleteData,proto3" json:"deleteData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `Delete` API.

func (*DeleteRunnerRequest) Descriptor added in v0.17.0 

func (*DeleteRunnerRequest) Descriptor() ([]byte, []int)

func (*DeleteRunnerRequest) GetDeleteData added in v0.17.0 

func (m *DeleteRunnerRequest) GetDeleteData() bool

func (*DeleteRunnerRequest) ProtoMessage added in v0.17.0 

func (*DeleteRunnerRequest) ProtoMessage()

func (*DeleteRunnerRequest) Reset added in v0.17.0 

func (m *DeleteRunnerRequest) Reset()

func (*DeleteRunnerRequest) String added in v0.17.0 

func (m *DeleteRunnerRequest) String() string

func (*DeleteRunnerRequest) XXX_DiscardUnknown added in v0.17.0 

func (m *DeleteRunnerRequest) XXX_DiscardUnknown()

func (*DeleteRunnerRequest) XXX_Marshal added in v0.17.0 

func (m *DeleteRunnerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRunnerRequest) XXX_Merge added in v0.17.0 

func (m *DeleteRunnerRequest) XXX_Merge(src proto.Message)

func (*DeleteRunnerRequest) XXX_Size added in v0.17.0 

func (m *DeleteRunnerRequest) XXX_Size() int

func (*DeleteRunnerRequest) XXX_Unmarshal added in v0.17.0 

func (m *DeleteRunnerRequest) XXX_Unmarshal(b []byte) error

type DeleteRunnerResponse added in v0.17.0 

type DeleteRunnerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response's data for the `Delete` API.

func (*DeleteRunnerResponse) Descriptor added in v0.17.0 

func (*DeleteRunnerResponse) Descriptor() ([]byte, []int)

func (*DeleteRunnerResponse) ProtoMessage added in v0.17.0 

func (*DeleteRunnerResponse) ProtoMessage()

func (*DeleteRunnerResponse) Reset added in v0.17.0 

func (m *DeleteRunnerResponse) Reset()

func (*DeleteRunnerResponse) String added in v0.17.0 

func (m *DeleteRunnerResponse) String() string

func (*DeleteRunnerResponse) XXX_DiscardUnknown added in v0.17.0 

func (m *DeleteRunnerResponse) XXX_DiscardUnknown()

func (*DeleteRunnerResponse) XXX_Marshal added in v0.17.0 

func (m *DeleteRunnerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRunnerResponse) XXX_Merge added in v0.17.0 

func (m *DeleteRunnerResponse) XXX_Merge(src proto.Message)

func (*DeleteRunnerResponse) XXX_Size added in v0.17.0 

func (m *DeleteRunnerResponse) XXX_Size() int

func (*DeleteRunnerResponse) XXX_Unmarshal added in v0.17.0 

func (m *DeleteRunnerResponse) XXX_Unmarshal(b []byte) error

type EventClient 

type EventClient interface {
	// Create creates event with data.
	Create(ctx context.Context, in *CreateEventRequest, opts ...grpc.CallOption) (*CreateEventResponse, error)
	// Stream returns a stream of events that satisfy criteria
	// specified in a request.
	Stream(ctx context.Context, in *StreamEventRequest, opts ...grpc.CallOption) (Event_StreamClient, error)
}

EventClient is the client API for Event service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEventClient 

func NewEventClient(cc *grpc.ClientConn) EventClient

type EventServer 

type EventServer interface {
	// Create creates event with data.
	Create(context.Context, *CreateEventRequest) (*CreateEventResponse, error)
	// Stream returns a stream of events that satisfy criteria
	// specified in a request.
	Stream(*StreamEventRequest, Event_StreamServer) error
}

EventServer is the server API for Event service.

type Event_StreamClient 

type Event_StreamClient interface {
	Recv() (*event.Event, error)
	grpc.ClientStream
}

type Event_StreamServer 

type Event_StreamServer interface {
	Send(*event.Event) error
	grpc.ServerStream
}

type ExecutionClient 

type ExecutionClient interface {
	// Create creates a single Execution specified in a request.
	Create(ctx context.Context, in *CreateExecutionRequest, opts ...grpc.CallOption) (*CreateExecutionResponse, error)
	// Get returns a single Execution specified in a request.
	Get(ctx context.Context, in *GetExecutionRequest, opts ...grpc.CallOption) (*execution.Execution, error)
	// List returns all Executions matching the criteria of the request.
	List(ctx context.Context, in *ListExecutionRequest, opts ...grpc.CallOption) (*ListExecutionResponse, error)
	// Stream returns a stream of executions that satisfy criteria
	// specified in a request.
	Stream(ctx context.Context, in *StreamExecutionRequest, opts ...grpc.CallOption) (Execution_StreamClient, error)
	// Update updates execution with outputs or an error.
	Update(ctx context.Context, in *UpdateExecutionRequest, opts ...grpc.CallOption) (*UpdateExecutionResponse, error)
}

ExecutionClient is the client API for Execution service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewExecutionClient 

func NewExecutionClient(cc *grpc.ClientConn) ExecutionClient

type ExecutionServer 

type ExecutionServer interface {
	// Create creates a single Execution specified in a request.
	Create(context.Context, *CreateExecutionRequest) (*CreateExecutionResponse, error)
	// Get returns a single Execution specified in a request.
	Get(context.Context, *GetExecutionRequest) (*execution.Execution, error)
	// List returns all Executions matching the criteria of the request.
	List(context.Context, *ListExecutionRequest) (*ListExecutionResponse, error)
	// Stream returns a stream of executions that satisfy criteria
	// specified in a request.
	Stream(*StreamExecutionRequest, Execution_StreamServer) error
	// Update updates execution with outputs or an error.
	Update(context.Context, *UpdateExecutionRequest) (*UpdateExecutionResponse, error)
}

ExecutionServer is the server API for Execution service.

type Execution_StreamClient 

type Execution_StreamClient interface {
	Recv() (*execution.Execution, error)
	grpc.ClientStream
}

type Execution_StreamServer 

type Execution_StreamServer interface {
	Send(*execution.Execution) error
	grpc.ServerStream
}

type ExistsServiceRequest added in v0.16.0 

type ExistsServiceRequest struct {
	// The service's hash of the existing service. This hash is nil if exists is fals.
	Hash                 github_com_mesg_foundation_engine_hash.Hash `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

The request's data for the `List` API.

func (*ExistsServiceRequest) Descriptor added in v0.16.0 

func (*ExistsServiceRequest) Descriptor() ([]byte, []int)

func (*ExistsServiceRequest) ProtoMessage added in v0.16.0 

func (*ExistsServiceRequest) ProtoMessage()

func (*ExistsServiceRequest) Reset added in v0.16.0 

func (m *ExistsServiceRequest) Reset()

func (*ExistsServiceRequest) String added in v0.16.0 

func (m *ExistsServiceRequest) String() string

func (*ExistsServiceRequest) XXX_DiscardUnknown added in v0.16.0 

func (m *ExistsServiceRequest) XXX_DiscardUnknown()

func (*ExistsServiceRequest) XXX_Marshal added in v0.16.0 

func (m *ExistsServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExistsServiceRequest) XXX_Merge added in v0.16.0 

func (m *ExistsServiceRequest) XXX_Merge(src proto.Message)

func (*ExistsServiceRequest) XXX_Size added in v0.16.0 

func (m *ExistsServiceRequest) XXX_Size() int

func (*ExistsServiceRequest) XXX_Unmarshal added in v0.16.0 

func (m *ExistsServiceRequest) XXX_Unmarshal(b []byte) error

type ExistsServiceResponse added in v0.16.0 

type ExistsServiceResponse struct {
	// True if a service already exists, false otherwise.
	Exists               bool     `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response's data for the `Exists` API.

func (*ExistsServiceResponse) Descriptor added in v0.16.0 

func (*ExistsServiceResponse) Descriptor() ([]byte, []int)

func (*ExistsServiceResponse) GetExists added in v0.16.0 

func (m *ExistsServiceResponse) GetExists() bool

func (*ExistsServiceResponse) ProtoMessage added in v0.16.0 

func (*ExistsServiceResponse) ProtoMessage()

func (*ExistsServiceResponse) Reset added in v0.16.0 

func (m *ExistsServiceResponse) Reset()

func (*ExistsServiceResponse) String added in v0.16.0 

func (m *ExistsServiceResponse) String() string

func (*ExistsServiceResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *ExistsServiceResponse) XXX_DiscardUnknown()

func (*ExistsServiceResponse) XXX_Marshal added in v0.16.0 

func (m *ExistsServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExistsServiceResponse) XXX_Merge added in v0.16.0 

func (m *ExistsServiceResponse) XXX_Merge(src proto.Message)

func (*ExistsServiceResponse) XXX_Size added in v0.16.0 

func (m *ExistsServiceResponse) XXX_Size() int

func (*ExistsServiceResponse) XXX_Unmarshal added in v0.16.0 

func (m *ExistsServiceResponse) XXX_Unmarshal(b []byte) error

type GetExecutionRequest 

type GetExecutionRequest struct {
	// Execution's hash to fetch.
	Hash                 github_com_mesg_foundation_engine_hash.Hash `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

GetExecutionRequest defines request to retrieve a single execution.

func (*GetExecutionRequest) Descriptor 

func (*GetExecutionRequest) Descriptor() ([]byte, []int)

func (*GetExecutionRequest) ProtoMessage 

func (*GetExecutionRequest) ProtoMessage()

func (*GetExecutionRequest) Reset 

func (m *GetExecutionRequest) Reset()

func (*GetExecutionRequest) String 

func (m *GetExecutionRequest) String() string

func (*GetExecutionRequest) XXX_DiscardUnknown 

func (m *GetExecutionRequest) XXX_DiscardUnknown()

func (*GetExecutionRequest) XXX_Marshal 

func (m *GetExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetExecutionRequest) XXX_Merge 

func (m *GetExecutionRequest) XXX_Merge(src proto.Message)

func (*GetExecutionRequest) XXX_Size 

func (m *GetExecutionRequest) XXX_Size() int

func (*GetExecutionRequest) XXX_Unmarshal 

func (m *GetExecutionRequest) XXX_Unmarshal(b []byte) error

type GetInstanceRequest 

type GetInstanceRequest struct {
	Hash                 github_com_mesg_foundation_engine_hash.Hash `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

The request's data for the `Get` API.

func (*GetInstanceRequest) Descriptor 

func (*GetInstanceRequest) Descriptor() ([]byte, []int)

func (*GetInstanceRequest) ProtoMessage 

func (*GetInstanceRequest) ProtoMessage()

func (*GetInstanceRequest) Reset 

func (m *GetInstanceRequest) Reset()

func (*GetInstanceRequest) String 

func (m *GetInstanceRequest) String() string

func (*GetInstanceRequest) XXX_DiscardUnknown 

func (m *GetInstanceRequest) XXX_DiscardUnknown()

func (*GetInstanceRequest) XXX_Marshal 

func (m *GetInstanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetInstanceRequest) XXX_Merge 

func (m *GetInstanceRequest) XXX_Merge(src proto.Message)

func (*GetInstanceRequest) XXX_Size 

func (m *GetInstanceRequest) XXX_Size() int

func (*GetInstanceRequest) XXX_Unmarshal 

func (m *GetInstanceRequest) XXX_Unmarshal(b []byte) error

type GetProcessRequest added in v0.14.0 

type GetProcessRequest struct {
	// The process's hash to fetch.
	Hash                 github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,1,opt,name=hash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"hash"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

The request's data for the `Get` API.

func (*GetProcessRequest) Descriptor added in v0.14.0 

func (*GetProcessRequest) Descriptor() ([]byte, []int)

func (*GetProcessRequest) ProtoMessage added in v0.14.0 

func (*GetProcessRequest) ProtoMessage()

func (*GetProcessRequest) Reset added in v0.14.0 

func (m *GetProcessRequest) Reset()

func (*GetProcessRequest) String added in v0.14.0 

func (m *GetProcessRequest) String() string

func (*GetProcessRequest) XXX_DiscardUnknown added in v0.14.0 

func (m *GetProcessRequest) XXX_DiscardUnknown()

func (*GetProcessRequest) XXX_Marshal added in v0.14.0 

func (m *GetProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetProcessRequest) XXX_Merge added in v0.14.0 

func (m *GetProcessRequest) XXX_Merge(src proto.Message)

func (*GetProcessRequest) XXX_Size added in v0.14.0 

func (m *GetProcessRequest) XXX_Size() int

func (*GetProcessRequest) XXX_Unmarshal added in v0.14.0 

func (m *GetProcessRequest) XXX_Unmarshal(b []byte) error

type GetRunnerRequest added in v0.17.0 

type GetRunnerRequest struct {
	Hash                 github_com_mesg_foundation_engine_hash.Hash `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

The request's data for the `Get` API.

func (*GetRunnerRequest) Descriptor added in v0.17.0 

func (*GetRunnerRequest) Descriptor() ([]byte, []int)

func (*GetRunnerRequest) ProtoMessage added in v0.17.0 

func (*GetRunnerRequest) ProtoMessage()

func (*GetRunnerRequest) Reset added in v0.17.0 

func (m *GetRunnerRequest) Reset()

func (*GetRunnerRequest) String added in v0.17.0 

func (m *GetRunnerRequest) String() string

func (*GetRunnerRequest) XXX_DiscardUnknown added in v0.17.0 

func (m *GetRunnerRequest) XXX_DiscardUnknown()

func (*GetRunnerRequest) XXX_Marshal added in v0.17.0 

func (m *GetRunnerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRunnerRequest) XXX_Merge added in v0.17.0 

func (m *GetRunnerRequest) XXX_Merge(src proto.Message)

func (*GetRunnerRequest) XXX_Size added in v0.17.0 

func (m *GetRunnerRequest) XXX_Size() int

func (*GetRunnerRequest) XXX_Unmarshal added in v0.17.0 

func (m *GetRunnerRequest) XXX_Unmarshal(b []byte) error

type GetServiceRequest 

type GetServiceRequest struct {
	// The service's hash to fetch.
	Hash                 github_com_mesg_foundation_engine_hash.Hash `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

The request's data for the `Get` API.

func (*GetServiceRequest) Descriptor 

func (*GetServiceRequest) Descriptor() ([]byte, []int)

func (*GetServiceRequest) ProtoMessage 

func (*GetServiceRequest) ProtoMessage()

func (*GetServiceRequest) Reset 

func (m *GetServiceRequest) Reset()

func (*GetServiceRequest) String 

func (m *GetServiceRequest) String() string

func (*GetServiceRequest) XXX_DiscardUnknown 

func (m *GetServiceRequest) XXX_DiscardUnknown()

func (*GetServiceRequest) XXX_Marshal 

func (m *GetServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServiceRequest) XXX_Merge 

func (m *GetServiceRequest) XXX_Merge(src proto.Message)

func (*GetServiceRequest) XXX_Size 

func (m *GetServiceRequest) XXX_Size() int

func (*GetServiceRequest) XXX_Unmarshal 

func (m *GetServiceRequest) XXX_Unmarshal(b []byte) error

type HashServiceResponse added in v0.16.0 

type HashServiceResponse struct {
	// Hash of the service calculated.
	Hash                 github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,1,opt,name=hash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"hash"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

The request's data for the `Hash` API.

func (*HashServiceResponse) Descriptor added in v0.16.0 

func (*HashServiceResponse) Descriptor() ([]byte, []int)

func (*HashServiceResponse) ProtoMessage added in v0.16.0 

func (*HashServiceResponse) ProtoMessage()

func (*HashServiceResponse) Reset added in v0.16.0 

func (m *HashServiceResponse) Reset()

func (*HashServiceResponse) String added in v0.16.0 

func (m *HashServiceResponse) String() string

func (*HashServiceResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *HashServiceResponse) XXX_DiscardUnknown()

func (*HashServiceResponse) XXX_Marshal added in v0.16.0 

func (m *HashServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HashServiceResponse) XXX_Merge added in v0.16.0 

func (m *HashServiceResponse) XXX_Merge(src proto.Message)

func (*HashServiceResponse) XXX_Size added in v0.16.0 

func (m *HashServiceResponse) XXX_Size() int

func (*HashServiceResponse) XXX_Unmarshal added in v0.16.0 

func (m *HashServiceResponse) XXX_Unmarshal(b []byte) error

type InstanceClient 

type InstanceClient interface {
	// Get returns an Instance matching the criteria of the request.
	Get(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*instance.Instance, error)
	// List returns all Instances matching the criteria of the request.
	List(ctx context.Context, in *ListInstanceRequest, opts ...grpc.CallOption) (*ListInstanceResponse, error)
}

InstanceClient is the client API for Instance service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewInstanceClient 

func NewInstanceClient(cc *grpc.ClientConn) InstanceClient

type InstanceServer 

type InstanceServer interface {
	// Get returns an Instance matching the criteria of the request.
	Get(context.Context, *GetInstanceRequest) (*instance.Instance, error)
	// List returns all Instances matching the criteria of the request.
	List(context.Context, *ListInstanceRequest) (*ListInstanceResponse, error)
}

InstanceServer is the server API for Instance service.

type ListExecutionRequest added in v0.17.0 

type ListExecutionRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `List` API.

func (*ListExecutionRequest) Descriptor added in v0.17.0 

func (*ListExecutionRequest) Descriptor() ([]byte, []int)

func (*ListExecutionRequest) ProtoMessage added in v0.17.0 

func (*ListExecutionRequest) ProtoMessage()

func (*ListExecutionRequest) Reset added in v0.17.0 

func (m *ListExecutionRequest) Reset()

func (*ListExecutionRequest) String added in v0.17.0 

func (m *ListExecutionRequest) String() string

func (*ListExecutionRequest) XXX_DiscardUnknown added in v0.17.0 

func (m *ListExecutionRequest) XXX_DiscardUnknown()

func (*ListExecutionRequest) XXX_Marshal added in v0.17.0 

func (m *ListExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListExecutionRequest) XXX_Merge added in v0.17.0 

func (m *ListExecutionRequest) XXX_Merge(src proto.Message)

func (*ListExecutionRequest) XXX_Size added in v0.17.0 

func (m *ListExecutionRequest) XXX_Size() int

func (*ListExecutionRequest) XXX_Unmarshal added in v0.17.0 

func (m *ListExecutionRequest) XXX_Unmarshal(b []byte) error

type ListExecutionResponse added in v0.17.0 

type ListExecutionResponse struct {
	// List of executions that match the request's filters.
	Executions           []*execution.Execution `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

The response's data for the `List` API.

func (*ListExecutionResponse) Descriptor added in v0.17.0 

func (*ListExecutionResponse) Descriptor() ([]byte, []int)

func (*ListExecutionResponse) GetExecutions added in v0.17.0 

func (m *ListExecutionResponse) GetExecutions() []*execution.Execution

func (*ListExecutionResponse) ProtoMessage added in v0.17.0 

func (*ListExecutionResponse) ProtoMessage()

func (*ListExecutionResponse) Reset added in v0.17.0 

func (m *ListExecutionResponse) Reset()

func (*ListExecutionResponse) String added in v0.17.0 

func (m *ListExecutionResponse) String() string

func (*ListExecutionResponse) XXX_DiscardUnknown added in v0.17.0 

func (m *ListExecutionResponse) XXX_DiscardUnknown()

func (*ListExecutionResponse) XXX_Marshal added in v0.17.0 

func (m *ListExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListExecutionResponse) XXX_Merge added in v0.17.0 

func (m *ListExecutionResponse) XXX_Merge(src proto.Message)

func (*ListExecutionResponse) XXX_Size added in v0.17.0 

func (m *ListExecutionResponse) XXX_Size() int

func (*ListExecutionResponse) XXX_Unmarshal added in v0.17.0 

func (m *ListExecutionResponse) XXX_Unmarshal(b []byte) error

type ListInstanceRequest added in v0.15.0 

type ListInstanceRequest struct {
	// Filter used to filter a list of instance.
	Filter               *ListInstanceRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

The request's data for the `List` API.

func (*ListInstanceRequest) Descriptor added in v0.15.0 

func (*ListInstanceRequest) Descriptor() ([]byte, []int)

func (*ListInstanceRequest) GetFilter added in v0.17.0 

func (m *ListInstanceRequest) GetFilter() *ListInstanceRequest_Filter

func (*ListInstanceRequest) ProtoMessage added in v0.15.0 

func (*ListInstanceRequest) ProtoMessage()

func (*ListInstanceRequest) Reset added in v0.15.0 

func (m *ListInstanceRequest) Reset()

func (*ListInstanceRequest) String added in v0.15.0 

func (m *ListInstanceRequest) String() string

func (*ListInstanceRequest) XXX_DiscardUnknown added in v0.15.0 

func (m *ListInstanceRequest) XXX_DiscardUnknown()

func (*ListInstanceRequest) XXX_Marshal added in v0.15.0 

func (m *ListInstanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListInstanceRequest) XXX_Merge added in v0.15.0 

func (m *ListInstanceRequest) XXX_Merge(src proto.Message)

func (*ListInstanceRequest) XXX_Size added in v0.15.0 

func (m *ListInstanceRequest) XXX_Size() int

func (*ListInstanceRequest) XXX_Unmarshal added in v0.15.0 

func (m *ListInstanceRequest) XXX_Unmarshal(b []byte) error

type ListInstanceRequest_Filter added in v0.17.0 

type ListInstanceRequest_Filter struct {
	// Service hash to filter executions.
	ServiceHash          github_com_mesg_foundation_engine_hash.Hash `` /* 146-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

Filter contains filtering criteria.

func (*ListInstanceRequest_Filter) Descriptor added in v0.17.0 

func (*ListInstanceRequest_Filter) Descriptor() ([]byte, []int)

func (*ListInstanceRequest_Filter) ProtoMessage added in v0.17.0 

func (*ListInstanceRequest_Filter) ProtoMessage()

func (*ListInstanceRequest_Filter) Reset added in v0.17.0 

func (m *ListInstanceRequest_Filter) Reset()

func (*ListInstanceRequest_Filter) String added in v0.17.0 

func (m *ListInstanceRequest_Filter) String() string

func (*ListInstanceRequest_Filter) XXX_DiscardUnknown added in v0.17.0 

func (m *ListInstanceRequest_Filter) XXX_DiscardUnknown()

func (*ListInstanceRequest_Filter) XXX_Marshal added in v0.17.0 

func (m *ListInstanceRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListInstanceRequest_Filter) XXX_Merge added in v0.17.0 

func (m *ListInstanceRequest_Filter) XXX_Merge(src proto.Message)

func (*ListInstanceRequest_Filter) XXX_Size added in v0.17.0 

func (m *ListInstanceRequest_Filter) XXX_Size() int

func (*ListInstanceRequest_Filter) XXX_Unmarshal added in v0.17.0 

func (m *ListInstanceRequest_Filter) XXX_Unmarshal(b []byte) error

type ListInstanceResponse added in v0.15.0 

type ListInstanceResponse struct {
	// List of instances that match the request's filters.
	Instances            []*instance.Instance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

The response's data for the `List` API.

func (*ListInstanceResponse) Descriptor added in v0.15.0 

func (*ListInstanceResponse) Descriptor() ([]byte, []int)

func (*ListInstanceResponse) GetInstances added in v0.15.0 

func (m *ListInstanceResponse) GetInstances() []*instance.Instance

func (*ListInstanceResponse) ProtoMessage added in v0.15.0 

func (*ListInstanceResponse) ProtoMessage()

func (*ListInstanceResponse) Reset added in v0.15.0 

func (m *ListInstanceResponse) Reset()

func (*ListInstanceResponse) String added in v0.15.0 

func (m *ListInstanceResponse) String() string

func (*ListInstanceResponse) XXX_DiscardUnknown added in v0.15.0 

func (m *ListInstanceResponse) XXX_DiscardUnknown()

func (*ListInstanceResponse) XXX_Marshal added in v0.15.0 

func (m *ListInstanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListInstanceResponse) XXX_Merge added in v0.15.0 

func (m *ListInstanceResponse) XXX_Merge(src proto.Message)

func (*ListInstanceResponse) XXX_Size added in v0.15.0 

func (m *ListInstanceResponse) XXX_Size() int

func (*ListInstanceResponse) XXX_Unmarshal added in v0.15.0 

func (m *ListInstanceResponse) XXX_Unmarshal(b []byte) error

type ListOwnershipRequest added in v0.16.0 

type ListOwnershipRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `List` API.

func (*ListOwnershipRequest) Descriptor added in v0.16.0 

func (*ListOwnershipRequest) Descriptor() ([]byte, []int)

func (*ListOwnershipRequest) ProtoMessage added in v0.16.0 

func (*ListOwnershipRequest) ProtoMessage()

func (*ListOwnershipRequest) Reset added in v0.16.0 

func (m *ListOwnershipRequest) Reset()

func (*ListOwnershipRequest) String added in v0.16.0 

func (m *ListOwnershipRequest) String() string

func (*ListOwnershipRequest) XXX_DiscardUnknown added in v0.16.0 

func (m *ListOwnershipRequest) XXX_DiscardUnknown()

func (*ListOwnershipRequest) XXX_Marshal added in v0.16.0 

func (m *ListOwnershipRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListOwnershipRequest) XXX_Merge added in v0.16.0 

func (m *ListOwnershipRequest) XXX_Merge(src proto.Message)

func (*ListOwnershipRequest) XXX_Size added in v0.16.0 

func (m *ListOwnershipRequest) XXX_Size() int

func (*ListOwnershipRequest) XXX_Unmarshal added in v0.16.0 

func (m *ListOwnershipRequest) XXX_Unmarshal(b []byte) error

type ListOwnershipResponse added in v0.16.0 

type ListOwnershipResponse struct {
	// List of ownerships that match the request's filters.
	Ownerships           []*ownership.Ownership `protobuf:"bytes,1,rep,name=ownerships,proto3" json:"ownerships,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

The response's data for the `List` API.

func (*ListOwnershipResponse) Descriptor added in v0.16.0 

func (*ListOwnershipResponse) Descriptor() ([]byte, []int)

func (*ListOwnershipResponse) GetOwnerships added in v0.16.0 

func (m *ListOwnershipResponse) GetOwnerships() []*ownership.Ownership

func (*ListOwnershipResponse) ProtoMessage added in v0.16.0 

func (*ListOwnershipResponse) ProtoMessage()

func (*ListOwnershipResponse) Reset added in v0.16.0 

func (m *ListOwnershipResponse) Reset()

func (*ListOwnershipResponse) String added in v0.16.0 

func (m *ListOwnershipResponse) String() string

func (*ListOwnershipResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *ListOwnershipResponse) XXX_DiscardUnknown()

func (*ListOwnershipResponse) XXX_Marshal added in v0.16.0 

func (m *ListOwnershipResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListOwnershipResponse) XXX_Merge added in v0.16.0 

func (m *ListOwnershipResponse) XXX_Merge(src proto.Message)

func (*ListOwnershipResponse) XXX_Size added in v0.16.0 

func (m *ListOwnershipResponse) XXX_Size() int

func (*ListOwnershipResponse) XXX_Unmarshal added in v0.16.0 

func (m *ListOwnershipResponse) XXX_Unmarshal(b []byte) error

type ListProcessRequest added in v0.14.0 

type ListProcessRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `List` API.

func (*ListProcessRequest) Descriptor added in v0.14.0 

func (*ListProcessRequest) Descriptor() ([]byte, []int)

func (*ListProcessRequest) ProtoMessage added in v0.14.0 

func (*ListProcessRequest) ProtoMessage()

func (*ListProcessRequest) Reset added in v0.14.0 

func (m *ListProcessRequest) Reset()

func (*ListProcessRequest) String added in v0.14.0 

func (m *ListProcessRequest) String() string

func (*ListProcessRequest) XXX_DiscardUnknown added in v0.14.0 

func (m *ListProcessRequest) XXX_DiscardUnknown()

func (*ListProcessRequest) XXX_Marshal added in v0.14.0 

func (m *ListProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListProcessRequest) XXX_Merge added in v0.14.0 

func (m *ListProcessRequest) XXX_Merge(src proto.Message)

func (*ListProcessRequest) XXX_Size added in v0.14.0 

func (m *ListProcessRequest) XXX_Size() int

func (*ListProcessRequest) XXX_Unmarshal added in v0.14.0 

func (m *ListProcessRequest) XXX_Unmarshal(b []byte) error

type ListProcessResponse added in v0.14.0 

type ListProcessResponse struct {
	// List of processes that match the request's filters.
	Processes            []*process.Process `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

The response's data for the `List` API.

func (*ListProcessResponse) Descriptor added in v0.14.0 

func (*ListProcessResponse) Descriptor() ([]byte, []int)

func (*ListProcessResponse) GetProcesses added in v0.14.0 

func (m *ListProcessResponse) GetProcesses() []*process.Process

func (*ListProcessResponse) ProtoMessage added in v0.14.0 

func (*ListProcessResponse) ProtoMessage()

func (*ListProcessResponse) Reset added in v0.14.0 

func (m *ListProcessResponse) Reset()

func (*ListProcessResponse) String added in v0.14.0 

func (m *ListProcessResponse) String() string

func (*ListProcessResponse) XXX_DiscardUnknown added in v0.14.0 

func (m *ListProcessResponse) XXX_DiscardUnknown()

func (*ListProcessResponse) XXX_Marshal added in v0.14.0 

func (m *ListProcessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListProcessResponse) XXX_Merge added in v0.14.0 

func (m *ListProcessResponse) XXX_Merge(src proto.Message)

func (*ListProcessResponse) XXX_Size added in v0.14.0 

func (m *ListProcessResponse) XXX_Size() int

func (*ListProcessResponse) XXX_Unmarshal added in v0.14.0 

func (m *ListProcessResponse) XXX_Unmarshal(b []byte) error

type ListRunnerRequest added in v0.17.0 

type ListRunnerRequest struct {
	// Filter used to filter runners.
	Filter               *ListRunnerRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

The request's data for the `List` API.

func (*ListRunnerRequest) Descriptor added in v0.17.0 

func (*ListRunnerRequest) Descriptor() ([]byte, []int)

func (*ListRunnerRequest) GetFilter added in v0.17.0 

func (m *ListRunnerRequest) GetFilter() *ListRunnerRequest_Filter

func (*ListRunnerRequest) ProtoMessage added in v0.17.0 

func (*ListRunnerRequest) ProtoMessage()

func (*ListRunnerRequest) Reset added in v0.17.0 

func (m *ListRunnerRequest) Reset()

func (*ListRunnerRequest) String added in v0.17.0 

func (m *ListRunnerRequest) String() string

func (*ListRunnerRequest) XXX_DiscardUnknown added in v0.17.0 

func (m *ListRunnerRequest) XXX_DiscardUnknown()

func (*ListRunnerRequest) XXX_Marshal added in v0.17.0 

func (m *ListRunnerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListRunnerRequest) XXX_Merge added in v0.17.0 

func (m *ListRunnerRequest) XXX_Merge(src proto.Message)

func (*ListRunnerRequest) XXX_Size added in v0.17.0 

func (m *ListRunnerRequest) XXX_Size() int

func (*ListRunnerRequest) XXX_Unmarshal added in v0.17.0 

func (m *ListRunnerRequest) XXX_Unmarshal(b []byte) error

type ListRunnerRequest_Filter added in v0.17.0 

type ListRunnerRequest_Filter struct {
	// Filter by instance hash.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 138-byte string literal not displayed */
	// Filter by address
	Address              string   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty" validate:"accaddress"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Filter contains filtering criteria.

func (*ListRunnerRequest_Filter) Descriptor added in v0.17.0 

func (*ListRunnerRequest_Filter) Descriptor() ([]byte, []int)

func (*ListRunnerRequest_Filter) GetAddress added in v0.17.0 

func (m *ListRunnerRequest_Filter) GetAddress() string

func (*ListRunnerRequest_Filter) ProtoMessage added in v0.17.0 

func (*ListRunnerRequest_Filter) ProtoMessage()

func (*ListRunnerRequest_Filter) Reset added in v0.17.0 

func (m *ListRunnerRequest_Filter) Reset()

func (*ListRunnerRequest_Filter) String added in v0.17.0 

func (m *ListRunnerRequest_Filter) String() string

func (*ListRunnerRequest_Filter) XXX_DiscardUnknown added in v0.17.0 

func (m *ListRunnerRequest_Filter) XXX_DiscardUnknown()

func (*ListRunnerRequest_Filter) XXX_Marshal added in v0.17.0 

func (m *ListRunnerRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListRunnerRequest_Filter) XXX_Merge added in v0.17.0 

func (m *ListRunnerRequest_Filter) XXX_Merge(src proto.Message)

func (*ListRunnerRequest_Filter) XXX_Size added in v0.17.0 

func (m *ListRunnerRequest_Filter) XXX_Size() int

func (*ListRunnerRequest_Filter) XXX_Unmarshal added in v0.17.0 

func (m *ListRunnerRequest_Filter) XXX_Unmarshal(b []byte) error

type ListRunnerResponse added in v0.17.0 

type ListRunnerResponse struct {
	// List of runners that match the request's filters.
	Runners              []*runner.Runner `protobuf:"bytes,1,rep,name=runners,proto3" json:"runners,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

The response's data for the `List` API.

func (*ListRunnerResponse) Descriptor added in v0.17.0 

func (*ListRunnerResponse) Descriptor() ([]byte, []int)

func (*ListRunnerResponse) GetRunners added in v0.17.0 

func (m *ListRunnerResponse) GetRunners() []*runner.Runner

func (*ListRunnerResponse) ProtoMessage added in v0.17.0 

func (*ListRunnerResponse) ProtoMessage()

func (*ListRunnerResponse) Reset added in v0.17.0 

func (m *ListRunnerResponse) Reset()

func (*ListRunnerResponse) String added in v0.17.0 

func (m *ListRunnerResponse) String() string

func (*ListRunnerResponse) XXX_DiscardUnknown added in v0.17.0 

func (m *ListRunnerResponse) XXX_DiscardUnknown()

func (*ListRunnerResponse) XXX_Marshal added in v0.17.0 

func (m *ListRunnerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListRunnerResponse) XXX_Merge added in v0.17.0 

func (m *ListRunnerResponse) XXX_Merge(src proto.Message)

func (*ListRunnerResponse) XXX_Size added in v0.17.0 

func (m *ListRunnerResponse) XXX_Size() int

func (*ListRunnerResponse) XXX_Unmarshal added in v0.17.0 

func (m *ListRunnerResponse) XXX_Unmarshal(b []byte) error

type ListServiceRequest 

type ListServiceRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `List` API.

func (*ListServiceRequest) Descriptor 

func (*ListServiceRequest) Descriptor() ([]byte, []int)

func (*ListServiceRequest) ProtoMessage 

func (*ListServiceRequest) ProtoMessage()

func (*ListServiceRequest) Reset 

func (m *ListServiceRequest) Reset()

func (*ListServiceRequest) String 

func (m *ListServiceRequest) String() string

func (*ListServiceRequest) XXX_DiscardUnknown 

func (m *ListServiceRequest) XXX_DiscardUnknown()

func (*ListServiceRequest) XXX_Marshal 

func (m *ListServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListServiceRequest) XXX_Merge 

func (m *ListServiceRequest) XXX_Merge(src proto.Message)

func (*ListServiceRequest) XXX_Size 

func (m *ListServiceRequest) XXX_Size() int

func (*ListServiceRequest) XXX_Unmarshal 

func (m *ListServiceRequest) XXX_Unmarshal(b []byte) error

type ListServiceResponse 

type ListServiceResponse struct {
	// List of services that match the request's filters.
	Services             []*service.Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

The response's data for the `List` API.

func (*ListServiceResponse) Descriptor 

func (*ListServiceResponse) Descriptor() ([]byte, []int)

func (*ListServiceResponse) GetServices 

func (m *ListServiceResponse) GetServices() []*service.Service

func (*ListServiceResponse) ProtoMessage 

func (*ListServiceResponse) ProtoMessage()

func (*ListServiceResponse) Reset 

func (m *ListServiceResponse) Reset()

func (*ListServiceResponse) String 

func (m *ListServiceResponse) String() string

func (*ListServiceResponse) XXX_DiscardUnknown 

func (m *ListServiceResponse) XXX_DiscardUnknown()

func (*ListServiceResponse) XXX_Marshal 

func (m *ListServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListServiceResponse) XXX_Merge 

func (m *ListServiceResponse) XXX_Merge(src proto.Message)

func (*ListServiceResponse) XXX_Size 

func (m *ListServiceResponse) XXX_Size() int

func (*ListServiceResponse) XXX_Unmarshal 

func (m *ListServiceResponse) XXX_Unmarshal(b []byte) error

type OwnershipClient added in v0.16.0 

type OwnershipClient interface {
	// List returns ownerships specified in a request.
	List(ctx context.Context, in *ListOwnershipRequest, opts ...grpc.CallOption) (*ListOwnershipResponse, error)
}

OwnershipClient is the client API for Ownership service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewOwnershipClient added in v0.16.0 

func NewOwnershipClient(cc *grpc.ClientConn) OwnershipClient

type OwnershipServer added in v0.16.0 

type OwnershipServer interface {
	// List returns ownerships specified in a request.
	List(context.Context, *ListOwnershipRequest) (*ListOwnershipResponse, error)
}

OwnershipServer is the server API for Ownership service.

type ProcessClient added in v0.14.0 

type ProcessClient interface {
	// Create a Process from a Process Definition.
	// It will return an unique identifier which is used to interact with the Process.
	Create(ctx context.Context, in *CreateProcessRequest, opts ...grpc.CallOption) (*CreateProcessResponse, error)
	// Delete a process.
	// An error is returned if one or more Instances of the process are running.
	Delete(ctx context.Context, in *DeleteProcessRequest, opts ...grpc.CallOption) (*DeleteProcessResponse, error)
	// Get returns a process matching the criteria of the request.
	Get(ctx context.Context, in *GetProcessRequest, opts ...grpc.CallOption) (*process.Process, error)
	// List returns processes specified in a request.
	List(ctx context.Context, in *ListProcessRequest, opts ...grpc.CallOption) (*ListProcessResponse, error)
}

ProcessClient is the client API for Process service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewProcessClient added in v0.14.0 

func NewProcessClient(cc *grpc.ClientConn) ProcessClient

type ProcessServer added in v0.14.0 

type ProcessServer interface {
	// Create a Process from a Process Definition.
	// It will return an unique identifier which is used to interact with the Process.
	Create(context.Context, *CreateProcessRequest) (*CreateProcessResponse, error)
	// Delete a process.
	// An error is returned if one or more Instances of the process are running.
	Delete(context.Context, *DeleteProcessRequest) (*DeleteProcessResponse, error)
	// Get returns a process matching the criteria of the request.
	Get(context.Context, *GetProcessRequest) (*process.Process, error)
	// List returns processes specified in a request.
	List(context.Context, *ListProcessRequest) (*ListProcessResponse, error)
}

ProcessServer is the server API for Process service.

type RunnerClient added in v0.17.0 

type RunnerClient interface {
	// Get returns an Runner matching the criteria of the request.
	Get(ctx context.Context, in *GetRunnerRequest, opts ...grpc.CallOption) (*runner.Runner, error)
	// List returns all Runners matching the criteria of the request.
	List(ctx context.Context, in *ListRunnerRequest, opts ...grpc.CallOption) (*ListRunnerResponse, error)
	// Create an Runner from a Service's hash and custom environmental variables.
	// It will return an unique identifier to identify the runner.
	Create(ctx context.Context, in *CreateRunnerRequest, opts ...grpc.CallOption) (*CreateRunnerResponse, error)
	// Delete an Runner.
	Delete(ctx context.Context, in *DeleteRunnerRequest, opts ...grpc.CallOption) (*DeleteRunnerResponse, error)
}

RunnerClient is the client API for Runner service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRunnerClient added in v0.17.0 

func NewRunnerClient(cc *grpc.ClientConn) RunnerClient

type RunnerServer added in v0.17.0 

type RunnerServer interface {
	// Get returns an Runner matching the criteria of the request.
	Get(context.Context, *GetRunnerRequest) (*runner.Runner, error)
	// List returns all Runners matching the criteria of the request.
	List(context.Context, *ListRunnerRequest) (*ListRunnerResponse, error)
	// Create an Runner from a Service's hash and custom environmental variables.
	// It will return an unique identifier to identify the runner.
	Create(context.Context, *CreateRunnerRequest) (*CreateRunnerResponse, error)
	// Delete an Runner.
	Delete(context.Context, *DeleteRunnerRequest) (*DeleteRunnerResponse, error)
}

RunnerServer is the server API for Runner service.

type ServiceClient 

type ServiceClient interface {
	// Create a Service from a Service Definition.
	// It will return an unique identifier which is used to interact with the Service.
	Create(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*CreateServiceResponse, error)
	// Get returns a Service matching the criteria of the request.
	Get(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*service.Service, error)
	// List returns services specified in a request.
	List(ctx context.Context, in *ListServiceRequest, opts ...grpc.CallOption) (*ListServiceResponse, error)
	// Exists return if a service already exists.
	Exists(ctx context.Context, in *ExistsServiceRequest, opts ...grpc.CallOption) (*ExistsServiceResponse, error)
	// Hash return the hash of a service
	Hash(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*HashServiceResponse, error)
}

ServiceClient is the client API for Service service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewServiceClient 

func NewServiceClient(cc *grpc.ClientConn) ServiceClient

type ServiceServer 

type ServiceServer interface {
	// Create a Service from a Service Definition.
	// It will return an unique identifier which is used to interact with the Service.
	Create(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)
	// Get returns a Service matching the criteria of the request.
	Get(context.Context, *GetServiceRequest) (*service.Service, error)
	// List returns services specified in a request.
	List(context.Context, *ListServiceRequest) (*ListServiceResponse, error)
	// Exists return if a service already exists.
	Exists(context.Context, *ExistsServiceRequest) (*ExistsServiceResponse, error)
	// Hash return the hash of a service
	Hash(context.Context, *CreateServiceRequest) (*HashServiceResponse, error)
}

ServiceServer is the server API for Service service.

type StreamEventRequest 

type StreamEventRequest struct {
	// Filter used to filter a stream of events.
	Filter               *StreamEventRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

StreamEventRequest defines request to retrieve a stream of events.

func (*StreamEventRequest) Descriptor 

func (*StreamEventRequest) Descriptor() ([]byte, []int)

func (*StreamEventRequest) GetFilter 

func (m *StreamEventRequest) GetFilter() *StreamEventRequest_Filter

func (*StreamEventRequest) ProtoMessage 

func (*StreamEventRequest) ProtoMessage()

func (*StreamEventRequest) Reset 

func (m *StreamEventRequest) Reset()

func (*StreamEventRequest) String 

func (m *StreamEventRequest) String() string

func (*StreamEventRequest) XXX_DiscardUnknown 

func (m *StreamEventRequest) XXX_DiscardUnknown()

func (*StreamEventRequest) XXX_Marshal 

func (m *StreamEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamEventRequest) XXX_Merge 

func (m *StreamEventRequest) XXX_Merge(src proto.Message)

func (*StreamEventRequest) XXX_Size 

func (m *StreamEventRequest) XXX_Size() int

func (*StreamEventRequest) XXX_Unmarshal 

func (m *StreamEventRequest) XXX_Unmarshal(b []byte) error

type StreamEventRequest_Filter 

type StreamEventRequest_Filter struct {
	// hash to filter events.
	Hash github_com_mesg_foundation_engine_hash.Hash `` /* 132-byte string literal not displayed */
	// instance's hash to filter events.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 148-byte string literal not displayed */
	// key is the key of the event.
	Key                  string   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty" validate:"printascii"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Filter contains filtering criteria.

func (*StreamEventRequest_Filter) Descriptor 

func (*StreamEventRequest_Filter) Descriptor() ([]byte, []int)

func (*StreamEventRequest_Filter) GetKey 

func (m *StreamEventRequest_Filter) GetKey() string

func (*StreamEventRequest_Filter) ProtoMessage 

func (*StreamEventRequest_Filter) ProtoMessage()

func (*StreamEventRequest_Filter) Reset 

func (m *StreamEventRequest_Filter) Reset()

func (*StreamEventRequest_Filter) String 

func (m *StreamEventRequest_Filter) String() string

func (*StreamEventRequest_Filter) XXX_DiscardUnknown 

func (m *StreamEventRequest_Filter) XXX_DiscardUnknown()

func (*StreamEventRequest_Filter) XXX_Marshal 

func (m *StreamEventRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamEventRequest_Filter) XXX_Merge 

func (m *StreamEventRequest_Filter) XXX_Merge(src proto.Message)

func (*StreamEventRequest_Filter) XXX_Size 

func (m *StreamEventRequest_Filter) XXX_Size() int

func (*StreamEventRequest_Filter) XXX_Unmarshal 

func (m *StreamEventRequest_Filter) XXX_Unmarshal(b []byte) error

type StreamExecutionRequest 

type StreamExecutionRequest struct {
	// Filter used to filter a stream of executions.
	Filter               *StreamExecutionRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

StreamExecutionRequest defines request to retrieve a stream of executions.

func (*StreamExecutionRequest) Descriptor 

func (*StreamExecutionRequest) Descriptor() ([]byte, []int)

func (*StreamExecutionRequest) GetFilter 

func (m *StreamExecutionRequest) GetFilter() *StreamExecutionRequest_Filter

func (*StreamExecutionRequest) ProtoMessage 

func (*StreamExecutionRequest) ProtoMessage()

func (*StreamExecutionRequest) Reset 

func (m *StreamExecutionRequest) Reset()

func (*StreamExecutionRequest) String 

func (m *StreamExecutionRequest) String() string

func (*StreamExecutionRequest) XXX_DiscardUnknown 

func (m *StreamExecutionRequest) XXX_DiscardUnknown()

func (*StreamExecutionRequest) XXX_Marshal 

func (m *StreamExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamExecutionRequest) XXX_Merge 

func (m *StreamExecutionRequest) XXX_Merge(src proto.Message)

func (*StreamExecutionRequest) XXX_Size 

func (m *StreamExecutionRequest) XXX_Size() int

func (*StreamExecutionRequest) XXX_Unmarshal 

func (m *StreamExecutionRequest) XXX_Unmarshal(b []byte) error

type StreamExecutionRequest_Filter 

type StreamExecutionRequest_Filter struct {
	// Statuses to filter executions. One status needs to be present in the execution.
	Statuses []execution.Status `protobuf:"varint,1,rep,packed,name=statuses,proto3,enum=mesg.types.Status" json:"statuses,omitempty"`
	// Instance's hash to filter executions.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 148-byte string literal not displayed */
	// taskKey to filter executions.
	TaskKey string `protobuf:"bytes,3,opt,name=taskKey,proto3" json:"taskKey,omitempty" validate:"printascii"`
	// tags to filter executions. All tags needs to be present in the execution.
	Tags []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty" validate:"dive,printascii"`
	// Executor's hash to filter executions.
	ExecutorHash         github_com_mesg_foundation_engine_hash.Hash `` /* 148-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

Filter contains filtering criteria.

func (*StreamExecutionRequest_Filter) Descriptor 

func (*StreamExecutionRequest_Filter) Descriptor() ([]byte, []int)

func (*StreamExecutionRequest_Filter) GetStatuses 

func (m *StreamExecutionRequest_Filter) GetStatuses() []execution.Status

func (*StreamExecutionRequest_Filter) GetTags 

func (m *StreamExecutionRequest_Filter) GetTags() []string

func (*StreamExecutionRequest_Filter) GetTaskKey 

func (m *StreamExecutionRequest_Filter) GetTaskKey() string

func (*StreamExecutionRequest_Filter) Match added in v0.17.0 

func (f *StreamExecutionRequest_Filter) Match(e *execution.Execution) bool

Match matches given execution with filter criteria.

func (*StreamExecutionRequest_Filter) ProtoMessage 

func (*StreamExecutionRequest_Filter) ProtoMessage()

func (*StreamExecutionRequest_Filter) Reset 

func (m *StreamExecutionRequest_Filter) Reset()

func (*StreamExecutionRequest_Filter) String 

func (m *StreamExecutionRequest_Filter) String() string

func (*StreamExecutionRequest_Filter) Validate added in v0.17.0 

func (f *StreamExecutionRequest_Filter) Validate() error

Validate checks if given filter is valid and returns error.

func (*StreamExecutionRequest_Filter) XXX_DiscardUnknown 

func (m *StreamExecutionRequest_Filter) XXX_DiscardUnknown()

func (*StreamExecutionRequest_Filter) XXX_Marshal 

func (m *StreamExecutionRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamExecutionRequest_Filter) XXX_Merge 

func (m *StreamExecutionRequest_Filter) XXX_Merge(src proto.Message)

func (*StreamExecutionRequest_Filter) XXX_Size 

func (m *StreamExecutionRequest_Filter) XXX_Size() int

func (*StreamExecutionRequest_Filter) XXX_Unmarshal 

func (m *StreamExecutionRequest_Filter) XXX_Unmarshal(b []byte) error

type UnimplementedEventServer added in v0.13.0 

type UnimplementedEventServer struct {
}

UnimplementedEventServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventServer) Create added in v0.13.0 

func (*UnimplementedEventServer) Create(ctx context.Context, req *CreateEventRequest) (*CreateEventResponse, error)

func (*UnimplementedEventServer) Stream added in v0.13.0 

func (*UnimplementedEventServer) Stream(req *StreamEventRequest, srv Event_StreamServer) error

type UnimplementedExecutionServer added in v0.13.0 

type UnimplementedExecutionServer struct {
}

UnimplementedExecutionServer can be embedded to have forward compatible implementations.

func (*UnimplementedExecutionServer) Create added in v0.13.0 

func (*UnimplementedExecutionServer) Create(ctx context.Context, req *CreateExecutionRequest) (*CreateExecutionResponse, error)

func (*UnimplementedExecutionServer) Get added in v0.13.0 

func (*UnimplementedExecutionServer) Get(ctx context.Context, req *GetExecutionRequest) (*execution.Execution, error)

func (*UnimplementedExecutionServer) List added in v0.17.0 

func (*UnimplementedExecutionServer) List(ctx context.Context, req *ListExecutionRequest) (*ListExecutionResponse, error)

func (*UnimplementedExecutionServer) Stream added in v0.13.0 

func (*UnimplementedExecutionServer) Stream(req *StreamExecutionRequest, srv Execution_StreamServer) error

func (*UnimplementedExecutionServer) Update added in v0.13.0 

func (*UnimplementedExecutionServer) Update(ctx context.Context, req *UpdateExecutionRequest) (*UpdateExecutionResponse, error)

type UnimplementedInstanceServer added in v0.13.0 

type UnimplementedInstanceServer struct {
}

UnimplementedInstanceServer can be embedded to have forward compatible implementations.

func (*UnimplementedInstanceServer) Get added in v0.13.0 

func (*UnimplementedInstanceServer) Get(ctx context.Context, req *GetInstanceRequest) (*instance.Instance, error)

func (*UnimplementedInstanceServer) List added in v0.13.0 

func (*UnimplementedInstanceServer) List(ctx context.Context, req *ListInstanceRequest) (*ListInstanceResponse, error)

type UnimplementedOwnershipServer added in v0.16.0 

type UnimplementedOwnershipServer struct {
}

UnimplementedOwnershipServer can be embedded to have forward compatible implementations.

func (*UnimplementedOwnershipServer) List added in v0.16.0 

func (*UnimplementedOwnershipServer) List(ctx context.Context, req *ListOwnershipRequest) (*ListOwnershipResponse, error)

type UnimplementedProcessServer added in v0.14.0 

type UnimplementedProcessServer struct {
}

UnimplementedProcessServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcessServer) Create added in v0.14.0 

func (*UnimplementedProcessServer) Create(ctx context.Context, req *CreateProcessRequest) (*CreateProcessResponse, error)

func (*UnimplementedProcessServer) Delete added in v0.14.0 

func (*UnimplementedProcessServer) Delete(ctx context.Context, req *DeleteProcessRequest) (*DeleteProcessResponse, error)

func (*UnimplementedProcessServer) Get added in v0.14.0 

func (*UnimplementedProcessServer) Get(ctx context.Context, req *GetProcessRequest) (*process.Process, error)

func (*UnimplementedProcessServer) List added in v0.14.0 

func (*UnimplementedProcessServer) List(ctx context.Context, req *ListProcessRequest) (*ListProcessResponse, error)

type UnimplementedRunnerServer added in v0.17.0 

type UnimplementedRunnerServer struct {
}

UnimplementedRunnerServer can be embedded to have forward compatible implementations.

func (*UnimplementedRunnerServer) Create added in v0.17.0 

func (*UnimplementedRunnerServer) Create(ctx context.Context, req *CreateRunnerRequest) (*CreateRunnerResponse, error)

func (*UnimplementedRunnerServer) Delete added in v0.17.0 

func (*UnimplementedRunnerServer) Delete(ctx context.Context, req *DeleteRunnerRequest) (*DeleteRunnerResponse, error)

func (*UnimplementedRunnerServer) Get added in v0.17.0 

func (*UnimplementedRunnerServer) Get(ctx context.Context, req *GetRunnerRequest) (*runner.Runner, error)

func (*UnimplementedRunnerServer) List added in v0.17.0 

func (*UnimplementedRunnerServer) List(ctx context.Context, req *ListRunnerRequest) (*ListRunnerResponse, error)

type UnimplementedServiceServer added in v0.13.0 

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceServer) Create added in v0.13.0 

func (*UnimplementedServiceServer) Create(ctx context.Context, req *CreateServiceRequest) (*CreateServiceResponse, error)

func (*UnimplementedServiceServer) Exists added in v0.16.0 

func (*UnimplementedServiceServer) Exists(ctx context.Context, req *ExistsServiceRequest) (*ExistsServiceResponse, error)

func (*UnimplementedServiceServer) Get added in v0.13.0 

func (*UnimplementedServiceServer) Get(ctx context.Context, req *GetServiceRequest) (*service.Service, error)

func (*UnimplementedServiceServer) Hash added in v0.16.0 

func (*UnimplementedServiceServer) Hash(ctx context.Context, req *CreateServiceRequest) (*HashServiceResponse, error)

func (*UnimplementedServiceServer) List added in v0.13.0 

func (*UnimplementedServiceServer) List(ctx context.Context, req *ListServiceRequest) (*ListServiceResponse, error)

type UpdateExecutionRequest 

type UpdateExecutionRequest struct {
	// Hash represents execution.
	Hash github_com_mesg_foundation_engine_hash.Hash `` /* 131-byte string literal not displayed */
	// result pass to execution
	//
	// Types that are valid to be assigned to Result:
	//	*UpdateExecutionRequest_Outputs
	//	*UpdateExecutionRequest_Error
	Result               isUpdateExecutionRequest_Result `protobuf_oneof:"result"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

UpdateExecutionRequest defines request for execution update.

func (*UpdateExecutionRequest) Descriptor 

func (*UpdateExecutionRequest) Descriptor() ([]byte, []int)

func (*UpdateExecutionRequest) GetError 

func (m *UpdateExecutionRequest) GetError() string

func (*UpdateExecutionRequest) GetOutputs 

func (m *UpdateExecutionRequest) GetOutputs() *types.Struct

func (*UpdateExecutionRequest) GetResult 

func (m *UpdateExecutionRequest) GetResult() isUpdateExecutionRequest_Result

func (*UpdateExecutionRequest) ProtoMessage 

func (*UpdateExecutionRequest) ProtoMessage()

func (*UpdateExecutionRequest) Reset 

func (m *UpdateExecutionRequest) Reset()

func (*UpdateExecutionRequest) String 

func (m *UpdateExecutionRequest) String() string

func (*UpdateExecutionRequest) XXX_DiscardUnknown 

func (m *UpdateExecutionRequest) XXX_DiscardUnknown()

func (*UpdateExecutionRequest) XXX_Marshal 

func (m *UpdateExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateExecutionRequest) XXX_Merge 

func (m *UpdateExecutionRequest) XXX_Merge(src proto.Message)

func (*UpdateExecutionRequest) XXX_OneofWrappers 

func (*UpdateExecutionRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*UpdateExecutionRequest) XXX_Size 

func (m *UpdateExecutionRequest) XXX_Size() int

func (*UpdateExecutionRequest) XXX_Unmarshal 

func (m *UpdateExecutionRequest) XXX_Unmarshal(b []byte) error

type UpdateExecutionRequest_Error 

type UpdateExecutionRequest_Error struct {
	Error string `protobuf:"bytes,3,opt,name=error,proto3,oneof" json:"error,omitempty"`
}

type UpdateExecutionRequest_Outputs 

type UpdateExecutionRequest_Outputs struct {
	Outputs *types.Struct `protobuf:"bytes,2,opt,name=outputs,proto3,oneof" json:"outputs,omitempty"`
}

type UpdateExecutionResponse 

type UpdateExecutionResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

UpdateExecutionResponse defines response for execution update.

func (*UpdateExecutionResponse) Descriptor 

func (*UpdateExecutionResponse) Descriptor() ([]byte, []int)

func (*UpdateExecutionResponse) ProtoMessage 

func (*UpdateExecutionResponse) ProtoMessage()

func (*UpdateExecutionResponse) Reset 

func (m *UpdateExecutionResponse) Reset()

func (*UpdateExecutionResponse) String 

func (m *UpdateExecutionResponse) String() string

func (*UpdateExecutionResponse) XXX_DiscardUnknown 

func (m *UpdateExecutionResponse) XXX_DiscardUnknown()

func (*UpdateExecutionResponse) XXX_Marshal 

func (m *UpdateExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateExecutionResponse) XXX_Merge 

func (m *UpdateExecutionResponse) XXX_Merge(src proto.Message)

func (*UpdateExecutionResponse) XXX_Size 

func (m *UpdateExecutionResponse) XXX_Size() int

func (*UpdateExecutionResponse) XXX_Unmarshal 

func (m *UpdateExecutionResponse) XXX_Unmarshal(b []byte) error

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.