Documentation
¶
Index ¶
- func RegisterAccountServer(s *grpc.Server, srv AccountServer)
- func RegisterEventServer(s *grpc.Server, srv EventServer)
- func RegisterExecutionServer(s *grpc.Server, srv ExecutionServer)
- func RegisterInstanceServer(s *grpc.Server, srv InstanceServer)
- func RegisterOwnershipServer(s *grpc.Server, srv OwnershipServer)
- func RegisterProcessServer(s *grpc.Server, srv ProcessServer)
- func RegisterRunnerServer(s *grpc.Server, srv RunnerServer)
- func RegisterServiceServer(s *grpc.Server, srv ServiceServer)
- type AccountClient
- type AccountServer
- type CreateAccountRequest
- func (*CreateAccountRequest) Descriptor() ([]byte, []int)
- func (m *CreateAccountRequest) GetName() string
- func (m *CreateAccountRequest) GetPassword() string
- func (*CreateAccountRequest) ProtoMessage()
- func (m *CreateAccountRequest) Reset()
- func (m *CreateAccountRequest) String() string
- func (m *CreateAccountRequest) XXX_DiscardUnknown()
- func (m *CreateAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateAccountRequest) XXX_Merge(src proto.Message)
- func (m *CreateAccountRequest) XXX_Size() int
- func (m *CreateAccountRequest) XXX_Unmarshal(b []byte) error
- type CreateAccountResponse
- func (*CreateAccountResponse) Descriptor() ([]byte, []int)
- func (m *CreateAccountResponse) GetAddress() string
- func (m *CreateAccountResponse) GetMnemonic() string
- func (*CreateAccountResponse) ProtoMessage()
- func (m *CreateAccountResponse) Reset()
- func (m *CreateAccountResponse) String() string
- func (m *CreateAccountResponse) XXX_DiscardUnknown()
- func (m *CreateAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateAccountResponse) XXX_Merge(src proto.Message)
- func (m *CreateAccountResponse) XXX_Size() int
- func (m *CreateAccountResponse) XXX_Unmarshal(b []byte) error
- type CreateEventRequest
- func (*CreateEventRequest) Descriptor() ([]byte, []int)
- func (m *CreateEventRequest) GetData() *types.Struct
- func (m *CreateEventRequest) GetKey() string
- func (*CreateEventRequest) ProtoMessage()
- func (m *CreateEventRequest) Reset()
- func (m *CreateEventRequest) String() string
- func (m *CreateEventRequest) XXX_DiscardUnknown()
- func (m *CreateEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateEventRequest) XXX_Merge(src proto.Message)
- func (m *CreateEventRequest) XXX_Size() int
- func (m *CreateEventRequest) XXX_Unmarshal(b []byte) error
- type CreateEventResponse
- func (*CreateEventResponse) Descriptor() ([]byte, []int)
- func (*CreateEventResponse) ProtoMessage()
- func (m *CreateEventResponse) Reset()
- func (m *CreateEventResponse) String() string
- func (m *CreateEventResponse) XXX_DiscardUnknown()
- func (m *CreateEventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateEventResponse) XXX_Merge(src proto.Message)
- func (m *CreateEventResponse) XXX_Size() int
- func (m *CreateEventResponse) XXX_Unmarshal(b []byte) error
- type CreateExecutionRequest
- func (*CreateExecutionRequest) Descriptor() ([]byte, []int)
- func (m *CreateExecutionRequest) GetInputs() *types.Struct
- func (m *CreateExecutionRequest) GetStepID() string
- func (m *CreateExecutionRequest) GetTags() []string
- func (m *CreateExecutionRequest) GetTaskKey() string
- func (*CreateExecutionRequest) ProtoMessage()
- func (m *CreateExecutionRequest) Reset()
- func (m *CreateExecutionRequest) String() string
- func (m *CreateExecutionRequest) XXX_DiscardUnknown()
- func (m *CreateExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateExecutionRequest) XXX_Merge(src proto.Message)
- func (m *CreateExecutionRequest) XXX_Size() int
- func (m *CreateExecutionRequest) XXX_Unmarshal(b []byte) error
- type CreateExecutionResponse
- func (*CreateExecutionResponse) Descriptor() ([]byte, []int)
- func (*CreateExecutionResponse) ProtoMessage()
- func (m *CreateExecutionResponse) Reset()
- func (m *CreateExecutionResponse) String() string
- func (m *CreateExecutionResponse) XXX_DiscardUnknown()
- func (m *CreateExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateExecutionResponse) XXX_Merge(src proto.Message)
- func (m *CreateExecutionResponse) XXX_Size() int
- func (m *CreateExecutionResponse) XXX_Unmarshal(b []byte) error
- type CreateProcessRequest
- func (*CreateProcessRequest) Descriptor() ([]byte, []int)
- func (m *CreateProcessRequest) GetEdges() []*process.Process_Edge
- func (m *CreateProcessRequest) GetKey() string
- func (m *CreateProcessRequest) GetNodes() []*process.Process_Node
- func (*CreateProcessRequest) ProtoMessage()
- func (m *CreateProcessRequest) Reset()
- func (m *CreateProcessRequest) String() string
- func (m *CreateProcessRequest) XXX_DiscardUnknown()
- func (m *CreateProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateProcessRequest) XXX_Merge(src proto.Message)
- func (m *CreateProcessRequest) XXX_Size() int
- func (m *CreateProcessRequest) XXX_Unmarshal(b []byte) error
- type CreateProcessResponse
- func (*CreateProcessResponse) Descriptor() ([]byte, []int)
- func (*CreateProcessResponse) ProtoMessage()
- func (m *CreateProcessResponse) Reset()
- func (m *CreateProcessResponse) String() string
- func (m *CreateProcessResponse) XXX_DiscardUnknown()
- func (m *CreateProcessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateProcessResponse) XXX_Merge(src proto.Message)
- func (m *CreateProcessResponse) XXX_Size() int
- func (m *CreateProcessResponse) XXX_Unmarshal(b []byte) error
- type CreateRunnerRequest
- func (*CreateRunnerRequest) Descriptor() ([]byte, []int)
- func (m *CreateRunnerRequest) GetEnv() []string
- func (*CreateRunnerRequest) ProtoMessage()
- func (m *CreateRunnerRequest) Reset()
- func (m *CreateRunnerRequest) String() string
- func (m *CreateRunnerRequest) XXX_DiscardUnknown()
- func (m *CreateRunnerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRunnerRequest) XXX_Merge(src proto.Message)
- func (m *CreateRunnerRequest) XXX_Size() int
- func (m *CreateRunnerRequest) XXX_Unmarshal(b []byte) error
- type CreateRunnerResponse
- func (*CreateRunnerResponse) Descriptor() ([]byte, []int)
- func (*CreateRunnerResponse) ProtoMessage()
- func (m *CreateRunnerResponse) Reset()
- func (m *CreateRunnerResponse) String() string
- func (m *CreateRunnerResponse) XXX_DiscardUnknown()
- func (m *CreateRunnerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRunnerResponse) XXX_Merge(src proto.Message)
- func (m *CreateRunnerResponse) XXX_Size() int
- func (m *CreateRunnerResponse) XXX_Unmarshal(b []byte) error
- type CreateServiceRequest
- func (*CreateServiceRequest) Descriptor() ([]byte, []int)
- func (m *CreateServiceRequest) GetConfiguration() service.Service_Configuration
- func (m *CreateServiceRequest) GetDependencies() []*service.Service_Dependency
- func (m *CreateServiceRequest) GetDescription() string
- func (m *CreateServiceRequest) GetEvents() []*service.Service_Event
- func (m *CreateServiceRequest) GetName() string
- func (m *CreateServiceRequest) GetRepository() string
- func (m *CreateServiceRequest) GetSid() string
- func (m *CreateServiceRequest) GetSource() string
- func (m *CreateServiceRequest) GetTasks() []*service.Service_Task
- func (*CreateServiceRequest) ProtoMessage()
- func (m *CreateServiceRequest) Reset()
- func (m *CreateServiceRequest) String() string
- func (m *CreateServiceRequest) XXX_DiscardUnknown()
- func (m *CreateServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateServiceRequest) XXX_Merge(src proto.Message)
- func (m *CreateServiceRequest) XXX_Size() int
- func (m *CreateServiceRequest) XXX_Unmarshal(b []byte) error
- type CreateServiceResponse
- func (*CreateServiceResponse) Descriptor() ([]byte, []int)
- func (*CreateServiceResponse) ProtoMessage()
- func (m *CreateServiceResponse) Reset()
- func (m *CreateServiceResponse) String() string
- func (m *CreateServiceResponse) XXX_DiscardUnknown()
- func (m *CreateServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateServiceResponse) XXX_Merge(src proto.Message)
- func (m *CreateServiceResponse) XXX_Size() int
- func (m *CreateServiceResponse) XXX_Unmarshal(b []byte) error
- type DeleteAccountRequest
- func (*DeleteAccountRequest) Descriptor() ([]byte, []int)
- func (*DeleteAccountRequest) ProtoMessage()
- func (m *DeleteAccountRequest) Reset()
- func (m *DeleteAccountRequest) String() string
- func (m *DeleteAccountRequest) XXX_DiscardUnknown()
- func (m *DeleteAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteAccountRequest) XXX_Merge(src proto.Message)
- func (m *DeleteAccountRequest) XXX_Size() int
- func (m *DeleteAccountRequest) XXX_Unmarshal(b []byte) error
- type DeleteAccountResponse
- func (*DeleteAccountResponse) Descriptor() ([]byte, []int)
- func (*DeleteAccountResponse) ProtoMessage()
- func (m *DeleteAccountResponse) Reset()
- func (m *DeleteAccountResponse) String() string
- func (m *DeleteAccountResponse) XXX_DiscardUnknown()
- func (m *DeleteAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteAccountResponse) XXX_Merge(src proto.Message)
- func (m *DeleteAccountResponse) XXX_Size() int
- func (m *DeleteAccountResponse) XXX_Unmarshal(b []byte) error
- type DeleteProcessRequest
- func (*DeleteProcessRequest) Descriptor() ([]byte, []int)
- func (*DeleteProcessRequest) ProtoMessage()
- func (m *DeleteProcessRequest) Reset()
- func (m *DeleteProcessRequest) String() string
- func (m *DeleteProcessRequest) XXX_DiscardUnknown()
- func (m *DeleteProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteProcessRequest) XXX_Merge(src proto.Message)
- func (m *DeleteProcessRequest) XXX_Size() int
- func (m *DeleteProcessRequest) XXX_Unmarshal(b []byte) error
- type DeleteProcessResponse
- func (*DeleteProcessResponse) Descriptor() ([]byte, []int)
- func (*DeleteProcessResponse) ProtoMessage()
- func (m *DeleteProcessResponse) Reset()
- func (m *DeleteProcessResponse) String() string
- func (m *DeleteProcessResponse) XXX_DiscardUnknown()
- func (m *DeleteProcessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteProcessResponse) XXX_Merge(src proto.Message)
- func (m *DeleteProcessResponse) XXX_Size() int
- func (m *DeleteProcessResponse) XXX_Unmarshal(b []byte) error
- type DeleteRunnerRequest
- func (*DeleteRunnerRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRunnerRequest) GetDeleteData() bool
- func (*DeleteRunnerRequest) ProtoMessage()
- func (m *DeleteRunnerRequest) Reset()
- func (m *DeleteRunnerRequest) String() string
- func (m *DeleteRunnerRequest) XXX_DiscardUnknown()
- func (m *DeleteRunnerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteRunnerRequest) XXX_Merge(src proto.Message)
- func (m *DeleteRunnerRequest) XXX_Size() int
- func (m *DeleteRunnerRequest) XXX_Unmarshal(b []byte) error
- type DeleteRunnerResponse
- func (*DeleteRunnerResponse) Descriptor() ([]byte, []int)
- func (*DeleteRunnerResponse) ProtoMessage()
- func (m *DeleteRunnerResponse) Reset()
- func (m *DeleteRunnerResponse) String() string
- func (m *DeleteRunnerResponse) XXX_DiscardUnknown()
- func (m *DeleteRunnerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteRunnerResponse) XXX_Merge(src proto.Message)
- func (m *DeleteRunnerResponse) XXX_Size() int
- func (m *DeleteRunnerResponse) XXX_Unmarshal(b []byte) error
- type EventClient
- type EventServer
- type Event_StreamClient
- type Event_StreamServer
- type ExecutionClient
- type ExecutionServer
- type Execution_StreamClient
- type Execution_StreamServer
- type ExistsServiceRequest
- func (*ExistsServiceRequest) Descriptor() ([]byte, []int)
- func (*ExistsServiceRequest) ProtoMessage()
- func (m *ExistsServiceRequest) Reset()
- func (m *ExistsServiceRequest) String() string
- func (m *ExistsServiceRequest) XXX_DiscardUnknown()
- func (m *ExistsServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExistsServiceRequest) XXX_Merge(src proto.Message)
- func (m *ExistsServiceRequest) XXX_Size() int
- func (m *ExistsServiceRequest) XXX_Unmarshal(b []byte) error
- type ExistsServiceResponse
- func (*ExistsServiceResponse) Descriptor() ([]byte, []int)
- func (m *ExistsServiceResponse) GetExists() bool
- func (*ExistsServiceResponse) ProtoMessage()
- func (m *ExistsServiceResponse) Reset()
- func (m *ExistsServiceResponse) String() string
- func (m *ExistsServiceResponse) XXX_DiscardUnknown()
- func (m *ExistsServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExistsServiceResponse) XXX_Merge(src proto.Message)
- func (m *ExistsServiceResponse) XXX_Size() int
- func (m *ExistsServiceResponse) XXX_Unmarshal(b []byte) error
- type GetAccountRequest
- func (*GetAccountRequest) Descriptor() ([]byte, []int)
- func (m *GetAccountRequest) GetName() string
- func (*GetAccountRequest) ProtoMessage()
- func (m *GetAccountRequest) Reset()
- func (m *GetAccountRequest) String() string
- func (m *GetAccountRequest) XXX_DiscardUnknown()
- func (m *GetAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetAccountRequest) XXX_Merge(src proto.Message)
- func (m *GetAccountRequest) XXX_Size() int
- func (m *GetAccountRequest) XXX_Unmarshal(b []byte) error
- type GetExecutionRequest
- func (*GetExecutionRequest) Descriptor() ([]byte, []int)
- func (*GetExecutionRequest) ProtoMessage()
- func (m *GetExecutionRequest) Reset()
- func (m *GetExecutionRequest) String() string
- func (m *GetExecutionRequest) XXX_DiscardUnknown()
- func (m *GetExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetExecutionRequest) XXX_Merge(src proto.Message)
- func (m *GetExecutionRequest) XXX_Size() int
- func (m *GetExecutionRequest) XXX_Unmarshal(b []byte) error
- type GetInstanceRequest
- func (*GetInstanceRequest) Descriptor() ([]byte, []int)
- func (*GetInstanceRequest) ProtoMessage()
- func (m *GetInstanceRequest) Reset()
- func (m *GetInstanceRequest) String() string
- func (m *GetInstanceRequest) XXX_DiscardUnknown()
- func (m *GetInstanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetInstanceRequest) XXX_Merge(src proto.Message)
- func (m *GetInstanceRequest) XXX_Size() int
- func (m *GetInstanceRequest) XXX_Unmarshal(b []byte) error
- type GetProcessRequest
- func (*GetProcessRequest) Descriptor() ([]byte, []int)
- func (*GetProcessRequest) ProtoMessage()
- func (m *GetProcessRequest) Reset()
- func (m *GetProcessRequest) String() string
- func (m *GetProcessRequest) XXX_DiscardUnknown()
- func (m *GetProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetProcessRequest) XXX_Merge(src proto.Message)
- func (m *GetProcessRequest) XXX_Size() int
- func (m *GetProcessRequest) XXX_Unmarshal(b []byte) error
- type GetRunnerRequest
- func (*GetRunnerRequest) Descriptor() ([]byte, []int)
- func (*GetRunnerRequest) ProtoMessage()
- func (m *GetRunnerRequest) Reset()
- func (m *GetRunnerRequest) String() string
- func (m *GetRunnerRequest) XXX_DiscardUnknown()
- func (m *GetRunnerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRunnerRequest) XXX_Merge(src proto.Message)
- func (m *GetRunnerRequest) XXX_Size() int
- func (m *GetRunnerRequest) XXX_Unmarshal(b []byte) error
- type GetServiceRequest
- func (*GetServiceRequest) Descriptor() ([]byte, []int)
- func (*GetServiceRequest) ProtoMessage()
- func (m *GetServiceRequest) Reset()
- func (m *GetServiceRequest) String() string
- func (m *GetServiceRequest) XXX_DiscardUnknown()
- func (m *GetServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetServiceRequest) XXX_Merge(src proto.Message)
- func (m *GetServiceRequest) XXX_Size() int
- func (m *GetServiceRequest) XXX_Unmarshal(b []byte) error
- type HashServiceResponse
- func (*HashServiceResponse) Descriptor() ([]byte, []int)
- func (*HashServiceResponse) ProtoMessage()
- func (m *HashServiceResponse) Reset()
- func (m *HashServiceResponse) String() string
- func (m *HashServiceResponse) XXX_DiscardUnknown()
- func (m *HashServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HashServiceResponse) XXX_Merge(src proto.Message)
- func (m *HashServiceResponse) XXX_Size() int
- func (m *HashServiceResponse) XXX_Unmarshal(b []byte) error
- type InstanceClient
- type InstanceServer
- type ListAccountRequest
- func (*ListAccountRequest) Descriptor() ([]byte, []int)
- func (*ListAccountRequest) ProtoMessage()
- func (m *ListAccountRequest) Reset()
- func (m *ListAccountRequest) String() string
- func (m *ListAccountRequest) XXX_DiscardUnknown()
- func (m *ListAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListAccountRequest) XXX_Merge(src proto.Message)
- func (m *ListAccountRequest) XXX_Size() int
- func (m *ListAccountRequest) XXX_Unmarshal(b []byte) error
- type ListAccountResponse
- func (*ListAccountResponse) Descriptor() ([]byte, []int)
- func (m *ListAccountResponse) GetAccounts() []*account.Account
- func (*ListAccountResponse) ProtoMessage()
- func (m *ListAccountResponse) Reset()
- func (m *ListAccountResponse) String() string
- func (m *ListAccountResponse) XXX_DiscardUnknown()
- func (m *ListAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListAccountResponse) XXX_Merge(src proto.Message)
- func (m *ListAccountResponse) XXX_Size() int
- func (m *ListAccountResponse) XXX_Unmarshal(b []byte) error
- type ListExecutionRequest
- func (*ListExecutionRequest) Descriptor() ([]byte, []int)
- func (*ListExecutionRequest) ProtoMessage()
- func (m *ListExecutionRequest) Reset()
- func (m *ListExecutionRequest) String() string
- func (m *ListExecutionRequest) XXX_DiscardUnknown()
- func (m *ListExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListExecutionRequest) XXX_Merge(src proto.Message)
- func (m *ListExecutionRequest) XXX_Size() int
- func (m *ListExecutionRequest) XXX_Unmarshal(b []byte) error
- type ListExecutionResponse
- func (*ListExecutionResponse) Descriptor() ([]byte, []int)
- func (m *ListExecutionResponse) GetExecutions() []*execution.Execution
- func (*ListExecutionResponse) ProtoMessage()
- func (m *ListExecutionResponse) Reset()
- func (m *ListExecutionResponse) String() string
- func (m *ListExecutionResponse) XXX_DiscardUnknown()
- func (m *ListExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListExecutionResponse) XXX_Merge(src proto.Message)
- func (m *ListExecutionResponse) XXX_Size() int
- func (m *ListExecutionResponse) XXX_Unmarshal(b []byte) error
- type ListInstanceRequest
- func (*ListInstanceRequest) Descriptor() ([]byte, []int)
- func (m *ListInstanceRequest) GetFilter() *ListInstanceRequest_Filter
- func (*ListInstanceRequest) ProtoMessage()
- func (m *ListInstanceRequest) Reset()
- func (m *ListInstanceRequest) String() string
- func (m *ListInstanceRequest) XXX_DiscardUnknown()
- func (m *ListInstanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListInstanceRequest) XXX_Merge(src proto.Message)
- func (m *ListInstanceRequest) XXX_Size() int
- func (m *ListInstanceRequest) XXX_Unmarshal(b []byte) error
- type ListInstanceRequest_Filter
- func (*ListInstanceRequest_Filter) Descriptor() ([]byte, []int)
- func (*ListInstanceRequest_Filter) ProtoMessage()
- func (m *ListInstanceRequest_Filter) Reset()
- func (m *ListInstanceRequest_Filter) String() string
- func (m *ListInstanceRequest_Filter) XXX_DiscardUnknown()
- func (m *ListInstanceRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListInstanceRequest_Filter) XXX_Merge(src proto.Message)
- func (m *ListInstanceRequest_Filter) XXX_Size() int
- func (m *ListInstanceRequest_Filter) XXX_Unmarshal(b []byte) error
- type ListInstanceResponse
- func (*ListInstanceResponse) Descriptor() ([]byte, []int)
- func (m *ListInstanceResponse) GetInstances() []*instance.Instance
- func (*ListInstanceResponse) ProtoMessage()
- func (m *ListInstanceResponse) Reset()
- func (m *ListInstanceResponse) String() string
- func (m *ListInstanceResponse) XXX_DiscardUnknown()
- func (m *ListInstanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListInstanceResponse) XXX_Merge(src proto.Message)
- func (m *ListInstanceResponse) XXX_Size() int
- func (m *ListInstanceResponse) XXX_Unmarshal(b []byte) error
- type ListOwnershipRequest
- func (*ListOwnershipRequest) Descriptor() ([]byte, []int)
- func (*ListOwnershipRequest) ProtoMessage()
- func (m *ListOwnershipRequest) Reset()
- func (m *ListOwnershipRequest) String() string
- func (m *ListOwnershipRequest) XXX_DiscardUnknown()
- func (m *ListOwnershipRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListOwnershipRequest) XXX_Merge(src proto.Message)
- func (m *ListOwnershipRequest) XXX_Size() int
- func (m *ListOwnershipRequest) XXX_Unmarshal(b []byte) error
- type ListOwnershipResponse
- func (*ListOwnershipResponse) Descriptor() ([]byte, []int)
- func (m *ListOwnershipResponse) GetOwnerships() []*ownership.Ownership
- func (*ListOwnershipResponse) ProtoMessage()
- func (m *ListOwnershipResponse) Reset()
- func (m *ListOwnershipResponse) String() string
- func (m *ListOwnershipResponse) XXX_DiscardUnknown()
- func (m *ListOwnershipResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListOwnershipResponse) XXX_Merge(src proto.Message)
- func (m *ListOwnershipResponse) XXX_Size() int
- func (m *ListOwnershipResponse) XXX_Unmarshal(b []byte) error
- type ListProcessRequest
- func (*ListProcessRequest) Descriptor() ([]byte, []int)
- func (*ListProcessRequest) ProtoMessage()
- func (m *ListProcessRequest) Reset()
- func (m *ListProcessRequest) String() string
- func (m *ListProcessRequest) XXX_DiscardUnknown()
- func (m *ListProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListProcessRequest) XXX_Merge(src proto.Message)
- func (m *ListProcessRequest) XXX_Size() int
- func (m *ListProcessRequest) XXX_Unmarshal(b []byte) error
- type ListProcessResponse
- func (*ListProcessResponse) Descriptor() ([]byte, []int)
- func (m *ListProcessResponse) GetProcesses() []*process.Process
- func (*ListProcessResponse) ProtoMessage()
- func (m *ListProcessResponse) Reset()
- func (m *ListProcessResponse) String() string
- func (m *ListProcessResponse) XXX_DiscardUnknown()
- func (m *ListProcessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListProcessResponse) XXX_Merge(src proto.Message)
- func (m *ListProcessResponse) XXX_Size() int
- func (m *ListProcessResponse) XXX_Unmarshal(b []byte) error
- type ListRunnerRequest
- func (*ListRunnerRequest) Descriptor() ([]byte, []int)
- func (m *ListRunnerRequest) GetFilter() *ListRunnerRequest_Filter
- func (*ListRunnerRequest) ProtoMessage()
- func (m *ListRunnerRequest) Reset()
- func (m *ListRunnerRequest) String() string
- func (m *ListRunnerRequest) XXX_DiscardUnknown()
- func (m *ListRunnerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRunnerRequest) XXX_Merge(src proto.Message)
- func (m *ListRunnerRequest) XXX_Size() int
- func (m *ListRunnerRequest) XXX_Unmarshal(b []byte) error
- type ListRunnerRequest_Filter
- func (*ListRunnerRequest_Filter) Descriptor() ([]byte, []int)
- func (m *ListRunnerRequest_Filter) GetAddress() string
- func (*ListRunnerRequest_Filter) ProtoMessage()
- func (m *ListRunnerRequest_Filter) Reset()
- func (m *ListRunnerRequest_Filter) String() string
- func (m *ListRunnerRequest_Filter) XXX_DiscardUnknown()
- func (m *ListRunnerRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRunnerRequest_Filter) XXX_Merge(src proto.Message)
- func (m *ListRunnerRequest_Filter) XXX_Size() int
- func (m *ListRunnerRequest_Filter) XXX_Unmarshal(b []byte) error
- type ListRunnerResponse
- func (*ListRunnerResponse) Descriptor() ([]byte, []int)
- func (m *ListRunnerResponse) GetRunners() []*runner.Runner
- func (*ListRunnerResponse) ProtoMessage()
- func (m *ListRunnerResponse) Reset()
- func (m *ListRunnerResponse) String() string
- func (m *ListRunnerResponse) XXX_DiscardUnknown()
- func (m *ListRunnerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRunnerResponse) XXX_Merge(src proto.Message)
- func (m *ListRunnerResponse) XXX_Size() int
- func (m *ListRunnerResponse) XXX_Unmarshal(b []byte) error
- type ListServiceRequest
- func (*ListServiceRequest) Descriptor() ([]byte, []int)
- func (*ListServiceRequest) ProtoMessage()
- func (m *ListServiceRequest) Reset()
- func (m *ListServiceRequest) String() string
- func (m *ListServiceRequest) XXX_DiscardUnknown()
- func (m *ListServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListServiceRequest) XXX_Merge(src proto.Message)
- func (m *ListServiceRequest) XXX_Size() int
- func (m *ListServiceRequest) XXX_Unmarshal(b []byte) error
- type ListServiceResponse
- func (*ListServiceResponse) Descriptor() ([]byte, []int)
- func (m *ListServiceResponse) GetServices() []*service.Service
- func (*ListServiceResponse) ProtoMessage()
- func (m *ListServiceResponse) Reset()
- func (m *ListServiceResponse) String() string
- func (m *ListServiceResponse) XXX_DiscardUnknown()
- func (m *ListServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListServiceResponse) XXX_Merge(src proto.Message)
- func (m *ListServiceResponse) XXX_Size() int
- func (m *ListServiceResponse) XXX_Unmarshal(b []byte) error
- type OwnershipClient
- type OwnershipServer
- type ProcessClient
- type ProcessServer
- type RunnerClient
- type RunnerServer
- type ServiceClient
- type ServiceServer
- type StreamEventRequest
- func (*StreamEventRequest) Descriptor() ([]byte, []int)
- func (m *StreamEventRequest) GetFilter() *StreamEventRequest_Filter
- func (*StreamEventRequest) ProtoMessage()
- func (m *StreamEventRequest) Reset()
- func (m *StreamEventRequest) String() string
- func (m *StreamEventRequest) XXX_DiscardUnknown()
- func (m *StreamEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamEventRequest) XXX_Merge(src proto.Message)
- func (m *StreamEventRequest) XXX_Size() int
- func (m *StreamEventRequest) XXX_Unmarshal(b []byte) error
- type StreamEventRequest_Filter
- func (*StreamEventRequest_Filter) Descriptor() ([]byte, []int)
- func (m *StreamEventRequest_Filter) GetKey() string
- func (*StreamEventRequest_Filter) ProtoMessage()
- func (m *StreamEventRequest_Filter) Reset()
- func (m *StreamEventRequest_Filter) String() string
- func (m *StreamEventRequest_Filter) XXX_DiscardUnknown()
- func (m *StreamEventRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamEventRequest_Filter) XXX_Merge(src proto.Message)
- func (m *StreamEventRequest_Filter) XXX_Size() int
- func (m *StreamEventRequest_Filter) XXX_Unmarshal(b []byte) error
- type StreamExecutionRequest
- func (*StreamExecutionRequest) Descriptor() ([]byte, []int)
- func (m *StreamExecutionRequest) GetFilter() *StreamExecutionRequest_Filter
- func (*StreamExecutionRequest) ProtoMessage()
- func (m *StreamExecutionRequest) Reset()
- func (m *StreamExecutionRequest) String() string
- func (m *StreamExecutionRequest) XXX_DiscardUnknown()
- func (m *StreamExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamExecutionRequest) XXX_Merge(src proto.Message)
- func (m *StreamExecutionRequest) XXX_Size() int
- func (m *StreamExecutionRequest) XXX_Unmarshal(b []byte) error
- type StreamExecutionRequest_Filter
- func (*StreamExecutionRequest_Filter) Descriptor() ([]byte, []int)
- func (m *StreamExecutionRequest_Filter) GetStatuses() []execution.Status
- func (m *StreamExecutionRequest_Filter) GetTags() []string
- func (m *StreamExecutionRequest_Filter) GetTaskKey() string
- func (f *StreamExecutionRequest_Filter) Match(e *execution.Execution) bool
- func (*StreamExecutionRequest_Filter) ProtoMessage()
- func (m *StreamExecutionRequest_Filter) Reset()
- func (m *StreamExecutionRequest_Filter) String() string
- func (f *StreamExecutionRequest_Filter) Validate() error
- func (m *StreamExecutionRequest_Filter) XXX_DiscardUnknown()
- func (m *StreamExecutionRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamExecutionRequest_Filter) XXX_Merge(src proto.Message)
- func (m *StreamExecutionRequest_Filter) XXX_Size() int
- func (m *StreamExecutionRequest_Filter) XXX_Unmarshal(b []byte) error
- type UnimplementedAccountServer
- func (*UnimplementedAccountServer) Create(ctx context.Context, req *CreateAccountRequest) (*CreateAccountResponse, error)
- func (*UnimplementedAccountServer) Delete(ctx context.Context, req *DeleteAccountRequest) (*DeleteAccountResponse, error)
- func (*UnimplementedAccountServer) Get(ctx context.Context, req *GetAccountRequest) (*account.Account, error)
- func (*UnimplementedAccountServer) List(ctx context.Context, req *ListAccountRequest) (*ListAccountResponse, error)
- type UnimplementedEventServer
- type UnimplementedExecutionServer
- func (*UnimplementedExecutionServer) Create(ctx context.Context, req *CreateExecutionRequest) (*CreateExecutionResponse, error)
- func (*UnimplementedExecutionServer) Get(ctx context.Context, req *GetExecutionRequest) (*execution.Execution, error)
- func (*UnimplementedExecutionServer) List(ctx context.Context, req *ListExecutionRequest) (*ListExecutionResponse, error)
- func (*UnimplementedExecutionServer) Stream(req *StreamExecutionRequest, srv Execution_StreamServer) error
- func (*UnimplementedExecutionServer) Update(ctx context.Context, req *UpdateExecutionRequest) (*UpdateExecutionResponse, error)
- type UnimplementedInstanceServer
- type UnimplementedOwnershipServer
- type UnimplementedProcessServer
- func (*UnimplementedProcessServer) Create(ctx context.Context, req *CreateProcessRequest) (*CreateProcessResponse, error)
- func (*UnimplementedProcessServer) Delete(ctx context.Context, req *DeleteProcessRequest) (*DeleteProcessResponse, error)
- func (*UnimplementedProcessServer) Get(ctx context.Context, req *GetProcessRequest) (*process.Process, error)
- func (*UnimplementedProcessServer) List(ctx context.Context, req *ListProcessRequest) (*ListProcessResponse, error)
- type UnimplementedRunnerServer
- func (*UnimplementedRunnerServer) Create(ctx context.Context, req *CreateRunnerRequest) (*CreateRunnerResponse, error)
- func (*UnimplementedRunnerServer) Delete(ctx context.Context, req *DeleteRunnerRequest) (*DeleteRunnerResponse, error)
- func (*UnimplementedRunnerServer) Get(ctx context.Context, req *GetRunnerRequest) (*runner.Runner, error)
- func (*UnimplementedRunnerServer) List(ctx context.Context, req *ListRunnerRequest) (*ListRunnerResponse, error)
- type UnimplementedServiceServer
- func (*UnimplementedServiceServer) Create(ctx context.Context, req *CreateServiceRequest) (*CreateServiceResponse, error)
- func (*UnimplementedServiceServer) Exists(ctx context.Context, req *ExistsServiceRequest) (*ExistsServiceResponse, error)
- func (*UnimplementedServiceServer) Get(ctx context.Context, req *GetServiceRequest) (*service.Service, error)
- func (*UnimplementedServiceServer) Hash(ctx context.Context, req *CreateServiceRequest) (*HashServiceResponse, error)
- func (*UnimplementedServiceServer) List(ctx context.Context, req *ListServiceRequest) (*ListServiceResponse, error)
- type UpdateExecutionRequest
- func (*UpdateExecutionRequest) Descriptor() ([]byte, []int)
- func (m *UpdateExecutionRequest) GetError() string
- func (m *UpdateExecutionRequest) GetOutputs() *types.Struct
- func (m *UpdateExecutionRequest) GetResult() isUpdateExecutionRequest_Result
- func (*UpdateExecutionRequest) ProtoMessage()
- func (m *UpdateExecutionRequest) Reset()
- func (m *UpdateExecutionRequest) String() string
- func (m *UpdateExecutionRequest) XXX_DiscardUnknown()
- func (m *UpdateExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateExecutionRequest) XXX_Merge(src proto.Message)
- func (*UpdateExecutionRequest) XXX_OneofWrappers() []interface{}
- func (m *UpdateExecutionRequest) XXX_Size() int
- func (m *UpdateExecutionRequest) XXX_Unmarshal(b []byte) error
- type UpdateExecutionRequest_Error
- type UpdateExecutionRequest_Outputs
- type UpdateExecutionResponse
- func (*UpdateExecutionResponse) Descriptor() ([]byte, []int)
- func (*UpdateExecutionResponse) ProtoMessage()
- func (m *UpdateExecutionResponse) Reset()
- func (m *UpdateExecutionResponse) String() string
- func (m *UpdateExecutionResponse) XXX_DiscardUnknown()
- func (m *UpdateExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateExecutionResponse) XXX_Merge(src proto.Message)
- func (m *UpdateExecutionResponse) XXX_Size() int
- func (m *UpdateExecutionResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterAccountServer ¶ added in v0.15.0
func RegisterAccountServer(s *grpc.Server, srv AccountServer)
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 AccountClient ¶ added in v0.15.0
type AccountClient interface {
// Get returns an Account matching the criteria of the request.
Get(ctx context.Context, in *GetAccountRequest, opts ...grpc.CallOption) (*account.Account, error)
// List returns all Accounts matching the criteria of the request.
List(ctx context.Context, in *ListAccountRequest, opts ...grpc.CallOption) (*ListAccountResponse, error)
// Create an Account with a name and password.
Create(ctx context.Context, in *CreateAccountRequest, opts ...grpc.CallOption) (*CreateAccountResponse, error)
// Delete an Account.
Delete(ctx context.Context, in *DeleteAccountRequest, opts ...grpc.CallOption) (*DeleteAccountResponse, error)
}
AccountClient is the client API for Account service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAccountClient ¶ added in v0.15.0
func NewAccountClient(cc *grpc.ClientConn) AccountClient
type AccountServer ¶ added in v0.15.0
type AccountServer interface {
// Get returns an Account matching the criteria of the request.
Get(context.Context, *GetAccountRequest) (*account.Account, error)
// List returns all Accounts matching the criteria of the request.
List(context.Context, *ListAccountRequest) (*ListAccountResponse, error)
// Create an Account with a name and password.
Create(context.Context, *CreateAccountRequest) (*CreateAccountResponse, error)
// Delete an Account.
Delete(context.Context, *DeleteAccountRequest) (*DeleteAccountResponse, error)
}
AccountServer is the server API for Account service.
type CreateAccountRequest ¶ added in v0.15.0
type CreateAccountRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
The request's data for the `Create` API.
func (*CreateAccountRequest) Descriptor ¶ added in v0.15.0
func (*CreateAccountRequest) Descriptor() ([]byte, []int)
func (*CreateAccountRequest) GetName ¶ added in v0.15.0
func (m *CreateAccountRequest) GetName() string
func (*CreateAccountRequest) GetPassword ¶ added in v0.15.0
func (m *CreateAccountRequest) GetPassword() string
func (*CreateAccountRequest) ProtoMessage ¶ added in v0.15.0
func (*CreateAccountRequest) ProtoMessage()
func (*CreateAccountRequest) Reset ¶ added in v0.15.0
func (m *CreateAccountRequest) Reset()
func (*CreateAccountRequest) String ¶ added in v0.15.0
func (m *CreateAccountRequest) String() string
func (*CreateAccountRequest) XXX_DiscardUnknown ¶ added in v0.15.0
func (m *CreateAccountRequest) XXX_DiscardUnknown()
func (*CreateAccountRequest) XXX_Marshal ¶ added in v0.15.0
func (m *CreateAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateAccountRequest) XXX_Merge ¶ added in v0.15.0
func (m *CreateAccountRequest) XXX_Merge(src proto.Message)
func (*CreateAccountRequest) XXX_Size ¶ added in v0.15.0
func (m *CreateAccountRequest) XXX_Size() int
func (*CreateAccountRequest) XXX_Unmarshal ¶ added in v0.15.0
func (m *CreateAccountRequest) XXX_Unmarshal(b []byte) error
type CreateAccountResponse ¶ added in v0.15.0
type CreateAccountResponse struct {
Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
Mnemonic string `protobuf:"bytes,2,opt,name=mnemonic,proto3" json:"mnemonic,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
The response's data for the `Create` API.
func (*CreateAccountResponse) Descriptor ¶ added in v0.15.0
func (*CreateAccountResponse) Descriptor() ([]byte, []int)
func (*CreateAccountResponse) GetAddress ¶ added in v0.15.0
func (m *CreateAccountResponse) GetAddress() string
func (*CreateAccountResponse) GetMnemonic ¶ added in v0.15.0
func (m *CreateAccountResponse) GetMnemonic() string
func (*CreateAccountResponse) ProtoMessage ¶ added in v0.15.0
func (*CreateAccountResponse) ProtoMessage()
func (*CreateAccountResponse) Reset ¶ added in v0.15.0
func (m *CreateAccountResponse) Reset()
func (*CreateAccountResponse) String ¶ added in v0.15.0
func (m *CreateAccountResponse) String() string
func (*CreateAccountResponse) XXX_DiscardUnknown ¶ added in v0.15.0
func (m *CreateAccountResponse) XXX_DiscardUnknown()
func (*CreateAccountResponse) XXX_Marshal ¶ added in v0.15.0
func (m *CreateAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateAccountResponse) XXX_Merge ¶ added in v0.15.0
func (m *CreateAccountResponse) XXX_Merge(src proto.Message)
func (*CreateAccountResponse) XXX_Size ¶ added in v0.15.0
func (m *CreateAccountResponse) XXX_Size() int
func (*CreateAccountResponse) XXX_Unmarshal ¶ added in v0.15.0
func (m *CreateAccountResponse) XXX_Unmarshal(b []byte) error
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 {
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"`
ParentHash github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,5,opt,name=parentHash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"parentHash"`
EventHash github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,6,opt,name=eventHash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"eventHash"`
ProcessHash github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,7,opt,name=processHash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"processHash"`
StepID string `protobuf:"bytes,8,opt,name=stepID,proto3" json:"stepID,omitempty"`
ExecutorHash github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,9,opt,name=executorHash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"executorHash"`
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) GetStepID ¶ added in v0.17.0
func (m *CreateExecutionRequest) GetStepID() 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 {
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 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 `protobuf:"bytes,1,opt,name=serviceHash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"serviceHash"`
// Environmental variables to start the runner with.
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 (*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"`
// 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 DeleteAccountRequest ¶ added in v0.15.0
type DeleteAccountRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
The request's data for the `Delete` API.
func (*DeleteAccountRequest) Descriptor ¶ added in v0.15.0
func (*DeleteAccountRequest) Descriptor() ([]byte, []int)
func (*DeleteAccountRequest) ProtoMessage ¶ added in v0.15.0
func (*DeleteAccountRequest) ProtoMessage()
func (*DeleteAccountRequest) Reset ¶ added in v0.15.0
func (m *DeleteAccountRequest) Reset()
func (*DeleteAccountRequest) String ¶ added in v0.15.0
func (m *DeleteAccountRequest) String() string
func (*DeleteAccountRequest) XXX_DiscardUnknown ¶ added in v0.15.0
func (m *DeleteAccountRequest) XXX_DiscardUnknown()
func (*DeleteAccountRequest) XXX_Marshal ¶ added in v0.15.0
func (m *DeleteAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteAccountRequest) XXX_Merge ¶ added in v0.15.0
func (m *DeleteAccountRequest) XXX_Merge(src proto.Message)
func (*DeleteAccountRequest) XXX_Size ¶ added in v0.15.0
func (m *DeleteAccountRequest) XXX_Size() int
func (*DeleteAccountRequest) XXX_Unmarshal ¶ added in v0.15.0
func (m *DeleteAccountRequest) XXX_Unmarshal(b []byte) error
type DeleteAccountResponse ¶ added in v0.15.0
type DeleteAccountResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
The response's data for the `Delete` API.
func (*DeleteAccountResponse) Descriptor ¶ added in v0.15.0
func (*DeleteAccountResponse) Descriptor() ([]byte, []int)
func (*DeleteAccountResponse) ProtoMessage ¶ added in v0.15.0
func (*DeleteAccountResponse) ProtoMessage()
func (*DeleteAccountResponse) Reset ¶ added in v0.15.0
func (m *DeleteAccountResponse) Reset()
func (*DeleteAccountResponse) String ¶ added in v0.15.0
func (m *DeleteAccountResponse) String() string
func (*DeleteAccountResponse) XXX_DiscardUnknown ¶ added in v0.15.0
func (m *DeleteAccountResponse) XXX_DiscardUnknown()
func (*DeleteAccountResponse) XXX_Marshal ¶ added in v0.15.0
func (m *DeleteAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteAccountResponse) XXX_Merge ¶ added in v0.15.0
func (m *DeleteAccountResponse) XXX_Merge(src proto.Message)
func (*DeleteAccountResponse) XXX_Size ¶ added in v0.15.0
func (m *DeleteAccountResponse) XXX_Size() int
func (*DeleteAccountResponse) XXX_Unmarshal ¶ added in v0.15.0
func (m *DeleteAccountResponse) 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 DeleteRunnerRequest ¶ added in v0.17.0
type DeleteRunnerRequest struct {
// Runner'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 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 `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 `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 GetAccountRequest ¶ added in v0.15.0
type GetAccountRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
The request's data for the `Get` API.
func (*GetAccountRequest) Descriptor ¶ added in v0.15.0
func (*GetAccountRequest) Descriptor() ([]byte, []int)
func (*GetAccountRequest) GetName ¶ added in v0.15.0
func (m *GetAccountRequest) GetName() string
func (*GetAccountRequest) ProtoMessage ¶ added in v0.15.0
func (*GetAccountRequest) ProtoMessage()
func (*GetAccountRequest) Reset ¶ added in v0.15.0
func (m *GetAccountRequest) Reset()
func (*GetAccountRequest) String ¶ added in v0.15.0
func (m *GetAccountRequest) String() string
func (*GetAccountRequest) XXX_DiscardUnknown ¶ added in v0.15.0
func (m *GetAccountRequest) XXX_DiscardUnknown()
func (*GetAccountRequest) XXX_Marshal ¶ added in v0.15.0
func (m *GetAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetAccountRequest) XXX_Merge ¶ added in v0.15.0
func (m *GetAccountRequest) XXX_Merge(src proto.Message)
func (*GetAccountRequest) XXX_Size ¶ added in v0.15.0
func (m *GetAccountRequest) XXX_Size() int
func (*GetAccountRequest) XXX_Unmarshal ¶ added in v0.15.0
func (m *GetAccountRequest) XXX_Unmarshal(b []byte) error
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 GetRunnerRequest ¶ added in v0.17.0
type GetRunnerRequest 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 (*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 `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 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 ListAccountRequest ¶ added in v0.15.0
type ListAccountRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
The request's data for the `List` API.
func (*ListAccountRequest) Descriptor ¶ added in v0.15.0
func (*ListAccountRequest) Descriptor() ([]byte, []int)
func (*ListAccountRequest) ProtoMessage ¶ added in v0.15.0
func (*ListAccountRequest) ProtoMessage()
func (*ListAccountRequest) Reset ¶ added in v0.15.0
func (m *ListAccountRequest) Reset()
func (*ListAccountRequest) String ¶ added in v0.15.0
func (m *ListAccountRequest) String() string
func (*ListAccountRequest) XXX_DiscardUnknown ¶ added in v0.15.0
func (m *ListAccountRequest) XXX_DiscardUnknown()
func (*ListAccountRequest) XXX_Marshal ¶ added in v0.15.0
func (m *ListAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListAccountRequest) XXX_Merge ¶ added in v0.15.0
func (m *ListAccountRequest) XXX_Merge(src proto.Message)
func (*ListAccountRequest) XXX_Size ¶ added in v0.15.0
func (m *ListAccountRequest) XXX_Size() int
func (*ListAccountRequest) XXX_Unmarshal ¶ added in v0.15.0
func (m *ListAccountRequest) XXX_Unmarshal(b []byte) error
type ListAccountResponse ¶ added in v0.15.0
type ListAccountResponse struct {
Accounts []*account.Account `protobuf:"bytes,1,rep,name=accounts,proto3" json:"accounts,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
The response's data for the `List` API.
func (*ListAccountResponse) Descriptor ¶ added in v0.15.0
func (*ListAccountResponse) Descriptor() ([]byte, []int)
func (*ListAccountResponse) GetAccounts ¶ added in v0.15.0
func (m *ListAccountResponse) GetAccounts() []*account.Account
func (*ListAccountResponse) ProtoMessage ¶ added in v0.15.0
func (*ListAccountResponse) ProtoMessage()
func (*ListAccountResponse) Reset ¶ added in v0.15.0
func (m *ListAccountResponse) Reset()
func (*ListAccountResponse) String ¶ added in v0.15.0
func (m *ListAccountResponse) String() string
func (*ListAccountResponse) XXX_DiscardUnknown ¶ added in v0.15.0
func (m *ListAccountResponse) XXX_DiscardUnknown()
func (*ListAccountResponse) XXX_Marshal ¶ added in v0.15.0
func (m *ListAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListAccountResponse) XXX_Merge ¶ added in v0.15.0
func (m *ListAccountResponse) XXX_Merge(src proto.Message)
func (*ListAccountResponse) XXX_Size ¶ added in v0.15.0
func (m *ListAccountResponse) XXX_Size() int
func (*ListAccountResponse) XXX_Unmarshal ¶ added in v0.15.0
func (m *ListAccountResponse) XXX_Unmarshal(b []byte) error
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 `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:"-"`
}
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 `protobuf:"bytes,1,opt,name=instanceHash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"instanceHash"`
// Filter by address
Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
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 `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=mesg.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"`
// Executor's hash to filter executions.
ExecutorHash github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,5,opt,name=executorHash,proto3,customtype=github.com/mesg-foundation/engine/hash.Hash" json:"executorHash"`
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 UnimplementedAccountServer ¶ added in v0.15.0
type UnimplementedAccountServer struct {
}
UnimplementedAccountServer can be embedded to have forward compatible implementations.
func (*UnimplementedAccountServer) Create ¶ added in v0.15.0
func (*UnimplementedAccountServer) Create(ctx context.Context, req *CreateAccountRequest) (*CreateAccountResponse, error)
func (*UnimplementedAccountServer) Delete ¶ added in v0.15.0
func (*UnimplementedAccountServer) Delete(ctx context.Context, req *DeleteAccountRequest) (*DeleteAccountResponse, error)
func (*UnimplementedAccountServer) Get ¶ added in v0.15.0
func (*UnimplementedAccountServer) Get(ctx context.Context, req *GetAccountRequest) (*account.Account, error)
func (*UnimplementedAccountServer) List ¶ added in v0.15.0
func (*UnimplementedAccountServer) List(ctx context.Context, req *ListAccountRequest) (*ListAccountResponse, 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 `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 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