runner

package
v0.0.0-...-3735483 Latest Latest
Warning

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

 Go to latest Published: May 11, 2018 License: Apache-2.0 Imports: 6 Imported by: 0

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
CallAcknowledged
DataFrame
HttpHeader
HttpRespMeta
CallResultStart
CallFinished
ClientMsg
RunnerMsg
RunnerStatus

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterRunnerProtocolServer 

func RegisterRunnerProtocolServer(s *grpc.Server, srv RunnerProtocolServer)

Types

type CallAcknowledged 

type CallAcknowledged struct {
	Committed             bool   `protobuf:"varint,1,opt,name=committed" json:"committed,omitempty"`
	Details               string `protobuf:"bytes,2,opt,name=details" json:"details,omitempty"`
	SlotAllocationLatency string `protobuf:"bytes,3,opt,name=slot_allocation_latency,json=slotAllocationLatency" json:"slot_allocation_latency,omitempty"`
}

Call has been accepted and a slot allocated, or it's been rejected

func (*CallAcknowledged) Descriptor 

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

func (*CallAcknowledged) GetCommitted 

func (m *CallAcknowledged) GetCommitted() bool

func (*CallAcknowledged) GetDetails 

func (m *CallAcknowledged) GetDetails() string

func (*CallAcknowledged) GetSlotAllocationLatency 

func (m *CallAcknowledged) GetSlotAllocationLatency() string

func (*CallAcknowledged) ProtoMessage 

func (*CallAcknowledged) ProtoMessage()

func (*CallAcknowledged) Reset 

func (m *CallAcknowledged) Reset()

func (*CallAcknowledged) String 

func (m *CallAcknowledged) String() string

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"`
}

Call has really finished, it might have completed or crashed

func (*CallFinished) Descriptor 

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

func (*CallFinished) GetDetails 

func (m *CallFinished) GetDetails() 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) Descriptor() ([]byte, []int)

func (*ClientMsg) GetBody 

func (m *ClientMsg) GetBody() isClientMsg_Body

func (*ClientMsg) GetData 

func (m *ClientMsg) GetData() *DataFrame

func (*ClientMsg) GetTry 

func (m *ClientMsg) GetTry() *TryCall

func (*ClientMsg) ProtoMessage 

func (*ClientMsg) ProtoMessage()

func (*ClientMsg) Reset 

func (m *ClientMsg) Reset()

func (*ClientMsg) String 

func (m *ClientMsg) String() string

func (*ClientMsg) XXX_OneofFuncs 

func (*ClientMsg) 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 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) Descriptor() ([]byte, []int)

func (*DataFrame) GetData 

func (m *DataFrame) GetData() []byte

func (*DataFrame) GetEof 

func (m *DataFrame) GetEof() bool

func (*DataFrame) ProtoMessage 

func (*DataFrame) ProtoMessage()

func (*DataFrame) Reset 

func (m *DataFrame) Reset()

func (*DataFrame) String 

func (m *DataFrame) String() string

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_Acknowledged
	//	*RunnerMsg_ResultStart
	//	*RunnerMsg_Data
	//	*RunnerMsg_Finished
	Body isRunnerMsg_Body `protobuf_oneof:"body"`
}

func (*RunnerMsg) Descriptor 

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

func (*RunnerMsg) GetAcknowledged 

func (m *RunnerMsg) GetAcknowledged() *CallAcknowledged

func (*RunnerMsg) GetBody 

func (m *RunnerMsg) GetBody() isRunnerMsg_Body

func (*RunnerMsg) GetData 

func (m *RunnerMsg) GetData() *DataFrame

func (*RunnerMsg) GetFinished 

func (m *RunnerMsg) GetFinished() *CallFinished

func (*RunnerMsg) GetResultStart 

func (m *RunnerMsg) GetResultStart() *CallResultStart

func (*RunnerMsg) ProtoMessage 

func (*RunnerMsg) ProtoMessage()

func (*RunnerMsg) Reset 

func (m *RunnerMsg) Reset()

func (*RunnerMsg) String 

func (m *RunnerMsg) String() string

func (*RunnerMsg) XXX_OneofFuncs 

func (*RunnerMsg) 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 RunnerMsg_Acknowledged 

type RunnerMsg_Acknowledged struct {
	Acknowledged *CallAcknowledged `protobuf:"bytes,1,opt,name=acknowledged,oneof"`
}

type RunnerMsg_Data 

type RunnerMsg_Data struct {
	Data *DataFrame `protobuf:"bytes,3,opt,name=data,oneof"`
}

type RunnerMsg_Finished 

type RunnerMsg_Finished struct {
	Finished *CallFinished `protobuf:"bytes,4,opt,name=finished,oneof"`
}

type RunnerMsg_ResultStart 

type RunnerMsg_ResultStart struct {
	ResultStart *CallResultStart `protobuf:"bytes,2,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 RunnerProtocol_EngageClient 

type RunnerProtocol_EngageClient interface {
	Send(*ClientMsg) error
	Recv() (*RunnerMsg, error)
	grpc.ClientStream
}

type RunnerProtocol_EngageServer 

type RunnerProtocol_EngageServer interface {
	Send(*RunnerMsg) error
	Recv() (*ClientMsg, error)
	grpc.ServerStream
}

type RunnerStatus 

type RunnerStatus struct {
	Active int32 `protobuf:"varint,2,opt,name=active" json:"active,omitempty"`
}

func (*RunnerStatus) Descriptor 

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

func (*RunnerStatus) GetActive 

func (m *RunnerStatus) GetActive() int32

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"`
}

Request to allocate a slot for a call

func (*TryCall) Descriptor 

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

func (*TryCall) GetModelsCallJson 

func (m *TryCall) GetModelsCallJson() string

func (*TryCall) ProtoMessage 

func (*TryCall) ProtoMessage()

func (*TryCall) Reset 

func (m *TryCall) Reset()

func (*TryCall) String 

func (m *TryCall) String() string

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.