remotev1

package

Go to main page

Versions in this module

v0

v0.10.11

Oct 28, 2024

v0.10.10

Oct 26, 2024

v0.10.9

Oct 22, 2024

v0.10.8

Oct 21, 2024

v0.10.7

Oct 18, 2024

v0.10.6

Oct 17, 2024

Changes in this version

+ const Worker_EncodeJWT_FullMethodName

+ type EncodeJWTRequest struct

+ Algorithm string

+ Connection string

+ Payload map[string]int64

+ RunnerId string

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

+ func (*EncodeJWTRequest) ProtoMessage()

+ func (x *EncodeJWTRequest) GetAlgorithm() string

+ func (x *EncodeJWTRequest) GetConnection() string

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

+ func (x *EncodeJWTRequest) GetRunnerId() string

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

+ func (x *EncodeJWTRequest) Reset()

+ func (x *EncodeJWTRequest) String() string

+ type EncodeJWTResponse struct

+ Error string

+ Jwt string

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

+ func (*EncodeJWTResponse) ProtoMessage()

+ func (x *EncodeJWTResponse) GetError() string

+ func (x *EncodeJWTResponse) GetJwt() string

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

+ func (x *EncodeJWTResponse) Reset()

+ func (x *EncodeJWTResponse) String() string

type UnimplementedWorkerServer

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

type WorkerClient

+ EncodeJWT func(ctx context.Context, in *EncodeJWTRequest, opts ...grpc.CallOption) (*EncodeJWTResponse, error)

type WorkerServer

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

v0.10.5

Oct 16, 2024

v0.10.4

Oct 16, 2024

Changes in this version

+ const Worker_RefreshOAuthToken_FullMethodName

+ const Worker_StartSession_FullMethodName

+ type RefreshRequest struct

+ Connection string

+ Integration string

+ RunnerId string

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

+ func (*RefreshRequest) ProtoMessage()

+ func (x *RefreshRequest) GetConnection() string

+ func (x *RefreshRequest) GetIntegration() string

+ func (x *RefreshRequest) GetRunnerId() string

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

+ func (x *RefreshRequest) Reset()

+ func (x *RefreshRequest) String() string

+ type RefreshResponse struct

+ Error string

+ Expires *timestamppb.Timestamp

+ Token string

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

+ func (*RefreshResponse) ProtoMessage()

+ func (x *RefreshResponse) GetError() string

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

+ func (x *RefreshResponse) GetToken() string

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

+ func (x *RefreshResponse) Reset()

+ func (x *RefreshResponse) String() string

+ type StartSessionRequest struct

+ Data []byte

+ Loc string

+ Memo []byte

+ RunnerId string

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

+ func (*StartSessionRequest) ProtoMessage()

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

+ func (x *StartSessionRequest) GetLoc() string

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

+ func (x *StartSessionRequest) GetRunnerId() string

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

+ func (x *StartSessionRequest) Reset()

+ func (x *StartSessionRequest) String() string

+ type StartSessionResponse struct

+ Error string

+ SessionId string

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

+ func (*StartSessionResponse) ProtoMessage()

+ func (x *StartSessionResponse) GetError() string

+ func (x *StartSessionResponse) GetSessionId() string

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

+ func (x *StartSessionResponse) Reset()

+ func (x *StartSessionResponse) String() string

type UnimplementedWorkerServer

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

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

type WorkerClient

+ RefreshOAuthToken func(ctx context.Context, in *RefreshRequest, opts ...grpc.CallOption) (*RefreshResponse, error)

+ StartSession func(ctx context.Context, in *StartSessionRequest, opts ...grpc.CallOption) (*StartSessionResponse, error)

type WorkerServer

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

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

v0.10.3

Oct 11, 2024

v0.10.2

Oct 9, 2024

v0.10.1

Oct 8, 2024

v0.10.0

Oct 6, 2024

Changes in this version

+ const RunnerManager_Health_FullMethodName

+ const RunnerManager_RunnerHealth_FullMethodName

+ const RunnerManager_Start_FullMethodName

+ const RunnerManager_Stop_FullMethodName

+ const Runner_ActivityReply_FullMethodName

+ const Runner_Execute_FullMethodName

+ const Runner_Exports_FullMethodName

+ const Runner_Health_FullMethodName

+ const Runner_Start_FullMethodName

+ const Worker_Activity_FullMethodName

+ const Worker_Done_FullMethodName

+ const Worker_Health_FullMethodName

+ const Worker_IsActiveRunner_FullMethodName

+ const Worker_Log_FullMethodName

+ const Worker_NextEvent_FullMethodName

+ const Worker_Print_FullMethodName

+ const Worker_Sleep_FullMethodName

+ const Worker_Subscribe_FullMethodName

+ const Worker_Unsubscribe_FullMethodName

+ var File_autokitteh_remote_v1_remote_proto protoreflect.FileDescriptor

+ var RunnerManager_ServiceDesc = grpc.ServiceDesc

+ var Runner_ServiceDesc = grpc.ServiceDesc

+ var Worker_ServiceDesc = grpc.ServiceDesc

+ func RegisterRunnerManagerServer(s grpc.ServiceRegistrar, srv RunnerManagerServer)

+ func RegisterRunnerServer(s grpc.ServiceRegistrar, srv RunnerServer)

+ func RegisterWorkerServer(s grpc.ServiceRegistrar, srv WorkerServer)

+ type ActivityReplyRequest struct

+ Data []byte

+ Error string

+ Result []byte

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

+ func (*ActivityReplyRequest) ProtoMessage()

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

+ func (x *ActivityReplyRequest) GetError() string

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

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

+ func (x *ActivityReplyRequest) Reset()

+ func (x *ActivityReplyRequest) String() string

+ type ActivityReplyResponse struct

+ Error string

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

+ func (*ActivityReplyResponse) ProtoMessage()

+ func (x *ActivityReplyResponse) GetError() string

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

+ func (x *ActivityReplyResponse) Reset()

+ func (x *ActivityReplyResponse) String() string

+ type ActivityRequest struct

+ CallInfo *CallInfo

+ Data []byte

+ RunnerId string

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

+ func (*ActivityRequest) ProtoMessage()

+ func (x *ActivityRequest) GetCallInfo() *CallInfo

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

+ func (x *ActivityRequest) GetRunnerId() string

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

+ func (x *ActivityRequest) Reset()

+ func (x *ActivityRequest) String() string

+ type ActivityResponse struct

+ Error string

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

+ func (*ActivityResponse) ProtoMessage()

+ func (x *ActivityResponse) GetError() string

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

+ func (x *ActivityResponse) Reset()

+ func (x *ActivityResponse) String() string

+ type CallInfo struct

+ Args []string

+ Function string

+ Kwargs map[string]string

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

+ func (*CallInfo) ProtoMessage()

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

+ func (x *CallInfo) GetFunction() string

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

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

+ func (x *CallInfo) Reset()

+ func (x *CallInfo) String() string

+ type ContainerConfig struct

+ Image string

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

+ func (*ContainerConfig) ProtoMessage()

+ func (x *ContainerConfig) GetImage() string

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

+ func (x *ContainerConfig) Reset()

+ func (x *ContainerConfig) String() string

+ type DoneRequest struct

+ Error string

+ Result []byte

+ RunnerId string

+ Traceback []*Frame

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

+ func (*DoneRequest) ProtoMessage()

+ func (x *DoneRequest) GetError() string

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

+ func (x *DoneRequest) GetRunnerId() string

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

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

+ func (x *DoneRequest) Reset()

+ func (x *DoneRequest) String() string

+ type DoneResponse struct

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

+ func (*DoneResponse) ProtoMessage()

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

+ func (x *DoneResponse) Reset()

+ func (x *DoneResponse) String() string

+ type Event struct

+ Data []byte

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

+ func (*Event) ProtoMessage()

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

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

+ func (x *Event) Reset()

+ func (x *Event) String() string

+ type ExecuteRequest struct

+ Data []byte

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

+ func (*ExecuteRequest) ProtoMessage()

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

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

+ func (x *ExecuteRequest) Reset()

+ func (x *ExecuteRequest) String() string

+ type ExecuteResponse struct

+ Error string

+ Result []byte

+ Traceback []*Frame

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

+ func (*ExecuteResponse) ProtoMessage()

+ func (x *ExecuteResponse) GetError() string

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

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

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

+ func (x *ExecuteResponse) Reset()

+ func (x *ExecuteResponse) String() string

+ type ExportsRequest struct

+ FileName string

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

+ func (*ExportsRequest) ProtoMessage()

+ func (x *ExportsRequest) GetFileName() string

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

+ func (x *ExportsRequest) Reset()

+ func (x *ExportsRequest) String() string

+ type ExportsResponse struct

+ Error string

+ Exports []string

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

+ func (*ExportsResponse) ProtoMessage()

+ func (x *ExportsResponse) GetError() string

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

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

+ func (x *ExportsResponse) Reset()

+ func (x *ExportsResponse) String() string

+ type Frame struct

+ Code string

+ Filename string

+ Lineno uint32

+ Name string

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

+ func (*Frame) ProtoMessage()

+ func (x *Frame) GetCode() string

+ func (x *Frame) GetFilename() string

+ func (x *Frame) GetLineno() uint32

+ func (x *Frame) GetName() string

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

+ func (x *Frame) Reset()

+ func (x *Frame) String() string

+ type HealthRequest struct

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

+ func (*HealthRequest) ProtoMessage()

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

+ func (x *HealthRequest) Reset()

+ func (x *HealthRequest) String() string

+ type HealthResponse struct

+ Error string

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

+ func (*HealthResponse) ProtoMessage()

+ func (x *HealthResponse) GetError() string

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

+ func (x *HealthResponse) Reset()

+ func (x *HealthResponse) String() string

+ type IsActiveRunnerRequest struct

+ RunnerId string

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

+ func (*IsActiveRunnerRequest) ProtoMessage()

+ func (x *IsActiveRunnerRequest) GetRunnerId() string

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

+ func (x *IsActiveRunnerRequest) Reset()

+ func (x *IsActiveRunnerRequest) String() string

+ type IsActiveRunnerResponse struct

+ Error string

+ IsActive bool

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

+ func (*IsActiveRunnerResponse) ProtoMessage()

+ func (x *IsActiveRunnerResponse) GetError() string

+ func (x *IsActiveRunnerResponse) GetIsActive() bool

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

+ func (x *IsActiveRunnerResponse) Reset()

+ func (x *IsActiveRunnerResponse) String() string

+ type LogRequest struct

+ Level string

+ Message string

+ RunnerId string

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

+ func (*LogRequest) ProtoMessage()

+ func (x *LogRequest) GetLevel() string

+ func (x *LogRequest) GetMessage() string

+ func (x *LogRequest) GetRunnerId() string

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

+ func (x *LogRequest) Reset()

+ func (x *LogRequest) String() string

+ type LogResponse struct

+ Error string

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

+ func (*LogResponse) ProtoMessage()

+ func (x *LogResponse) GetError() string

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

+ func (x *LogResponse) Reset()

+ func (x *LogResponse) String() string

+ type NextEventRequest struct

+ RunnerId string

+ SignalIds []string

+ TimeoutMs int64

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

+ func (*NextEventRequest) ProtoMessage()

+ func (x *NextEventRequest) GetRunnerId() string

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

+ func (x *NextEventRequest) GetTimeoutMs() int64

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

+ func (x *NextEventRequest) Reset()

+ func (x *NextEventRequest) String() string

+ type NextEventResponse struct

+ Error string

+ Event *Event

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

+ func (*NextEventResponse) ProtoMessage()

+ func (x *NextEventResponse) GetError() string

+ func (x *NextEventResponse) GetEvent() *Event

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

+ func (x *NextEventResponse) Reset()

+ func (x *NextEventResponse) String() string

+ type PrintRequest struct

+ Message string

+ RunnerId string

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

+ func (*PrintRequest) ProtoMessage()

+ func (x *PrintRequest) GetMessage() string

+ func (x *PrintRequest) GetRunnerId() string

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

+ func (x *PrintRequest) Reset()

+ func (x *PrintRequest) String() string

+ type PrintResponse struct

+ Error string

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

+ func (*PrintResponse) ProtoMessage()

+ func (x *PrintResponse) GetError() string

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

+ func (x *PrintResponse) Reset()

+ func (x *PrintResponse) String() string

+ type RunnerClient interface

+ ActivityReply func(ctx context.Context, in *ActivityReplyRequest, opts ...grpc.CallOption) (*ActivityReplyResponse, error)

+ Execute func(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)

+ Exports func(ctx context.Context, in *ExportsRequest, opts ...grpc.CallOption) (*ExportsResponse, error)

+ Health func(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)

+ Start func(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)

+ func NewRunnerClient(cc grpc.ClientConnInterface) RunnerClient

+ type RunnerHealthRequest struct

+ RunnerId string

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

+ func (*RunnerHealthRequest) ProtoMessage()

+ func (x *RunnerHealthRequest) GetRunnerId() string

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

+ func (x *RunnerHealthRequest) Reset()

+ func (x *RunnerHealthRequest) String() string

+ type RunnerHealthResponse struct

+ Error string

+ Healthy bool

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

+ func (*RunnerHealthResponse) ProtoMessage()

+ func (x *RunnerHealthResponse) GetError() string

+ func (x *RunnerHealthResponse) GetHealthy() bool

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

+ func (x *RunnerHealthResponse) Reset()

+ func (x *RunnerHealthResponse) String() string

+ type RunnerManagerClient interface

+ Health func(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)

+ RunnerHealth func(ctx context.Context, in *RunnerHealthRequest, opts ...grpc.CallOption) (*RunnerHealthResponse, error)

+ Start func(ctx context.Context, in *StartRunnerRequest, opts ...grpc.CallOption) (*StartRunnerResponse, error)

+ Stop func(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)

+ func NewRunnerManagerClient(cc grpc.ClientConnInterface) RunnerManagerClient

+ type RunnerManagerServer interface

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

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

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

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

+ type RunnerServer interface

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

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

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

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

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

+ type SleepRequest struct

+ DurationMs int64

+ RunnerId string

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

+ func (*SleepRequest) ProtoMessage()

+ func (x *SleepRequest) GetDurationMs() int64

+ func (x *SleepRequest) GetRunnerId() string

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

+ func (x *SleepRequest) Reset()

+ func (x *SleepRequest) String() string

+ type SleepResponse struct

+ Error string

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

+ func (*SleepResponse) ProtoMessage()

+ func (x *SleepResponse) GetError() string

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

+ func (x *SleepResponse) Reset()

+ func (x *SleepResponse) String() string

+ type StartRequest struct

+ EntryPoint string

+ Event *Event

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

+ func (*StartRequest) ProtoMessage()

+ func (x *StartRequest) GetEntryPoint() string

+ func (x *StartRequest) GetEvent() *Event

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

+ func (x *StartRequest) Reset()

+ func (x *StartRequest) String() string

+ type StartResponse struct

+ Error string

+ Traceback []*Frame

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

+ func (*StartResponse) ProtoMessage()

+ func (x *StartResponse) GetError() string

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

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

+ func (x *StartResponse) Reset()

+ func (x *StartResponse) String() string

+ type StartRunnerRequest struct

+ BuildArtifact []byte

+ ContainerConfig *ContainerConfig

+ Vars map[string]string

+ WorkerAddress string

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

+ func (*StartRunnerRequest) ProtoMessage()

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

+ func (x *StartRunnerRequest) GetContainerConfig() *ContainerConfig

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

+ func (x *StartRunnerRequest) GetWorkerAddress() string

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

+ func (x *StartRunnerRequest) Reset()

+ func (x *StartRunnerRequest) String() string

+ type StartRunnerResponse struct

+ Error string

+ RunnerAddress string

+ RunnerId string

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

+ func (*StartRunnerResponse) ProtoMessage()

+ func (x *StartRunnerResponse) GetError() string

+ func (x *StartRunnerResponse) GetRunnerAddress() string

+ func (x *StartRunnerResponse) GetRunnerId() string

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

+ func (x *StartRunnerResponse) Reset()

+ func (x *StartRunnerResponse) String() string

+ type StopRequest struct

+ RunnerId string

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

+ func (*StopRequest) ProtoMessage()

+ func (x *StopRequest) GetRunnerId() string

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

+ func (x *StopRequest) Reset()

+ func (x *StopRequest) String() string

+ type StopResponse struct

+ Error string

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

+ func (*StopResponse) ProtoMessage()

+ func (x *StopResponse) GetError() string

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

+ func (x *StopResponse) Reset()

+ func (x *StopResponse) String() string

+ type SubscribeRequest struct

+ Connection string

+ Filter string

+ RunnerId string

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

+ func (*SubscribeRequest) ProtoMessage()

+ func (x *SubscribeRequest) GetConnection() string

+ func (x *SubscribeRequest) GetFilter() string

+ func (x *SubscribeRequest) GetRunnerId() string

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

+ func (x *SubscribeRequest) Reset()

+ func (x *SubscribeRequest) String() string

+ type SubscribeResponse struct

+ Error string

+ SignalId string

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

+ func (*SubscribeResponse) ProtoMessage()

+ func (x *SubscribeResponse) GetError() string

+ func (x *SubscribeResponse) GetSignalId() string

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

+ func (x *SubscribeResponse) Reset()

+ func (x *SubscribeResponse) String() string

+ type UnimplementedRunnerManagerServer struct

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

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

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

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

+ type UnimplementedRunnerServer struct

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

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

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

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

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

+ type UnimplementedWorkerServer struct

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

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

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

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

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

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

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

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

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

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

+ type UnsafeRunnerManagerServer interface

+ type UnsafeRunnerServer interface

+ type UnsafeWorkerServer interface

+ type UnsubscribeRequest struct

+ RunnerId string

+ SignalId string

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

+ func (*UnsubscribeRequest) ProtoMessage()

+ func (x *UnsubscribeRequest) GetRunnerId() string

+ func (x *UnsubscribeRequest) GetSignalId() string

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

+ func (x *UnsubscribeRequest) Reset()

+ func (x *UnsubscribeRequest) String() string

+ type UnsubscribeResponse struct

+ Error string

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

+ func (*UnsubscribeResponse) ProtoMessage()

+ func (x *UnsubscribeResponse) GetError() string

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

+ func (x *UnsubscribeResponse) Reset()

+ func (x *UnsubscribeResponse) String() string

+ type WorkerClient interface

+ Activity func(ctx context.Context, in *ActivityRequest, opts ...grpc.CallOption) (*ActivityResponse, error)

+ Done func(ctx context.Context, in *DoneRequest, opts ...grpc.CallOption) (*DoneResponse, error)

+ Health func(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)

+ IsActiveRunner func(ctx context.Context, in *IsActiveRunnerRequest, opts ...grpc.CallOption) (*IsActiveRunnerResponse, error)

+ Log func(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*LogResponse, error)

+ NextEvent func(ctx context.Context, in *NextEventRequest, opts ...grpc.CallOption) (*NextEventResponse, error)

+ Print func(ctx context.Context, in *PrintRequest, opts ...grpc.CallOption) (*PrintResponse, error)

+ Sleep func(ctx context.Context, in *SleepRequest, opts ...grpc.CallOption) (*SleepResponse, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)

+ Unsubscribe func(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*UnsubscribeResponse, error)

+ func NewWorkerClient(cc grpc.ClientConnInterface) WorkerClient

+ type WorkerServer interface

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

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

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

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

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

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

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

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

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

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL