runner

package
v0.0.0-...-3e3bf6f Latest Latest
Warning

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

 Go to latest Published: Jul 13, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RunnerProtocol_Engage_FullMethodName          = "/runner.RunnerProtocol/Engage"
	RunnerProtocol_Status_FullMethodName          = "/runner.RunnerProtocol/Status"
	RunnerProtocol_ConfigureRunner_FullMethodName = "/runner.RunnerProtocol/ConfigureRunner"
	RunnerProtocol_StreamLogs_FullMethodName      = "/runner.RunnerProtocol/StreamLogs"
	RunnerProtocol_Status2_FullMethodName         = "/runner.RunnerProtocol/Status2"
)

Variables

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

Enum value maps for LogResponseMsg_Container_Request_Line_Source.

View Source 
var File_runner_proto protoreflect.FileDescriptor
View Source 
var RunnerProtocol_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "runner.RunnerProtocol",
	HandlerType: (*RunnerProtocolServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Status",
			Handler:    _RunnerProtocol_Status_Handler,
		},
		{
			MethodName: "ConfigureRunner",
			Handler:    _RunnerProtocol_ConfigureRunner_Handler,
		},
		{
			MethodName: "Status2",
			Handler:    _RunnerProtocol_Status2_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Engage",
			Handler:       _RunnerProtocol_Engage_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "StreamLogs",
			Handler:       _RunnerProtocol_StreamLogs_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "runner.proto",
}

RunnerProtocol_ServiceDesc is the grpc.ServiceDesc for RunnerProtocol service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterRunnerProtocolServer 

func RegisterRunnerProtocolServer(s grpc.ServiceRegistrar, 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"`
	Image                 string `protobuf:"bytes,11,opt,name=image,proto3" json:"image,omitempty"`
	ImagePullWaitDuration int64  `protobuf:"varint,12,opt,name=imagePullWaitDuration,proto3" json:"imagePullWaitDuration,omitempty"`
	CtrPrepDuration       int64  `protobuf:"varint,13,opt,name=ctrPrepDuration,proto3" json:"ctrPrepDuration,omitempty"`
	CtrCreateDuration     int64  `protobuf:"varint,14,opt,name=ctrCreateDuration,proto3" json:"ctrCreateDuration,omitempty"`
	InitStartTime         int64  `protobuf:"varint,15,opt,name=initStartTime,proto3" json:"initStartTime,omitempty"`
	// contains filtered or unexported fields
}

Call has really finished, it might have completed or crashed

func (*CallFinished) Descriptor deprecated 

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

Deprecated: Use CallFinished.ProtoReflect.Descriptor instead.

func (*CallFinished) GetCompletedAt 

func (x *CallFinished) GetCompletedAt() string

func (*CallFinished) GetCreatedAt 

func (x *CallFinished) GetCreatedAt() string

func (*CallFinished) GetCtrCreateDuration 

func (x *CallFinished) GetCtrCreateDuration() int64

func (*CallFinished) GetCtrPrepDuration 

func (x *CallFinished) GetCtrPrepDuration() int64

func (*CallFinished) GetDetails 

func (x *CallFinished) GetDetails() string

func (*CallFinished) GetErrorCode 

func (x *CallFinished) GetErrorCode() int32

func (*CallFinished) GetErrorStr 

func (x *CallFinished) GetErrorStr() string

func (*CallFinished) GetErrorUser 

func (x *CallFinished) GetErrorUser() bool

func (*CallFinished) GetExecutionDuration 

func (x *CallFinished) GetExecutionDuration() int64

func (*CallFinished) GetImage 

func (x *CallFinished) GetImage() string

func (*CallFinished) GetImagePullWaitDuration 

func (x *CallFinished) GetImagePullWaitDuration() int64

func (*CallFinished) GetInitStartTime 

func (x *CallFinished) GetInitStartTime() int64

func (*CallFinished) GetSchedulerDuration 

func (x *CallFinished) GetSchedulerDuration() int64

func (*CallFinished) GetStartedAt 

func (x *CallFinished) GetStartedAt() string

func (*CallFinished) GetSuccess 

func (x *CallFinished) GetSuccess() bool

func (*CallFinished) ProtoMessage 

func (*CallFinished) ProtoMessage()

func (*CallFinished) ProtoReflect 

func (x *CallFinished) ProtoReflect() protoreflect.Message

func (*CallFinished) Reset 

func (x *CallFinished) Reset()

func (*CallFinished) String 

func (x *CallFinished) String() string

type CallResultStart 

type CallResultStart struct {

	// Types that are assignable to Meta:
	//
	//	*CallResultStart_Http
	Meta isCallResultStart_Meta `protobuf_oneof:"meta"`
	// contains filtered or unexported fields
}

Call has started to finish - data might not be here yet and it will be sent as DataFrames.

func (*CallResultStart) Descriptor deprecated 

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

Deprecated: Use CallResultStart.ProtoReflect.Descriptor instead.

func (*CallResultStart) GetHttp 

func (x *CallResultStart) GetHttp() *HttpRespMeta

func (*CallResultStart) GetMeta 

func (m *CallResultStart) GetMeta() isCallResultStart_Meta

func (*CallResultStart) ProtoMessage 

func (*CallResultStart) ProtoMessage()

func (*CallResultStart) ProtoReflect 

func (x *CallResultStart) ProtoReflect() protoreflect.Message

func (*CallResultStart) Reset 

func (x *CallResultStart) Reset()

func (*CallResultStart) String 

func (x *CallResultStart) String() string

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 assignable to Body:
	//
	//	*ClientMsg_Try
	//	*ClientMsg_Data
	Body isClientMsg_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

func (*ClientMsg) Descriptor deprecated 

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

Deprecated: Use ClientMsg.ProtoReflect.Descriptor instead.

func (*ClientMsg) GetBody 

func (m *ClientMsg) GetBody() isClientMsg_Body

func (*ClientMsg) GetData 

func (x *ClientMsg) GetData() *DataFrame

func (*ClientMsg) GetTry 

func (x *ClientMsg) GetTry() *TryCall

func (*ClientMsg) ProtoMessage 

func (*ClientMsg) ProtoMessage()

func (*ClientMsg) ProtoReflect 

func (x *ClientMsg) ProtoReflect() protoreflect.Message

func (*ClientMsg) Reset 

func (x *ClientMsg) Reset()

func (*ClientMsg) String 

func (x *ClientMsg) String() string

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 

type ConfigMsg struct {
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigMsg) Descriptor deprecated 

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

Deprecated: Use ConfigMsg.ProtoReflect.Descriptor instead.

func (*ConfigMsg) GetConfig 

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

func (*ConfigMsg) ProtoMessage 

func (*ConfigMsg) ProtoMessage()

func (*ConfigMsg) ProtoReflect 

func (x *ConfigMsg) ProtoReflect() protoreflect.Message

func (*ConfigMsg) Reset 

func (x *ConfigMsg) Reset()

func (*ConfigMsg) String 

func (x *ConfigMsg) String() string

type ConfigStatus 

type ConfigStatus struct {
	// contains filtered or unexported fields
}

func (*ConfigStatus) Descriptor deprecated 

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

Deprecated: Use ConfigStatus.ProtoReflect.Descriptor instead.

func (*ConfigStatus) ProtoMessage 

func (*ConfigStatus) ProtoMessage()

func (*ConfigStatus) ProtoReflect 

func (x *ConfigStatus) ProtoReflect() protoreflect.Message

func (*ConfigStatus) Reset 

func (x *ConfigStatus) Reset()

func (*ConfigStatus) String 

func (x *ConfigStatus) String() string

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"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use DataFrame.ProtoReflect.Descriptor instead.

func (*DataFrame) GetData 

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

func (*DataFrame) GetEof 

func (x *DataFrame) GetEof() bool

func (*DataFrame) ProtoMessage 

func (*DataFrame) ProtoMessage()

func (*DataFrame) ProtoReflect 

func (x *DataFrame) ProtoReflect() protoreflect.Message

func (*DataFrame) Reset 

func (x *DataFrame) Reset()

func (*DataFrame) String 

func (x *DataFrame) String() string

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"`
	// contains filtered or unexported fields
}

func (*HttpHeader) Descriptor deprecated 

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

Deprecated: Use HttpHeader.ProtoReflect.Descriptor instead.

func (*HttpHeader) GetKey 

func (x *HttpHeader) GetKey() string

func (*HttpHeader) GetValue 

func (x *HttpHeader) GetValue() string

func (*HttpHeader) ProtoMessage 

func (*HttpHeader) ProtoMessage()

func (*HttpHeader) ProtoReflect 

func (x *HttpHeader) ProtoReflect() protoreflect.Message

func (*HttpHeader) Reset 

func (x *HttpHeader) Reset()

func (*HttpHeader) String 

func (x *HttpHeader) String() string

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"`
	// contains filtered or unexported fields
}

func (*HttpRespMeta) Descriptor deprecated 

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

Deprecated: Use HttpRespMeta.ProtoReflect.Descriptor instead.

func (*HttpRespMeta) GetHeaders 

func (x *HttpRespMeta) GetHeaders() []*HttpHeader

func (*HttpRespMeta) GetStatusCode 

func (x *HttpRespMeta) GetStatusCode() int32

func (*HttpRespMeta) ProtoMessage 

func (*HttpRespMeta) ProtoMessage()

func (*HttpRespMeta) ProtoReflect 

func (x *HttpRespMeta) ProtoReflect() protoreflect.Message

func (*HttpRespMeta) Reset 

func (x *HttpRespMeta) Reset()

func (*HttpRespMeta) String 

func (x *HttpRespMeta) String() string

type LogRequestMsg 

type LogRequestMsg struct {

	// Types that are assignable to Body:
	//
	//	*LogRequestMsg_Start_
	//	*LogRequestMsg_Ack_
	//	*LogRequestMsg_Ready_
	Body isLogRequestMsg_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

Collector to Runner messages

func (*LogRequestMsg) Descriptor deprecated 

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

Deprecated: Use LogRequestMsg.ProtoReflect.Descriptor instead.

func (*LogRequestMsg) GetAck 

func (x *LogRequestMsg) GetAck() *LogRequestMsg_Ack

func (*LogRequestMsg) GetBody 

func (m *LogRequestMsg) GetBody() isLogRequestMsg_Body

func (*LogRequestMsg) GetReady 

func (x *LogRequestMsg) GetReady() *LogRequestMsg_Ready

func (*LogRequestMsg) GetStart 

func (x *LogRequestMsg) GetStart() *LogRequestMsg_Start

func (*LogRequestMsg) ProtoMessage 

func (*LogRequestMsg) ProtoMessage()

func (*LogRequestMsg) ProtoReflect 

func (x *LogRequestMsg) ProtoReflect() protoreflect.Message

func (*LogRequestMsg) Reset 

func (x *LogRequestMsg) Reset()

func (*LogRequestMsg) String 

func (x *LogRequestMsg) String() string

type LogRequestMsg_Ack 

type LogRequestMsg_Ack struct {
	// contains filtered or unexported fields
}

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

func (*LogRequestMsg_Ack) Descriptor deprecated 

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

Deprecated: Use LogRequestMsg_Ack.ProtoReflect.Descriptor instead.

func (*LogRequestMsg_Ack) ProtoMessage 

func (*LogRequestMsg_Ack) ProtoMessage()

func (*LogRequestMsg_Ack) ProtoReflect 

func (x *LogRequestMsg_Ack) ProtoReflect() protoreflect.Message

func (*LogRequestMsg_Ack) Reset 

func (x *LogRequestMsg_Ack) Reset()

func (*LogRequestMsg_Ack) String 

func (x *LogRequestMsg_Ack) String() string

type LogRequestMsg_Ack_ 

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

type LogRequestMsg_Ready 

type LogRequestMsg_Ready struct {
	// contains filtered or unexported fields
}

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

func (*LogRequestMsg_Ready) Descriptor deprecated 

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

Deprecated: Use LogRequestMsg_Ready.ProtoReflect.Descriptor instead.

func (*LogRequestMsg_Ready) ProtoMessage 

func (*LogRequestMsg_Ready) ProtoMessage()

func (*LogRequestMsg_Ready) ProtoReflect 

func (x *LogRequestMsg_Ready) ProtoReflect() protoreflect.Message

func (*LogRequestMsg_Ready) Reset 

func (x *LogRequestMsg_Ready) Reset()

func (*LogRequestMsg_Ready) String 

func (x *LogRequestMsg_Ready) String() string

type LogRequestMsg_Ready_ 

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

type LogRequestMsg_Start 

type LogRequestMsg_Start struct {
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Initial Logging session message sent by Collectors to Runners

func (*LogRequestMsg_Start) Descriptor deprecated 

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

Deprecated: Use LogRequestMsg_Start.ProtoReflect.Descriptor instead.

func (*LogRequestMsg_Start) GetConfig 

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

func (*LogRequestMsg_Start) ProtoMessage 

func (*LogRequestMsg_Start) ProtoMessage()

func (*LogRequestMsg_Start) ProtoReflect 

func (x *LogRequestMsg_Start) ProtoReflect() protoreflect.Message

func (*LogRequestMsg_Start) Reset 

func (x *LogRequestMsg_Start) Reset()

func (*LogRequestMsg_Start) String 

func (x *LogRequestMsg_Start) String() string

type LogRequestMsg_Start_ 

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

type LogResponseMsg 

type LogResponseMsg struct {
	Data []*LogResponseMsg_Container `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // container logs
	// contains filtered or unexported fields
}

Runners to Collectors

func (*LogResponseMsg) Descriptor deprecated 

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

Deprecated: Use LogResponseMsg.ProtoReflect.Descriptor instead.

func (*LogResponseMsg) GetData 

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

func (*LogResponseMsg) ProtoMessage 

func (*LogResponseMsg) ProtoMessage()

func (*LogResponseMsg) ProtoReflect 

func (x *LogResponseMsg) ProtoReflect() protoreflect.Message

func (*LogResponseMsg) Reset 

func (x *LogResponseMsg) Reset()

func (*LogResponseMsg) String 

func (x *LogResponseMsg) String() string

type LogResponseMsg_Container 

type LogResponseMsg_Container struct {
	ApplicationId string                              `protobuf:"bytes,1,opt,name=applicationId,proto3" json:"applicationId,omitempty"` // application id
	FunctionId    string                              `protobuf:"bytes,2,opt,name=functionId,proto3" json:"functionId,omitempty"`       // function id
	ContainerId   string                              `protobuf:"bytes,3,opt,name=containerId,proto3" json:"containerId,omitempty"`     // container id
	Data          []*LogResponseMsg_Container_Request `protobuf:"bytes,4,rep,name=data,proto3" json:"data,omitempty"`                   // request logs
	// contains filtered or unexported fields
}

Per container log data

func (*LogResponseMsg_Container) Descriptor deprecated 

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

Deprecated: Use LogResponseMsg_Container.ProtoReflect.Descriptor instead.

func (*LogResponseMsg_Container) GetApplicationId 

func (x *LogResponseMsg_Container) GetApplicationId() string

func (*LogResponseMsg_Container) GetContainerId 

func (x *LogResponseMsg_Container) GetContainerId() string

func (*LogResponseMsg_Container) GetData 

func (x *LogResponseMsg_Container) GetData() []*LogResponseMsg_Container_Request

func (*LogResponseMsg_Container) GetFunctionId 

func (x *LogResponseMsg_Container) GetFunctionId() string

func (*LogResponseMsg_Container) ProtoMessage 

func (*LogResponseMsg_Container) ProtoMessage()

func (*LogResponseMsg_Container) ProtoReflect 

func (x *LogResponseMsg_Container) ProtoReflect() protoreflect.Message

func (*LogResponseMsg_Container) Reset 

func (x *LogResponseMsg_Container) Reset()

func (*LogResponseMsg_Container) String 

func (x *LogResponseMsg_Container) String() string

type LogResponseMsg_Container_Request 

type LogResponseMsg_Container_Request struct {
	RequestId string                                   `protobuf:"bytes,1,opt,name=requestId,proto3" json:"requestId,omitempty"` // call request id
	Data      []*LogResponseMsg_Container_Request_Line `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`           // log lines
	// contains filtered or unexported fields
}

Per request log data

func (*LogResponseMsg_Container_Request) Descriptor deprecated 

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

Deprecated: Use LogResponseMsg_Container_Request.ProtoReflect.Descriptor instead.

func (*LogResponseMsg_Container_Request) GetData 

func (x *LogResponseMsg_Container_Request) GetData() []*LogResponseMsg_Container_Request_Line

func (*LogResponseMsg_Container_Request) GetRequestId 

func (x *LogResponseMsg_Container_Request) GetRequestId() string

func (*LogResponseMsg_Container_Request) ProtoMessage 

func (*LogResponseMsg_Container_Request) ProtoMessage()

func (*LogResponseMsg_Container_Request) ProtoReflect 

func (x *LogResponseMsg_Container_Request) ProtoReflect() protoreflect.Message

func (*LogResponseMsg_Container_Request) Reset 

func (x *LogResponseMsg_Container_Request) Reset()

func (*LogResponseMsg_Container_Request) String 

func (x *LogResponseMsg_Container_Request) String() string

type LogResponseMsg_Container_Request_Line 

type LogResponseMsg_Container_Request_Line struct {
	Timestamp int64                                        `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                                                    // utc unix time msecs
	Source    LogResponseMsg_Container_Request_Line_Source `protobuf:"varint,2,opt,name=source,proto3,enum=runner.LogResponseMsg_Container_Request_Line_Source" json:"source,omitempty"` // stderr or stdout
	Data      []byte                                       `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`                                                               // opaque log data
	// contains filtered or unexported fields
}

Log lines

func (*LogResponseMsg_Container_Request_Line) Descriptor deprecated 

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

Deprecated: Use LogResponseMsg_Container_Request_Line.ProtoReflect.Descriptor instead.

func (*LogResponseMsg_Container_Request_Line) GetData 

func (x *LogResponseMsg_Container_Request_Line) GetData() []byte

func (*LogResponseMsg_Container_Request_Line) GetSource 

func (x *LogResponseMsg_Container_Request_Line) GetSource() LogResponseMsg_Container_Request_Line_Source

func (*LogResponseMsg_Container_Request_Line) GetTimestamp 

func (x *LogResponseMsg_Container_Request_Line) GetTimestamp() int64

func (*LogResponseMsg_Container_Request_Line) ProtoMessage 

func (*LogResponseMsg_Container_Request_Line) ProtoMessage()

func (*LogResponseMsg_Container_Request_Line) ProtoReflect 

func (x *LogResponseMsg_Container_Request_Line) ProtoReflect() protoreflect.Message

func (*LogResponseMsg_Container_Request_Line) Reset 

func (x *LogResponseMsg_Container_Request_Line) Reset()

func (*LogResponseMsg_Container_Request_Line) String 

func (x *LogResponseMsg_Container_Request_Line) String() string

type LogResponseMsg_Container_Request_Line_Source 

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) Descriptor 

func (LogResponseMsg_Container_Request_Line_Source) Descriptor() protoreflect.EnumDescriptor

func (LogResponseMsg_Container_Request_Line_Source) Enum 

func (x LogResponseMsg_Container_Request_Line_Source) Enum() *LogResponseMsg_Container_Request_Line_Source

func (LogResponseMsg_Container_Request_Line_Source) EnumDescriptor deprecated 

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

Deprecated: Use LogResponseMsg_Container_Request_Line_Source.Descriptor instead.

func (LogResponseMsg_Container_Request_Line_Source) Number 

func (x LogResponseMsg_Container_Request_Line_Source) Number() protoreflect.EnumNumber

func (LogResponseMsg_Container_Request_Line_Source) String 

func (x LogResponseMsg_Container_Request_Line_Source) String() string

func (LogResponseMsg_Container_Request_Line_Source) Type 

func (LogResponseMsg_Container_Request_Line_Source) Type() protoreflect.EnumType

type RunnerMsg 

type RunnerMsg struct {

	// Types that are assignable to Body:
	//
	//	*RunnerMsg_ResultStart
	//	*RunnerMsg_Data
	//	*RunnerMsg_Finished
	Body isRunnerMsg_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

func (*RunnerMsg) Descriptor deprecated 

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

Deprecated: Use RunnerMsg.ProtoReflect.Descriptor instead.

func (*RunnerMsg) GetBody 

func (m *RunnerMsg) GetBody() isRunnerMsg_Body

func (*RunnerMsg) GetData 

func (x *RunnerMsg) GetData() *DataFrame

func (*RunnerMsg) GetFinished 

func (x *RunnerMsg) GetFinished() *CallFinished

func (*RunnerMsg) GetResultStart 

func (x *RunnerMsg) GetResultStart() *CallResultStart

func (*RunnerMsg) ProtoMessage 

func (*RunnerMsg) ProtoMessage()

func (*RunnerMsg) ProtoReflect 

func (x *RunnerMsg) ProtoReflect() protoreflect.Message

func (*RunnerMsg) Reset 

func (x *RunnerMsg) Reset()

func (*RunnerMsg) String 

func (x *RunnerMsg) String() string

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)
	// Deprecated: Do not use.
	// Rather than rely on Prometheus for this, expose status that's specific to the runner lifecycle through this.
	Status(ctx context.Context, in *emptypb.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)
	// If a status image container is configured (for handling custom statuses)
	// / the supplied opaque JSON is passed as an input to that image.
	// Output from the container is sent back via RunnerStatus.Details
	// as before.
	Status2(ctx context.Context, in *structpb.Struct, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRunnerProtocolClient 

func NewRunnerProtocolClient(cc grpc.ClientConnInterface) RunnerProtocolClient

type RunnerProtocolServer 

type RunnerProtocolServer interface {
	Engage(RunnerProtocol_EngageServer) error
	// Deprecated: Do not use.
	// Rather than rely on Prometheus for this, expose status that's specific to the runner lifecycle through this.
	Status(context.Context, *emptypb.Empty) (*RunnerStatus, error)
	// Configure the remote runner by passing config data.
	ConfigureRunner(context.Context, *ConfigMsg) (*ConfigStatus, error)
	// Logging Interface
	StreamLogs(RunnerProtocol_StreamLogsServer) error
	// If a status image container is configured (for handling custom statuses)
	// / the supplied opaque JSON is passed as an input to that image.
	// Output from the container is sent back via RunnerStatus.Details
	// as before.
	Status2(context.Context, *structpb.Struct) (*RunnerStatus, error)
	// contains filtered or unexported methods
}

RunnerProtocolServer is the server API for RunnerProtocol service. All implementations must embed UnimplementedRunnerProtocolServer for forward compatibility

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 

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

type RunnerProtocol_StreamLogsServer 

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"`                        // Number of currently inflight responses
	Failed            bool              `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"`                        // if status was successful or not
	Id                string            `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`                                 // call id if status image was used
	Details           string            `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`                       // response from status image
	ErrorCode         int32             `protobuf:"varint,6,opt,name=errorCode,proto3" json:"errorCode,omitempty"`                  // error code if not successful
	ErrorStr          string            `protobuf:"bytes,7,opt,name=errorStr,proto3" json:"errorStr,omitempty"`                     // error description if not successful
	CreatedAt         string            `protobuf:"bytes,8,opt,name=createdAt,proto3" json:"createdAt,omitempty"`                   // call latency details: initialization time
	StartedAt         string            `protobuf:"bytes,9,opt,name=startedAt,proto3" json:"startedAt,omitempty"`                   // call latency details: start time in container
	CompletedAt       string            `protobuf:"bytes,10,opt,name=completedAt,proto3" json:"completedAt,omitempty"`              // call latency details: end time
	Cached            bool              `protobuf:"varint,11,opt,name=cached,proto3" json:"cached,omitempty"`                       // true if status response was provided from cache
	RequestsReceived  uint64            `protobuf:"varint,12,opt,name=requestsReceived,proto3" json:"requestsReceived,omitempty"`   // number of requests received by runner
	RequestsHandled   uint64            `protobuf:"varint,13,opt,name=requestsHandled,proto3" json:"requestsHandled,omitempty"`     // number of requests processed by runner without NACK
	KdumpsOnDisk      uint64            `protobuf:"varint,14,opt,name=kdumpsOnDisk,proto3" json:"kdumpsOnDisk,omitempty"`           // number of kdumps on local disk
	SchedulerDuration int64             `protobuf:"varint,15,opt,name=schedulerDuration,proto3" json:"schedulerDuration,omitempty"` // the amount of time for scheduler execution
	ExecutionDuration int64             `protobuf:"varint,16,opt,name=executionDuration,proto3" json:"executionDuration,omitempty"` // the amount of time for function execution
	IsNetworkDisabled bool              `protobuf:"varint,17,opt,name=isNetworkDisabled,proto3" json:"isNetworkDisabled,omitempty"` // returns true if runner network is not ready
	CustomStatus      map[string]string ``                                                                                          // returns any user defined healthcheck status
	/* 166-byte string literal not displayed */
	ImagePullWaitDuration int64 `protobuf:"varint,19,opt,name=imagePullWaitDuration,proto3" json:"imagePullWaitDuration,omitempty"`
	CtrPrepDuration       int64 `protobuf:"varint,20,opt,name=ctrPrepDuration,proto3" json:"ctrPrepDuration,omitempty"`
	CtrCreateDuration     int64 `protobuf:"varint,21,opt,name=ctrCreateDuration,proto3" json:"ctrCreateDuration,omitempty"`
	InitStartTime         int64 `protobuf:"varint,22,opt,name=initStartTime,proto3" json:"initStartTime,omitempty"`
	// contains filtered or unexported fields
}

func (*RunnerStatus) Descriptor deprecated 

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

Deprecated: Use RunnerStatus.ProtoReflect.Descriptor instead.

func (*RunnerStatus) GetActive 

func (x *RunnerStatus) GetActive() int32

func (*RunnerStatus) GetCached 

func (x *RunnerStatus) GetCached() bool

func (*RunnerStatus) GetCompletedAt 

func (x *RunnerStatus) GetCompletedAt() string

func (*RunnerStatus) GetCreatedAt 

func (x *RunnerStatus) GetCreatedAt() string

func (*RunnerStatus) GetCtrCreateDuration 

func (x *RunnerStatus) GetCtrCreateDuration() int64

func (*RunnerStatus) GetCtrPrepDuration 

func (x *RunnerStatus) GetCtrPrepDuration() int64

func (*RunnerStatus) GetCustomStatus 

func (x *RunnerStatus) GetCustomStatus() map[string]string

func (*RunnerStatus) GetDetails 

func (x *RunnerStatus) GetDetails() string

func (*RunnerStatus) GetErrorCode 

func (x *RunnerStatus) GetErrorCode() int32

func (*RunnerStatus) GetErrorStr 

func (x *RunnerStatus) GetErrorStr() string

func (*RunnerStatus) GetExecutionDuration 

func (x *RunnerStatus) GetExecutionDuration() int64

func (*RunnerStatus) GetFailed 

func (x *RunnerStatus) GetFailed() bool

func (*RunnerStatus) GetId 

func (x *RunnerStatus) GetId() string

func (*RunnerStatus) GetImagePullWaitDuration 

func (x *RunnerStatus) GetImagePullWaitDuration() int64

func (*RunnerStatus) GetInitStartTime 

func (x *RunnerStatus) GetInitStartTime() int64

func (*RunnerStatus) GetIsNetworkDisabled 

func (x *RunnerStatus) GetIsNetworkDisabled() bool

func (*RunnerStatus) GetKdumpsOnDisk 

func (x *RunnerStatus) GetKdumpsOnDisk() uint64

func (*RunnerStatus) GetRequestsHandled 

func (x *RunnerStatus) GetRequestsHandled() uint64

func (*RunnerStatus) GetRequestsReceived 

func (x *RunnerStatus) GetRequestsReceived() uint64

func (*RunnerStatus) GetSchedulerDuration 

func (x *RunnerStatus) GetSchedulerDuration() int64

func (*RunnerStatus) GetStartedAt 

func (x *RunnerStatus) GetStartedAt() string

func (*RunnerStatus) ProtoMessage 

func (*RunnerStatus) ProtoMessage()

func (*RunnerStatus) ProtoReflect 

func (x *RunnerStatus) ProtoReflect() protoreflect.Message

func (*RunnerStatus) Reset 

func (x *RunnerStatus) Reset()

func (*RunnerStatus) String 

func (x *RunnerStatus) String() string

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 */
	// contains filtered or unexported fields
}

Request to allocate a slot for a call

func (*TryCall) Descriptor deprecated 

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

Deprecated: Use TryCall.ProtoReflect.Descriptor instead.

func (*TryCall) GetExtensions 

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

func (*TryCall) GetModelsCallJson 

func (x *TryCall) GetModelsCallJson() string

func (*TryCall) GetSlotHashId 

func (x *TryCall) GetSlotHashId() string

func (*TryCall) ProtoMessage 

func (*TryCall) ProtoMessage()

func (*TryCall) ProtoReflect 

func (x *TryCall) ProtoReflect() protoreflect.Message

func (*TryCall) Reset 

func (x *TryCall) Reset()

func (*TryCall) String 

func (x *TryCall) String() string

type UnimplementedRunnerProtocolServer 

type UnimplementedRunnerProtocolServer struct {
}

UnimplementedRunnerProtocolServer must be embedded to have forward compatible implementations.

func (UnimplementedRunnerProtocolServer) ConfigureRunner 

func (UnimplementedRunnerProtocolServer) ConfigureRunner(context.Context, *ConfigMsg) (*ConfigStatus, error)

func (UnimplementedRunnerProtocolServer) Engage 

func (UnimplementedRunnerProtocolServer) Engage(RunnerProtocol_EngageServer) error

func (UnimplementedRunnerProtocolServer) Status 

func (UnimplementedRunnerProtocolServer) Status(context.Context, *emptypb.Empty) (*RunnerStatus, error)

func (UnimplementedRunnerProtocolServer) Status2 

func (UnimplementedRunnerProtocolServer) Status2(context.Context, *structpb.Struct) (*RunnerStatus, error)

func (UnimplementedRunnerProtocolServer) StreamLogs 

func (UnimplementedRunnerProtocolServer) StreamLogs(RunnerProtocol_StreamLogsServer) error

type UnsafeRunnerProtocolServer 

type UnsafeRunnerProtocolServer interface {
	// contains filtered or unexported methods
}

UnsafeRunnerProtocolServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RunnerProtocolServer will result in compilation errors.

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.