user_codev1

package
v0.10.12 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	HandlerService_Activity_FullMethodName          = "/autokitteh.user_code.v1.HandlerService/Activity"
	HandlerService_Done_FullMethodName              = "/autokitteh.user_code.v1.HandlerService/Done"
	HandlerService_Log_FullMethodName               = "/autokitteh.user_code.v1.HandlerService/Log"
	HandlerService_Print_FullMethodName             = "/autokitteh.user_code.v1.HandlerService/Print"
	HandlerService_Sleep_FullMethodName             = "/autokitteh.user_code.v1.HandlerService/Sleep"
	HandlerService_Subscribe_FullMethodName         = "/autokitteh.user_code.v1.HandlerService/Subscribe"
	HandlerService_NextEvent_FullMethodName         = "/autokitteh.user_code.v1.HandlerService/NextEvent"
	HandlerService_Unsubscribe_FullMethodName       = "/autokitteh.user_code.v1.HandlerService/Unsubscribe"
	HandlerService_StartSession_FullMethodName      = "/autokitteh.user_code.v1.HandlerService/StartSession"
	HandlerService_EncodeJWT_FullMethodName         = "/autokitteh.user_code.v1.HandlerService/EncodeJWT"
	HandlerService_RefreshOAuthToken_FullMethodName = "/autokitteh.user_code.v1.HandlerService/RefreshOAuthToken"
	HandlerService_Health_FullMethodName            = "/autokitteh.user_code.v1.HandlerService/Health"
	HandlerService_IsActiveRunner_FullMethodName    = "/autokitteh.user_code.v1.HandlerService/IsActiveRunner"
)
View Source 
const (
	RunnerService_Exports_FullMethodName       = "/autokitteh.user_code.v1.RunnerService/Exports"
	RunnerService_Start_FullMethodName         = "/autokitteh.user_code.v1.RunnerService/Start"
	RunnerService_Execute_FullMethodName       = "/autokitteh.user_code.v1.RunnerService/Execute"
	RunnerService_ActivityReply_FullMethodName = "/autokitteh.user_code.v1.RunnerService/ActivityReply"
	RunnerService_Health_FullMethodName        = "/autokitteh.user_code.v1.RunnerService/Health"
)

Variables

View Source 
var File_autokitteh_user_code_v1_handler_svc_proto protoreflect.FileDescriptor
View Source 
var File_autokitteh_user_code_v1_runner_svc_proto protoreflect.FileDescriptor
View Source 
var File_autokitteh_user_code_v1_user_code_proto protoreflect.FileDescriptor
View Source 
var HandlerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "autokitteh.user_code.v1.HandlerService",
	HandlerType: (*HandlerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Activity",
			Handler:    _HandlerService_Activity_Handler,
		},
		{
			MethodName: "Done",
			Handler:    _HandlerService_Done_Handler,
		},
		{
			MethodName: "Log",
			Handler:    _HandlerService_Log_Handler,
		},
		{
			MethodName: "Print",
			Handler:    _HandlerService_Print_Handler,
		},
		{
			MethodName: "Sleep",
			Handler:    _HandlerService_Sleep_Handler,
		},
		{
			MethodName: "Subscribe",
			Handler:    _HandlerService_Subscribe_Handler,
		},
		{
			MethodName: "NextEvent",
			Handler:    _HandlerService_NextEvent_Handler,
		},
		{
			MethodName: "Unsubscribe",
			Handler:    _HandlerService_Unsubscribe_Handler,
		},
		{
			MethodName: "StartSession",
			Handler:    _HandlerService_StartSession_Handler,
		},
		{
			MethodName: "EncodeJWT",
			Handler:    _HandlerService_EncodeJWT_Handler,
		},
		{
			MethodName: "RefreshOAuthToken",
			Handler:    _HandlerService_RefreshOAuthToken_Handler,
		},
		{
			MethodName: "Health",
			Handler:    _HandlerService_Health_Handler,
		},
		{
			MethodName: "IsActiveRunner",
			Handler:    _HandlerService_IsActiveRunner_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "autokitteh/user_code/v1/handler_svc.proto",
}

HandlerService_ServiceDesc is the grpc.ServiceDesc for HandlerService 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 RunnerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "autokitteh.user_code.v1.RunnerService",
	HandlerType: (*RunnerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Exports",
			Handler:    _RunnerService_Exports_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _RunnerService_Start_Handler,
		},
		{
			MethodName: "Execute",
			Handler:    _RunnerService_Execute_Handler,
		},
		{
			MethodName: "ActivityReply",
			Handler:    _RunnerService_ActivityReply_Handler,
		},
		{
			MethodName: "Health",
			Handler:    _RunnerService_Health_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "autokitteh/user_code/v1/runner_svc.proto",
}

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

Functions

func RegisterHandlerServiceServer 

func RegisterHandlerServiceServer(s grpc.ServiceRegistrar, srv HandlerServiceServer)

func RegisterRunnerServiceServer 

func RegisterRunnerServiceServer(s grpc.ServiceRegistrar, srv RunnerServiceServer)

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

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 

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

Deprecated: Use EncodeJWTRequest.ProtoReflect.Descriptor instead.

func (*EncodeJWTRequest) GetAlgorithm 

func (x *EncodeJWTRequest) GetAlgorithm() string

func (*EncodeJWTRequest) GetConnection 

func (x *EncodeJWTRequest) GetConnection() string

func (*EncodeJWTRequest) GetPayload 

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

func (*EncodeJWTRequest) GetRunnerId 

func (x *EncodeJWTRequest) GetRunnerId() string

func (*EncodeJWTRequest) ProtoMessage 

func (*EncodeJWTRequest) ProtoMessage()

func (*EncodeJWTRequest) ProtoReflect 

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

func (*EncodeJWTRequest) Reset 

func (x *EncodeJWTRequest) Reset()

func (*EncodeJWTRequest) String 

func (x *EncodeJWTRequest) String() string

type EncodeJWTResponse 

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 

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

Deprecated: Use EncodeJWTResponse.ProtoReflect.Descriptor instead.

func (*EncodeJWTResponse) GetError 

func (x *EncodeJWTResponse) GetError() string

func (*EncodeJWTResponse) GetJwt 

func (x *EncodeJWTResponse) GetJwt() string

func (*EncodeJWTResponse) ProtoMessage 

func (*EncodeJWTResponse) ProtoMessage()

func (*EncodeJWTResponse) ProtoReflect 

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

func (*EncodeJWTResponse) Reset 

func (x *EncodeJWTResponse) Reset()

func (*EncodeJWTResponse) String 

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 HandlerHealthRequest 

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

func (*HandlerHealthRequest) Descriptor deprecated 

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

Deprecated: Use HandlerHealthRequest.ProtoReflect.Descriptor instead.

func (*HandlerHealthRequest) ProtoMessage 

func (*HandlerHealthRequest) ProtoMessage()

func (*HandlerHealthRequest) ProtoReflect 

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

func (*HandlerHealthRequest) Reset 

func (x *HandlerHealthRequest) Reset()

func (*HandlerHealthRequest) String 

func (x *HandlerHealthRequest) String() string

type HandlerHealthResponse 

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

func (*HandlerHealthResponse) Descriptor deprecated 

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

Deprecated: Use HandlerHealthResponse.ProtoReflect.Descriptor instead.

func (*HandlerHealthResponse) GetError 

func (x *HandlerHealthResponse) GetError() string

func (*HandlerHealthResponse) ProtoMessage 

func (*HandlerHealthResponse) ProtoMessage()

func (*HandlerHealthResponse) ProtoReflect 

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

func (*HandlerHealthResponse) Reset 

func (x *HandlerHealthResponse) Reset()

func (*HandlerHealthResponse) String 

func (x *HandlerHealthResponse) String() string

type HandlerServiceClient 

type HandlerServiceClient 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 *HandlerHealthRequest, opts ...grpc.CallOption) (*HandlerHealthResponse, error)
	IsActiveRunner(ctx context.Context, in *IsActiveRunnerRequest, opts ...grpc.CallOption) (*IsActiveRunnerResponse, error)
}

HandlerServiceClient is the client API for HandlerService 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 NewHandlerServiceClient 

func NewHandlerServiceClient(cc grpc.ClientConnInterface) HandlerServiceClient

type HandlerServiceServer 

type HandlerServiceServer 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, *HandlerHealthRequest) (*HandlerHealthResponse, error)
	IsActiveRunner(context.Context, *IsActiveRunnerRequest) (*IsActiveRunnerResponse, error)
	// contains filtered or unexported methods
}

HandlerServiceServer is the server API for HandlerService service. All implementations must embed UnimplementedHandlerServiceServer for forward compatibility.

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 

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 

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

Deprecated: Use RefreshRequest.ProtoReflect.Descriptor instead.

func (*RefreshRequest) GetConnection 

func (x *RefreshRequest) GetConnection() string

func (*RefreshRequest) GetIntegration 

func (x *RefreshRequest) GetIntegration() string

func (*RefreshRequest) GetRunnerId 

func (x *RefreshRequest) GetRunnerId() string

func (*RefreshRequest) ProtoMessage 

func (*RefreshRequest) ProtoMessage()

func (*RefreshRequest) ProtoReflect 

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

func (*RefreshRequest) Reset 

func (x *RefreshRequest) Reset()

func (*RefreshRequest) String 

func (x *RefreshRequest) String() string

type RefreshResponse 

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 

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

Deprecated: Use RefreshResponse.ProtoReflect.Descriptor instead.

func (*RefreshResponse) GetError 

func (x *RefreshResponse) GetError() string

func (*RefreshResponse) GetExpires 

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

func (*RefreshResponse) GetToken 

func (x *RefreshResponse) GetToken() string

func (*RefreshResponse) ProtoMessage 

func (*RefreshResponse) ProtoMessage()

func (*RefreshResponse) ProtoReflect 

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

func (*RefreshResponse) Reset 

func (x *RefreshResponse) Reset()

func (*RefreshResponse) String 

func (x *RefreshResponse) String() string

type RunnerHealthRequest 

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

func (*RunnerHealthRequest) Descriptor deprecated 

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

Deprecated: Use RunnerHealthRequest.ProtoReflect.Descriptor instead.

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 {
	Error string `protobuf:"bytes,1,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) 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 RunnerServiceClient 

type RunnerServiceClient 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 *RunnerHealthRequest, opts ...grpc.CallOption) (*RunnerHealthResponse, error)
}

RunnerServiceClient is the client API for RunnerService 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 NewRunnerServiceClient 

func NewRunnerServiceClient(cc grpc.ClientConnInterface) RunnerServiceClient

type RunnerServiceServer 

type RunnerServiceServer 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, *RunnerHealthRequest) (*RunnerHealthResponse, error)
	// contains filtered or unexported methods
}

RunnerServiceServer is the server API for RunnerService service. All implementations must embed UnimplementedRunnerServiceServer 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 StartSessionRequest 

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 

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

Deprecated: Use StartSessionRequest.ProtoReflect.Descriptor instead.

func (*StartSessionRequest) GetData 

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

func (*StartSessionRequest) GetLoc 

func (x *StartSessionRequest) GetLoc() string

func (*StartSessionRequest) GetMemo 

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

func (*StartSessionRequest) GetRunnerId 

func (x *StartSessionRequest) GetRunnerId() string

func (*StartSessionRequest) ProtoMessage 

func (*StartSessionRequest) ProtoMessage()

func (*StartSessionRequest) ProtoReflect 

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

func (*StartSessionRequest) Reset 

func (x *StartSessionRequest) Reset()

func (*StartSessionRequest) String 

func (x *StartSessionRequest) String() string

type StartSessionResponse 

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 

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

Deprecated: Use StartSessionResponse.ProtoReflect.Descriptor instead.

func (*StartSessionResponse) GetError 

func (x *StartSessionResponse) GetError() string

func (*StartSessionResponse) GetSessionId 

func (x *StartSessionResponse) GetSessionId() string

func (*StartSessionResponse) ProtoMessage 

func (*StartSessionResponse) ProtoMessage()

func (*StartSessionResponse) ProtoReflect 

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

func (*StartSessionResponse) Reset 

func (x *StartSessionResponse) Reset()

func (*StartSessionResponse) String 

func (x *StartSessionResponse) 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 UnimplementedHandlerServiceServer 

type UnimplementedHandlerServiceServer struct{}

UnimplementedHandlerServiceServer 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 (UnimplementedHandlerServiceServer) Activity 

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

func (UnimplementedHandlerServiceServer) Done 

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

func (UnimplementedHandlerServiceServer) EncodeJWT 

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

func (UnimplementedHandlerServiceServer) Health 

func (UnimplementedHandlerServiceServer) Health(context.Context, *HandlerHealthRequest) (*HandlerHealthResponse, error)

func (UnimplementedHandlerServiceServer) IsActiveRunner 

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

func (UnimplementedHandlerServiceServer) Log 

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

func (UnimplementedHandlerServiceServer) NextEvent 

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

func (UnimplementedHandlerServiceServer) Print 

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

func (UnimplementedHandlerServiceServer) RefreshOAuthToken 

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

func (UnimplementedHandlerServiceServer) Sleep 

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

func (UnimplementedHandlerServiceServer) StartSession 

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

func (UnimplementedHandlerServiceServer) Subscribe 

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

func (UnimplementedHandlerServiceServer) Unsubscribe 

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

type UnimplementedRunnerServiceServer 

type UnimplementedRunnerServiceServer struct{}

UnimplementedRunnerServiceServer 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 (UnimplementedRunnerServiceServer) ActivityReply 

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

func (UnimplementedRunnerServiceServer) Execute 

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

func (UnimplementedRunnerServiceServer) Exports 

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

func (UnimplementedRunnerServiceServer) Health 

func (UnimplementedRunnerServiceServer) Health(context.Context, *RunnerHealthRequest) (*RunnerHealthResponse, error)

func (UnimplementedRunnerServiceServer) Start 

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

type UnsafeHandlerServiceServer 

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

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

type UnsafeRunnerServiceServer 

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

UnsafeRunnerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RunnerServiceServer 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

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.