api

package

Go to main page

Versions in this module

v0

v0.20.0

Mar 17, 2020

Changes in this version

type ListRunnerRequest_Filter

+ Owner string

+ func (m *ListRunnerRequest_Filter) GetOwner() string

v0.19.0

Mar 2, 2020

Changes in this version

+ func RegisterCodec(cdc *codec.Codec)

type CreateExecutionRequest

+ Price string

+ func (m *CreateExecutionRequest) GetPrice() string

v0.18.3

Feb 5, 2020

v0.18.2

Jan 15, 2020

v0.18.1

Jan 14, 2020

v0.18.0

Dec 26, 2019

Changes in this version

type CreateExecutionRequest

+ NodeKey string

+ func (m *CreateExecutionRequest) GetNodeKey() string

type CreateProcessRequest

+ Name string

+ func (m *CreateProcessRequest) GetName() string

v0.17.0

Nov 26, 2019

Changes in this version

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

type CreateExecutionRequest

+ EventHash github_com_mesg_foundation_engine_hash.Hash

+ ExecutorHash github_com_mesg_foundation_engine_hash.Hash

+ ParentHash github_com_mesg_foundation_engine_hash.Hash

+ ProcessHash github_com_mesg_foundation_engine_hash.Hash

+ StepID string

+ func (m *CreateExecutionRequest) GetStepID() string

+ type CreateRunnerRequest struct

+ Env []string

+ ServiceHash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateRunnerRequest) ProtoMessage()

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

+ 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 struct

+ Hash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 DeleteRunnerRequest struct

+ DeleteData bool

+ Hash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteRunnerRequest) ProtoMessage()

+ func (m *DeleteRunnerRequest) GetDeleteData() bool

+ 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 struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 ExecutionClient

+ List func(ctx context.Context, in *ListExecutionRequest, opts ...grpc.CallOption) (*ListExecutionResponse, error)

type ExecutionServer

+ List func(context.Context, *ListExecutionRequest) (*ListExecutionResponse, error)

+ type GetRunnerRequest struct

+ Hash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 ListExecutionRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 struct

+ Executions []*execution.Execution

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListExecutionResponse) ProtoMessage()

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

+ 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

+ Filter *ListInstanceRequest_Filter

+ func (m *ListInstanceRequest) GetFilter() *ListInstanceRequest_Filter

+ type ListInstanceRequest_Filter struct

+ ServiceHash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 ListRunnerRequest struct

+ Filter *ListRunnerRequest_Filter

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListRunnerRequest) ProtoMessage()

+ func (m *ListRunnerRequest) GetFilter() *ListRunnerRequest_Filter

+ 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 struct

+ Address string

+ InstanceHash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListRunnerRequest_Filter) ProtoMessage()

+ func (m *ListRunnerRequest_Filter) GetAddress() string

+ 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 struct

+ Runners []*runner.Runner

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListRunnerResponse) ProtoMessage()

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

+ 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 RunnerClient interface

+ Create func(ctx context.Context, in *CreateRunnerRequest, opts ...grpc.CallOption) (*CreateRunnerResponse, error)

+ Delete func(ctx context.Context, in *DeleteRunnerRequest, opts ...grpc.CallOption) (*DeleteRunnerResponse, error)

+ Get func(ctx context.Context, in *GetRunnerRequest, opts ...grpc.CallOption) (*runner.Runner, error)

+ List func(ctx context.Context, in *ListRunnerRequest, opts ...grpc.CallOption) (*ListRunnerResponse, error)

+ func NewRunnerClient(cc *grpc.ClientConn) RunnerClient

+ type RunnerServer interface

+ Create func(context.Context, *CreateRunnerRequest) (*CreateRunnerResponse, error)

+ Delete func(context.Context, *DeleteRunnerRequest) (*DeleteRunnerResponse, error)

+ Get func(context.Context, *GetRunnerRequest) (*runner.Runner, error)

+ List func(context.Context, *ListRunnerRequest) (*ListRunnerResponse, error)

type StreamExecutionRequest_Filter

+ ExecutorHash github_com_mesg_foundation_engine_hash.Hash

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

+ func (f *StreamExecutionRequest_Filter) Validate() error

type UnimplementedExecutionServer

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

+ type UnimplementedRunnerServer struct

+ 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)

v0.16.0

Oct 25, 2019

Changes in this version

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

+ type ExistsServiceRequest struct

+ Hash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 struct

+ Exists bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ExistsServiceResponse) ProtoMessage()

+ func (m *ExistsServiceResponse) GetExists() bool

+ 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 HashServiceResponse struct

+ Hash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 ListOwnershipRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 struct

+ Ownerships []*ownership.Ownership

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListOwnershipResponse) ProtoMessage()

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

+ 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 OwnershipClient interface

+ List func(ctx context.Context, in *ListOwnershipRequest, opts ...grpc.CallOption) (*ListOwnershipResponse, error)

+ func NewOwnershipClient(cc *grpc.ClientConn) OwnershipClient

+ type OwnershipServer interface

+ List func(context.Context, *ListOwnershipRequest) (*ListOwnershipResponse, error)

type ServiceClient

+ Exists func(ctx context.Context, in *ExistsServiceRequest, opts ...grpc.CallOption) (*ExistsServiceResponse, error)

+ Hash func(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*HashServiceResponse, error)

type ServiceServer

+ Exists func(context.Context, *ExistsServiceRequest) (*ExistsServiceResponse, error)

+ Hash func(context.Context, *CreateServiceRequest) (*HashServiceResponse, error)

+ type UnimplementedOwnershipServer struct

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

type UnimplementedServiceServer

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

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

v0.15.0

Sep 23, 2019

Changes in this version

+ func RegisterAccountServer(s *grpc.Server, srv AccountServer)

+ type AccountClient interface

+ Create func(ctx context.Context, in *CreateAccountRequest, opts ...grpc.CallOption) (*CreateAccountResponse, error)

+ Delete func(ctx context.Context, in *DeleteAccountRequest, opts ...grpc.CallOption) (*DeleteAccountResponse, error)

+ Get func(ctx context.Context, in *GetAccountRequest, opts ...grpc.CallOption) (*account.Account, error)

+ List func(ctx context.Context, in *ListAccountRequest, opts ...grpc.CallOption) (*ListAccountResponse, error)

+ func NewAccountClient(cc *grpc.ClientConn) AccountClient

+ type AccountServer interface

+ Create func(context.Context, *CreateAccountRequest) (*CreateAccountResponse, error)

+ Delete func(context.Context, *DeleteAccountRequest) (*DeleteAccountResponse, error)

+ Get func(context.Context, *GetAccountRequest) (*account.Account, error)

+ List func(context.Context, *ListAccountRequest) (*ListAccountResponse, error)

+ type CreateAccountRequest struct

+ Name string

+ Password string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateAccountRequest) Descriptor() ([]byte, []int)

+ func (*CreateAccountRequest) ProtoMessage()

+ func (m *CreateAccountRequest) GetName() string

+ func (m *CreateAccountRequest) GetPassword() string

+ 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 struct

+ Address string

+ Mnemonic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateAccountResponse) Descriptor() ([]byte, []int)

+ func (*CreateAccountResponse) ProtoMessage()

+ func (m *CreateAccountResponse) GetAddress() string

+ func (m *CreateAccountResponse) GetMnemonic() string

+ 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 DeleteAccountRequest struct

+ Name string

+ Password string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeleteAccountRequest) Descriptor() ([]byte, []int)

+ func (*DeleteAccountRequest) ProtoMessage()

+ func (m *DeleteAccountRequest) GetName() string

+ func (m *DeleteAccountRequest) GetPassword() string

+ 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 struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 GetAccountRequest struct

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetAccountRequest) Descriptor() ([]byte, []int)

+ func (*GetAccountRequest) ProtoMessage()

+ func (m *GetAccountRequest) GetName() string

+ 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 ListAccountRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 struct

+ Accounts []*account.Account

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListAccountResponse) Descriptor() ([]byte, []int)

+ func (*ListAccountResponse) ProtoMessage()

+ func (m *ListAccountResponse) GetAccounts() []*account.Account

+ 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 ListInstanceRequest struct

+ ServiceHash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ 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 ListInstanceResponse struct

+ Instances []*instance.Instance

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListInstanceResponse) ProtoMessage()

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

+ 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 UnimplementedAccountServer struct

+ 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)

v0.14.2

Sep 16, 2019

v0.14.1

Sep 11, 2019

v0.14.0

Sep 6, 2019

Changes in this version

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

+ type CreateProcessRequest struct

+ Edges []*process.Process_Edge

+ Key string

+ Nodes []*process.Process_Node

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateProcessRequest) ProtoMessage()

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

+ func (m *CreateProcessRequest) GetKey() string

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

+ 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 struct

+ Hash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 DeleteProcessRequest struct

+ Hash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 GetProcessRequest struct

+ Hash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 ListProcessRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 struct

+ Processes []*process.Process

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListProcessResponse) ProtoMessage()

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

+ 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 ProcessClient interface

+ Create func(ctx context.Context, in *CreateProcessRequest, opts ...grpc.CallOption) (*CreateProcessResponse, error)

+ Delete func(ctx context.Context, in *DeleteProcessRequest, opts ...grpc.CallOption) (*DeleteProcessResponse, error)

+ Get func(ctx context.Context, in *GetProcessRequest, opts ...grpc.CallOption) (*process.Process, error)

+ List func(ctx context.Context, in *ListProcessRequest, opts ...grpc.CallOption) (*ListProcessResponse, error)

+ func NewProcessClient(cc *grpc.ClientConn) ProcessClient

+ type ProcessServer interface

+ Create func(context.Context, *CreateProcessRequest) (*CreateProcessResponse, error)

+ Delete func(context.Context, *DeleteProcessRequest) (*DeleteProcessResponse, error)

+ Get func(context.Context, *GetProcessRequest) (*process.Process, error)

+ List func(context.Context, *ListProcessRequest) (*ListProcessResponse, error)

+ type UnimplementedProcessServer struct

+ 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)

v0.13.0

Aug 16, 2019

Changes in this version

+ func RegisterWorkflowServer(s *grpc.Server, srv WorkflowServer)

+ type CreateWorkflowRequest struct

+ Edges []*types.Workflow_Edge

+ Key string

+ Nodes []*types.Workflow_Node

+ Trigger *types.Workflow_Trigger

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*CreateWorkflowRequest) ProtoMessage()

+ func (m *CreateWorkflowRequest) GetEdges() []*types.Workflow_Edge

+ func (m *CreateWorkflowRequest) GetKey() string

+ func (m *CreateWorkflowRequest) GetNodes() []*types.Workflow_Node

+ func (m *CreateWorkflowRequest) GetTrigger() *types.Workflow_Trigger

+ func (m *CreateWorkflowRequest) Reset()

+ func (m *CreateWorkflowRequest) String() string

+ func (m *CreateWorkflowRequest) XXX_DiscardUnknown()

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

+ func (m *CreateWorkflowRequest) XXX_Merge(src proto.Message)

+ func (m *CreateWorkflowRequest) XXX_Size() int

+ func (m *CreateWorkflowRequest) XXX_Unmarshal(b []byte) error

+ type CreateWorkflowResponse struct

+ Hash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateWorkflowResponse) Descriptor() ([]byte, []int)

+ func (*CreateWorkflowResponse) ProtoMessage()

+ func (m *CreateWorkflowResponse) GetHash() string

+ func (m *CreateWorkflowResponse) Reset()

+ func (m *CreateWorkflowResponse) String() string

+ func (m *CreateWorkflowResponse) XXX_DiscardUnknown()

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

+ func (m *CreateWorkflowResponse) XXX_Merge(src proto.Message)

+ func (m *CreateWorkflowResponse) XXX_Size() int

+ func (m *CreateWorkflowResponse) XXX_Unmarshal(b []byte) error

+ type DeleteWorkflowRequest struct

+ Hash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeleteWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*DeleteWorkflowRequest) ProtoMessage()

+ func (m *DeleteWorkflowRequest) GetHash() string

+ func (m *DeleteWorkflowRequest) Reset()

+ func (m *DeleteWorkflowRequest) String() string

+ func (m *DeleteWorkflowRequest) XXX_DiscardUnknown()

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

+ func (m *DeleteWorkflowRequest) XXX_Merge(src proto.Message)

+ func (m *DeleteWorkflowRequest) XXX_Size() int

+ func (m *DeleteWorkflowRequest) XXX_Unmarshal(b []byte) error

+ type DeleteWorkflowResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeleteWorkflowResponse) Descriptor() ([]byte, []int)

+ func (*DeleteWorkflowResponse) ProtoMessage()

+ func (m *DeleteWorkflowResponse) Reset()

+ func (m *DeleteWorkflowResponse) String() string

+ func (m *DeleteWorkflowResponse) XXX_DiscardUnknown()

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

+ func (m *DeleteWorkflowResponse) XXX_Merge(src proto.Message)

+ func (m *DeleteWorkflowResponse) XXX_Size() int

+ func (m *DeleteWorkflowResponse) XXX_Unmarshal(b []byte) error

+ type GetWorkflowRequest struct

+ Hash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*GetWorkflowRequest) ProtoMessage()

+ func (m *GetWorkflowRequest) GetHash() string

+ func (m *GetWorkflowRequest) Reset()

+ func (m *GetWorkflowRequest) String() string

+ func (m *GetWorkflowRequest) XXX_DiscardUnknown()

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

+ func (m *GetWorkflowRequest) XXX_Merge(src proto.Message)

+ func (m *GetWorkflowRequest) XXX_Size() int

+ func (m *GetWorkflowRequest) XXX_Unmarshal(b []byte) error

+ type ListWorkflowRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*ListWorkflowRequest) ProtoMessage()

+ func (m *ListWorkflowRequest) Reset()

+ func (m *ListWorkflowRequest) String() string

+ func (m *ListWorkflowRequest) XXX_DiscardUnknown()

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

+ func (m *ListWorkflowRequest) XXX_Merge(src proto.Message)

+ func (m *ListWorkflowRequest) XXX_Size() int

+ func (m *ListWorkflowRequest) XXX_Unmarshal(b []byte) error

+ type ListWorkflowResponse struct

+ Workflows []*types.Workflow

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListWorkflowResponse) Descriptor() ([]byte, []int)

+ func (*ListWorkflowResponse) ProtoMessage()

+ func (m *ListWorkflowResponse) GetWorkflows() []*types.Workflow

+ func (m *ListWorkflowResponse) Reset()

+ func (m *ListWorkflowResponse) String() string

+ func (m *ListWorkflowResponse) XXX_DiscardUnknown()

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

+ func (m *ListWorkflowResponse) XXX_Merge(src proto.Message)

+ func (m *ListWorkflowResponse) XXX_Size() int

+ func (m *ListWorkflowResponse) XXX_Unmarshal(b []byte) error

+ type UnimplementedEventServer struct

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

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

+ type UnimplementedExecutionServer struct

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

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

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

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

+ type UnimplementedInstanceServer struct

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

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

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

+ func (*UnimplementedInstanceServer) List(ctx context.Context, req *ListInstancesRequest) (*ListInstancesResponse, error)

+ type UnimplementedServiceServer struct

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

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

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

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

+ type UnimplementedWorkflowServer struct

+ func (*UnimplementedWorkflowServer) Create(ctx context.Context, req *CreateWorkflowRequest) (*CreateWorkflowResponse, error)

+ func (*UnimplementedWorkflowServer) Delete(ctx context.Context, req *DeleteWorkflowRequest) (*DeleteWorkflowResponse, error)

+ func (*UnimplementedWorkflowServer) Get(ctx context.Context, req *GetWorkflowRequest) (*types.Workflow, error)

+ func (*UnimplementedWorkflowServer) List(ctx context.Context, req *ListWorkflowRequest) (*ListWorkflowResponse, error)

+ type WorkflowClient interface

+ Create func(ctx context.Context, in *CreateWorkflowRequest, opts ...grpc.CallOption) (*CreateWorkflowResponse, error)

+ Delete func(ctx context.Context, in *DeleteWorkflowRequest, opts ...grpc.CallOption) (*DeleteWorkflowResponse, error)

+ Get func(ctx context.Context, in *GetWorkflowRequest, opts ...grpc.CallOption) (*types.Workflow, error)

+ List func(ctx context.Context, in *ListWorkflowRequest, opts ...grpc.CallOption) (*ListWorkflowResponse, error)

+ func NewWorkflowClient(cc *grpc.ClientConn) WorkflowClient

+ type WorkflowServer interface

+ Create func(context.Context, *CreateWorkflowRequest) (*CreateWorkflowResponse, error)

+ Delete func(context.Context, *DeleteWorkflowRequest) (*DeleteWorkflowResponse, error)

+ Get func(context.Context, *GetWorkflowRequest) (*types.Workflow, error)

+ List func(context.Context, *ListWorkflowRequest) (*ListWorkflowResponse, error)

v0.12.1

Jul 31, 2019

v0.12.0

Jul 30, 2019

Changes in this version

type CreateServiceRequest

+ Workflows []*types.Service_Workflow

+ func (m *CreateServiceRequest) GetWorkflows() []*types.Service_Workflow

v0.11.0

Jul 5, 2019

Changes in this version

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

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

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

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

+ type CreateEventRequest struct

+ Data string

+ InstanceHash string

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateEventRequest) ProtoMessage()

+ func (m *CreateEventRequest) GetData() string

+ func (m *CreateEventRequest) GetInstanceHash() string

+ func (m *CreateEventRequest) GetKey() string

+ 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 struct

+ Hash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateEventResponse) ProtoMessage()

+ func (m *CreateEventResponse) GetHash() string

+ 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 struct

+ Inputs string

+ InstanceHash string

+ Tags []string

+ TaskKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateExecutionRequest) ProtoMessage()

+ func (m *CreateExecutionRequest) GetInputs() string

+ func (m *CreateExecutionRequest) GetInstanceHash() string

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

+ func (m *CreateExecutionRequest) GetTaskKey() string

+ 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 struct

+ Hash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateExecutionResponse) ProtoMessage()

+ func (m *CreateExecutionResponse) GetHash() string

+ 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 CreateInstanceRequest struct

+ Env []string

+ ServiceHash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateInstanceRequest) ProtoMessage()

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

+ func (m *CreateInstanceRequest) GetServiceHash() string

+ func (m *CreateInstanceRequest) Reset()

+ func (m *CreateInstanceRequest) String() string

+ func (m *CreateInstanceRequest) XXX_DiscardUnknown()

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

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

+ func (m *CreateInstanceRequest) XXX_Size() int

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

+ type CreateInstanceResponse struct

+ Hash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateInstanceResponse) ProtoMessage()

+ func (m *CreateInstanceResponse) GetHash() string

+ func (m *CreateInstanceResponse) Reset()

+ func (m *CreateInstanceResponse) String() string

+ func (m *CreateInstanceResponse) XXX_DiscardUnknown()

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

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

+ func (m *CreateInstanceResponse) XXX_Size() int

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

+ type CreateServiceRequest struct

+ Configuration *types.Service_Configuration

+ Dependencies []*types.Service_Dependency

+ Description string

+ Events []*types.Service_Event

+ Name string

+ Repository string

+ Sid string

+ Source string

+ Tasks []*types.Service_Task

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateServiceRequest) ProtoMessage()

+ func (m *CreateServiceRequest) GetConfiguration() *types.Service_Configuration

+ func (m *CreateServiceRequest) GetDependencies() []*types.Service_Dependency

+ func (m *CreateServiceRequest) GetDescription() string

+ func (m *CreateServiceRequest) GetEvents() []*types.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() []*types.Service_Task

+ 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 struct

+ Hash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateServiceResponse) ProtoMessage()

+ func (m *CreateServiceResponse) GetHash() string

+ 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 DeleteInstanceRequest struct

+ DeleteData bool

+ Hash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteInstanceRequest) ProtoMessage()

+ func (m *DeleteInstanceRequest) GetDeleteData() bool

+ func (m *DeleteInstanceRequest) GetHash() string

+ func (m *DeleteInstanceRequest) Reset()

+ func (m *DeleteInstanceRequest) String() string

+ func (m *DeleteInstanceRequest) XXX_DiscardUnknown()

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

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

+ func (m *DeleteInstanceRequest) XXX_Size() int

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

+ type DeleteInstanceResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteInstanceResponse) ProtoMessage()

+ func (m *DeleteInstanceResponse) Reset()

+ func (m *DeleteInstanceResponse) String() string

+ func (m *DeleteInstanceResponse) XXX_DiscardUnknown()

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

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

+ func (m *DeleteInstanceResponse) XXX_Size() int

+ func (m *DeleteInstanceResponse) XXX_Unmarshal(b []byte) error

+ type DeleteServiceRequest struct

+ Hash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteServiceRequest) ProtoMessage()

+ func (m *DeleteServiceRequest) GetHash() string

+ func (m *DeleteServiceRequest) Reset()

+ func (m *DeleteServiceRequest) String() string

+ func (m *DeleteServiceRequest) XXX_DiscardUnknown()

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

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

+ func (m *DeleteServiceRequest) XXX_Size() int

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

+ type DeleteServiceResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteServiceResponse) ProtoMessage()

+ func (m *DeleteServiceResponse) Reset()

+ func (m *DeleteServiceResponse) String() string

+ func (m *DeleteServiceResponse) XXX_DiscardUnknown()

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

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

+ func (m *DeleteServiceResponse) XXX_Size() int

+ func (m *DeleteServiceResponse) XXX_Unmarshal(b []byte) error

+ type EventClient interface

+ Create func(ctx context.Context, in *CreateEventRequest, opts ...grpc.CallOption) (*CreateEventResponse, error)

+ Stream func(ctx context.Context, in *StreamEventRequest, opts ...grpc.CallOption) (Event_StreamClient, error)

+ func NewEventClient(cc *grpc.ClientConn) EventClient

+ type EventServer interface

+ Create func(context.Context, *CreateEventRequest) (*CreateEventResponse, error)

+ Stream func(*StreamEventRequest, Event_StreamServer) error

+ type Event_StreamClient interface

+ Recv func() (*types.Event, error)

+ type Event_StreamServer interface

+ Send func(*types.Event) error

+ type ExecutionClient interface

+ Create func(ctx context.Context, in *CreateExecutionRequest, opts ...grpc.CallOption) (*CreateExecutionResponse, error)

+ Get func(ctx context.Context, in *GetExecutionRequest, opts ...grpc.CallOption) (*types.Execution, error)

+ Stream func(ctx context.Context, in *StreamExecutionRequest, opts ...grpc.CallOption) (Execution_StreamClient, error)

+ Update func(ctx context.Context, in *UpdateExecutionRequest, opts ...grpc.CallOption) (*UpdateExecutionResponse, error)

+ func NewExecutionClient(cc *grpc.ClientConn) ExecutionClient

+ type ExecutionServer interface

+ Create func(context.Context, *CreateExecutionRequest) (*CreateExecutionResponse, error)

+ Get func(context.Context, *GetExecutionRequest) (*types.Execution, error)

+ Stream func(*StreamExecutionRequest, Execution_StreamServer) error

+ Update func(context.Context, *UpdateExecutionRequest) (*UpdateExecutionResponse, error)

+ type Execution_StreamClient interface

+ Recv func() (*types.Execution, error)

+ type Execution_StreamServer interface

+ Send func(*types.Execution) error

+ type GetExecutionRequest struct

+ Hash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetExecutionRequest) ProtoMessage()

+ func (m *GetExecutionRequest) GetHash() string

+ 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 struct

+ Hash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetInstanceRequest) ProtoMessage()

+ func (m *GetInstanceRequest) GetHash() string

+ 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 GetServiceRequest struct

+ Hash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetServiceRequest) ProtoMessage()

+ func (m *GetServiceRequest) GetHash() string

+ 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 InstanceClient interface

+ Create func(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)

+ Delete func(ctx context.Context, in *DeleteInstanceRequest, opts ...grpc.CallOption) (*DeleteInstanceResponse, error)

+ Get func(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*types.Instance, error)

+ List func(ctx context.Context, in *ListInstancesRequest, opts ...grpc.CallOption) (*ListInstancesResponse, error)

+ func NewInstanceClient(cc *grpc.ClientConn) InstanceClient

+ type InstanceServer interface

+ Create func(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)

+ Delete func(context.Context, *DeleteInstanceRequest) (*DeleteInstanceResponse, error)

+ Get func(context.Context, *GetInstanceRequest) (*types.Instance, error)

+ List func(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)

+ type ListInstancesRequest struct

+ ServiceHash string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListInstancesRequest) ProtoMessage()

+ func (m *ListInstancesRequest) GetServiceHash() string

+ func (m *ListInstancesRequest) Reset()

+ func (m *ListInstancesRequest) String() string

+ func (m *ListInstancesRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListInstancesRequest) XXX_Size() int

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

+ type ListInstancesResponse struct

+ Instances []*types.Instance

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListInstancesResponse) ProtoMessage()

+ func (m *ListInstancesResponse) GetInstances() []*types.Instance

+ func (m *ListInstancesResponse) Reset()

+ func (m *ListInstancesResponse) String() string

+ func (m *ListInstancesResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListInstancesResponse) XXX_Size() int

+ func (m *ListInstancesResponse) XXX_Unmarshal(b []byte) error

+ type ListServiceRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 struct

+ Services []*types.Service

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListServiceResponse) ProtoMessage()

+ func (m *ListServiceResponse) GetServices() []*types.Service

+ 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 ServiceClient interface

+ Create func(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*CreateServiceResponse, error)

+ Delete func(ctx context.Context, in *DeleteServiceRequest, opts ...grpc.CallOption) (*DeleteServiceResponse, error)

+ Get func(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*types.Service, error)

+ List func(ctx context.Context, in *ListServiceRequest, opts ...grpc.CallOption) (*ListServiceResponse, error)

+ func NewServiceClient(cc *grpc.ClientConn) ServiceClient

+ type ServiceServer interface

+ Create func(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)

+ Delete func(context.Context, *DeleteServiceRequest) (*DeleteServiceResponse, error)

+ Get func(context.Context, *GetServiceRequest) (*types.Service, error)

+ List func(context.Context, *ListServiceRequest) (*ListServiceResponse, error)

+ type StreamEventRequest struct

+ Filter *StreamEventRequest_Filter

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamEventRequest) ProtoMessage()

+ func (m *StreamEventRequest) GetFilter() *StreamEventRequest_Filter

+ 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 struct

+ Hash string

+ InstanceHash string

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamEventRequest_Filter) ProtoMessage()

+ func (m *StreamEventRequest_Filter) GetHash() string

+ func (m *StreamEventRequest_Filter) GetInstanceHash() string

+ func (m *StreamEventRequest_Filter) GetKey() string

+ 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 struct

+ Filter *StreamExecutionRequest_Filter

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamExecutionRequest) ProtoMessage()

+ func (m *StreamExecutionRequest) GetFilter() *StreamExecutionRequest_Filter

+ 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 struct

+ InstanceHash string

+ Statuses []types.Status

+ Tags []string

+ TaskKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamExecutionRequest_Filter) ProtoMessage()

+ func (m *StreamExecutionRequest_Filter) GetInstanceHash() string

+ func (m *StreamExecutionRequest_Filter) GetStatuses() []types.Status

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

+ func (m *StreamExecutionRequest_Filter) GetTaskKey() string

+ func (m *StreamExecutionRequest_Filter) Reset()

+ func (m *StreamExecutionRequest_Filter) String() string

+ 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 UpdateExecutionRequest struct

+ Hash string

+ Result isUpdateExecutionRequest_Result

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UpdateExecutionRequest) ProtoMessage()

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

+ func (m *UpdateExecutionRequest) GetError() string

+ func (m *UpdateExecutionRequest) GetHash() string

+ func (m *UpdateExecutionRequest) GetOutputs() string

+ func (m *UpdateExecutionRequest) GetResult() isUpdateExecutionRequest_Result

+ 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 (m *UpdateExecutionRequest) XXX_Size() int

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

+ type UpdateExecutionRequest_Error struct

+ Error string

+ type UpdateExecutionRequest_Outputs struct

+ Outputs string

+ type UpdateExecutionResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL