orchestrator

package
v0.26.0 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2020 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source 
const RequestSignature = "mesg_request_signature"

RequestSignature is the name of the key to use in the gRPC metadata to set the request signature.

Variables

This section is empty.

Functions

func RegisterEventServer 

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

func RegisterExecutionServer 

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

func RegisterRunnerServer 

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

Types

type Authorizer 

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

Authorizer is the type to aggregate all Admin APIs.

func NewAuthorizer 

func NewAuthorizer(cdc *codec.Codec, authorizedPubKeys []string) (*Authorizer, error)

NewAuthorizer creates a new Authorizer.

func (*Authorizer) IsAuthorized 

func (a *Authorizer) IsAuthorized(ctx context.Context, payload interface{}) error

IsAuthorized checks the context for a signature signed by one of the authorizedPubKeys.

type EventClient 

type EventClient interface {
	// Stream returns a stream of events that satisfy criteria specified.
	Stream(ctx context.Context, in *EventStreamRequest, 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 {
	// Stream returns a stream of events that satisfy criteria specified.
	Stream(*EventStreamRequest, Event_StreamServer) error
}

EventServer is the server API for Event service.

func NewEventServer 

func NewEventServer(eventPublisher *publisher.EventPublisher, auth *Authorizer) EventServer

NewEventServer creates a new Event Server.

type EventStreamRequest 

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

Stream returns a stream of events that satisfy specified filter.

func (*EventStreamRequest) Descriptor 

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

func (*EventStreamRequest) GetFilter 

func (m *EventStreamRequest) GetFilter() *EventStreamRequest_Filter

func (*EventStreamRequest) ProtoMessage 

func (*EventStreamRequest) ProtoMessage()

func (*EventStreamRequest) Reset 

func (m *EventStreamRequest) Reset()

func (*EventStreamRequest) String 

func (m *EventStreamRequest) String() string

func (*EventStreamRequest) XXX_DiscardUnknown 

func (m *EventStreamRequest) XXX_DiscardUnknown()

func (*EventStreamRequest) XXX_Marshal 

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

func (*EventStreamRequest) XXX_Merge 

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

func (*EventStreamRequest) XXX_Size 

func (m *EventStreamRequest) XXX_Size() int

func (*EventStreamRequest) XXX_Unmarshal 

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

type EventStreamRequest_Filter 

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

Filter contains filtering criteria.

func (*EventStreamRequest_Filter) Descriptor 

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

func (*EventStreamRequest_Filter) GetHash 

func (m *EventStreamRequest_Filter) GetHash() github_com_mesg_foundation_engine_hash.Hash

func (*EventStreamRequest_Filter) GetInstanceHash 

func (m *EventStreamRequest_Filter) GetInstanceHash() github_com_mesg_foundation_engine_hash.Hash

func (*EventStreamRequest_Filter) GetKey 

func (m *EventStreamRequest_Filter) GetKey() string

func (*EventStreamRequest_Filter) ProtoMessage 

func (*EventStreamRequest_Filter) ProtoMessage()

func (*EventStreamRequest_Filter) Reset 

func (m *EventStreamRequest_Filter) Reset()

func (*EventStreamRequest_Filter) String 

func (m *EventStreamRequest_Filter) String() string

func (*EventStreamRequest_Filter) XXX_DiscardUnknown 

func (m *EventStreamRequest_Filter) XXX_DiscardUnknown()

func (*EventStreamRequest_Filter) XXX_Marshal 

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

func (*EventStreamRequest_Filter) XXX_Merge 

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

func (*EventStreamRequest_Filter) XXX_Size 

func (m *EventStreamRequest_Filter) XXX_Size() int

func (*EventStreamRequest_Filter) XXX_Unmarshal 

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

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 an execution on the blockchain.
	Create(ctx context.Context, in *ExecutionCreateRequest, opts ...grpc.CallOption) (*ExecutionCreateResponse, error)
	// Stream returns a stream of executions that satisfy specified filter.
	Stream(ctx context.Context, in *ExecutionStreamRequest, opts ...grpc.CallOption) (Execution_StreamClient, 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 ExecutionCreateRequest 

type ExecutionCreateRequest struct {
	TaskKey              string                                      `protobuf:"bytes,1,opt,name=taskKey,proto3" json:"taskKey,omitempty" validate:"required,printascii"`
	Inputs               *types.Struct                               `protobuf:"bytes,2,opt,name=inputs,proto3" json:"inputs,omitempty"`
	Tags                 []string                                    `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty" validate:"dive,printascii"`
	ExecutorHash         github_com_mesg_foundation_engine_hash.Hash `` /* 156-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

ExecutionCreateRequest is the request of the endpoint ExecutionCreate.

func (*ExecutionCreateRequest) Descriptor 

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

func (*ExecutionCreateRequest) GetExecutorHash 

func (m *ExecutionCreateRequest) GetExecutorHash() github_com_mesg_foundation_engine_hash.Hash

func (*ExecutionCreateRequest) GetInputs 

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

func (*ExecutionCreateRequest) GetTags 

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

func (*ExecutionCreateRequest) GetTaskKey 

func (m *ExecutionCreateRequest) GetTaskKey() string

func (*ExecutionCreateRequest) ProtoMessage 

func (*ExecutionCreateRequest) ProtoMessage()

func (*ExecutionCreateRequest) Reset 

func (m *ExecutionCreateRequest) Reset()

func (*ExecutionCreateRequest) String 

func (m *ExecutionCreateRequest) String() string

func (*ExecutionCreateRequest) XXX_DiscardUnknown 

func (m *ExecutionCreateRequest) XXX_DiscardUnknown()

func (*ExecutionCreateRequest) XXX_Marshal 

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

func (*ExecutionCreateRequest) XXX_Merge 

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

func (*ExecutionCreateRequest) XXX_Size 

func (m *ExecutionCreateRequest) XXX_Size() int

func (*ExecutionCreateRequest) XXX_Unmarshal 

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

type ExecutionCreateResponse 

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

ExecutionCreateResponse is the response of the endpoint ExecutionCreate.

func (*ExecutionCreateResponse) Descriptor 

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

func (*ExecutionCreateResponse) GetHash 

func (m *ExecutionCreateResponse) GetHash() github_com_mesg_foundation_engine_hash.Hash

func (*ExecutionCreateResponse) ProtoMessage 

func (*ExecutionCreateResponse) ProtoMessage()

func (*ExecutionCreateResponse) Reset 

func (m *ExecutionCreateResponse) Reset()

func (*ExecutionCreateResponse) String 

func (m *ExecutionCreateResponse) String() string

func (*ExecutionCreateResponse) XXX_DiscardUnknown 

func (m *ExecutionCreateResponse) XXX_DiscardUnknown()

func (*ExecutionCreateResponse) XXX_Marshal 

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

func (*ExecutionCreateResponse) XXX_Merge 

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

func (*ExecutionCreateResponse) XXX_Size 

func (m *ExecutionCreateResponse) XXX_Size() int

func (*ExecutionCreateResponse) XXX_Unmarshal 

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

type ExecutionServer 

type ExecutionServer interface {
	// Create an execution on the blockchain.
	Create(context.Context, *ExecutionCreateRequest) (*ExecutionCreateResponse, error)
	// Stream returns a stream of executions that satisfy specified filter.
	Stream(*ExecutionStreamRequest, Execution_StreamServer) error
}

ExecutionServer is the server API for Execution service.

func NewExecutionServer 

func NewExecutionServer(rpc *cosmos.RPC, auth *Authorizer) ExecutionServer

NewExecutionServer creates a new Execution Server.

type ExecutionStreamRequest 

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

ExecutionStreamRequest defines request to retrieve a stream of executions.

func (*ExecutionStreamRequest) Descriptor 

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

func (*ExecutionStreamRequest) GetFilter 

func (m *ExecutionStreamRequest) GetFilter() *ExecutionStreamRequest_Filter

func (*ExecutionStreamRequest) ProtoMessage 

func (*ExecutionStreamRequest) ProtoMessage()

func (*ExecutionStreamRequest) Reset 

func (m *ExecutionStreamRequest) Reset()

func (*ExecutionStreamRequest) String 

func (m *ExecutionStreamRequest) String() string

func (*ExecutionStreamRequest) XXX_DiscardUnknown 

func (m *ExecutionStreamRequest) XXX_DiscardUnknown()

func (*ExecutionStreamRequest) XXX_Marshal 

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

func (*ExecutionStreamRequest) XXX_Merge 

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

func (*ExecutionStreamRequest) XXX_Size 

func (m *ExecutionStreamRequest) XXX_Size() int

func (*ExecutionStreamRequest) XXX_Unmarshal 

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

type ExecutionStreamRequest_Filter 

type ExecutionStreamRequest_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 `` /* 156-byte string literal not displayed */
	// taskKey to filter executions.
	TaskKey string `protobuf:"bytes,3,opt,name=taskKey,proto3" json:"taskKey,omitempty" validate:"printascii"`
	// tags to filter executions. All tags needs to be present in the execution.
	Tags []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty" validate:"dive,printascii"`
	// Executor's hash to filter executions.
	ExecutorHash         github_com_mesg_foundation_engine_hash.Hash `` /* 156-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

Filter contains filtering criteria.

func (*ExecutionStreamRequest_Filter) Descriptor 

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

func (*ExecutionStreamRequest_Filter) GetExecutorHash 

func (m *ExecutionStreamRequest_Filter) GetExecutorHash() github_com_mesg_foundation_engine_hash.Hash

func (*ExecutionStreamRequest_Filter) GetInstanceHash 

func (m *ExecutionStreamRequest_Filter) GetInstanceHash() github_com_mesg_foundation_engine_hash.Hash

func (*ExecutionStreamRequest_Filter) GetStatuses 

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

func (*ExecutionStreamRequest_Filter) GetTags 

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

func (*ExecutionStreamRequest_Filter) GetTaskKey 

func (m *ExecutionStreamRequest_Filter) GetTaskKey() string

func (*ExecutionStreamRequest_Filter) Match 

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

Match matches given execution with filter criteria.

func (*ExecutionStreamRequest_Filter) ProtoMessage 

func (*ExecutionStreamRequest_Filter) ProtoMessage()

func (*ExecutionStreamRequest_Filter) Reset 

func (m *ExecutionStreamRequest_Filter) Reset()

func (*ExecutionStreamRequest_Filter) String 

func (m *ExecutionStreamRequest_Filter) String() string

func (*ExecutionStreamRequest_Filter) XXX_DiscardUnknown 

func (m *ExecutionStreamRequest_Filter) XXX_DiscardUnknown()

func (*ExecutionStreamRequest_Filter) XXX_Marshal 

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

func (*ExecutionStreamRequest_Filter) XXX_Merge 

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

func (*ExecutionStreamRequest_Filter) XXX_Size 

func (m *ExecutionStreamRequest_Filter) XXX_Size() int

func (*ExecutionStreamRequest_Filter) XXX_Unmarshal 

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

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 RunnerClient 

type RunnerClient interface {
	// Register registers a new runner to the Engine.
	// This endpoint should only be called when the runner is ready to receive execution and emit events.
	// This endpoint returns a credential token that must be use to reach the Runner APIs.
	Register(ctx context.Context, in *RunnerRegisterRequest, opts ...grpc.CallOption) (*RunnerRegisterResponse, error)
	// Delete a runner from the blockchain.
	Delete(ctx context.Context, in *RunnerDeleteRequest, opts ...grpc.CallOption) (*RunnerDeleteResponse, 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 

func NewRunnerClient(cc *grpc.ClientConn) RunnerClient

type RunnerDeleteRequest 

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

RunnerDeleteRequest is the request of the endpoint DeleteRunner.

func (*RunnerDeleteRequest) Descriptor 

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

func (*RunnerDeleteRequest) GetRunnerHash 

func (m *RunnerDeleteRequest) GetRunnerHash() github_com_mesg_foundation_engine_hash.Hash

func (*RunnerDeleteRequest) ProtoMessage 

func (*RunnerDeleteRequest) ProtoMessage()

func (*RunnerDeleteRequest) Reset 

func (m *RunnerDeleteRequest) Reset()

func (*RunnerDeleteRequest) String 

func (m *RunnerDeleteRequest) String() string

func (*RunnerDeleteRequest) XXX_DiscardUnknown 

func (m *RunnerDeleteRequest) XXX_DiscardUnknown()

func (*RunnerDeleteRequest) XXX_Marshal 

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

func (*RunnerDeleteRequest) XXX_Merge 

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

func (*RunnerDeleteRequest) XXX_Size 

func (m *RunnerDeleteRequest) XXX_Size() int

func (*RunnerDeleteRequest) XXX_Unmarshal 

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

type RunnerDeleteResponse 

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

RunnerDeleteResponse is the response of the endpoint DeleteRunner.

func (*RunnerDeleteResponse) Descriptor 

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

func (*RunnerDeleteResponse) ProtoMessage 

func (*RunnerDeleteResponse) ProtoMessage()

func (*RunnerDeleteResponse) Reset 

func (m *RunnerDeleteResponse) Reset()

func (*RunnerDeleteResponse) String 

func (m *RunnerDeleteResponse) String() string

func (*RunnerDeleteResponse) XXX_DiscardUnknown 

func (m *RunnerDeleteResponse) XXX_DiscardUnknown()

func (*RunnerDeleteResponse) XXX_Marshal 

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

func (*RunnerDeleteResponse) XXX_Merge 

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

func (*RunnerDeleteResponse) XXX_Size 

func (m *RunnerDeleteResponse) XXX_Size() int

func (*RunnerDeleteResponse) XXX_Unmarshal 

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

type RunnerRegisterRequest 

type RunnerRegisterRequest struct {
	// Service's hash to start the runner with.
	ServiceHash github_com_mesg_foundation_engine_hash.Hash `` /* 153-byte string literal not displayed */
	// Hash of the customized environmental variables (not the ones in the service configuration).
	EnvHash              github_com_mesg_foundation_engine_hash.Hash `` /* 146-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

RunnerRegisterRequest is the request of the endpoint Register.

func (*RunnerRegisterRequest) Descriptor 

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

func (*RunnerRegisterRequest) GetEnvHash 

func (m *RunnerRegisterRequest) GetEnvHash() github_com_mesg_foundation_engine_hash.Hash

func (*RunnerRegisterRequest) GetServiceHash 

func (m *RunnerRegisterRequest) GetServiceHash() github_com_mesg_foundation_engine_hash.Hash

func (*RunnerRegisterRequest) ProtoMessage 

func (*RunnerRegisterRequest) ProtoMessage()

func (*RunnerRegisterRequest) Reset 

func (m *RunnerRegisterRequest) Reset()

func (*RunnerRegisterRequest) String 

func (m *RunnerRegisterRequest) String() string

func (*RunnerRegisterRequest) XXX_DiscardUnknown 

func (m *RunnerRegisterRequest) XXX_DiscardUnknown()

func (*RunnerRegisterRequest) XXX_Marshal 

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

func (*RunnerRegisterRequest) XXX_Merge 

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

func (*RunnerRegisterRequest) XXX_Size 

func (m *RunnerRegisterRequest) XXX_Size() int

func (*RunnerRegisterRequest) XXX_Unmarshal 

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

type RunnerRegisterResponse 

type RunnerRegisterResponse struct {
	// token to use with the other endpoints of this API.
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RunnerRegisterResponse is the response of the endpoint Register.

func (*RunnerRegisterResponse) Descriptor 

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

func (*RunnerRegisterResponse) GetToken 

func (m *RunnerRegisterResponse) GetToken() string

func (*RunnerRegisterResponse) ProtoMessage 

func (*RunnerRegisterResponse) ProtoMessage()

func (*RunnerRegisterResponse) Reset 

func (m *RunnerRegisterResponse) Reset()

func (*RunnerRegisterResponse) String 

func (m *RunnerRegisterResponse) String() string

func (*RunnerRegisterResponse) XXX_DiscardUnknown 

func (m *RunnerRegisterResponse) XXX_DiscardUnknown()

func (*RunnerRegisterResponse) XXX_Marshal 

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

func (*RunnerRegisterResponse) XXX_Merge 

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

func (*RunnerRegisterResponse) XXX_Size 

func (m *RunnerRegisterResponse) XXX_Size() int

func (*RunnerRegisterResponse) XXX_Unmarshal 

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

type RunnerServer 

type RunnerServer interface {
	// Register registers a new runner to the Engine.
	// This endpoint should only be called when the runner is ready to receive execution and emit events.
	// This endpoint returns a credential token that must be use to reach the Runner APIs.
	Register(context.Context, *RunnerRegisterRequest) (*RunnerRegisterResponse, error)
	// Delete a runner from the blockchain.
	Delete(context.Context, *RunnerDeleteRequest) (*RunnerDeleteResponse, error)
}

RunnerServer is the server API for Runner service.

func NewRunnerServer 

func NewRunnerServer(rpc *cosmos.RPC, tokenToRunnerHash *sync.Map, auth *Authorizer) RunnerServer

NewRunnerServer creates a new Runner Server.

type UnimplementedEventServer 

type UnimplementedEventServer struct {
}

UnimplementedEventServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventServer) Stream 

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

type UnimplementedExecutionServer 

type UnimplementedExecutionServer struct {
}

UnimplementedExecutionServer can be embedded to have forward compatible implementations.

func (*UnimplementedExecutionServer) Create 

func (*UnimplementedExecutionServer) Create(ctx context.Context, req *ExecutionCreateRequest) (*ExecutionCreateResponse, error)

func (*UnimplementedExecutionServer) Stream 

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

type UnimplementedRunnerServer 

type UnimplementedRunnerServer struct {
}

UnimplementedRunnerServer can be embedded to have forward compatible implementations.

func (*UnimplementedRunnerServer) Delete 

func (*UnimplementedRunnerServer) Delete(ctx context.Context, req *RunnerDeleteRequest) (*RunnerDeleteResponse, error)

func (*UnimplementedRunnerServer) Register 

func (*UnimplementedRunnerServer) Register(ctx context.Context, req *RunnerRegisterRequest) (*RunnerRegisterResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.