runner

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
}

type CallResultStart struct {

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

type CallResultStart_Http struct {
	Http *HttpRespMeta `protobuf:"bytes,100,opt,name=http,proto3,oneof"`
}

type ClientMsg struct {

	// Types that are assignable to Body:
	//
	//	*ClientMsg_Try
	//	*ClientMsg_Data
	Body isClientMsg_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

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

type ClientMsg_Try struct {
	Try *TryCall `protobuf:"bytes,1,opt,name=try,proto3,oneof"`
}

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

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

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
}

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
}

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
}

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
}

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

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

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

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

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

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

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

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
}

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
}

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
}

type LogResponseMsg_Container_Request_Line_Source int32

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
}

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

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

type RunnerMsg_ResultStart struct {
	ResultStart *CallResultStart `protobuf:"bytes,1,opt,name=result_start,json=resultStart,proto3,oneof"`
}

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

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
}

type RunnerProtocol_EngageClient interface {
	Send(*ClientMsg) error
	Recv() (*RunnerMsg, error)
	grpc.ClientStream
}

type RunnerProtocol_EngageServer interface {
	Send(*RunnerMsg) error
	Recv() (*ClientMsg, error)
	grpc.ServerStream
}

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

type RunnerProtocol_StreamLogsServer interface {
	Send(*LogResponseMsg) error
	Recv() (*LogRequestMsg, error)
	grpc.ServerStream
}

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
}

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
}

type UnimplementedRunnerProtocolServer struct {
}

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