remotev1

package
v0.10.6 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RunnerManager_Start_FullMethodName        = "/autokitteh.remote.v1.RunnerManager/Start"
	RunnerManager_RunnerHealth_FullMethodName = "/autokitteh.remote.v1.RunnerManager/RunnerHealth"
	RunnerManager_Stop_FullMethodName         = "/autokitteh.remote.v1.RunnerManager/Stop"
	RunnerManager_Health_FullMethodName       = "/autokitteh.remote.v1.RunnerManager/Health"
)
View Source 
const (
	Runner_Exports_FullMethodName       = "/autokitteh.remote.v1.Runner/Exports"
	Runner_Start_FullMethodName         = "/autokitteh.remote.v1.Runner/Start"
	Runner_Execute_FullMethodName       = "/autokitteh.remote.v1.Runner/Execute"
	Runner_ActivityReply_FullMethodName = "/autokitteh.remote.v1.Runner/ActivityReply"
	Runner_Health_FullMethodName        = "/autokitteh.remote.v1.Runner/Health"
)
View Source 
const (
	Worker_Activity_FullMethodName          = "/autokitteh.remote.v1.Worker/Activity"
	Worker_Done_FullMethodName              = "/autokitteh.remote.v1.Worker/Done"
	Worker_Log_FullMethodName               = "/autokitteh.remote.v1.Worker/Log"
	Worker_Print_FullMethodName             = "/autokitteh.remote.v1.Worker/Print"
	Worker_Sleep_FullMethodName             = "/autokitteh.remote.v1.Worker/Sleep"
	Worker_Subscribe_FullMethodName         = "/autokitteh.remote.v1.Worker/Subscribe"
	Worker_NextEvent_FullMethodName         = "/autokitteh.remote.v1.Worker/NextEvent"
	Worker_Unsubscribe_FullMethodName       = "/autokitteh.remote.v1.Worker/Unsubscribe"
	Worker_StartSession_FullMethodName      = "/autokitteh.remote.v1.Worker/StartSession"
	Worker_EncodeJWT_FullMethodName         = "/autokitteh.remote.v1.Worker/EncodeJWT"
	Worker_RefreshOAuthToken_FullMethodName = "/autokitteh.remote.v1.Worker/RefreshOAuthToken"
	Worker_Health_FullMethodName            = "/autokitteh.remote.v1.Worker/Health"
	Worker_IsActiveRunner_FullMethodName    = "/autokitteh.remote.v1.Worker/IsActiveRunner"
)

Variables

View Source 
var File_autokitteh_remote_v1_remote_proto protoreflect.FileDescriptor
View Source 
var RunnerManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "autokitteh.remote.v1.RunnerManager",
	HandlerType: (*RunnerManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Start",
			Handler:    _RunnerManager_Start_Handler,
		},
		{
			MethodName: "RunnerHealth",
			Handler:    _RunnerManager_RunnerHealth_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _RunnerManager_Stop_Handler,
		},
		{
			MethodName: "Health",
			Handler:    _RunnerManager_Health_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "autokitteh/remote/v1/remote.proto",
}

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

View Source 
var Runner_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "autokitteh.remote.v1.Runner",
	HandlerType: (*RunnerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Exports",
			Handler:    _Runner_Exports_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _Runner_Start_Handler,
		},
		{
			MethodName: "Execute",
			Handler:    _Runner_Execute_Handler,
		},
		{
			MethodName: "ActivityReply",
			Handler:    _Runner_ActivityReply_Handler,
		},
		{
			MethodName: "Health",
			Handler:    _Runner_Health_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "autokitteh/remote/v1/remote.proto",
}

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

View Source 
var Worker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "autokitteh.remote.v1.Worker",
	HandlerType: (*WorkerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Activity",
			Handler:    _Worker_Activity_Handler,
		},
		{
			MethodName: "Done",
			Handler:    _Worker_Done_Handler,
		},
		{
			MethodName: "Log",
			Handler:    _Worker_Log_Handler,
		},
		{
			MethodName: "Print",
			Handler:    _Worker_Print_Handler,
		},
		{
			MethodName: "Sleep",
			Handler:    _Worker_Sleep_Handler,
		},
		{
			MethodName: "Subscribe",
			Handler:    _Worker_Subscribe_Handler,
		},
		{
			MethodName: "NextEvent",
			Handler:    _Worker_NextEvent_Handler,
		},
		{
			MethodName: "Unsubscribe",
			Handler:    _Worker_Unsubscribe_Handler,
		},
		{
			MethodName: "StartSession",
			Handler:    _Worker_StartSession_Handler,
		},
		{
			MethodName: "EncodeJWT",
			Handler:    _Worker_EncodeJWT_Handler,
		},
		{
			MethodName: "RefreshOAuthToken",
			Handler:    _Worker_RefreshOAuthToken_Handler,
		},
		{
			MethodName: "Health",
			Handler:    _Worker_Health_Handler,
		},
		{
			MethodName: "IsActiveRunner",
			Handler:    _Worker_IsActiveRunner_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "autokitteh/remote/v1/remote.proto",
}

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

Functions

func RegisterRunnerManagerServer 

func RegisterRunnerManagerServer(s grpc.ServiceRegistrar, srv RunnerManagerServer)

func RegisterRunnerServer 

func RegisterRunnerServer(s grpc.ServiceRegistrar, srv RunnerServer)

func RegisterWorkerServer 

func RegisterWorkerServer(s grpc.ServiceRegistrar, srv WorkerServer)

Types

type ActivityReplyRequest 

type ActivityReplyRequest struct {
	Data   []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Result []byte `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Error  string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityReplyRequest) Descriptor deprecated 

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

Deprecated: Use ActivityReplyRequest.ProtoReflect.Descriptor instead.

func (*ActivityReplyRequest) GetData 

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

func (*ActivityReplyRequest) GetError 

func (x *ActivityReplyRequest) GetError() string

func (*ActivityReplyRequest) GetResult 

func (x *ActivityReplyRequest) GetResult() []byte

func (*ActivityReplyRequest) ProtoMessage 

func (*ActivityReplyRequest) ProtoMessage()

func (*ActivityReplyRequest) ProtoReflect 

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

func (*ActivityReplyRequest) Reset 

func (x *ActivityReplyRequest) Reset()

func (*ActivityReplyRequest) String 

func (x *ActivityReplyRequest) String() string

type ActivityReplyResponse 

type ActivityReplyResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityReplyResponse) Descriptor deprecated 

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

Deprecated: Use ActivityReplyResponse.ProtoReflect.Descriptor instead.

func (*ActivityReplyResponse) GetError 

func (x *ActivityReplyResponse) GetError() string

func (*ActivityReplyResponse) ProtoMessage 

func (*ActivityReplyResponse) ProtoMessage()

func (*ActivityReplyResponse) ProtoReflect 

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

func (*ActivityReplyResponse) Reset 

func (x *ActivityReplyResponse) Reset()

func (*ActivityReplyResponse) String 

func (x *ActivityReplyResponse) String() string

type ActivityRequest 

type ActivityRequest struct {
	RunnerId string `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Data     []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// call ID must be deterministic for replays
	CallInfo *CallInfo `protobuf:"bytes,3,opt,name=call_info,json=callInfo,proto3" json:"call_info,omitempty"` // for ak display
	// contains filtered or unexported fields
}

func (*ActivityRequest) Descriptor deprecated 

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

Deprecated: Use ActivityRequest.ProtoReflect.Descriptor instead.

func (*ActivityRequest) GetCallInfo 

func (x *ActivityRequest) GetCallInfo() *CallInfo

func (*ActivityRequest) GetData 

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

func (*ActivityRequest) GetRunnerId 

func (x *ActivityRequest) GetRunnerId() string

func (*ActivityRequest) ProtoMessage 

func (*ActivityRequest) ProtoMessage()

func (*ActivityRequest) ProtoReflect 

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

func (*ActivityRequest) Reset 

func (x *ActivityRequest) Reset()

func (*ActivityRequest) String 

func (x *ActivityRequest) String() string

type ActivityResponse 

type ActivityResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityResponse) Descriptor deprecated 

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

Deprecated: Use ActivityResponse.ProtoReflect.Descriptor instead.

func (*ActivityResponse) GetError 

func (x *ActivityResponse) GetError() string

func (*ActivityResponse) ProtoMessage 

func (*ActivityResponse) ProtoMessage()

func (*ActivityResponse) ProtoReflect 

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

func (*ActivityResponse) Reset 

func (x *ActivityResponse) Reset()

func (*ActivityResponse) String 

func (x *ActivityResponse) String() string

type CallInfo 

type CallInfo struct {
	Function string            `protobuf:"bytes,1,opt,name=function,proto3" json:"function,omitempty"`
	Args     []string          `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	Kwargs   map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CallInfo) Descriptor deprecated 

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

Deprecated: Use CallInfo.ProtoReflect.Descriptor instead.

func (*CallInfo) GetArgs 

func (x *CallInfo) GetArgs() []string

func (*CallInfo) GetFunction 

func (x *CallInfo) GetFunction() string

func (*CallInfo) GetKwargs 

func (x *CallInfo) GetKwargs() map[string]string

func (*CallInfo) ProtoMessage 

func (*CallInfo) ProtoMessage()

func (*CallInfo) ProtoReflect 

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

func (*CallInfo) Reset 

func (x *CallInfo) Reset()

func (*CallInfo) String 

func (x *CallInfo) String() string

type ContainerConfig 

type ContainerConfig struct {
	Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"` // TBD by @efiShtain
	// contains filtered or unexported fields
}

func (*ContainerConfig) Descriptor deprecated 

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

Deprecated: Use ContainerConfig.ProtoReflect.Descriptor instead.

func (*ContainerConfig) GetImage 

func (x *ContainerConfig) GetImage() string

func (*ContainerConfig) ProtoMessage 

func (*ContainerConfig) ProtoMessage()

func (*ContainerConfig) ProtoReflect 

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

func (*ContainerConfig) Reset 

func (x *ContainerConfig) Reset()

func (*ContainerConfig) String 

func (x *ContainerConfig) String() string

type DoneRequest 

type DoneRequest struct {
	RunnerId  string   `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Result    []byte   `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Error     string   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Traceback []*Frame `protobuf:"bytes,4,rep,name=traceback,proto3" json:"traceback,omitempty"`
	// contains filtered or unexported fields
}

func (*DoneRequest) Descriptor deprecated 

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

Deprecated: Use DoneRequest.ProtoReflect.Descriptor instead.

func (*DoneRequest) GetError 

func (x *DoneRequest) GetError() string

func (*DoneRequest) GetResult 

func (x *DoneRequest) GetResult() []byte

func (*DoneRequest) GetRunnerId 

func (x *DoneRequest) GetRunnerId() string

func (*DoneRequest) GetTraceback 

func (x *DoneRequest) GetTraceback() []*Frame

func (*DoneRequest) ProtoMessage 

func (*DoneRequest) ProtoMessage()

func (*DoneRequest) ProtoReflect 

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

func (*DoneRequest) Reset 

func (x *DoneRequest) Reset()

func (*DoneRequest) String 

func (x *DoneRequest) String() string

type DoneResponse 

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

func (*DoneResponse) Descriptor deprecated 

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

Deprecated: Use DoneResponse.ProtoReflect.Descriptor instead.

func (*DoneResponse) ProtoMessage 

func (*DoneResponse) ProtoMessage()

func (*DoneResponse) ProtoReflect 

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

func (*DoneResponse) Reset 

func (x *DoneResponse) Reset()

func (*DoneResponse) String 

func (x *DoneResponse) String() string

type EncodeJWTRequest added in v0.10.6 

type EncodeJWTRequest struct {
	RunnerId   string           `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Payload    map[string]int64 `` /* 156-byte string literal not displayed */
	Connection string           `protobuf:"bytes,3,opt,name=connection,proto3" json:"connection,omitempty"`
	Algorithm  string           `protobuf:"bytes,4,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	// contains filtered or unexported fields
}

func (*EncodeJWTRequest) Descriptor deprecated added in v0.10.6 

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

Deprecated: Use EncodeJWTRequest.ProtoReflect.Descriptor instead.

func (*EncodeJWTRequest) GetAlgorithm added in v0.10.6 

func (x *EncodeJWTRequest) GetAlgorithm() string

func (*EncodeJWTRequest) GetConnection added in v0.10.6 

func (x *EncodeJWTRequest) GetConnection() string

func (*EncodeJWTRequest) GetPayload added in v0.10.6 

func (x *EncodeJWTRequest) GetPayload() map[string]int64

func (*EncodeJWTRequest) GetRunnerId added in v0.10.6 

func (x *EncodeJWTRequest) GetRunnerId() string

func (*EncodeJWTRequest) ProtoMessage added in v0.10.6 

func (*EncodeJWTRequest) ProtoMessage()

func (*EncodeJWTRequest) ProtoReflect added in v0.10.6 

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

func (*EncodeJWTRequest) Reset added in v0.10.6 

func (x *EncodeJWTRequest) Reset()

func (*EncodeJWTRequest) String added in v0.10.6 

func (x *EncodeJWTRequest) String() string

type EncodeJWTResponse added in v0.10.6 

type EncodeJWTResponse struct {
	Jwt   string `protobuf:"bytes,1,opt,name=jwt,proto3" json:"jwt,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*EncodeJWTResponse) Descriptor deprecated added in v0.10.6 

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

Deprecated: Use EncodeJWTResponse.ProtoReflect.Descriptor instead.

func (*EncodeJWTResponse) GetError added in v0.10.6 

func (x *EncodeJWTResponse) GetError() string

func (*EncodeJWTResponse) GetJwt added in v0.10.6 

func (x *EncodeJWTResponse) GetJwt() string

func (*EncodeJWTResponse) ProtoMessage added in v0.10.6 

func (*EncodeJWTResponse) ProtoMessage()

func (*EncodeJWTResponse) ProtoReflect added in v0.10.6 

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

func (*EncodeJWTResponse) Reset added in v0.10.6 

func (x *EncodeJWTResponse) Reset()

func (*EncodeJWTResponse) String added in v0.10.6 

func (x *EncodeJWTResponse) String() string

type Event 

type Event struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // raw event from connection
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetData 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type ExecuteRequest 

type ExecuteRequest struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetData 

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

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect 

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

func (*ExecuteRequest) Reset 

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (x *ExecuteRequest) String() string

type ExecuteResponse 

type ExecuteResponse struct {
	Result    []byte   `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Error     string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Traceback []*Frame `protobuf:"bytes,3,rep,name=traceback,proto3" json:"traceback,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetError 

func (x *ExecuteResponse) GetError() string

func (*ExecuteResponse) GetResult 

func (x *ExecuteResponse) GetResult() []byte

func (*ExecuteResponse) GetTraceback 

func (x *ExecuteResponse) GetTraceback() []*Frame

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect 

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

func (*ExecuteResponse) Reset 

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String 

func (x *ExecuteResponse) String() string

type ExportsRequest 

type ExportsRequest struct {
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportsRequest) Descriptor deprecated 

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

Deprecated: Use ExportsRequest.ProtoReflect.Descriptor instead.

func (*ExportsRequest) GetFileName 

func (x *ExportsRequest) GetFileName() string

func (*ExportsRequest) ProtoMessage 

func (*ExportsRequest) ProtoMessage()

func (*ExportsRequest) ProtoReflect 

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

func (*ExportsRequest) Reset 

func (x *ExportsRequest) Reset()

func (*ExportsRequest) String 

func (x *ExportsRequest) String() string

type ExportsResponse 

type ExportsResponse struct {
	Exports []string `protobuf:"bytes,1,rep,name=exports,proto3" json:"exports,omitempty"`
	Error   string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportsResponse) Descriptor deprecated 

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

Deprecated: Use ExportsResponse.ProtoReflect.Descriptor instead.

func (*ExportsResponse) GetError 

func (x *ExportsResponse) GetError() string

func (*ExportsResponse) GetExports 

func (x *ExportsResponse) GetExports() []string

func (*ExportsResponse) ProtoMessage 

func (*ExportsResponse) ProtoMessage()

func (*ExportsResponse) ProtoReflect 

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

func (*ExportsResponse) Reset 

func (x *ExportsResponse) Reset()

func (*ExportsResponse) String 

func (x *ExportsResponse) String() string

type Frame 

type Frame struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Lineno   uint32 `protobuf:"varint,2,opt,name=lineno,proto3" json:"lineno,omitempty"`
	Code     string `protobuf:"bytes,3,opt,name=code,proto3" json:"code,omitempty"`
	Name     string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Frame) Descriptor deprecated 

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

Deprecated: Use Frame.ProtoReflect.Descriptor instead.

func (*Frame) GetCode 

func (x *Frame) GetCode() string

func (*Frame) GetFilename 

func (x *Frame) GetFilename() string

func (*Frame) GetLineno 

func (x *Frame) GetLineno() uint32

func (*Frame) GetName 

func (x *Frame) GetName() string

func (*Frame) ProtoMessage 

func (*Frame) ProtoMessage()

func (*Frame) ProtoReflect 

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

func (*Frame) Reset 

func (x *Frame) Reset()

func (*Frame) String 

func (x *Frame) String() string

type HealthRequest 

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

func (*HealthRequest) Descriptor deprecated 

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

Deprecated: Use HealthRequest.ProtoReflect.Descriptor instead.

func (*HealthRequest) ProtoMessage 

func (*HealthRequest) ProtoMessage()

func (*HealthRequest) ProtoReflect 

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

func (*HealthRequest) Reset 

func (x *HealthRequest) Reset()

func (*HealthRequest) String 

func (x *HealthRequest) String() string

type HealthResponse 

type HealthResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthResponse) Descriptor deprecated 

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

Deprecated: Use HealthResponse.ProtoReflect.Descriptor instead.

func (*HealthResponse) GetError 

func (x *HealthResponse) GetError() string

func (*HealthResponse) ProtoMessage 

func (*HealthResponse) ProtoMessage()

func (*HealthResponse) ProtoReflect 

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

func (*HealthResponse) Reset 

func (x *HealthResponse) Reset()

func (*HealthResponse) String 

func (x *HealthResponse) String() string

type IsActiveRunnerRequest 

type IsActiveRunnerRequest struct {
	RunnerId string `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	// contains filtered or unexported fields
}

func (*IsActiveRunnerRequest) Descriptor deprecated 

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

Deprecated: Use IsActiveRunnerRequest.ProtoReflect.Descriptor instead.

func (*IsActiveRunnerRequest) GetRunnerId 

func (x *IsActiveRunnerRequest) GetRunnerId() string

func (*IsActiveRunnerRequest) ProtoMessage 

func (*IsActiveRunnerRequest) ProtoMessage()

func (*IsActiveRunnerRequest) ProtoReflect 

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

func (*IsActiveRunnerRequest) Reset 

func (x *IsActiveRunnerRequest) Reset()

func (*IsActiveRunnerRequest) String 

func (x *IsActiveRunnerRequest) String() string

type IsActiveRunnerResponse 

type IsActiveRunnerResponse struct {
	IsActive bool   `protobuf:"varint,1,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	Error    string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*IsActiveRunnerResponse) Descriptor deprecated 

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

Deprecated: Use IsActiveRunnerResponse.ProtoReflect.Descriptor instead.

func (*IsActiveRunnerResponse) GetError 

func (x *IsActiveRunnerResponse) GetError() string

func (*IsActiveRunnerResponse) GetIsActive 

func (x *IsActiveRunnerResponse) GetIsActive() bool

func (*IsActiveRunnerResponse) ProtoMessage 

func (*IsActiveRunnerResponse) ProtoMessage()

func (*IsActiveRunnerResponse) ProtoReflect 

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

func (*IsActiveRunnerResponse) Reset 

func (x *IsActiveRunnerResponse) Reset()

func (*IsActiveRunnerResponse) String 

func (x *IsActiveRunnerResponse) String() string

type LogRequest 

type LogRequest struct {
	RunnerId string `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Level    string `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty"`
	Message  string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*LogRequest) Descriptor deprecated 

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

Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.

func (*LogRequest) GetLevel 

func (x *LogRequest) GetLevel() string

func (*LogRequest) GetMessage 

func (x *LogRequest) GetMessage() string

func (*LogRequest) GetRunnerId 

func (x *LogRequest) GetRunnerId() string

func (*LogRequest) ProtoMessage 

func (*LogRequest) ProtoMessage()

func (*LogRequest) ProtoReflect 

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

func (*LogRequest) Reset 

func (x *LogRequest) Reset()

func (*LogRequest) String 

func (x *LogRequest) String() string

type LogResponse 

type LogResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*LogResponse) Descriptor deprecated 

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

Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.

func (*LogResponse) GetError 

func (x *LogResponse) GetError() string

func (*LogResponse) ProtoMessage 

func (*LogResponse) ProtoMessage()

func (*LogResponse) ProtoReflect 

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

func (*LogResponse) Reset 

func (x *LogResponse) Reset()

func (*LogResponse) String 

func (x *LogResponse) String() string

type NextEventRequest 

type NextEventRequest struct {
	RunnerId  string   `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	SignalIds []string `protobuf:"bytes,2,rep,name=signal_ids,json=signalIds,proto3" json:"signal_ids,omitempty"`
	TimeoutMs int64    `protobuf:"varint,3,opt,name=timeout_ms,json=timeoutMs,proto3" json:"timeout_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*NextEventRequest) Descriptor deprecated 

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

Deprecated: Use NextEventRequest.ProtoReflect.Descriptor instead.

func (*NextEventRequest) GetRunnerId 

func (x *NextEventRequest) GetRunnerId() string

func (*NextEventRequest) GetSignalIds 

func (x *NextEventRequest) GetSignalIds() []string

func (*NextEventRequest) GetTimeoutMs 

func (x *NextEventRequest) GetTimeoutMs() int64

func (*NextEventRequest) ProtoMessage 

func (*NextEventRequest) ProtoMessage()

func (*NextEventRequest) ProtoReflect 

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

func (*NextEventRequest) Reset 

func (x *NextEventRequest) Reset()

func (*NextEventRequest) String 

func (x *NextEventRequest) String() string

type NextEventResponse 

type NextEventResponse struct {
	Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*NextEventResponse) Descriptor deprecated 

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

Deprecated: Use NextEventResponse.ProtoReflect.Descriptor instead.

func (*NextEventResponse) GetError 

func (x *NextEventResponse) GetError() string

func (*NextEventResponse) GetEvent 

func (x *NextEventResponse) GetEvent() *Event

func (*NextEventResponse) ProtoMessage 

func (*NextEventResponse) ProtoMessage()

func (*NextEventResponse) ProtoReflect 

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

func (*NextEventResponse) Reset 

func (x *NextEventResponse) Reset()

func (*NextEventResponse) String 

func (x *NextEventResponse) String() string

type PrintRequest 

type PrintRequest struct {
	RunnerId string `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Message  string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*PrintRequest) Descriptor deprecated 

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

Deprecated: Use PrintRequest.ProtoReflect.Descriptor instead.

func (*PrintRequest) GetMessage 

func (x *PrintRequest) GetMessage() string

func (*PrintRequest) GetRunnerId 

func (x *PrintRequest) GetRunnerId() string

func (*PrintRequest) ProtoMessage 

func (*PrintRequest) ProtoMessage()

func (*PrintRequest) ProtoReflect 

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

func (*PrintRequest) Reset 

func (x *PrintRequest) Reset()

func (*PrintRequest) String 

func (x *PrintRequest) String() string

type PrintResponse 

type PrintResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*PrintResponse) Descriptor deprecated 

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

Deprecated: Use PrintResponse.ProtoReflect.Descriptor instead.

func (*PrintResponse) GetError 

func (x *PrintResponse) GetError() string

func (*PrintResponse) ProtoMessage 

func (*PrintResponse) ProtoMessage()

func (*PrintResponse) ProtoReflect 

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

func (*PrintResponse) Reset 

func (x *PrintResponse) Reset()

func (*PrintResponse) String 

func (x *PrintResponse) String() string

type RefreshRequest added in v0.10.4 

type RefreshRequest struct {
	RunnerId    string `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Integration string `protobuf:"bytes,2,opt,name=integration,proto3" json:"integration,omitempty"`
	Connection  string `protobuf:"bytes,3,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshRequest) Descriptor deprecated added in v0.10.4 

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

Deprecated: Use RefreshRequest.ProtoReflect.Descriptor instead.

func (*RefreshRequest) GetConnection added in v0.10.4 

func (x *RefreshRequest) GetConnection() string

func (*RefreshRequest) GetIntegration added in v0.10.4 

func (x *RefreshRequest) GetIntegration() string

func (*RefreshRequest) GetRunnerId added in v0.10.4 

func (x *RefreshRequest) GetRunnerId() string

func (*RefreshRequest) ProtoMessage added in v0.10.4 

func (*RefreshRequest) ProtoMessage()

func (*RefreshRequest) ProtoReflect added in v0.10.4 

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

func (*RefreshRequest) Reset added in v0.10.4 

func (x *RefreshRequest) Reset()

func (*RefreshRequest) String added in v0.10.4 

func (x *RefreshRequest) String() string

type RefreshResponse added in v0.10.4 

type RefreshResponse struct {
	Token   string                 `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Expires *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires,proto3" json:"expires,omitempty"`
	Error   string                 `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshResponse) Descriptor deprecated added in v0.10.4 

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

Deprecated: Use RefreshResponse.ProtoReflect.Descriptor instead.

func (*RefreshResponse) GetError added in v0.10.4 

func (x *RefreshResponse) GetError() string

func (*RefreshResponse) GetExpires added in v0.10.4 

func (x *RefreshResponse) GetExpires() *timestamppb.Timestamp

func (*RefreshResponse) GetToken added in v0.10.4 

func (x *RefreshResponse) GetToken() string

func (*RefreshResponse) ProtoMessage added in v0.10.4 

func (*RefreshResponse) ProtoMessage()

func (*RefreshResponse) ProtoReflect added in v0.10.4 

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

func (*RefreshResponse) Reset added in v0.10.4 

func (x *RefreshResponse) Reset()

func (*RefreshResponse) String added in v0.10.4 

func (x *RefreshResponse) String() string

type RunnerClient 

type RunnerClient interface {
	// Get exports
	Exports(ctx context.Context, in *ExportsRequest, opts ...grpc.CallOption) (*ExportsResponse, error)
	// Called at start of session
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	// Execute a function in the runtime (skipped if it's a reply)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
	// Reply from activity
	ActivityReply(ctx context.Context, in *ActivityReplyRequest, opts ...grpc.CallOption) (*ActivityReplyResponse, error)
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
}

RunnerClient is the client API for Runner 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 NewRunnerClient 

func NewRunnerClient(cc grpc.ClientConnInterface) RunnerClient

type RunnerHealthRequest 

type RunnerHealthRequest struct {
	RunnerId string `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RunnerHealthRequest) Descriptor deprecated 

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

Deprecated: Use RunnerHealthRequest.ProtoReflect.Descriptor instead.

func (*RunnerHealthRequest) GetRunnerId 

func (x *RunnerHealthRequest) GetRunnerId() string

func (*RunnerHealthRequest) ProtoMessage 

func (*RunnerHealthRequest) ProtoMessage()

func (*RunnerHealthRequest) ProtoReflect 

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

func (*RunnerHealthRequest) Reset 

func (x *RunnerHealthRequest) Reset()

func (*RunnerHealthRequest) String 

func (x *RunnerHealthRequest) String() string

type RunnerHealthResponse 

type RunnerHealthResponse struct {
	Healthy bool   `protobuf:"varint,1,opt,name=healthy,proto3" json:"healthy,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RunnerHealthResponse) Descriptor deprecated 

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

Deprecated: Use RunnerHealthResponse.ProtoReflect.Descriptor instead.

func (*RunnerHealthResponse) GetError 

func (x *RunnerHealthResponse) GetError() string

func (*RunnerHealthResponse) GetHealthy 

func (x *RunnerHealthResponse) GetHealthy() bool

func (*RunnerHealthResponse) ProtoMessage 

func (*RunnerHealthResponse) ProtoMessage()

func (*RunnerHealthResponse) ProtoReflect 

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

func (*RunnerHealthResponse) Reset 

func (x *RunnerHealthResponse) Reset()

func (*RunnerHealthResponse) String 

func (x *RunnerHealthResponse) String() string

type RunnerManagerClient 

type RunnerManagerClient interface {
	Start(ctx context.Context, in *StartRunnerRequest, opts ...grpc.CallOption) (*StartRunnerResponse, error)
	RunnerHealth(ctx context.Context, in *RunnerHealthRequest, opts ...grpc.CallOption) (*RunnerHealthResponse, error)
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
}

RunnerManagerClient is the client API for RunnerManager 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 NewRunnerManagerClient 

func NewRunnerManagerClient(cc grpc.ClientConnInterface) RunnerManagerClient

type RunnerManagerServer 

type RunnerManagerServer interface {
	Start(context.Context, *StartRunnerRequest) (*StartRunnerResponse, error)
	RunnerHealth(context.Context, *RunnerHealthRequest) (*RunnerHealthResponse, error)
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	// contains filtered or unexported methods
}

RunnerManagerServer is the server API for RunnerManager service. All implementations must embed UnimplementedRunnerManagerServer for forward compatibility.

type RunnerServer 

type RunnerServer interface {
	// Get exports
	Exports(context.Context, *ExportsRequest) (*ExportsResponse, error)
	// Called at start of session
	Start(context.Context, *StartRequest) (*StartResponse, error)
	// Execute a function in the runtime (skipped if it's a reply)
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	// Reply from activity
	ActivityReply(context.Context, *ActivityReplyRequest) (*ActivityReplyResponse, error)
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	// contains filtered or unexported methods
}

RunnerServer is the server API for Runner service. All implementations must embed UnimplementedRunnerServer for forward compatibility.

type SleepRequest 

type SleepRequest struct {
	RunnerId   string `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	DurationMs int64  `protobuf:"varint,2,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*SleepRequest) Descriptor deprecated 

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

Deprecated: Use SleepRequest.ProtoReflect.Descriptor instead.

func (*SleepRequest) GetDurationMs 

func (x *SleepRequest) GetDurationMs() int64

func (*SleepRequest) GetRunnerId 

func (x *SleepRequest) GetRunnerId() string

func (*SleepRequest) ProtoMessage 

func (*SleepRequest) ProtoMessage()

func (*SleepRequest) ProtoReflect 

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

func (*SleepRequest) Reset 

func (x *SleepRequest) Reset()

func (*SleepRequest) String 

func (x *SleepRequest) String() string

type SleepResponse 

type SleepResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*SleepResponse) Descriptor deprecated 

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

Deprecated: Use SleepResponse.ProtoReflect.Descriptor instead.

func (*SleepResponse) GetError 

func (x *SleepResponse) GetError() string

func (*SleepResponse) ProtoMessage 

func (*SleepResponse) ProtoMessage()

func (*SleepResponse) ProtoReflect 

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

func (*SleepResponse) Reset 

func (x *SleepResponse) Reset()

func (*SleepResponse) String 

func (x *SleepResponse) String() string

type StartRequest 

type StartRequest struct {
	EntryPoint string `protobuf:"bytes,1,opt,name=entry_point,json=entryPoint,proto3" json:"entry_point,omitempty"` // "main.py:on_event"
	Event      *Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*StartRequest) Descriptor deprecated 

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

Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.

func (*StartRequest) GetEntryPoint 

func (x *StartRequest) GetEntryPoint() string

func (*StartRequest) GetEvent 

func (x *StartRequest) GetEvent() *Event

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) ProtoReflect 

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

func (*StartRequest) Reset 

func (x *StartRequest) Reset()

func (*StartRequest) String 

func (x *StartRequest) String() string

type StartResponse 

type StartResponse struct {
	Error     string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Traceback []*Frame `protobuf:"bytes,2,rep,name=traceback,proto3" json:"traceback,omitempty"`
	// contains filtered or unexported fields
}

func (*StartResponse) Descriptor deprecated 

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

Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.

func (*StartResponse) GetError 

func (x *StartResponse) GetError() string

func (*StartResponse) GetTraceback 

func (x *StartResponse) GetTraceback() []*Frame

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) ProtoReflect 

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

func (*StartResponse) Reset 

func (x *StartResponse) Reset()

func (*StartResponse) String 

func (x *StartResponse) String() string

type StartRunnerRequest 

type StartRunnerRequest struct {
	ContainerConfig *ContainerConfig `protobuf:"bytes,1,opt,name=container_config,json=containerConfig,proto3" json:"container_config,omitempty"`
	// user code as tar archive
	BuildArtifact []byte `protobuf:"bytes,2,opt,name=build_artifact,json=buildArtifact,proto3" json:"build_artifact,omitempty"`
	// vars from manifest, secrets and connections
	Vars          map[string]string `` /* 149-byte string literal not displayed */
	WorkerAddress string            `protobuf:"bytes,4,opt,name=worker_address,json=workerAddress,proto3" json:"worker_address,omitempty"`
	// contains filtered or unexported fields
}

TODO: Will become Start once we split to files Tell runner manager to start a runner

func (*StartRunnerRequest) Descriptor deprecated 

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

Deprecated: Use StartRunnerRequest.ProtoReflect.Descriptor instead.

func (*StartRunnerRequest) GetBuildArtifact 

func (x *StartRunnerRequest) GetBuildArtifact() []byte

func (*StartRunnerRequest) GetContainerConfig 

func (x *StartRunnerRequest) GetContainerConfig() *ContainerConfig

func (*StartRunnerRequest) GetVars 

func (x *StartRunnerRequest) GetVars() map[string]string

func (*StartRunnerRequest) GetWorkerAddress 

func (x *StartRunnerRequest) GetWorkerAddress() string

func (*StartRunnerRequest) ProtoMessage 

func (*StartRunnerRequest) ProtoMessage()

func (*StartRunnerRequest) ProtoReflect 

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

func (*StartRunnerRequest) Reset 

func (x *StartRunnerRequest) Reset()

func (*StartRunnerRequest) String 

func (x *StartRunnerRequest) String() string

type StartRunnerResponse 

type StartRunnerResponse struct {
	RunnerId      string `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	RunnerAddress string `protobuf:"bytes,2,opt,name=runner_address,json=runnerAddress,proto3" json:"runner_address,omitempty"`
	Error         string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*StartRunnerResponse) Descriptor deprecated 

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

Deprecated: Use StartRunnerResponse.ProtoReflect.Descriptor instead.

func (*StartRunnerResponse) GetError 

func (x *StartRunnerResponse) GetError() string

func (*StartRunnerResponse) GetRunnerAddress 

func (x *StartRunnerResponse) GetRunnerAddress() string

func (*StartRunnerResponse) GetRunnerId 

func (x *StartRunnerResponse) GetRunnerId() string

func (*StartRunnerResponse) ProtoMessage 

func (*StartRunnerResponse) ProtoMessage()

func (*StartRunnerResponse) ProtoReflect 

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

func (*StartRunnerResponse) Reset 

func (x *StartRunnerResponse) Reset()

func (*StartRunnerResponse) String 

func (x *StartRunnerResponse) String() string

type StartSessionRequest added in v0.10.4 

type StartSessionRequest struct {
	RunnerId string `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Loc      string `protobuf:"bytes,2,opt,name=loc,proto3" json:"loc,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Memo     []byte `protobuf:"bytes,4,opt,name=memo,proto3" json:"memo,omitempty"`
	// contains filtered or unexported fields
}

func (*StartSessionRequest) Descriptor deprecated added in v0.10.4 

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

Deprecated: Use StartSessionRequest.ProtoReflect.Descriptor instead.

func (*StartSessionRequest) GetData added in v0.10.4 

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

func (*StartSessionRequest) GetLoc added in v0.10.4 

func (x *StartSessionRequest) GetLoc() string

func (*StartSessionRequest) GetMemo added in v0.10.4 

func (x *StartSessionRequest) GetMemo() []byte

func (*StartSessionRequest) GetRunnerId added in v0.10.4 

func (x *StartSessionRequest) GetRunnerId() string

func (*StartSessionRequest) ProtoMessage added in v0.10.4 

func (*StartSessionRequest) ProtoMessage()

func (*StartSessionRequest) ProtoReflect added in v0.10.4 

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

func (*StartSessionRequest) Reset added in v0.10.4 

func (x *StartSessionRequest) Reset()

func (*StartSessionRequest) String added in v0.10.4 

func (x *StartSessionRequest) String() string

type StartSessionResponse added in v0.10.4 

type StartSessionResponse struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Error     string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*StartSessionResponse) Descriptor deprecated added in v0.10.4 

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

Deprecated: Use StartSessionResponse.ProtoReflect.Descriptor instead.

func (*StartSessionResponse) GetError added in v0.10.4 

func (x *StartSessionResponse) GetError() string

func (*StartSessionResponse) GetSessionId added in v0.10.4 

func (x *StartSessionResponse) GetSessionId() string

func (*StartSessionResponse) ProtoMessage added in v0.10.4 

func (*StartSessionResponse) ProtoMessage()

func (*StartSessionResponse) ProtoReflect added in v0.10.4 

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

func (*StartSessionResponse) Reset added in v0.10.4 

func (x *StartSessionResponse) Reset()

func (*StartSessionResponse) String added in v0.10.4 

func (x *StartSessionResponse) String() string

type StopRequest 

type StopRequest struct {
	RunnerId string `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StopRequest) Descriptor deprecated 

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

Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.

func (*StopRequest) GetRunnerId 

func (x *StopRequest) GetRunnerId() string

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) ProtoReflect 

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

func (*StopRequest) Reset 

func (x *StopRequest) Reset()

func (*StopRequest) String 

func (x *StopRequest) String() string

type StopResponse 

type StopResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*StopResponse) Descriptor deprecated 

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

Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.

func (*StopResponse) GetError 

func (x *StopResponse) GetError() string

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) ProtoReflect 

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

func (*StopResponse) Reset 

func (x *StopResponse) Reset()

func (*StopResponse) String 

func (x *StopResponse) String() string

type SubscribeRequest 

type SubscribeRequest struct {
	RunnerId   string `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	Connection string `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	Filter     string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetConnection 

func (x *SubscribeRequest) GetConnection() string

func (*SubscribeRequest) GetFilter 

func (x *SubscribeRequest) GetFilter() string

func (*SubscribeRequest) GetRunnerId 

func (x *SubscribeRequest) GetRunnerId() string

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeResponse 

type SubscribeResponse struct {
	SignalId string `protobuf:"bytes,1,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	Error    string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetError 

func (x *SubscribeResponse) GetError() string

func (*SubscribeResponse) GetSignalId 

func (x *SubscribeResponse) GetSignalId() string

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

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

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *SubscribeResponse) String() string

type UnimplementedRunnerManagerServer 

type UnimplementedRunnerManagerServer struct{}

UnimplementedRunnerManagerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedRunnerManagerServer) Health 

func (UnimplementedRunnerManagerServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)

func (UnimplementedRunnerManagerServer) RunnerHealth 

func (UnimplementedRunnerManagerServer) RunnerHealth(context.Context, *RunnerHealthRequest) (*RunnerHealthResponse, error)

func (UnimplementedRunnerManagerServer) Start 

func (UnimplementedRunnerManagerServer) Start(context.Context, *StartRunnerRequest) (*StartRunnerResponse, error)

func (UnimplementedRunnerManagerServer) Stop 

func (UnimplementedRunnerManagerServer) Stop(context.Context, *StopRequest) (*StopResponse, error)

type UnimplementedRunnerServer 

type UnimplementedRunnerServer struct{}

UnimplementedRunnerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedRunnerServer) ActivityReply 

func (UnimplementedRunnerServer) ActivityReply(context.Context, *ActivityReplyRequest) (*ActivityReplyResponse, error)

func (UnimplementedRunnerServer) Execute 

func (UnimplementedRunnerServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)

func (UnimplementedRunnerServer) Exports 

func (UnimplementedRunnerServer) Exports(context.Context, *ExportsRequest) (*ExportsResponse, error)

func (UnimplementedRunnerServer) Health 

func (UnimplementedRunnerServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)

func (UnimplementedRunnerServer) Start 

func (UnimplementedRunnerServer) Start(context.Context, *StartRequest) (*StartResponse, error)

type UnimplementedWorkerServer 

type UnimplementedWorkerServer struct{}

UnimplementedWorkerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedWorkerServer) Activity 

func (UnimplementedWorkerServer) Activity(context.Context, *ActivityRequest) (*ActivityResponse, error)

func (UnimplementedWorkerServer) Done 

func (UnimplementedWorkerServer) Done(context.Context, *DoneRequest) (*DoneResponse, error)

func (UnimplementedWorkerServer) EncodeJWT added in v0.10.6 

func (UnimplementedWorkerServer) EncodeJWT(context.Context, *EncodeJWTRequest) (*EncodeJWTResponse, error)

func (UnimplementedWorkerServer) Health 

func (UnimplementedWorkerServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)

func (UnimplementedWorkerServer) IsActiveRunner 

func (UnimplementedWorkerServer) IsActiveRunner(context.Context, *IsActiveRunnerRequest) (*IsActiveRunnerResponse, error)

func (UnimplementedWorkerServer) Log 

func (UnimplementedWorkerServer) Log(context.Context, *LogRequest) (*LogResponse, error)

func (UnimplementedWorkerServer) NextEvent 

func (UnimplementedWorkerServer) NextEvent(context.Context, *NextEventRequest) (*NextEventResponse, error)

func (UnimplementedWorkerServer) Print 

func (UnimplementedWorkerServer) Print(context.Context, *PrintRequest) (*PrintResponse, error)

func (UnimplementedWorkerServer) RefreshOAuthToken added in v0.10.4 

func (UnimplementedWorkerServer) RefreshOAuthToken(context.Context, *RefreshRequest) (*RefreshResponse, error)

func (UnimplementedWorkerServer) Sleep 

func (UnimplementedWorkerServer) Sleep(context.Context, *SleepRequest) (*SleepResponse, error)

func (UnimplementedWorkerServer) StartSession added in v0.10.4 

func (UnimplementedWorkerServer) StartSession(context.Context, *StartSessionRequest) (*StartSessionResponse, error)

func (UnimplementedWorkerServer) Subscribe 

func (UnimplementedWorkerServer) Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)

func (UnimplementedWorkerServer) Unsubscribe 

func (UnimplementedWorkerServer) Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, error)

type UnsafeRunnerManagerServer 

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

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

type UnsafeRunnerServer 

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

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

type UnsafeWorkerServer 

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

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

type UnsubscribeRequest 

type UnsubscribeRequest struct {
	RunnerId string `protobuf:"bytes,1,opt,name=runner_id,json=runnerId,proto3" json:"runner_id,omitempty"`
	SignalId string `protobuf:"bytes,2,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeRequest) Descriptor deprecated 

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

Deprecated: Use UnsubscribeRequest.ProtoReflect.Descriptor instead.

func (*UnsubscribeRequest) GetRunnerId 

func (x *UnsubscribeRequest) GetRunnerId() string

func (*UnsubscribeRequest) GetSignalId 

func (x *UnsubscribeRequest) GetSignalId() string

func (*UnsubscribeRequest) ProtoMessage 

func (*UnsubscribeRequest) ProtoMessage()

func (*UnsubscribeRequest) ProtoReflect 

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

func (*UnsubscribeRequest) Reset 

func (x *UnsubscribeRequest) Reset()

func (*UnsubscribeRequest) String 

func (x *UnsubscribeRequest) String() string

type UnsubscribeResponse 

type UnsubscribeResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeResponse) Descriptor deprecated 

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

Deprecated: Use UnsubscribeResponse.ProtoReflect.Descriptor instead.

func (*UnsubscribeResponse) GetError 

func (x *UnsubscribeResponse) GetError() string

func (*UnsubscribeResponse) ProtoMessage 

func (*UnsubscribeResponse) ProtoMessage()

func (*UnsubscribeResponse) ProtoReflect 

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

func (*UnsubscribeResponse) Reset 

func (x *UnsubscribeResponse) Reset()

func (*UnsubscribeResponse) String 

func (x *UnsubscribeResponse) String() string

type WorkerClient 

type WorkerClient interface {
	// Runner starting activity
	Activity(ctx context.Context, in *ActivityRequest, opts ...grpc.CallOption) (*ActivityResponse, error)
	// Runner done with activity
	Done(ctx context.Context, in *DoneRequest, opts ...grpc.CallOption) (*DoneResponse, error)
	// Session logs
	Log(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*LogResponse, error)
	// Print to session log
	Print(ctx context.Context, in *PrintRequest, opts ...grpc.CallOption) (*PrintResponse, error)
	// ak functions
	Sleep(ctx context.Context, in *SleepRequest, opts ...grpc.CallOption) (*SleepResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)
	NextEvent(ctx context.Context, in *NextEventRequest, opts ...grpc.CallOption) (*NextEventResponse, error)
	Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*UnsubscribeResponse, error)
	StartSession(ctx context.Context, in *StartSessionRequest, opts ...grpc.CallOption) (*StartSessionResponse, error)
	// Utility functions
	EncodeJWT(ctx context.Context, in *EncodeJWTRequest, opts ...grpc.CallOption) (*EncodeJWTResponse, error)
	RefreshOAuthToken(ctx context.Context, in *RefreshRequest, opts ...grpc.CallOption) (*RefreshResponse, error)
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
	IsActiveRunner(ctx context.Context, in *IsActiveRunnerRequest, opts ...grpc.CallOption) (*IsActiveRunnerResponse, error)
}

WorkerClient is the client API for Worker 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 NewWorkerClient 

func NewWorkerClient(cc grpc.ClientConnInterface) WorkerClient

type WorkerServer 

type WorkerServer interface {
	// Runner starting activity
	Activity(context.Context, *ActivityRequest) (*ActivityResponse, error)
	// Runner done with activity
	Done(context.Context, *DoneRequest) (*DoneResponse, error)
	// Session logs
	Log(context.Context, *LogRequest) (*LogResponse, error)
	// Print to session log
	Print(context.Context, *PrintRequest) (*PrintResponse, error)
	// ak functions
	Sleep(context.Context, *SleepRequest) (*SleepResponse, error)
	Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)
	NextEvent(context.Context, *NextEventRequest) (*NextEventResponse, error)
	Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, error)
	StartSession(context.Context, *StartSessionRequest) (*StartSessionResponse, error)
	// Utility functions
	EncodeJWT(context.Context, *EncodeJWTRequest) (*EncodeJWTResponse, error)
	RefreshOAuthToken(context.Context, *RefreshRequest) (*RefreshResponse, error)
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	IsActiveRunner(context.Context, *IsActiveRunnerRequest) (*IsActiveRunnerResponse, error)
	// contains filtered or unexported methods
}

WorkerServer is the server API for Worker service. All implementations must embed UnimplementedWorkerServer for forward compatibility.

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.