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 (m *LogResponseMsg_Container) GetData() []*LogResponseMsg_Container_Request

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 (m *LogResponseMsg_Container_Request) GetData() []*LogResponseMsg_Container_Request_Line

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 (m *LogResponseMsg_Container_Request) Reset()

func (*LogResponseMsg_Container_Request) String added in v0.3.676 

func (m *LogResponseMsg_Container_Request) String() string

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 (m *LogResponseMsg_Container_Request) XXX_Merge(src proto.Message)

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 (m *LogResponseMsg_Container_Request_Line) GetData() []byte

func (*LogResponseMsg_Container_Request_Line) GetSource added in v0.3.676 

func (m *LogResponseMsg_Container_Request_Line) GetSource() LogResponseMsg_Container_Request_Line_Source

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 (m *LogResponseMsg_Container_Request_Line) Reset()

func (*LogResponseMsg_Container_Request_Line) String added in v0.3.676 

func (m *LogResponseMsg_Container_Request_Line) String() string

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 (m *LogResponseMsg_Container_Request_Line) XXX_Merge(src proto.Message)

func (*LogResponseMsg_Container_Request_Line) XXX_Size added in v0.3.676 

func (m *LogResponseMsg_Container_Request_Line) XXX_Size() int

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 

func (x LogResponseMsg_Container_Request_Line_Source) 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"`
	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

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.