runner

package
v0.3.656 Latest Latest
Warning

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

 Go to latest Published: Jan 24, 2019 License: Apache-2.0 Imports: 6 Imported by: 1

Documentation

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,proto3" json:"success,omitempty"`
	Details              string   `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	ErrorCode            int32    `protobuf:"varint,3,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	ErrorStr             string   `protobuf:"bytes,4,opt,name=errorStr,proto3" json:"errorStr,omitempty"`
	CreatedAt            string   `protobuf:"bytes,5,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	StartedAt            string   `protobuf:"bytes,6,opt,name=startedAt,proto3" json:"startedAt,omitempty"`
	CompletedAt          string   `protobuf:"bytes,7,opt,name=completedAt,proto3" json:"completedAt,omitempty"`
	SchedulerDuration    int64    `protobuf:"varint,8,opt,name=schedulerDuration,proto3" json:"schedulerDuration,omitempty"`
	ExecutionDuration    int64    `protobuf:"varint,9,opt,name=executionDuration,proto3" json:"executionDuration,omitempty"`
	ErrorUser            bool     `protobuf:"varint,10,opt,name=errorUser,proto3" json:"errorUser,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) GetErrorUser added in v0.3.649 

func (m *CallFinished) GetErrorUser() bool

func (*CallFinished) GetExecutionDuration added in v0.3.646 

func (m *CallFinished) GetExecutionDuration() int64

func (*CallFinished) GetSchedulerDuration added in v0.3.646 

func (m *CallFinished) GetSchedulerDuration() int64

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

func (*CallFinished) XXX_DiscardUnknown added in v0.3.624 

func (m *CallFinished) XXX_DiscardUnknown()

func (*CallFinished) XXX_Marshal added in v0.3.624 

func (m *CallFinished) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CallFinished) XXX_Merge added in v0.3.624 

func (m *CallFinished) XXX_Merge(src proto.Message)

func (*CallFinished) XXX_Size added in v0.3.624 

func (m *CallFinished) XXX_Size() int

func (*CallFinished) XXX_Unmarshal added in v0.3.624 

func (m *CallFinished) XXX_Unmarshal(b []byte) error

type CallResultStart 

type CallResultStart struct {
	// Types that are valid to be assigned to Meta:
	//	*CallResultStart_Http
	Meta                 isCallResultStart_Meta `protobuf_oneof:"meta"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

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_DiscardUnknown added in v0.3.624 

func (m *CallResultStart) XXX_DiscardUnknown()

func (*CallResultStart) XXX_Marshal added in v0.3.624 

func (m *CallResultStart) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CallResultStart) XXX_Merge added in v0.3.624 

func (m *CallResultStart) XXX_Merge(src proto.Message)

func (*CallResultStart) XXX_OneofWrappers added in v0.3.644 

func (*CallResultStart) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CallResultStart) XXX_Size added in v0.3.624 

func (m *CallResultStart) XXX_Size() int

func (*CallResultStart) XXX_Unmarshal added in v0.3.624 

func (m *CallResultStart) XXX_Unmarshal(b []byte) error

type CallResultStart_Http 

type CallResultStart_Http struct {
	Http *HttpRespMeta `protobuf:"bytes,100,opt,name=http,proto3,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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

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_DiscardUnknown added in v0.3.624 

func (m *ClientMsg) XXX_DiscardUnknown()

func (*ClientMsg) XXX_Marshal added in v0.3.624 

func (m *ClientMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientMsg) XXX_Merge added in v0.3.624 

func (m *ClientMsg) XXX_Merge(src proto.Message)

func (*ClientMsg) XXX_OneofWrappers added in v0.3.644 

func (*ClientMsg) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ClientMsg) XXX_Size added in v0.3.624 

func (m *ClientMsg) XXX_Size() int

func (*ClientMsg) XXX_Unmarshal added in v0.3.624 

func (m *ClientMsg) XXX_Unmarshal(b []byte) error

type ClientMsg_Data 

type ClientMsg_Data struct {
	Data *DataFrame `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type ClientMsg_Try 

type ClientMsg_Try struct {
	Try *TryCall `protobuf:"bytes,1,opt,name=try,proto3,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,proto3" json:"eof,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*DataFrame) XXX_DiscardUnknown added in v0.3.624 

func (m *DataFrame) XXX_DiscardUnknown()

func (*DataFrame) XXX_Marshal added in v0.3.624 

func (m *DataFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataFrame) XXX_Merge added in v0.3.624 

func (m *DataFrame) XXX_Merge(src proto.Message)

func (*DataFrame) XXX_Size added in v0.3.624 

func (m *DataFrame) XXX_Size() int

func (*DataFrame) XXX_Unmarshal added in v0.3.624 

func (m *DataFrame) XXX_Unmarshal(b []byte) error

type HttpHeader 

type HttpHeader struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*HttpHeader) XXX_DiscardUnknown added in v0.3.624 

func (m *HttpHeader) XXX_DiscardUnknown()

func (*HttpHeader) XXX_Marshal added in v0.3.624 

func (m *HttpHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HttpHeader) XXX_Merge added in v0.3.624 

func (m *HttpHeader) XXX_Merge(src proto.Message)

func (*HttpHeader) XXX_Size added in v0.3.624 

func (m *HttpHeader) XXX_Size() int

func (*HttpHeader) XXX_Unmarshal added in v0.3.624 

func (m *HttpHeader) XXX_Unmarshal(b []byte) error

type HttpRespMeta 

type HttpRespMeta struct {
	StatusCode           int32         `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Headers              []*HttpHeader `protobuf:"bytes,2,rep,name=headers,proto3" json:"headers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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

func (*HttpRespMeta) XXX_DiscardUnknown added in v0.3.624 

func (m *HttpRespMeta) XXX_DiscardUnknown()

func (*HttpRespMeta) XXX_Marshal added in v0.3.624 

func (m *HttpRespMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HttpRespMeta) XXX_Merge added in v0.3.624 

func (m *HttpRespMeta) XXX_Merge(src proto.Message)

func (*HttpRespMeta) XXX_Size added in v0.3.624 

func (m *HttpRespMeta) XXX_Size() int

func (*HttpRespMeta) XXX_Unmarshal added in v0.3.624 

func (m *HttpRespMeta) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

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_DiscardUnknown added in v0.3.624 

func (m *RunnerMsg) XXX_DiscardUnknown()

func (*RunnerMsg) XXX_Marshal added in v0.3.624 

func (m *RunnerMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunnerMsg) XXX_Merge added in v0.3.624 

func (m *RunnerMsg) XXX_Merge(src proto.Message)

func (*RunnerMsg) XXX_OneofWrappers added in v0.3.644 

func (*RunnerMsg) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*RunnerMsg) XXX_Size added in v0.3.624 

func (m *RunnerMsg) XXX_Size() int

func (*RunnerMsg) XXX_Unmarshal added in v0.3.624 

func (m *RunnerMsg) XXX_Unmarshal(b []byte) error

type RunnerMsg_Data 

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

type RunnerMsg_Finished 

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

type RunnerMsg_ResultStart 

type RunnerMsg_ResultStart struct {
	ResultStart *CallResultStart `protobuf:"bytes,1,opt,name=result_start,json=resultStart,proto3,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 *empty.Empty, opts ...grpc.CallOption) (*RunnerStatus, error)
}

RunnerProtocolClient is the client API for RunnerProtocol service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

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, *empty.Empty) (*RunnerStatus, error)
}

RunnerProtocolServer is the server API for RunnerProtocol service.

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,proto3" json:"active,omitempty"`
	Failed               bool     `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"`
	Id                   string   `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	Details              string   `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`
	ErrorCode            int32    `protobuf:"varint,6,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	ErrorStr             string   `protobuf:"bytes,7,opt,name=errorStr,proto3" json:"errorStr,omitempty"`
	CreatedAt            string   `protobuf:"bytes,8,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	StartedAt            string   `protobuf:"bytes,9,opt,name=startedAt,proto3" json:"startedAt,omitempty"`
	CompletedAt          string   `protobuf:"bytes,10,opt,name=completedAt,proto3" json:"completedAt,omitempty"`
	Cached               bool     `protobuf:"varint,11,opt,name=cached,proto3" json:"cached,omitempty"`
	RequestsReceived     uint64   `protobuf:"varint,12,opt,name=requestsReceived,proto3" json:"requestsReceived,omitempty"`
	RequestsHandled      uint64   `protobuf:"varint,13,opt,name=requestsHandled,proto3" json:"requestsHandled,omitempty"`
	KdumpsOnDisk         uint64   `protobuf:"varint,14,opt,name=kdumpsOnDisk,proto3" json:"kdumpsOnDisk,omitempty"`
	SchedulerDuration    int64    `protobuf:"varint,15,opt,name=schedulerDuration,proto3" json:"schedulerDuration,omitempty"`
	ExecutionDuration    int64    `protobuf:"varint,16,opt,name=executionDuration,proto3" json:"executionDuration,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) GetExecutionDuration added in v0.3.646 

func (m *RunnerStatus) GetExecutionDuration() int64

func (*RunnerStatus) GetFailed 

func (m *RunnerStatus) GetFailed() bool

func (*RunnerStatus) GetId 

func (m *RunnerStatus) GetId() string

func (*RunnerStatus) GetKdumpsOnDisk added in v0.3.624 

func (m *RunnerStatus) GetKdumpsOnDisk() uint64

func (*RunnerStatus) GetRequestsHandled 

func (m *RunnerStatus) GetRequestsHandled() uint64

func (*RunnerStatus) GetRequestsReceived 

func (m *RunnerStatus) GetRequestsReceived() uint64

func (*RunnerStatus) GetSchedulerDuration added in v0.3.646 

func (m *RunnerStatus) GetSchedulerDuration() int64

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

func (*RunnerStatus) XXX_DiscardUnknown added in v0.3.624 

func (m *RunnerStatus) XXX_DiscardUnknown()

func (*RunnerStatus) XXX_Marshal added in v0.3.624 

func (m *RunnerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunnerStatus) XXX_Merge added in v0.3.624 

func (m *RunnerStatus) XXX_Merge(src proto.Message)

func (*RunnerStatus) XXX_Size added in v0.3.624 

func (m *RunnerStatus) XXX_Size() int

func (*RunnerStatus) XXX_Unmarshal added in v0.3.624 

func (m *RunnerStatus) XXX_Unmarshal(b []byte) error

type TryCall 

type TryCall struct {
	ModelsCallJson       string            `protobuf:"bytes,1,opt,name=models_call_json,json=modelsCallJson,proto3" json:"models_call_json,omitempty"`
	SlotHashId           string            `protobuf:"bytes,2,opt,name=slot_hash_id,json=slotHashId,proto3" json:"slot_hash_id,omitempty"`
	Extensions           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (*TryCall) XXX_DiscardUnknown added in v0.3.624 

func (m *TryCall) XXX_DiscardUnknown()

func (*TryCall) XXX_Marshal added in v0.3.624 

func (m *TryCall) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TryCall) XXX_Merge added in v0.3.624 

func (m *TryCall) XXX_Merge(src proto.Message)

func (*TryCall) XXX_Size added in v0.3.624 

func (m *TryCall) XXX_Size() int

func (*TryCall) XXX_Unmarshal added in v0.3.624 

func (m *TryCall) XXX_Unmarshal(b []byte) error

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.