runner

package
v0.3.696 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source
var LogResponseMsg_Container_Request_Line_Source_name = map[int32]string{
	0: "STDOUT",
	1: "STDERR",
}
View Source
var LogResponseMsg_Container_Request_Line_Source_value = map[string]int32{
	"STDOUT": 0,
	"STDERR": 1,
}

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 ConfigMsg added in v0.3.671

type ConfigMsg struct {
	Config               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ConfigMsg) Descriptor added in v0.3.671

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

func (*ConfigMsg) GetConfig added in v0.3.671

func (m *ConfigMsg) GetConfig() map[string]string

func (*ConfigMsg) ProtoMessage added in v0.3.671

func (*ConfigMsg) ProtoMessage()

func (*ConfigMsg) Reset added in v0.3.671

func (m *ConfigMsg) Reset()

func (*ConfigMsg) String added in v0.3.671

func (m *ConfigMsg) String() string

func (*ConfigMsg) XXX_DiscardUnknown added in v0.3.671

func (m *ConfigMsg) XXX_DiscardUnknown()

func (*ConfigMsg) XXX_Marshal added in v0.3.671

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

func (*ConfigMsg) XXX_Merge added in v0.3.671

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

func (*ConfigMsg) XXX_Size added in v0.3.671

func (m *ConfigMsg) XXX_Size() int

func (*ConfigMsg) XXX_Unmarshal added in v0.3.671

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

type ConfigStatus added in v0.3.671

type ConfigStatus struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConfigStatus) Descriptor added in v0.3.671

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

func (*ConfigStatus) ProtoMessage added in v0.3.671

func (*ConfigStatus) ProtoMessage()

func (*ConfigStatus) Reset added in v0.3.671

func (m *ConfigStatus) Reset()

func (*ConfigStatus) String added in v0.3.671

func (m *ConfigStatus) String() string

func (*ConfigStatus) XXX_DiscardUnknown added in v0.3.671

func (m *ConfigStatus) XXX_DiscardUnknown()

func (*ConfigStatus) XXX_Marshal added in v0.3.671

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

func (*ConfigStatus) XXX_Merge added in v0.3.671

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

func (*ConfigStatus) XXX_Size added in v0.3.671

func (m *ConfigStatus) XXX_Size() int

func (*ConfigStatus) XXX_Unmarshal added in v0.3.671

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

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 LogRequestMsg added in v0.3.676

type LogRequestMsg struct {
	// Types that are valid to be assigned to Body:
	//	*LogRequestMsg_Start_
	//	*LogRequestMsg_Ack_
	//	*LogRequestMsg_Ready_
	Body                 isLogRequestMsg_Body `protobuf_oneof:"body"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Collector to Runner messages

func (*LogRequestMsg) Descriptor added in v0.3.676

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

func (*LogRequestMsg) GetAck added in v0.3.676

func (m *LogRequestMsg) GetAck() *LogRequestMsg_Ack

func (*LogRequestMsg) GetBody added in v0.3.676

func (m *LogRequestMsg) GetBody() isLogRequestMsg_Body

func (*LogRequestMsg) GetReady added in v0.3.684

func (m *LogRequestMsg) GetReady() *LogRequestMsg_Ready

func (*LogRequestMsg) GetStart added in v0.3.676

func (m *LogRequestMsg) GetStart() *LogRequestMsg_Start

func (*LogRequestMsg) ProtoMessage added in v0.3.676

func (*LogRequestMsg) ProtoMessage()

func (*LogRequestMsg) Reset added in v0.3.676

func (m *LogRequestMsg) Reset()

func (*LogRequestMsg) String added in v0.3.676

func (m *LogRequestMsg) String() string

func (*LogRequestMsg) XXX_DiscardUnknown added in v0.3.676

func (m *LogRequestMsg) XXX_DiscardUnknown()

func (*LogRequestMsg) XXX_Marshal added in v0.3.676

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

func (*LogRequestMsg) XXX_Merge added in v0.3.676

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

func (*LogRequestMsg) XXX_OneofWrappers added in v0.3.676

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*LogRequestMsg) XXX_Size added in v0.3.676

func (m *LogRequestMsg) XXX_Size() int

func (*LogRequestMsg) XXX_Unmarshal added in v0.3.676

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

type LogRequestMsg_Ack added in v0.3.676

type LogRequestMsg_Ack struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Acknowledgement of last data in stream: a message sent by Collectors to Runners

func (*LogRequestMsg_Ack) Descriptor added in v0.3.676

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

func (*LogRequestMsg_Ack) ProtoMessage added in v0.3.676

func (*LogRequestMsg_Ack) ProtoMessage()

func (*LogRequestMsg_Ack) Reset added in v0.3.676

func (m *LogRequestMsg_Ack) Reset()

func (*LogRequestMsg_Ack) String added in v0.3.676

func (m *LogRequestMsg_Ack) String() string

func (*LogRequestMsg_Ack) XXX_DiscardUnknown added in v0.3.676

func (m *LogRequestMsg_Ack) XXX_DiscardUnknown()

func (*LogRequestMsg_Ack) XXX_Marshal added in v0.3.676

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

func (*LogRequestMsg_Ack) XXX_Merge added in v0.3.676

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

func (*LogRequestMsg_Ack) XXX_Size added in v0.3.676

func (m *LogRequestMsg_Ack) XXX_Size() int

func (*LogRequestMsg_Ack) XXX_Unmarshal added in v0.3.676

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

type LogRequestMsg_Ack_ added in v0.3.676

type LogRequestMsg_Ack_ struct {
	Ack *LogRequestMsg_Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type LogRequestMsg_Ready added in v0.3.684

type LogRequestMsg_Ready struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Enable stream readiness for push: a message sent by Collectors to Runners

func (*LogRequestMsg_Ready) Descriptor added in v0.3.684

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

func (*LogRequestMsg_Ready) ProtoMessage added in v0.3.684

func (*LogRequestMsg_Ready) ProtoMessage()

func (*LogRequestMsg_Ready) Reset added in v0.3.684

func (m *LogRequestMsg_Ready) Reset()

func (*LogRequestMsg_Ready) String added in v0.3.684

func (m *LogRequestMsg_Ready) String() string

func (*LogRequestMsg_Ready) XXX_DiscardUnknown added in v0.3.684

func (m *LogRequestMsg_Ready) XXX_DiscardUnknown()

func (*LogRequestMsg_Ready) XXX_Marshal added in v0.3.684

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

func (*LogRequestMsg_Ready) XXX_Merge added in v0.3.684

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

func (*LogRequestMsg_Ready) XXX_Size added in v0.3.684

func (m *LogRequestMsg_Ready) XXX_Size() int

func (*LogRequestMsg_Ready) XXX_Unmarshal added in v0.3.684

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

type LogRequestMsg_Ready_ added in v0.3.684

type LogRequestMsg_Ready_ struct {
	Ready *LogRequestMsg_Ready `protobuf:"bytes,3,opt,name=ready,proto3,oneof"`
}

type LogRequestMsg_Start added in v0.3.676

type LogRequestMsg_Start struct {
	Config               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Initial Logging session message sent by Collectors to Runners

func (*LogRequestMsg_Start) Descriptor added in v0.3.676

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

func (*LogRequestMsg_Start) GetConfig added in v0.3.676

func (m *LogRequestMsg_Start) GetConfig() map[string]string

func (*LogRequestMsg_Start) ProtoMessage added in v0.3.676

func (*LogRequestMsg_Start) ProtoMessage()

func (*LogRequestMsg_Start) Reset added in v0.3.676

func (m *LogRequestMsg_Start) Reset()

func (*LogRequestMsg_Start) String added in v0.3.676

func (m *LogRequestMsg_Start) String() string

func (*LogRequestMsg_Start) XXX_DiscardUnknown added in v0.3.676

func (m *LogRequestMsg_Start) XXX_DiscardUnknown()

func (*LogRequestMsg_Start) XXX_Marshal added in v0.3.676

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

func (*LogRequestMsg_Start) XXX_Merge added in v0.3.676

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

func (*LogRequestMsg_Start) XXX_Size added in v0.3.676

func (m *LogRequestMsg_Start) XXX_Size() int

func (*LogRequestMsg_Start) XXX_Unmarshal added in v0.3.676

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

type LogRequestMsg_Start_ added in v0.3.676

type LogRequestMsg_Start_ struct {
	Start *LogRequestMsg_Start `protobuf:"bytes,1,opt,name=start,proto3,oneof"`
}

type LogResponseMsg added in v0.3.676

type LogResponseMsg struct {
	Data                 []*LogResponseMsg_Container `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Runners to Collectors

func (*LogResponseMsg) Descriptor added in v0.3.676

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

func (*LogResponseMsg) GetData added in v0.3.676

func (m *LogResponseMsg) GetData() []*LogResponseMsg_Container

func (*LogResponseMsg) ProtoMessage added in v0.3.676

func (*LogResponseMsg) ProtoMessage()

func (*LogResponseMsg) Reset added in v0.3.676

func (m *LogResponseMsg) Reset()

func (*LogResponseMsg) String added in v0.3.676

func (m *LogResponseMsg) String() string

func (*LogResponseMsg) XXX_DiscardUnknown added in v0.3.676

func (m *LogResponseMsg) XXX_DiscardUnknown()

func (*LogResponseMsg) XXX_Marshal added in v0.3.676

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

func (*LogResponseMsg) XXX_Merge added in v0.3.676

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

func (*LogResponseMsg) XXX_Size added in v0.3.676

func (m *LogResponseMsg) XXX_Size() int

func (*LogResponseMsg) XXX_Unmarshal added in v0.3.676

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

type LogResponseMsg_Container added in v0.3.676

type LogResponseMsg_Container struct {
	ApplicationId        string                              `protobuf:"bytes,1,opt,name=applicationId,proto3" json:"applicationId,omitempty"`
	FunctionId           string                              `protobuf:"bytes,2,opt,name=functionId,proto3" json:"functionId,omitempty"`
	ContainerId          string                              `protobuf:"bytes,3,opt,name=containerId,proto3" json:"containerId,omitempty"`
	Data                 []*LogResponseMsg_Container_Request `protobuf:"bytes,4,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

Per container log data

func (*LogResponseMsg_Container) Descriptor added in v0.3.676

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

func (*LogResponseMsg_Container) GetApplicationId added in v0.3.676

func (m *LogResponseMsg_Container) GetApplicationId() string

func (*LogResponseMsg_Container) GetContainerId added in v0.3.676

func (m *LogResponseMsg_Container) GetContainerId() string

func (*LogResponseMsg_Container) GetData added in v0.3.676

func (*LogResponseMsg_Container) GetFunctionId added in v0.3.676

func (m *LogResponseMsg_Container) GetFunctionId() string

func (*LogResponseMsg_Container) ProtoMessage added in v0.3.676

func (*LogResponseMsg_Container) ProtoMessage()

func (*LogResponseMsg_Container) Reset added in v0.3.676

func (m *LogResponseMsg_Container) Reset()

func (*LogResponseMsg_Container) String added in v0.3.676

func (m *LogResponseMsg_Container) String() string

func (*LogResponseMsg_Container) XXX_DiscardUnknown added in v0.3.676

func (m *LogResponseMsg_Container) XXX_DiscardUnknown()

func (*LogResponseMsg_Container) XXX_Marshal added in v0.3.676

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

func (*LogResponseMsg_Container) XXX_Merge added in v0.3.676

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

func (*LogResponseMsg_Container) XXX_Size added in v0.3.676

func (m *LogResponseMsg_Container) XXX_Size() int

func (*LogResponseMsg_Container) XXX_Unmarshal added in v0.3.676

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

type LogResponseMsg_Container_Request added in v0.3.676

type LogResponseMsg_Container_Request struct {
	RequestId            string                                   `protobuf:"bytes,1,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Data                 []*LogResponseMsg_Container_Request_Line `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
	XXX_unrecognized     []byte                                   `json:"-"`
	XXX_sizecache        int32                                    `json:"-"`
}

Per request log data

func (*LogResponseMsg_Container_Request) Descriptor added in v0.3.676

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

func (*LogResponseMsg_Container_Request) GetData added in v0.3.676

func (*LogResponseMsg_Container_Request) GetRequestId added in v0.3.676

func (m *LogResponseMsg_Container_Request) GetRequestId() string

func (*LogResponseMsg_Container_Request) ProtoMessage added in v0.3.676

func (*LogResponseMsg_Container_Request) ProtoMessage()

func (*LogResponseMsg_Container_Request) Reset added in v0.3.676

func (*LogResponseMsg_Container_Request) String added in v0.3.676

func (*LogResponseMsg_Container_Request) XXX_DiscardUnknown added in v0.3.676

func (m *LogResponseMsg_Container_Request) XXX_DiscardUnknown()

func (*LogResponseMsg_Container_Request) XXX_Marshal added in v0.3.676

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

func (*LogResponseMsg_Container_Request) XXX_Merge added in v0.3.676

func (*LogResponseMsg_Container_Request) XXX_Size added in v0.3.676

func (m *LogResponseMsg_Container_Request) XXX_Size() int

func (*LogResponseMsg_Container_Request) XXX_Unmarshal added in v0.3.676

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

type LogResponseMsg_Container_Request_Line added in v0.3.676

type LogResponseMsg_Container_Request_Line struct {
	Timestamp            int64                                        `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Source               LogResponseMsg_Container_Request_Line_Source `protobuf:"varint,2,opt,name=source,proto3,enum=LogResponseMsg_Container_Request_Line_Source" json:"source,omitempty"`
	Data                 []byte                                       `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                     `json:"-"`
	XXX_unrecognized     []byte                                       `json:"-"`
	XXX_sizecache        int32                                        `json:"-"`
}

Log lines

func (*LogResponseMsg_Container_Request_Line) Descriptor added in v0.3.676

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

func (*LogResponseMsg_Container_Request_Line) GetData added in v0.3.676

func (*LogResponseMsg_Container_Request_Line) GetSource added in v0.3.676

func (*LogResponseMsg_Container_Request_Line) GetTimestamp added in v0.3.676

func (m *LogResponseMsg_Container_Request_Line) GetTimestamp() int64

func (*LogResponseMsg_Container_Request_Line) ProtoMessage added in v0.3.676

func (*LogResponseMsg_Container_Request_Line) ProtoMessage()

func (*LogResponseMsg_Container_Request_Line) Reset added in v0.3.676

func (*LogResponseMsg_Container_Request_Line) String added in v0.3.676

func (*LogResponseMsg_Container_Request_Line) XXX_DiscardUnknown added in v0.3.676

func (m *LogResponseMsg_Container_Request_Line) XXX_DiscardUnknown()

func (*LogResponseMsg_Container_Request_Line) XXX_Marshal added in v0.3.676

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

func (*LogResponseMsg_Container_Request_Line) XXX_Merge added in v0.3.676

func (*LogResponseMsg_Container_Request_Line) XXX_Size added in v0.3.676

func (*LogResponseMsg_Container_Request_Line) XXX_Unmarshal added in v0.3.676

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

type LogResponseMsg_Container_Request_Line_Source added in v0.3.676

type LogResponseMsg_Container_Request_Line_Source int32
const (
	LogResponseMsg_Container_Request_Line_STDOUT LogResponseMsg_Container_Request_Line_Source = 0
	LogResponseMsg_Container_Request_Line_STDERR LogResponseMsg_Container_Request_Line_Source = 1
)

func (LogResponseMsg_Container_Request_Line_Source) EnumDescriptor added in v0.3.676

func (LogResponseMsg_Container_Request_Line_Source) EnumDescriptor() ([]byte, []int)

func (LogResponseMsg_Container_Request_Line_Source) String added in v0.3.676

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)
	// Configure the remote runner by passing config data.
	ConfigureRunner(ctx context.Context, in *ConfigMsg, opts ...grpc.CallOption) (*ConfigStatus, error)
	// Logging Interface
	StreamLogs(ctx context.Context, opts ...grpc.CallOption) (RunnerProtocol_StreamLogsClient, 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)
	// Configure the remote runner by passing config data.
	ConfigureRunner(context.Context, *ConfigMsg) (*ConfigStatus, error)
	// Logging Interface
	StreamLogs(RunnerProtocol_StreamLogsServer) 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 RunnerProtocol_StreamLogsClient added in v0.3.676

type RunnerProtocol_StreamLogsClient interface {
	Send(*LogRequestMsg) error
	Recv() (*LogResponseMsg, error)
	grpc.ClientStream
}

type RunnerProtocol_StreamLogsServer added in v0.3.676

type RunnerProtocol_StreamLogsServer interface {
	Send(*LogResponseMsg) error
	Recv() (*LogRequestMsg, 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"`
	IsNetworkDisabled    bool              `protobuf:"varint,17,opt,name=isNetworkDisabled,proto3" json:"isNetworkDisabled,omitempty"`
	CustomStatus         map[string]string `` /* 166-byte string literal not displayed */
	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) GetCustomStatus added in v0.3.687

func (m *RunnerStatus) GetCustomStatus() map[string]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) GetIsNetworkDisabled added in v0.3.659

func (m *RunnerStatus) GetIsNetworkDisabled() bool

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL