api

package
v0.14.0 Latest Latest
Warning

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

 Go to latest Published: Sep 6, 2019 License: Apache-2.0 Imports: 15 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 RegisterProcessServer added in v0.14.0 

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

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 `protobuf:"bytes,1,opt,name=instanceHash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"instanceHash"`
	// key is the key of the event.
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// 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 {
	InstanceHash         github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,1,opt,name=instanceHash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"instanceHash"`
	TaskKey              string                                      `protobuf:"bytes,2,opt,name=taskKey,proto3" json:"taskKey,omitempty"`
	Inputs               *types.Struct                               `protobuf:"bytes,3,opt,name=inputs,proto3" json:"inputs,omitempty"`
	Tags                 []string                                    `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	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) 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 CreateInstanceRequest 

type CreateInstanceRequest struct {
	// Service's hash.
	ServiceHash github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,1,opt,name=serviceHash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"serviceHash"`
	// Environmental variables to apply to the Instance.
	Env                  []string `protobuf:"bytes,2,rep,name=env,proto3" json:"env,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*CreateInstanceRequest) Descriptor 

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

func (*CreateInstanceRequest) GetEnv 

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

func (*CreateInstanceRequest) ProtoMessage 

func (*CreateInstanceRequest) ProtoMessage()

func (*CreateInstanceRequest) Reset 

func (m *CreateInstanceRequest) Reset()

func (*CreateInstanceRequest) String 

func (m *CreateInstanceRequest) String() string

func (*CreateInstanceRequest) XXX_DiscardUnknown 

func (m *CreateInstanceRequest) XXX_DiscardUnknown()

func (*CreateInstanceRequest) XXX_Marshal 

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

func (*CreateInstanceRequest) XXX_Merge 

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

func (*CreateInstanceRequest) XXX_Size 

func (m *CreateInstanceRequest) XXX_Size() int

func (*CreateInstanceRequest) XXX_Unmarshal 

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

type CreateInstanceResponse 

type CreateInstanceResponse struct {
	// The instance'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 (*CreateInstanceResponse) Descriptor 

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

func (*CreateInstanceResponse) ProtoMessage 

func (*CreateInstanceResponse) ProtoMessage()

func (*CreateInstanceResponse) Reset 

func (m *CreateInstanceResponse) Reset()

func (*CreateInstanceResponse) String 

func (m *CreateInstanceResponse) String() string

func (*CreateInstanceResponse) XXX_DiscardUnknown 

func (m *CreateInstanceResponse) XXX_DiscardUnknown()

func (*CreateInstanceResponse) XXX_Marshal 

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

func (*CreateInstanceResponse) XXX_Merge 

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

func (*CreateInstanceResponse) XXX_Size 

func (m *CreateInstanceResponse) XXX_Size() int

func (*CreateInstanceResponse) XXX_Unmarshal 

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

type CreateProcessRequest added in v0.14.0 

type CreateProcessRequest struct {
	Key                  string                  `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Nodes                []*process.Process_Node `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes,omitempty"`
	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) GetKey added in v0.14.0 

func (m *CreateProcessRequest) GetKey() 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 CreateServiceRequest 

type CreateServiceRequest struct {
	// Service's sid.
	Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`
	// Service's name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Service's description.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Configurations related to the service
	Configuration service.Service_Configuration `protobuf:"bytes,4,opt,name=configuration,proto3" json:"configuration"`
	// The list of tasks this service can execute.
	Tasks []*service.Service_Task `protobuf:"bytes,5,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// The list of events this service can emit.
	Events []*service.Service_Event `protobuf:"bytes,6,rep,name=events,proto3" json:"events,omitempty"`
	// The container dependencies this service requires.
	Dependencies []*service.Service_Dependency `protobuf:"bytes,7,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// Service's repository url.
	Repository string `protobuf:"bytes,8,opt,name=repository,proto3" json:"repository,omitempty"`
	// The hash id of service's source code on IPFS.
	Source               string   `protobuf:"bytes,9,opt,name=source,proto3" json:"source,omitempty"`
	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 DeleteInstanceRequest 

type DeleteInstanceRequest struct {
	// Instance'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"`
	// If true, any persistent data (volumes) that belongs to the instance 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 (*DeleteInstanceRequest) Descriptor 

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

func (*DeleteInstanceRequest) GetDeleteData 

func (m *DeleteInstanceRequest) GetDeleteData() bool

func (*DeleteInstanceRequest) ProtoMessage 

func (*DeleteInstanceRequest) ProtoMessage()

func (*DeleteInstanceRequest) Reset 

func (m *DeleteInstanceRequest) Reset()

func (*DeleteInstanceRequest) String 

func (m *DeleteInstanceRequest) String() string

func (*DeleteInstanceRequest) XXX_DiscardUnknown 

func (m *DeleteInstanceRequest) XXX_DiscardUnknown()

func (*DeleteInstanceRequest) XXX_Marshal 

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

func (*DeleteInstanceRequest) XXX_Merge 

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

func (*DeleteInstanceRequest) XXX_Size 

func (m *DeleteInstanceRequest) XXX_Size() int

func (*DeleteInstanceRequest) XXX_Unmarshal 

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

type DeleteInstanceResponse 

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

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

func (*DeleteInstanceResponse) Descriptor 

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

func (*DeleteInstanceResponse) ProtoMessage 

func (*DeleteInstanceResponse) ProtoMessage()

func (*DeleteInstanceResponse) Reset 

func (m *DeleteInstanceResponse) Reset()

func (*DeleteInstanceResponse) String 

func (m *DeleteInstanceResponse) String() string

func (*DeleteInstanceResponse) XXX_DiscardUnknown 

func (m *DeleteInstanceResponse) XXX_DiscardUnknown()

func (*DeleteInstanceResponse) XXX_Marshal 

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

func (*DeleteInstanceResponse) XXX_Merge 

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

func (*DeleteInstanceResponse) XXX_Size 

func (m *DeleteInstanceResponse) XXX_Size() int

func (*DeleteInstanceResponse) XXX_Unmarshal 

func (m *DeleteInstanceResponse) 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 `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 `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 DeleteServiceRequest 

type DeleteServiceRequest struct {
	// The service's hash to delete.
	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 `Delete` API.

func (*DeleteServiceRequest) Descriptor 

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

func (*DeleteServiceRequest) ProtoMessage 

func (*DeleteServiceRequest) ProtoMessage()

func (*DeleteServiceRequest) Reset 

func (m *DeleteServiceRequest) Reset()

func (*DeleteServiceRequest) String 

func (m *DeleteServiceRequest) String() string

func (*DeleteServiceRequest) XXX_DiscardUnknown 

func (m *DeleteServiceRequest) XXX_DiscardUnknown()

func (*DeleteServiceRequest) XXX_Marshal 

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

func (*DeleteServiceRequest) XXX_Merge 

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

func (*DeleteServiceRequest) XXX_Size 

func (m *DeleteServiceRequest) XXX_Size() int

func (*DeleteServiceRequest) XXX_Unmarshal 

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

type DeleteServiceResponse 

type DeleteServiceResponse 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 (*DeleteServiceResponse) Descriptor 

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

func (*DeleteServiceResponse) ProtoMessage 

func (*DeleteServiceResponse) ProtoMessage()

func (*DeleteServiceResponse) Reset 

func (m *DeleteServiceResponse) Reset()

func (*DeleteServiceResponse) String 

func (m *DeleteServiceResponse) String() string

func (*DeleteServiceResponse) XXX_DiscardUnknown 

func (m *DeleteServiceResponse) XXX_DiscardUnknown()

func (*DeleteServiceResponse) XXX_Marshal 

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

func (*DeleteServiceResponse) XXX_Merge 

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

func (*DeleteServiceResponse) XXX_Size 

func (m *DeleteServiceResponse) XXX_Size() int

func (*DeleteServiceResponse) XXX_Unmarshal 

func (m *DeleteServiceResponse) 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)
	// 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)
	// 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 GetExecutionRequest 

type GetExecutionRequest struct {
	// Execution'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:"-"`
}

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 `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 (*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 GetServiceRequest 

type GetServiceRequest struct {
	// The service'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 (*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 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 *ListInstancesRequest, opts ...grpc.CallOption) (*ListInstancesResponse, error)
	// Create an Instance from a Service's hash and custom environmental variables.
	// It will return an unique identifier which is used to interact with the Instance.
	Create(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	// Delete an Instance.
	Delete(ctx context.Context, in *DeleteInstanceRequest, opts ...grpc.CallOption) (*DeleteInstanceResponse, 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, *ListInstancesRequest) (*ListInstancesResponse, error)
	// Create an Instance from a Service's hash and custom environmental variables.
	// It will return an unique identifier which is used to interact with the Instance.
	Create(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	// Delete an Instance.
	Delete(context.Context, *DeleteInstanceRequest) (*DeleteInstanceResponse, error)
}

InstanceServer is the server API for Instance service.

type ListInstancesRequest 

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

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

func (*ListInstancesRequest) Descriptor 

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

func (*ListInstancesRequest) ProtoMessage 

func (*ListInstancesRequest) ProtoMessage()

func (*ListInstancesRequest) Reset 

func (m *ListInstancesRequest) Reset()

func (*ListInstancesRequest) String 

func (m *ListInstancesRequest) String() string

func (*ListInstancesRequest) XXX_DiscardUnknown 

func (m *ListInstancesRequest) XXX_DiscardUnknown()

func (*ListInstancesRequest) XXX_Marshal 

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

func (*ListInstancesRequest) XXX_Merge 

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

func (*ListInstancesRequest) XXX_Size 

func (m *ListInstancesRequest) XXX_Size() int

func (*ListInstancesRequest) XXX_Unmarshal 

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

type ListInstancesResponse 

type ListInstancesResponse 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 (*ListInstancesResponse) Descriptor 

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

func (*ListInstancesResponse) GetInstances 

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

func (*ListInstancesResponse) ProtoMessage 

func (*ListInstancesResponse) ProtoMessage()

func (*ListInstancesResponse) Reset 

func (m *ListInstancesResponse) Reset()

func (*ListInstancesResponse) String 

func (m *ListInstancesResponse) String() string

func (*ListInstancesResponse) XXX_DiscardUnknown 

func (m *ListInstancesResponse) XXX_DiscardUnknown()

func (*ListInstancesResponse) XXX_Marshal 

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

func (*ListInstancesResponse) XXX_Merge 

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

func (*ListInstancesResponse) XXX_Size 

func (m *ListInstancesResponse) XXX_Size() int

func (*ListInstancesResponse) XXX_Unmarshal 

func (m *ListInstancesResponse) 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 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 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 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)
	// Delete a Service.
	// An error is returned if one or more Instances of the Service are running.
	Delete(ctx context.Context, in *DeleteServiceRequest, opts ...grpc.CallOption) (*DeleteServiceResponse, 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)
}

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)
	// Delete a Service.
	// An error is returned if one or more Instances of the Service are running.
	Delete(context.Context, *DeleteServiceRequest) (*DeleteServiceResponse, 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)
}

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 `protobuf:"bytes,1,opt,name=hash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"hash"`
	// instance's hash to filter events.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,2,opt,name=instanceHash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"instanceHash"`
	// key is the key of the event.
	Key                  string   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	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=types.Status" json:"statuses,omitempty"`
	// Instance's hash to filter executions.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,2,opt,name=instanceHash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"instanceHash"`
	// taskKey to filter executions.
	TaskKey string `protobuf:"bytes,3,opt,name=taskKey,proto3" json:"taskKey,omitempty"`
	// 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"`
	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) 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) 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) 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) Create added in v0.13.0 

func (*UnimplementedInstanceServer) Create(ctx context.Context, req *CreateInstanceRequest) (*CreateInstanceResponse, error)

func (*UnimplementedInstanceServer) Delete added in v0.13.0 

func (*UnimplementedInstanceServer) Delete(ctx context.Context, req *DeleteInstanceRequest) (*DeleteInstanceResponse, error)

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 *ListInstancesRequest) (*ListInstancesResponse, 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 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) Delete added in v0.13.0 

func (*UnimplementedServiceServer) Delete(ctx context.Context, req *DeleteServiceRequest) (*DeleteServiceResponse, error)

func (*UnimplementedServiceServer) Get added in v0.13.0 

func (*UnimplementedServiceServer) Get(ctx context.Context, req *GetServiceRequest) (*service.Service, 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 `protobuf:"bytes,1,opt,name=hash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"hash"`
	// 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.