Documentation
¶
Overview ¶
Package runner is a generated protocol buffer package.
It is generated from these files:
runner.proto
It has these top-level messages:
TryCall DataFrame HttpHeader HttpRespMeta CallResultStart CallFinished ClientMsg RunnerMsg RunnerStatus
Index ¶
- func RegisterRunnerProtocolServer(s *grpc.Server, srv RunnerProtocolServer)
- type CallFinished
- func (*CallFinished) Descriptor() ([]byte, []int)
- func (m *CallFinished) GetCompletedAt() string
- func (m *CallFinished) GetCreatedAt() string
- func (m *CallFinished) GetDetails() string
- func (m *CallFinished) GetErrorCode() int32
- func (m *CallFinished) GetErrorStr() string
- func (m *CallFinished) GetStartedAt() string
- func (m *CallFinished) GetSuccess() bool
- func (*CallFinished) ProtoMessage()
- func (m *CallFinished) Reset()
- func (m *CallFinished) String() string
- type CallResultStart
- func (*CallResultStart) Descriptor() ([]byte, []int)
- func (m *CallResultStart) GetHttp() *HttpRespMeta
- func (m *CallResultStart) GetMeta() isCallResultStart_Meta
- func (*CallResultStart) ProtoMessage()
- func (m *CallResultStart) Reset()
- func (m *CallResultStart) String() string
- func (*CallResultStart) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type CallResultStart_Http
- type ClientMsg
- func (*ClientMsg) Descriptor() ([]byte, []int)
- func (m *ClientMsg) GetBody() isClientMsg_Body
- func (m *ClientMsg) GetData() *DataFrame
- func (m *ClientMsg) GetTry() *TryCall
- func (*ClientMsg) ProtoMessage()
- func (m *ClientMsg) Reset()
- func (m *ClientMsg) String() string
- func (*ClientMsg) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type ClientMsg_Data
- type ClientMsg_Try
- type DataFrame
- type HttpHeader
- type HttpRespMeta
- type RunnerMsg
- func (*RunnerMsg) Descriptor() ([]byte, []int)
- func (m *RunnerMsg) GetBody() isRunnerMsg_Body
- func (m *RunnerMsg) GetData() *DataFrame
- func (m *RunnerMsg) GetFinished() *CallFinished
- func (m *RunnerMsg) GetResultStart() *CallResultStart
- func (*RunnerMsg) ProtoMessage()
- func (m *RunnerMsg) Reset()
- func (m *RunnerMsg) String() string
- func (*RunnerMsg) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type RunnerMsg_Data
- type RunnerMsg_Finished
- type RunnerMsg_ResultStart
- type RunnerProtocolClient
- type RunnerProtocolServer
- type RunnerProtocol_EngageClient
- type RunnerProtocol_EngageServer
- type RunnerStatus
- func (*RunnerStatus) Descriptor() ([]byte, []int)
- func (m *RunnerStatus) GetActive() int32
- func (m *RunnerStatus) GetCached() bool
- func (m *RunnerStatus) GetCompletedAt() string
- func (m *RunnerStatus) GetCreatedAt() string
- func (m *RunnerStatus) GetDetails() string
- func (m *RunnerStatus) GetErrorCode() int32
- func (m *RunnerStatus) GetErrorStr() string
- func (m *RunnerStatus) GetFailed() bool
- func (m *RunnerStatus) GetId() string
- func (m *RunnerStatus) GetRequestsHandled() uint64
- func (m *RunnerStatus) GetRequestsReceived() uint64
- func (m *RunnerStatus) GetStartedAt() string
- func (*RunnerStatus) ProtoMessage()
- func (m *RunnerStatus) Reset()
- func (m *RunnerStatus) String() string
- type TryCall
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterRunnerProtocolServer ¶
func RegisterRunnerProtocolServer(s *grpc.Server, srv RunnerProtocolServer)
Types ¶
type CallFinished ¶
type CallFinished struct { Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"` Details string `protobuf:"bytes,2,opt,name=details" json:"details,omitempty"` ErrorCode int32 `protobuf:"varint,3,opt,name=errorCode" json:"errorCode,omitempty"` ErrorStr string `protobuf:"bytes,4,opt,name=errorStr" json:"errorStr,omitempty"` CreatedAt string `protobuf:"bytes,5,opt,name=createdAt" json:"createdAt,omitempty"` StartedAt string `protobuf:"bytes,6,opt,name=startedAt" json:"startedAt,omitempty"` CompletedAt string `protobuf:"bytes,7,opt,name=completedAt" json:"completedAt,omitempty"` }
Call has really finished, it might have completed or crashed
func (*CallFinished) Descriptor ¶
func (*CallFinished) Descriptor() ([]byte, []int)
func (*CallFinished) GetCompletedAt ¶
func (m *CallFinished) GetCompletedAt() string
func (*CallFinished) GetCreatedAt ¶
func (m *CallFinished) GetCreatedAt() string
func (*CallFinished) GetDetails ¶
func (m *CallFinished) GetDetails() string
func (*CallFinished) GetErrorCode ¶
func (m *CallFinished) GetErrorCode() int32
func (*CallFinished) GetErrorStr ¶
func (m *CallFinished) GetErrorStr() string
func (*CallFinished) GetStartedAt ¶
func (m *CallFinished) GetStartedAt() string
func (*CallFinished) GetSuccess ¶
func (m *CallFinished) GetSuccess() bool
func (*CallFinished) ProtoMessage ¶
func (*CallFinished) ProtoMessage()
func (*CallFinished) Reset ¶
func (m *CallFinished) Reset()
func (*CallFinished) String ¶
func (m *CallFinished) String() string
type CallResultStart ¶
type CallResultStart struct { // Types that are valid to be assigned to Meta: // *CallResultStart_Http Meta isCallResultStart_Meta `protobuf_oneof:"meta"` }
Call has started to finish - data might not be here yet and it will be sent as DataFrames.
func (*CallResultStart) Descriptor ¶
func (*CallResultStart) Descriptor() ([]byte, []int)
func (*CallResultStart) GetHttp ¶
func (m *CallResultStart) GetHttp() *HttpRespMeta
func (*CallResultStart) GetMeta ¶
func (m *CallResultStart) GetMeta() isCallResultStart_Meta
func (*CallResultStart) ProtoMessage ¶
func (*CallResultStart) ProtoMessage()
func (*CallResultStart) Reset ¶
func (m *CallResultStart) Reset()
func (*CallResultStart) String ¶
func (m *CallResultStart) String() string
func (*CallResultStart) XXX_OneofFuncs ¶
func (*CallResultStart) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type CallResultStart_Http ¶
type CallResultStart_Http struct {
Http *HttpRespMeta `protobuf:"bytes,100,opt,name=http,oneof"`
}
type ClientMsg ¶
type ClientMsg struct { // Types that are valid to be assigned to Body: // *ClientMsg_Try // *ClientMsg_Data Body isClientMsg_Body `protobuf_oneof:"body"` }
func (*ClientMsg) Descriptor ¶
func (*ClientMsg) ProtoMessage ¶
func (*ClientMsg) ProtoMessage()
type ClientMsg_Data ¶
type ClientMsg_Data struct {
Data *DataFrame `protobuf:"bytes,2,opt,name=data,oneof"`
}
type ClientMsg_Try ¶
type ClientMsg_Try struct {
Try *TryCall `protobuf:"bytes,1,opt,name=try,oneof"`
}
type DataFrame ¶
type DataFrame struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` Eof bool `protobuf:"varint,2,opt,name=eof" json:"eof,omitempty"` }
Data sent C2S and S2C - as soon as the runner sees the first of these it will start running. If empty content, there must be one of these with eof. The runner will send these for the body of the response, AFTER it has sent a CallEnding message.
func (*DataFrame) Descriptor ¶
func (*DataFrame) ProtoMessage ¶
func (*DataFrame) ProtoMessage()
type HttpHeader ¶
type HttpHeader struct { Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` }
func (*HttpHeader) Descriptor ¶
func (*HttpHeader) Descriptor() ([]byte, []int)
func (*HttpHeader) GetKey ¶
func (m *HttpHeader) GetKey() string
func (*HttpHeader) GetValue ¶
func (m *HttpHeader) GetValue() string
func (*HttpHeader) ProtoMessage ¶
func (*HttpHeader) ProtoMessage()
func (*HttpHeader) Reset ¶
func (m *HttpHeader) Reset()
func (*HttpHeader) String ¶
func (m *HttpHeader) String() string
type HttpRespMeta ¶
type HttpRespMeta struct { StatusCode int32 `protobuf:"varint,1,opt,name=status_code,json=statusCode" json:"status_code,omitempty"` Headers []*HttpHeader `protobuf:"bytes,2,rep,name=headers" json:"headers,omitempty"` }
func (*HttpRespMeta) Descriptor ¶
func (*HttpRespMeta) Descriptor() ([]byte, []int)
func (*HttpRespMeta) GetHeaders ¶
func (m *HttpRespMeta) GetHeaders() []*HttpHeader
func (*HttpRespMeta) GetStatusCode ¶
func (m *HttpRespMeta) GetStatusCode() int32
func (*HttpRespMeta) ProtoMessage ¶
func (*HttpRespMeta) ProtoMessage()
func (*HttpRespMeta) Reset ¶
func (m *HttpRespMeta) Reset()
func (*HttpRespMeta) String ¶
func (m *HttpRespMeta) String() string
type RunnerMsg ¶
type RunnerMsg struct { // Types that are valid to be assigned to Body: // *RunnerMsg_ResultStart // *RunnerMsg_Data // *RunnerMsg_Finished Body isRunnerMsg_Body `protobuf_oneof:"body"` }
func (*RunnerMsg) Descriptor ¶
func (*RunnerMsg) GetFinished ¶
func (m *RunnerMsg) GetFinished() *CallFinished
func (*RunnerMsg) GetResultStart ¶
func (m *RunnerMsg) GetResultStart() *CallResultStart
func (*RunnerMsg) ProtoMessage ¶
func (*RunnerMsg) ProtoMessage()
type RunnerMsg_Data ¶
type RunnerMsg_Data struct {
Data *DataFrame `protobuf:"bytes,2,opt,name=data,oneof"`
}
type RunnerMsg_Finished ¶
type RunnerMsg_Finished struct {
Finished *CallFinished `protobuf:"bytes,3,opt,name=finished,oneof"`
}
type RunnerMsg_ResultStart ¶
type RunnerMsg_ResultStart struct {
ResultStart *CallResultStart `protobuf:"bytes,1,opt,name=result_start,json=resultStart,oneof"`
}
type RunnerProtocolClient ¶
type RunnerProtocolClient interface { Engage(ctx context.Context, opts ...grpc.CallOption) (RunnerProtocol_EngageClient, error) // Rather than rely on Prometheus for this, expose status that's specific to the runner lifecycle through this. Status(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*RunnerStatus, error) }
func NewRunnerProtocolClient ¶
func NewRunnerProtocolClient(cc *grpc.ClientConn) RunnerProtocolClient
type RunnerProtocolServer ¶
type RunnerProtocolServer interface { Engage(RunnerProtocol_EngageServer) error // Rather than rely on Prometheus for this, expose status that's specific to the runner lifecycle through this. Status(context.Context, *google_protobuf.Empty) (*RunnerStatus, error) }
type RunnerStatus ¶
type RunnerStatus struct { Active int32 `protobuf:"varint,2,opt,name=active" json:"active,omitempty"` Failed bool `protobuf:"varint,3,opt,name=failed" json:"failed,omitempty"` Id string `protobuf:"bytes,4,opt,name=id" json:"id,omitempty"` Details string `protobuf:"bytes,5,opt,name=details" json:"details,omitempty"` ErrorCode int32 `protobuf:"varint,6,opt,name=errorCode" json:"errorCode,omitempty"` ErrorStr string `protobuf:"bytes,7,opt,name=errorStr" json:"errorStr,omitempty"` CreatedAt string `protobuf:"bytes,8,opt,name=createdAt" json:"createdAt,omitempty"` StartedAt string `protobuf:"bytes,9,opt,name=startedAt" json:"startedAt,omitempty"` CompletedAt string `protobuf:"bytes,10,opt,name=completedAt" json:"completedAt,omitempty"` Cached bool `protobuf:"varint,11,opt,name=cached" json:"cached,omitempty"` RequestsReceived uint64 `protobuf:"varint,12,opt,name=requestsReceived" json:"requestsReceived,omitempty"` RequestsHandled uint64 `protobuf:"varint,13,opt,name=requestsHandled" json:"requestsHandled,omitempty"` }
func (*RunnerStatus) Descriptor ¶
func (*RunnerStatus) Descriptor() ([]byte, []int)
func (*RunnerStatus) GetActive ¶
func (m *RunnerStatus) GetActive() int32
func (*RunnerStatus) GetCached ¶
func (m *RunnerStatus) GetCached() bool
func (*RunnerStatus) GetCompletedAt ¶
func (m *RunnerStatus) GetCompletedAt() string
func (*RunnerStatus) GetCreatedAt ¶
func (m *RunnerStatus) GetCreatedAt() string
func (*RunnerStatus) GetDetails ¶
func (m *RunnerStatus) GetDetails() string
func (*RunnerStatus) GetErrorCode ¶
func (m *RunnerStatus) GetErrorCode() int32
func (*RunnerStatus) GetErrorStr ¶
func (m *RunnerStatus) GetErrorStr() string
func (*RunnerStatus) GetFailed ¶
func (m *RunnerStatus) GetFailed() bool
func (*RunnerStatus) GetId ¶
func (m *RunnerStatus) GetId() string
func (*RunnerStatus) GetRequestsHandled ¶
func (m *RunnerStatus) GetRequestsHandled() uint64
func (*RunnerStatus) GetRequestsReceived ¶
func (m *RunnerStatus) GetRequestsReceived() uint64
func (*RunnerStatus) GetStartedAt ¶
func (m *RunnerStatus) GetStartedAt() string
func (*RunnerStatus) ProtoMessage ¶
func (*RunnerStatus) ProtoMessage()
func (*RunnerStatus) Reset ¶
func (m *RunnerStatus) Reset()
func (*RunnerStatus) String ¶
func (m *RunnerStatus) String() string
type TryCall ¶
type TryCall struct { ModelsCallJson string `protobuf:"bytes,1,opt,name=models_call_json,json=modelsCallJson" json:"models_call_json,omitempty"` SlotHashId string `protobuf:"bytes,2,opt,name=slot_hash_id,json=slotHashId" json:"slot_hash_id,omitempty"` Extensions map[string]string `` /* 140-byte string literal not displayed */ }
Request to allocate a slot for a call
func (*TryCall) Descriptor ¶
func (*TryCall) GetExtensions ¶
func (*TryCall) GetModelsCallJson ¶
func (*TryCall) GetSlotHashId ¶
func (*TryCall) ProtoMessage ¶
func (*TryCall) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.