Documentation ¶
Overview ¶
Package antha_runner_v1 is a generated protocol buffer package.
It is generated from these files:
github.com/antha-lang/antha/driver/antha_runner_v1/runner.proto
It has these top-level messages:
RunRequest RunRefRequest RunReply MessagesRequest MessagesReply SupportedRunTypesRequest SupportedRunTypesReply
Index ¶
- func RegisterRunnerServer(s *grpc.Server, srv RunnerServer)
- type MessagesReply
- type MessagesReply_Message
- func (*MessagesReply_Message) Descriptor() ([]byte, []int)
- func (m *MessagesReply_Message) GetCode() string
- func (m *MessagesReply_Message) GetData() []byte
- func (m *MessagesReply_Message) GetSeq() int32
- func (*MessagesReply_Message) ProtoMessage()
- func (m *MessagesReply_Message) Reset()
- func (m *MessagesReply_Message) String() string
- type MessagesRequest
- type RunRefRequest
- func (*RunRefRequest) Descriptor() ([]byte, []int)
- func (m *RunRefRequest) GetData() *antha_driver_v1.HttpCall
- func (m *RunRefRequest) GetDone() *antha_driver_v1.HttpCall
- func (m *RunRefRequest) GetType() string
- func (*RunRefRequest) ProtoMessage()
- func (m *RunRefRequest) Reset()
- func (m *RunRefRequest) String() string
- type RunReply
- type RunRequest
- type RunnerClient
- type RunnerServer
- type SupportedRunTypesReply
- type SupportedRunTypesRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterRunnerServer ¶
func RegisterRunnerServer(s *grpc.Server, srv RunnerServer)
Types ¶
type MessagesReply ¶
type MessagesReply struct {
Values []*MessagesReply_Message `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
}
func (*MessagesReply) Descriptor ¶
func (*MessagesReply) Descriptor() ([]byte, []int)
func (*MessagesReply) GetValues ¶
func (m *MessagesReply) GetValues() []*MessagesReply_Message
func (*MessagesReply) ProtoMessage ¶
func (*MessagesReply) ProtoMessage()
func (*MessagesReply) Reset ¶
func (m *MessagesReply) Reset()
func (*MessagesReply) String ¶
func (m *MessagesReply) String() string
type MessagesReply_Message ¶
type MessagesReply_Message struct { Code string `protobuf:"bytes,1,opt,name=code" json:"code,omitempty"` Seq int32 `protobuf:"varint,2,opt,name=seq" json:"seq,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` }
func (*MessagesReply_Message) Descriptor ¶
func (*MessagesReply_Message) Descriptor() ([]byte, []int)
func (*MessagesReply_Message) GetCode ¶
func (m *MessagesReply_Message) GetCode() string
func (*MessagesReply_Message) GetData ¶
func (m *MessagesReply_Message) GetData() []byte
func (*MessagesReply_Message) GetSeq ¶
func (m *MessagesReply_Message) GetSeq() int32
func (*MessagesReply_Message) ProtoMessage ¶
func (*MessagesReply_Message) ProtoMessage()
func (*MessagesReply_Message) Reset ¶
func (m *MessagesReply_Message) Reset()
func (*MessagesReply_Message) String ¶
func (m *MessagesReply_Message) String() string
type MessagesRequest ¶
type MessagesRequest struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}
func (*MessagesRequest) Descriptor ¶
func (*MessagesRequest) Descriptor() ([]byte, []int)
func (*MessagesRequest) GetId ¶
func (m *MessagesRequest) GetId() string
func (*MessagesRequest) ProtoMessage ¶
func (*MessagesRequest) ProtoMessage()
func (*MessagesRequest) Reset ¶
func (m *MessagesRequest) Reset()
func (*MessagesRequest) String ¶
func (m *MessagesRequest) String() string
type RunRefRequest ¶
type RunRefRequest struct { Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"` Data *antha_driver_v1.HttpCall `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"` Done *antha_driver_v1.HttpCall `protobuf:"bytes,3,opt,name=done" json:"done,omitempty"` }
func (*RunRefRequest) Descriptor ¶
func (*RunRefRequest) Descriptor() ([]byte, []int)
func (*RunRefRequest) GetData ¶
func (m *RunRefRequest) GetData() *antha_driver_v1.HttpCall
func (*RunRefRequest) GetDone ¶
func (m *RunRefRequest) GetDone() *antha_driver_v1.HttpCall
func (*RunRefRequest) GetType ¶
func (m *RunRefRequest) GetType() string
func (*RunRefRequest) ProtoMessage ¶
func (*RunRefRequest) ProtoMessage()
func (*RunRefRequest) Reset ¶
func (m *RunRefRequest) Reset()
func (*RunRefRequest) String ¶
func (m *RunRefRequest) String() string
type RunReply ¶
type RunReply struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}
func (*RunReply) Descriptor ¶
func (*RunReply) ProtoMessage ¶
func (*RunReply) ProtoMessage()
type RunRequest ¶
type RunRequest struct { Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` Done *antha_driver_v1.HttpCall `protobuf:"bytes,3,opt,name=done" json:"done,omitempty"` }
func (*RunRequest) Descriptor ¶
func (*RunRequest) Descriptor() ([]byte, []int)
func (*RunRequest) GetData ¶
func (m *RunRequest) GetData() []byte
func (*RunRequest) GetDone ¶
func (m *RunRequest) GetDone() *antha_driver_v1.HttpCall
func (*RunRequest) GetType ¶
func (m *RunRequest) GetType() string
func (*RunRequest) ProtoMessage ¶
func (*RunRequest) ProtoMessage()
func (*RunRequest) Reset ¶
func (m *RunRequest) Reset()
func (*RunRequest) String ¶
func (m *RunRequest) String() string
type RunnerClient ¶
type RunnerClient interface { // Run a blob Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunReply, error) // Run a blob identified by reference RunRef(ctx context.Context, in *RunRefRequest, opts ...grpc.CallOption) (*RunReply, error) // Messages from run (call repeatedly to get more messages) Messages(ctx context.Context, in *MessagesRequest, opts ...grpc.CallOption) (*MessagesReply, error) // Types of files that can be run SupportedRunTypes(ctx context.Context, in *SupportedRunTypesRequest, opts ...grpc.CallOption) (*SupportedRunTypesReply, error) }
func NewRunnerClient ¶
func NewRunnerClient(cc *grpc.ClientConn) RunnerClient
type RunnerServer ¶
type RunnerServer interface { // Run a blob Run(context.Context, *RunRequest) (*RunReply, error) // Run a blob identified by reference RunRef(context.Context, *RunRefRequest) (*RunReply, error) // Messages from run (call repeatedly to get more messages) Messages(context.Context, *MessagesRequest) (*MessagesReply, error) // Types of files that can be run SupportedRunTypes(context.Context, *SupportedRunTypesRequest) (*SupportedRunTypesReply, error) }
type SupportedRunTypesReply ¶
type SupportedRunTypesReply struct {
Types []string `protobuf:"bytes,1,rep,name=types" json:"types,omitempty"`
}
func (*SupportedRunTypesReply) Descriptor ¶
func (*SupportedRunTypesReply) Descriptor() ([]byte, []int)
func (*SupportedRunTypesReply) GetTypes ¶
func (m *SupportedRunTypesReply) GetTypes() []string
func (*SupportedRunTypesReply) ProtoMessage ¶
func (*SupportedRunTypesReply) ProtoMessage()
func (*SupportedRunTypesReply) Reset ¶
func (m *SupportedRunTypesReply) Reset()
func (*SupportedRunTypesReply) String ¶
func (m *SupportedRunTypesReply) String() string
type SupportedRunTypesRequest ¶
type SupportedRunTypesRequest struct { }
func (*SupportedRunTypesRequest) Descriptor ¶
func (*SupportedRunTypesRequest) Descriptor() ([]byte, []int)
func (*SupportedRunTypesRequest) ProtoMessage ¶
func (*SupportedRunTypesRequest) ProtoMessage()
func (*SupportedRunTypesRequest) Reset ¶
func (m *SupportedRunTypesRequest) Reset()
func (*SupportedRunTypesRequest) String ¶
func (m *SupportedRunTypesRequest) String() string
Click to show internal directories.
Click to hide internal directories.