Documentation ¶
Overview ¶
Package grpc_anemos_v1alpha1 is a generated protocol buffer package.
It is generated from these files:
grpc/anemos/v1alpha1/anemos.proto
It has these top-level messages:
TaskInstance Event TriggerRequest TriggerResponse ObserverCommandStreamRequest ObserverCommand ExecutorCommandStreamRequest ExecutorCommand
Index ¶
- func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)
- func RegisterObserverServer(s *grpc.Server, srv ObserverServer)
- type Event
- type ExecutorClient
- type ExecutorCommand
- type ExecutorCommandStreamRequest
- type ExecutorServer
- type Executor_CommandStreamClient
- type Executor_CommandStreamServer
- type ObserverClient
- type ObserverCommand
- type ObserverCommandStreamRequest
- type ObserverServer
- type Observer_CommandStreamClient
- type Observer_CommandStreamServer
- type TaskInstance
- func (*TaskInstance) Descriptor() ([]byte, []int)
- func (m *TaskInstance) GetAttributes() map[string]string
- func (m *TaskInstance) GetId() string
- func (m *TaskInstance) GetMetadata() map[string]string
- func (m *TaskInstance) GetName() string
- func (m *TaskInstance) GetOperation() string
- func (m *TaskInstance) GetProvider() string
- func (*TaskInstance) ProtoMessage()
- func (m *TaskInstance) Reset()
- func (m *TaskInstance) String() string
- type TriggerRequest
- type TriggerResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterExecutorServer ¶
func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)
func RegisterObserverServer ¶
func RegisterObserverServer(s *grpc.Server, srv ObserverServer)
Types ¶
type Event ¶
type Event struct { Uri string `protobuf:"bytes,1,opt,name=uri" json:"uri,omitempty"` Metadata map[string]string `` /* 136-byte string literal not displayed */ }
func (*Event) Descriptor ¶
func (*Event) GetMetadata ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
type ExecutorClient ¶
type ExecutorClient interface {
CommandStream(ctx context.Context, in *ExecutorCommandStreamRequest, opts ...grpc.CallOption) (Executor_CommandStreamClient, error)
}
func NewExecutorClient ¶
func NewExecutorClient(cc *grpc.ClientConn) ExecutorClient
type ExecutorCommand ¶
type ExecutorCommand struct {
Instance *TaskInstance `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
}
func (*ExecutorCommand) Descriptor ¶
func (*ExecutorCommand) Descriptor() ([]byte, []int)
func (*ExecutorCommand) GetInstance ¶
func (m *ExecutorCommand) GetInstance() *TaskInstance
func (*ExecutorCommand) ProtoMessage ¶
func (*ExecutorCommand) ProtoMessage()
func (*ExecutorCommand) Reset ¶
func (m *ExecutorCommand) Reset()
func (*ExecutorCommand) String ¶
func (m *ExecutorCommand) String() string
type ExecutorCommandStreamRequest ¶
type ExecutorCommandStreamRequest struct { }
func (*ExecutorCommandStreamRequest) Descriptor ¶
func (*ExecutorCommandStreamRequest) Descriptor() ([]byte, []int)
func (*ExecutorCommandStreamRequest) ProtoMessage ¶
func (*ExecutorCommandStreamRequest) ProtoMessage()
func (*ExecutorCommandStreamRequest) Reset ¶
func (m *ExecutorCommandStreamRequest) Reset()
func (*ExecutorCommandStreamRequest) String ¶
func (m *ExecutorCommandStreamRequest) String() string
type ExecutorServer ¶
type ExecutorServer interface {
CommandStream(*ExecutorCommandStreamRequest, Executor_CommandStreamServer) error
}
type Executor_CommandStreamClient ¶
type Executor_CommandStreamClient interface { Recv() (*ExecutorCommand, error) grpc.ClientStream }
type Executor_CommandStreamServer ¶
type Executor_CommandStreamServer interface { Send(*ExecutorCommand) error grpc.ServerStream }
type ObserverClient ¶
type ObserverClient interface { CommandStream(ctx context.Context, in *ObserverCommandStreamRequest, opts ...grpc.CallOption) (Observer_CommandStreamClient, error) Trigger(ctx context.Context, in *TriggerRequest, opts ...grpc.CallOption) (*TriggerResponse, error) }
func NewObserverClient ¶
func NewObserverClient(cc *grpc.ClientConn) ObserverClient
type ObserverCommand ¶
type ObserverCommand struct { }
func (*ObserverCommand) Descriptor ¶
func (*ObserverCommand) Descriptor() ([]byte, []int)
func (*ObserverCommand) ProtoMessage ¶
func (*ObserverCommand) ProtoMessage()
func (*ObserverCommand) Reset ¶
func (m *ObserverCommand) Reset()
func (*ObserverCommand) String ¶
func (m *ObserverCommand) String() string
type ObserverCommandStreamRequest ¶
type ObserverCommandStreamRequest struct { }
func (*ObserverCommandStreamRequest) Descriptor ¶
func (*ObserverCommandStreamRequest) Descriptor() ([]byte, []int)
func (*ObserverCommandStreamRequest) ProtoMessage ¶
func (*ObserverCommandStreamRequest) ProtoMessage()
func (*ObserverCommandStreamRequest) Reset ¶
func (m *ObserverCommandStreamRequest) Reset()
func (*ObserverCommandStreamRequest) String ¶
func (m *ObserverCommandStreamRequest) String() string
type ObserverServer ¶
type ObserverServer interface { CommandStream(*ObserverCommandStreamRequest, Observer_CommandStreamServer) error Trigger(context.Context, *TriggerRequest) (*TriggerResponse, error) }
type Observer_CommandStreamClient ¶
type Observer_CommandStreamClient interface { Recv() (*ObserverCommand, error) grpc.ClientStream }
type Observer_CommandStreamServer ¶
type Observer_CommandStreamServer interface { Send(*ObserverCommand) error grpc.ServerStream }
type TaskInstance ¶
type TaskInstance struct { Provider string `protobuf:"bytes,1,opt,name=provider" json:"provider,omitempty"` Operation string `protobuf:"bytes,2,opt,name=operation" json:"operation,omitempty"` Name string `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"` Id string `protobuf:"bytes,4,opt,name=id" json:"id,omitempty"` Attributes map[string]string `` /* 140-byte string literal not displayed */ Metadata map[string]string `` /* 136-byte string literal not displayed */ }
func (*TaskInstance) Descriptor ¶
func (*TaskInstance) Descriptor() ([]byte, []int)
func (*TaskInstance) GetAttributes ¶
func (m *TaskInstance) GetAttributes() map[string]string
func (*TaskInstance) GetId ¶
func (m *TaskInstance) GetId() string
func (*TaskInstance) GetMetadata ¶
func (m *TaskInstance) GetMetadata() map[string]string
func (*TaskInstance) GetName ¶
func (m *TaskInstance) GetName() string
func (*TaskInstance) GetOperation ¶
func (m *TaskInstance) GetOperation() string
func (*TaskInstance) GetProvider ¶
func (m *TaskInstance) GetProvider() string
func (*TaskInstance) ProtoMessage ¶
func (*TaskInstance) ProtoMessage()
func (*TaskInstance) Reset ¶
func (m *TaskInstance) Reset()
func (*TaskInstance) String ¶
func (m *TaskInstance) String() string
type TriggerRequest ¶
type TriggerRequest struct {
Event *Event `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
}
func (*TriggerRequest) Descriptor ¶
func (*TriggerRequest) Descriptor() ([]byte, []int)
func (*TriggerRequest) GetEvent ¶
func (m *TriggerRequest) GetEvent() *Event
func (*TriggerRequest) ProtoMessage ¶
func (*TriggerRequest) ProtoMessage()
func (*TriggerRequest) Reset ¶
func (m *TriggerRequest) Reset()
func (*TriggerRequest) String ¶
func (m *TriggerRequest) String() string
type TriggerResponse ¶
type TriggerResponse struct { }
func (*TriggerResponse) Descriptor ¶
func (*TriggerResponse) Descriptor() ([]byte, []int)
func (*TriggerResponse) ProtoMessage ¶
func (*TriggerResponse) ProtoMessage()
func (*TriggerResponse) Reset ¶
func (m *TriggerResponse) Reset()
func (*TriggerResponse) String ¶
func (m *TriggerResponse) String() string
Click to show internal directories.
Click to hide internal directories.