runner

package
v0.3.623 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2018 License: Apache-2.0 Imports: 6 Imported by: 1

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

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

func (*RunnerMsg) Descriptor 

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

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_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 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"`
	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) Descriptor() ([]byte, []int)

func (*TryCall) GetExtensions 

func (m *TryCall) GetExtensions() map[string]string

func (*TryCall) GetModelsCallJson 

func (m *TryCall) GetModelsCallJson() string

func (*TryCall) GetSlotHashId 

func (m *TryCall) GetSlotHashId() 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.