Documentation ¶
Index ¶
- func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)
- type CancelCommandRequest
- func (*CancelCommandRequest) Descriptor() ([]byte, []int)
- func (m *CancelCommandRequest) GetExecutionID() string
- func (*CancelCommandRequest) ProtoMessage()
- func (m *CancelCommandRequest) Reset()
- func (m *CancelCommandRequest) String() string
- func (m *CancelCommandRequest) XXX_DiscardUnknown()
- func (m *CancelCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CancelCommandRequest) XXX_Merge(src proto.Message)
- func (m *CancelCommandRequest) XXX_Size() int
- func (m *CancelCommandRequest) XXX_Unmarshal(b []byte) error
- type CancelCommandResponse
- func (*CancelCommandResponse) Descriptor() ([]byte, []int)
- func (*CancelCommandResponse) ProtoMessage()
- func (m *CancelCommandResponse) Reset()
- func (m *CancelCommandResponse) String() string
- func (m *CancelCommandResponse) XXX_DiscardUnknown()
- func (m *CancelCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CancelCommandResponse) XXX_Merge(src proto.Message)
- func (m *CancelCommandResponse) XXX_Size() int
- func (m *CancelCommandResponse) XXX_Unmarshal(b []byte) error
- type ExecutorClient
- type ExecutorServer
- type Executor_GetOutputStreamClient
- type Executor_GetOutputStreamServer
- type Executor_WaitClient
- type Executor_WaitServer
- type IsInstalledRequest
- func (*IsInstalledRequest) Descriptor() ([]byte, []int)
- func (*IsInstalledRequest) ProtoMessage()
- func (m *IsInstalledRequest) Reset()
- func (m *IsInstalledRequest) String() string
- func (m *IsInstalledRequest) XXX_DiscardUnknown()
- func (m *IsInstalledRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IsInstalledRequest) XXX_Merge(src proto.Message)
- func (m *IsInstalledRequest) XXX_Size() int
- func (m *IsInstalledRequest) XXX_Unmarshal(b []byte) error
- type IsInstalledResponse
- func (*IsInstalledResponse) Descriptor() ([]byte, []int)
- func (m *IsInstalledResponse) GetInstalled() bool
- func (*IsInstalledResponse) ProtoMessage()
- func (m *IsInstalledResponse) Reset()
- func (m *IsInstalledResponse) String() string
- func (m *IsInstalledResponse) XXX_DiscardUnknown()
- func (m *IsInstalledResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IsInstalledResponse) XXX_Merge(src proto.Message)
- func (m *IsInstalledResponse) XXX_Size() int
- func (m *IsInstalledResponse) XXX_Unmarshal(b []byte) error
- type OutputStreamRequest
- func (*OutputStreamRequest) Descriptor() ([]byte, []int)
- func (m *OutputStreamRequest) GetExecutionID() string
- func (m *OutputStreamRequest) GetFollow() bool
- func (m *OutputStreamRequest) GetHistory() bool
- func (*OutputStreamRequest) ProtoMessage()
- func (m *OutputStreamRequest) Reset()
- func (m *OutputStreamRequest) String() string
- func (m *OutputStreamRequest) XXX_DiscardUnknown()
- func (m *OutputStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OutputStreamRequest) XXX_Merge(src proto.Message)
- func (m *OutputStreamRequest) XXX_Size() int
- func (m *OutputStreamRequest) XXX_Unmarshal(b []byte) error
- type OutputStreamResponse
- func (*OutputStreamResponse) Descriptor() ([]byte, []int)
- func (m *OutputStreamResponse) GetData() []byte
- func (*OutputStreamResponse) ProtoMessage()
- func (m *OutputStreamResponse) Reset()
- func (m *OutputStreamResponse) String() string
- func (m *OutputStreamResponse) XXX_DiscardUnknown()
- func (m *OutputStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OutputStreamResponse) XXX_Merge(src proto.Message)
- func (m *OutputStreamResponse) XXX_Size() int
- func (m *OutputStreamResponse) XXX_Unmarshal(b []byte) error
- type RunCommandRequest
- func (*RunCommandRequest) Descriptor() ([]byte, []int)
- func (m *RunCommandRequest) GetParams() []byte
- func (*RunCommandRequest) ProtoMessage()
- func (m *RunCommandRequest) Reset()
- func (m *RunCommandRequest) String() string
- func (m *RunCommandRequest) XXX_DiscardUnknown()
- func (m *RunCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunCommandRequest) XXX_Merge(src proto.Message)
- func (m *RunCommandRequest) XXX_Size() int
- func (m *RunCommandRequest) XXX_Unmarshal(b []byte) error
- type RunCommandResponse
- func (*RunCommandResponse) Descriptor() ([]byte, []int)
- func (m *RunCommandResponse) GetParams() []byte
- func (*RunCommandResponse) ProtoMessage()
- func (m *RunCommandResponse) Reset()
- func (m *RunCommandResponse) String() string
- func (m *RunCommandResponse) XXX_DiscardUnknown()
- func (m *RunCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunCommandResponse) XXX_Merge(src proto.Message)
- func (m *RunCommandResponse) XXX_Size() int
- func (m *RunCommandResponse) XXX_Unmarshal(b []byte) error
- type ShouldBidBasedOnUsageRequest
- func (*ShouldBidBasedOnUsageRequest) Descriptor() ([]byte, []int)
- func (m *ShouldBidBasedOnUsageRequest) GetBidRequest() []byte
- func (m *ShouldBidBasedOnUsageRequest) GetUsage() []byte
- func (*ShouldBidBasedOnUsageRequest) ProtoMessage()
- func (m *ShouldBidBasedOnUsageRequest) Reset()
- func (m *ShouldBidBasedOnUsageRequest) String() string
- func (m *ShouldBidBasedOnUsageRequest) XXX_DiscardUnknown()
- func (m *ShouldBidBasedOnUsageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShouldBidBasedOnUsageRequest) XXX_Merge(src proto.Message)
- func (m *ShouldBidBasedOnUsageRequest) XXX_Size() int
- func (m *ShouldBidBasedOnUsageRequest) XXX_Unmarshal(b []byte) error
- type ShouldBidRequest
- func (*ShouldBidRequest) Descriptor() ([]byte, []int)
- func (m *ShouldBidRequest) GetBidRequest() []byte
- func (*ShouldBidRequest) ProtoMessage()
- func (m *ShouldBidRequest) Reset()
- func (m *ShouldBidRequest) String() string
- func (m *ShouldBidRequest) XXX_DiscardUnknown()
- func (m *ShouldBidRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShouldBidRequest) XXX_Merge(src proto.Message)
- func (m *ShouldBidRequest) XXX_Size() int
- func (m *ShouldBidRequest) XXX_Unmarshal(b []byte) error
- type ShouldBidResponse
- func (*ShouldBidResponse) Descriptor() ([]byte, []int)
- func (m *ShouldBidResponse) GetBidResponse() []byte
- func (*ShouldBidResponse) ProtoMessage()
- func (m *ShouldBidResponse) Reset()
- func (m *ShouldBidResponse) String() string
- func (m *ShouldBidResponse) XXX_DiscardUnknown()
- func (m *ShouldBidResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShouldBidResponse) XXX_Merge(src proto.Message)
- func (m *ShouldBidResponse) XXX_Size() int
- func (m *ShouldBidResponse) XXX_Unmarshal(b []byte) error
- type StartResponse
- func (*StartResponse) Descriptor() ([]byte, []int)
- func (*StartResponse) ProtoMessage()
- func (m *StartResponse) Reset()
- func (m *StartResponse) String() string
- func (m *StartResponse) XXX_DiscardUnknown()
- func (m *StartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartResponse) XXX_Merge(src proto.Message)
- func (m *StartResponse) XXX_Size() int
- func (m *StartResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedExecutorServer
- func (*UnimplementedExecutorServer) Cancel(ctx context.Context, req *CancelCommandRequest) (*CancelCommandResponse, error)
- func (*UnimplementedExecutorServer) GetOutputStream(req *OutputStreamRequest, srv Executor_GetOutputStreamServer) error
- func (*UnimplementedExecutorServer) IsInstalled(ctx context.Context, req *IsInstalledRequest) (*IsInstalledResponse, error)
- func (*UnimplementedExecutorServer) Run(ctx context.Context, req *RunCommandRequest) (*RunCommandResponse, error)
- func (*UnimplementedExecutorServer) ShouldBid(ctx context.Context, req *ShouldBidRequest) (*ShouldBidResponse, error)
- func (*UnimplementedExecutorServer) ShouldBidBasedOnUsage(ctx context.Context, req *ShouldBidBasedOnUsageRequest) (*ShouldBidResponse, error)
- func (*UnimplementedExecutorServer) Start(ctx context.Context, req *RunCommandRequest) (*StartResponse, error)
- func (*UnimplementedExecutorServer) Wait(req *WaitRequest, srv Executor_WaitServer) error
- type WaitRequest
- func (*WaitRequest) Descriptor() ([]byte, []int)
- func (m *WaitRequest) GetExecutionID() string
- func (*WaitRequest) ProtoMessage()
- func (m *WaitRequest) Reset()
- func (m *WaitRequest) String() string
- func (m *WaitRequest) XXX_DiscardUnknown()
- func (m *WaitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WaitRequest) XXX_Merge(src proto.Message)
- func (m *WaitRequest) XXX_Size() int
- func (m *WaitRequest) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterExecutorServer ¶
func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)
Types ¶
type CancelCommandRequest ¶
type CancelCommandRequest struct { ExecutionID string `protobuf:"bytes,1,opt,name=ExecutionID,proto3" json:"ExecutionID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CancelCommandRequest) Descriptor ¶
func (*CancelCommandRequest) Descriptor() ([]byte, []int)
func (*CancelCommandRequest) GetExecutionID ¶
func (m *CancelCommandRequest) GetExecutionID() string
func (*CancelCommandRequest) ProtoMessage ¶
func (*CancelCommandRequest) ProtoMessage()
func (*CancelCommandRequest) Reset ¶
func (m *CancelCommandRequest) Reset()
func (*CancelCommandRequest) String ¶
func (m *CancelCommandRequest) String() string
func (*CancelCommandRequest) XXX_DiscardUnknown ¶
func (m *CancelCommandRequest) XXX_DiscardUnknown()
func (*CancelCommandRequest) XXX_Marshal ¶
func (m *CancelCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CancelCommandRequest) XXX_Merge ¶
func (m *CancelCommandRequest) XXX_Merge(src proto.Message)
func (*CancelCommandRequest) XXX_Size ¶
func (m *CancelCommandRequest) XXX_Size() int
func (*CancelCommandRequest) XXX_Unmarshal ¶
func (m *CancelCommandRequest) XXX_Unmarshal(b []byte) error
type CancelCommandResponse ¶
type CancelCommandResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CancelCommandResponse) Descriptor ¶
func (*CancelCommandResponse) Descriptor() ([]byte, []int)
func (*CancelCommandResponse) ProtoMessage ¶
func (*CancelCommandResponse) ProtoMessage()
func (*CancelCommandResponse) Reset ¶
func (m *CancelCommandResponse) Reset()
func (*CancelCommandResponse) String ¶
func (m *CancelCommandResponse) String() string
func (*CancelCommandResponse) XXX_DiscardUnknown ¶
func (m *CancelCommandResponse) XXX_DiscardUnknown()
func (*CancelCommandResponse) XXX_Marshal ¶
func (m *CancelCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CancelCommandResponse) XXX_Merge ¶
func (m *CancelCommandResponse) XXX_Merge(src proto.Message)
func (*CancelCommandResponse) XXX_Size ¶
func (m *CancelCommandResponse) XXX_Size() int
func (*CancelCommandResponse) XXX_Unmarshal ¶
func (m *CancelCommandResponse) XXX_Unmarshal(b []byte) error
type ExecutorClient ¶
type ExecutorClient interface { Run(ctx context.Context, in *RunCommandRequest, opts ...grpc.CallOption) (*RunCommandResponse, error) Start(ctx context.Context, in *RunCommandRequest, opts ...grpc.CallOption) (*StartResponse, error) Wait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (Executor_WaitClient, error) Cancel(ctx context.Context, in *CancelCommandRequest, opts ...grpc.CallOption) (*CancelCommandResponse, error) IsInstalled(ctx context.Context, in *IsInstalledRequest, opts ...grpc.CallOption) (*IsInstalledResponse, error) ShouldBid(ctx context.Context, in *ShouldBidRequest, opts ...grpc.CallOption) (*ShouldBidResponse, error) ShouldBidBasedOnUsage(ctx context.Context, in *ShouldBidBasedOnUsageRequest, opts ...grpc.CallOption) (*ShouldBidResponse, error) GetOutputStream(ctx context.Context, in *OutputStreamRequest, opts ...grpc.CallOption) (Executor_GetOutputStreamClient, error) }
ExecutorClient is the client API for Executor service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewExecutorClient ¶
func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient
type ExecutorServer ¶
type ExecutorServer interface { Run(context.Context, *RunCommandRequest) (*RunCommandResponse, error) Start(context.Context, *RunCommandRequest) (*StartResponse, error) Wait(*WaitRequest, Executor_WaitServer) error Cancel(context.Context, *CancelCommandRequest) (*CancelCommandResponse, error) IsInstalled(context.Context, *IsInstalledRequest) (*IsInstalledResponse, error) ShouldBid(context.Context, *ShouldBidRequest) (*ShouldBidResponse, error) ShouldBidBasedOnUsage(context.Context, *ShouldBidBasedOnUsageRequest) (*ShouldBidResponse, error) GetOutputStream(*OutputStreamRequest, Executor_GetOutputStreamServer) error }
ExecutorServer is the server API for Executor service.
type Executor_GetOutputStreamClient ¶
type Executor_GetOutputStreamClient interface { Recv() (*OutputStreamResponse, error) grpc.ClientStream }
type Executor_GetOutputStreamServer ¶
type Executor_GetOutputStreamServer interface { Send(*OutputStreamResponse) error grpc.ServerStream }
type Executor_WaitClient ¶
type Executor_WaitClient interface { Recv() (*RunCommandResponse, error) grpc.ClientStream }
type Executor_WaitServer ¶
type Executor_WaitServer interface { Send(*RunCommandResponse) error grpc.ServerStream }
type IsInstalledRequest ¶
type IsInstalledRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IsInstalledRequest) Descriptor ¶
func (*IsInstalledRequest) Descriptor() ([]byte, []int)
func (*IsInstalledRequest) ProtoMessage ¶
func (*IsInstalledRequest) ProtoMessage()
func (*IsInstalledRequest) Reset ¶
func (m *IsInstalledRequest) Reset()
func (*IsInstalledRequest) String ¶
func (m *IsInstalledRequest) String() string
func (*IsInstalledRequest) XXX_DiscardUnknown ¶
func (m *IsInstalledRequest) XXX_DiscardUnknown()
func (*IsInstalledRequest) XXX_Marshal ¶
func (m *IsInstalledRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IsInstalledRequest) XXX_Merge ¶
func (m *IsInstalledRequest) XXX_Merge(src proto.Message)
func (*IsInstalledRequest) XXX_Size ¶
func (m *IsInstalledRequest) XXX_Size() int
func (*IsInstalledRequest) XXX_Unmarshal ¶
func (m *IsInstalledRequest) XXX_Unmarshal(b []byte) error
type IsInstalledResponse ¶
type IsInstalledResponse struct { Installed bool `protobuf:"varint,1,opt,name=Installed,proto3" json:"Installed,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IsInstalledResponse) Descriptor ¶
func (*IsInstalledResponse) Descriptor() ([]byte, []int)
func (*IsInstalledResponse) GetInstalled ¶
func (m *IsInstalledResponse) GetInstalled() bool
func (*IsInstalledResponse) ProtoMessage ¶
func (*IsInstalledResponse) ProtoMessage()
func (*IsInstalledResponse) Reset ¶
func (m *IsInstalledResponse) Reset()
func (*IsInstalledResponse) String ¶
func (m *IsInstalledResponse) String() string
func (*IsInstalledResponse) XXX_DiscardUnknown ¶
func (m *IsInstalledResponse) XXX_DiscardUnknown()
func (*IsInstalledResponse) XXX_Marshal ¶
func (m *IsInstalledResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IsInstalledResponse) XXX_Merge ¶
func (m *IsInstalledResponse) XXX_Merge(src proto.Message)
func (*IsInstalledResponse) XXX_Size ¶
func (m *IsInstalledResponse) XXX_Size() int
func (*IsInstalledResponse) XXX_Unmarshal ¶
func (m *IsInstalledResponse) XXX_Unmarshal(b []byte) error
type OutputStreamRequest ¶
type OutputStreamRequest struct { ExecutionID string `protobuf:"bytes,1,opt,name=ExecutionID,proto3" json:"ExecutionID,omitempty"` History bool `protobuf:"varint,2,opt,name=History,proto3" json:"History,omitempty"` Follow bool `protobuf:"varint,3,opt,name=Follow,proto3" json:"Follow,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OutputStreamRequest) Descriptor ¶
func (*OutputStreamRequest) Descriptor() ([]byte, []int)
func (*OutputStreamRequest) GetExecutionID ¶
func (m *OutputStreamRequest) GetExecutionID() string
func (*OutputStreamRequest) GetFollow ¶
func (m *OutputStreamRequest) GetFollow() bool
func (*OutputStreamRequest) GetHistory ¶
func (m *OutputStreamRequest) GetHistory() bool
func (*OutputStreamRequest) ProtoMessage ¶
func (*OutputStreamRequest) ProtoMessage()
func (*OutputStreamRequest) Reset ¶
func (m *OutputStreamRequest) Reset()
func (*OutputStreamRequest) String ¶
func (m *OutputStreamRequest) String() string
func (*OutputStreamRequest) XXX_DiscardUnknown ¶
func (m *OutputStreamRequest) XXX_DiscardUnknown()
func (*OutputStreamRequest) XXX_Marshal ¶
func (m *OutputStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OutputStreamRequest) XXX_Merge ¶
func (m *OutputStreamRequest) XXX_Merge(src proto.Message)
func (*OutputStreamRequest) XXX_Size ¶
func (m *OutputStreamRequest) XXX_Size() int
func (*OutputStreamRequest) XXX_Unmarshal ¶
func (m *OutputStreamRequest) XXX_Unmarshal(b []byte) error
type OutputStreamResponse ¶
type OutputStreamResponse struct { Data []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OutputStreamResponse) Descriptor ¶
func (*OutputStreamResponse) Descriptor() ([]byte, []int)
func (*OutputStreamResponse) GetData ¶
func (m *OutputStreamResponse) GetData() []byte
func (*OutputStreamResponse) ProtoMessage ¶
func (*OutputStreamResponse) ProtoMessage()
func (*OutputStreamResponse) Reset ¶
func (m *OutputStreamResponse) Reset()
func (*OutputStreamResponse) String ¶
func (m *OutputStreamResponse) String() string
func (*OutputStreamResponse) XXX_DiscardUnknown ¶
func (m *OutputStreamResponse) XXX_DiscardUnknown()
func (*OutputStreamResponse) XXX_Marshal ¶
func (m *OutputStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OutputStreamResponse) XXX_Merge ¶
func (m *OutputStreamResponse) XXX_Merge(src proto.Message)
func (*OutputStreamResponse) XXX_Size ¶
func (m *OutputStreamResponse) XXX_Size() int
func (*OutputStreamResponse) XXX_Unmarshal ¶
func (m *OutputStreamResponse) XXX_Unmarshal(b []byte) error
type RunCommandRequest ¶
type RunCommandRequest struct { Params []byte `protobuf:"bytes,1,opt,name=Params,proto3" json:"Params,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunCommandRequest) Descriptor ¶
func (*RunCommandRequest) Descriptor() ([]byte, []int)
func (*RunCommandRequest) GetParams ¶
func (m *RunCommandRequest) GetParams() []byte
func (*RunCommandRequest) ProtoMessage ¶
func (*RunCommandRequest) ProtoMessage()
func (*RunCommandRequest) Reset ¶
func (m *RunCommandRequest) Reset()
func (*RunCommandRequest) String ¶
func (m *RunCommandRequest) String() string
func (*RunCommandRequest) XXX_DiscardUnknown ¶
func (m *RunCommandRequest) XXX_DiscardUnknown()
func (*RunCommandRequest) XXX_Marshal ¶
func (m *RunCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunCommandRequest) XXX_Merge ¶
func (m *RunCommandRequest) XXX_Merge(src proto.Message)
func (*RunCommandRequest) XXX_Size ¶
func (m *RunCommandRequest) XXX_Size() int
func (*RunCommandRequest) XXX_Unmarshal ¶
func (m *RunCommandRequest) XXX_Unmarshal(b []byte) error
type RunCommandResponse ¶
type RunCommandResponse struct { Params []byte `protobuf:"bytes,1,opt,name=Params,proto3" json:"Params,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunCommandResponse) Descriptor ¶
func (*RunCommandResponse) Descriptor() ([]byte, []int)
func (*RunCommandResponse) GetParams ¶
func (m *RunCommandResponse) GetParams() []byte
func (*RunCommandResponse) ProtoMessage ¶
func (*RunCommandResponse) ProtoMessage()
func (*RunCommandResponse) Reset ¶
func (m *RunCommandResponse) Reset()
func (*RunCommandResponse) String ¶
func (m *RunCommandResponse) String() string
func (*RunCommandResponse) XXX_DiscardUnknown ¶
func (m *RunCommandResponse) XXX_DiscardUnknown()
func (*RunCommandResponse) XXX_Marshal ¶
func (m *RunCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunCommandResponse) XXX_Merge ¶
func (m *RunCommandResponse) XXX_Merge(src proto.Message)
func (*RunCommandResponse) XXX_Size ¶
func (m *RunCommandResponse) XXX_Size() int
func (*RunCommandResponse) XXX_Unmarshal ¶
func (m *RunCommandResponse) XXX_Unmarshal(b []byte) error
type ShouldBidBasedOnUsageRequest ¶
type ShouldBidBasedOnUsageRequest struct { BidRequest []byte `protobuf:"bytes,1,opt,name=BidRequest,proto3" json:"BidRequest,omitempty"` Usage []byte `protobuf:"bytes,2,opt,name=Usage,proto3" json:"Usage,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ShouldBidBasedOnUsageRequest) Descriptor ¶
func (*ShouldBidBasedOnUsageRequest) Descriptor() ([]byte, []int)
func (*ShouldBidBasedOnUsageRequest) GetBidRequest ¶
func (m *ShouldBidBasedOnUsageRequest) GetBidRequest() []byte
func (*ShouldBidBasedOnUsageRequest) GetUsage ¶
func (m *ShouldBidBasedOnUsageRequest) GetUsage() []byte
func (*ShouldBidBasedOnUsageRequest) ProtoMessage ¶
func (*ShouldBidBasedOnUsageRequest) ProtoMessage()
func (*ShouldBidBasedOnUsageRequest) Reset ¶
func (m *ShouldBidBasedOnUsageRequest) Reset()
func (*ShouldBidBasedOnUsageRequest) String ¶
func (m *ShouldBidBasedOnUsageRequest) String() string
func (*ShouldBidBasedOnUsageRequest) XXX_DiscardUnknown ¶
func (m *ShouldBidBasedOnUsageRequest) XXX_DiscardUnknown()
func (*ShouldBidBasedOnUsageRequest) XXX_Marshal ¶
func (m *ShouldBidBasedOnUsageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShouldBidBasedOnUsageRequest) XXX_Merge ¶
func (m *ShouldBidBasedOnUsageRequest) XXX_Merge(src proto.Message)
func (*ShouldBidBasedOnUsageRequest) XXX_Size ¶
func (m *ShouldBidBasedOnUsageRequest) XXX_Size() int
func (*ShouldBidBasedOnUsageRequest) XXX_Unmarshal ¶
func (m *ShouldBidBasedOnUsageRequest) XXX_Unmarshal(b []byte) error
type ShouldBidRequest ¶
type ShouldBidRequest struct { BidRequest []byte `protobuf:"bytes,1,opt,name=BidRequest,proto3" json:"BidRequest,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ShouldBidRequest) Descriptor ¶
func (*ShouldBidRequest) Descriptor() ([]byte, []int)
func (*ShouldBidRequest) GetBidRequest ¶
func (m *ShouldBidRequest) GetBidRequest() []byte
func (*ShouldBidRequest) ProtoMessage ¶
func (*ShouldBidRequest) ProtoMessage()
func (*ShouldBidRequest) Reset ¶
func (m *ShouldBidRequest) Reset()
func (*ShouldBidRequest) String ¶
func (m *ShouldBidRequest) String() string
func (*ShouldBidRequest) XXX_DiscardUnknown ¶
func (m *ShouldBidRequest) XXX_DiscardUnknown()
func (*ShouldBidRequest) XXX_Marshal ¶
func (m *ShouldBidRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShouldBidRequest) XXX_Merge ¶
func (m *ShouldBidRequest) XXX_Merge(src proto.Message)
func (*ShouldBidRequest) XXX_Size ¶
func (m *ShouldBidRequest) XXX_Size() int
func (*ShouldBidRequest) XXX_Unmarshal ¶
func (m *ShouldBidRequest) XXX_Unmarshal(b []byte) error
type ShouldBidResponse ¶
type ShouldBidResponse struct { BidResponse []byte `protobuf:"bytes,1,opt,name=BidResponse,proto3" json:"BidResponse,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
shared by both semantic and resource bid
func (*ShouldBidResponse) Descriptor ¶
func (*ShouldBidResponse) Descriptor() ([]byte, []int)
func (*ShouldBidResponse) GetBidResponse ¶
func (m *ShouldBidResponse) GetBidResponse() []byte
func (*ShouldBidResponse) ProtoMessage ¶
func (*ShouldBidResponse) ProtoMessage()
func (*ShouldBidResponse) Reset ¶
func (m *ShouldBidResponse) Reset()
func (*ShouldBidResponse) String ¶
func (m *ShouldBidResponse) String() string
func (*ShouldBidResponse) XXX_DiscardUnknown ¶
func (m *ShouldBidResponse) XXX_DiscardUnknown()
func (*ShouldBidResponse) XXX_Marshal ¶
func (m *ShouldBidResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShouldBidResponse) XXX_Merge ¶
func (m *ShouldBidResponse) XXX_Merge(src proto.Message)
func (*ShouldBidResponse) XXX_Size ¶
func (m *ShouldBidResponse) XXX_Size() int
func (*ShouldBidResponse) XXX_Unmarshal ¶
func (m *ShouldBidResponse) XXX_Unmarshal(b []byte) error
type StartResponse ¶
type StartResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StartResponse) Descriptor ¶
func (*StartResponse) Descriptor() ([]byte, []int)
func (*StartResponse) ProtoMessage ¶
func (*StartResponse) ProtoMessage()
func (*StartResponse) Reset ¶
func (m *StartResponse) Reset()
func (*StartResponse) String ¶
func (m *StartResponse) String() string
func (*StartResponse) XXX_DiscardUnknown ¶
func (m *StartResponse) XXX_DiscardUnknown()
func (*StartResponse) XXX_Marshal ¶
func (m *StartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartResponse) XXX_Merge ¶
func (m *StartResponse) XXX_Merge(src proto.Message)
func (*StartResponse) XXX_Size ¶
func (m *StartResponse) XXX_Size() int
func (*StartResponse) XXX_Unmarshal ¶
func (m *StartResponse) XXX_Unmarshal(b []byte) error
type UnimplementedExecutorServer ¶
type UnimplementedExecutorServer struct { }
UnimplementedExecutorServer can be embedded to have forward compatible implementations.
func (*UnimplementedExecutorServer) Cancel ¶
func (*UnimplementedExecutorServer) Cancel(ctx context.Context, req *CancelCommandRequest) (*CancelCommandResponse, error)
func (*UnimplementedExecutorServer) GetOutputStream ¶
func (*UnimplementedExecutorServer) GetOutputStream(req *OutputStreamRequest, srv Executor_GetOutputStreamServer) error
func (*UnimplementedExecutorServer) IsInstalled ¶
func (*UnimplementedExecutorServer) IsInstalled(ctx context.Context, req *IsInstalledRequest) (*IsInstalledResponse, error)
func (*UnimplementedExecutorServer) Run ¶
func (*UnimplementedExecutorServer) Run(ctx context.Context, req *RunCommandRequest) (*RunCommandResponse, error)
func (*UnimplementedExecutorServer) ShouldBid ¶
func (*UnimplementedExecutorServer) ShouldBid(ctx context.Context, req *ShouldBidRequest) (*ShouldBidResponse, error)
func (*UnimplementedExecutorServer) ShouldBidBasedOnUsage ¶
func (*UnimplementedExecutorServer) ShouldBidBasedOnUsage(ctx context.Context, req *ShouldBidBasedOnUsageRequest) (*ShouldBidResponse, error)
func (*UnimplementedExecutorServer) Start ¶
func (*UnimplementedExecutorServer) Start(ctx context.Context, req *RunCommandRequest) (*StartResponse, error)
func (*UnimplementedExecutorServer) Wait ¶
func (*UnimplementedExecutorServer) Wait(req *WaitRequest, srv Executor_WaitServer) error
type WaitRequest ¶
type WaitRequest struct { ExecutionID string `protobuf:"bytes,1,opt,name=ExecutionID,proto3" json:"ExecutionID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WaitRequest) Descriptor ¶
func (*WaitRequest) Descriptor() ([]byte, []int)
func (*WaitRequest) GetExecutionID ¶
func (m *WaitRequest) GetExecutionID() string
func (*WaitRequest) ProtoMessage ¶
func (*WaitRequest) ProtoMessage()
func (*WaitRequest) Reset ¶
func (m *WaitRequest) Reset()
func (*WaitRequest) String ¶
func (m *WaitRequest) String() string
func (*WaitRequest) XXX_DiscardUnknown ¶
func (m *WaitRequest) XXX_DiscardUnknown()
func (*WaitRequest) XXX_Marshal ¶
func (m *WaitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WaitRequest) XXX_Merge ¶
func (m *WaitRequest) XXX_Merge(src proto.Message)
func (*WaitRequest) XXX_Size ¶
func (m *WaitRequest) XXX_Size() int
func (*WaitRequest) XXX_Unmarshal ¶
func (m *WaitRequest) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.