Versions in this module Expand all Collapse all v0 v0.7.2 Jan 16, 2025 v0.7.0 Dec 12, 2024 Changes in this version + const Callbacks_CreateCallback_FullMethodName + const Locks_AcquireLock_FullMethodName + const Locks_HeartbeatLocks_FullMethodName + const Locks_ReleaseLock_FullMethodName + const Promises_CancelPromise_FullMethodName + const Promises_CreatePromiseAndCallback_FullMethodName + const Promises_CreatePromiseAndTask_FullMethodName + const Promises_CreatePromise_FullMethodName + const Promises_ReadPromise_FullMethodName + const Promises_RejectPromise_FullMethodName + const Promises_ResolvePromise_FullMethodName + const Promises_SearchPromises_FullMethodName + const Schedules_CreateSchedule_FullMethodName + const Schedules_DeleteSchedule_FullMethodName + const Schedules_ReadSchedule_FullMethodName + const Schedules_SearchSchedules_FullMethodName + const Tasks_ClaimTask_FullMethodName + const Tasks_CompleteTask_FullMethodName + const Tasks_HeartbeatTasks_FullMethodName + var Callbacks_ServiceDesc = grpc.ServiceDesc + var File_internal_app_subsystems_api_grpc_pb_callback_proto protoreflect.FileDescriptor + var File_internal_app_subsystems_api_grpc_pb_callback_t_proto protoreflect.FileDescriptor + var File_internal_app_subsystems_api_grpc_pb_lock_proto protoreflect.FileDescriptor + var File_internal_app_subsystems_api_grpc_pb_promise_proto protoreflect.FileDescriptor + var File_internal_app_subsystems_api_grpc_pb_promise_t_proto protoreflect.FileDescriptor + var File_internal_app_subsystems_api_grpc_pb_schedule_proto protoreflect.FileDescriptor + var File_internal_app_subsystems_api_grpc_pb_schedule_t_proto protoreflect.FileDescriptor + var File_internal_app_subsystems_api_grpc_pb_task_proto protoreflect.FileDescriptor + var Locks_ServiceDesc = grpc.ServiceDesc + var Promises_ServiceDesc = grpc.ServiceDesc + var Schedules_ServiceDesc = grpc.ServiceDesc + var SearchState_name = map[int32]string + var SearchState_value = map[string]int32 + var State_name = map[int32]string + var State_value = map[string]int32 + var Tasks_ServiceDesc = grpc.ServiceDesc + func RegisterCallbacksServer(s grpc.ServiceRegistrar, srv CallbacksServer) + func RegisterLocksServer(s grpc.ServiceRegistrar, srv LocksServer) + func RegisterPromisesServer(s grpc.ServiceRegistrar, srv PromisesServer) + func RegisterSchedulesServer(s grpc.ServiceRegistrar, srv SchedulesServer) + func RegisterTasksServer(s grpc.ServiceRegistrar, srv TasksServer) + type AcquireLockRequest struct + ExecutionId string + ProcessId string + RequestId string + ResourceId string + Ttl int64 + func (*AcquireLockRequest) Descriptor() ([]byte, []int) + func (*AcquireLockRequest) ProtoMessage() + func (x *AcquireLockRequest) GetExecutionId() string + func (x *AcquireLockRequest) GetProcessId() string + func (x *AcquireLockRequest) GetRequestId() string + func (x *AcquireLockRequest) GetResourceId() string + func (x *AcquireLockRequest) GetTtl() int64 + func (x *AcquireLockRequest) ProtoReflect() protoreflect.Message + func (x *AcquireLockRequest) Reset() + func (x *AcquireLockRequest) String() string + type AcquireLockResponse struct + Acquired bool + func (*AcquireLockResponse) Descriptor() ([]byte, []int) + func (*AcquireLockResponse) ProtoMessage() + func (x *AcquireLockResponse) GetAcquired() bool + func (x *AcquireLockResponse) ProtoReflect() protoreflect.Message + func (x *AcquireLockResponse) Reset() + func (x *AcquireLockResponse) String() string + type Callback struct + CreatedOn int64 + Id string + PromiseId string + Timeout int64 + func (*Callback) Descriptor() ([]byte, []int) + func (*Callback) ProtoMessage() + func (x *Callback) GetCreatedOn() int64 + func (x *Callback) GetId() string + func (x *Callback) GetPromiseId() string + func (x *Callback) GetTimeout() int64 + func (x *Callback) ProtoReflect() protoreflect.Message + func (x *Callback) Reset() + func (x *Callback) String() string + type CallbacksClient interface + CreateCallback func(ctx context.Context, in *CreateCallbackRequest, opts ...grpc.CallOption) (*CreateCallbackResponse, error) + func NewCallbacksClient(cc grpc.ClientConnInterface) CallbacksClient + type CallbacksServer interface + CreateCallback func(context.Context, *CreateCallbackRequest) (*CreateCallbackResponse, error) + type CancelPromiseRequest struct + Id string + IdempotencyKey string + RequestId string + Strict bool + Value *Value + func (*CancelPromiseRequest) Descriptor() ([]byte, []int) + func (*CancelPromiseRequest) ProtoMessage() + func (x *CancelPromiseRequest) GetId() string + func (x *CancelPromiseRequest) GetIdempotencyKey() string + func (x *CancelPromiseRequest) GetRequestId() string + func (x *CancelPromiseRequest) GetStrict() bool + func (x *CancelPromiseRequest) GetValue() *Value + func (x *CancelPromiseRequest) ProtoReflect() protoreflect.Message + func (x *CancelPromiseRequest) Reset() + func (x *CancelPromiseRequest) String() string + type CancelPromiseResponse struct + Noop bool + Promise *Promise + func (*CancelPromiseResponse) Descriptor() ([]byte, []int) + func (*CancelPromiseResponse) ProtoMessage() + func (x *CancelPromiseResponse) GetNoop() bool + func (x *CancelPromiseResponse) GetPromise() *Promise + func (x *CancelPromiseResponse) ProtoReflect() protoreflect.Message + func (x *CancelPromiseResponse) Reset() + func (x *CancelPromiseResponse) String() string + type ClaimTaskRequest struct + Counter int32 + Id string + ProcessId string + RequestId string + Ttl int32 + func (*ClaimTaskRequest) Descriptor() ([]byte, []int) + func (*ClaimTaskRequest) ProtoMessage() + func (x *ClaimTaskRequest) GetCounter() int32 + func (x *ClaimTaskRequest) GetId() string + func (x *ClaimTaskRequest) GetProcessId() string + func (x *ClaimTaskRequest) GetRequestId() string + func (x *ClaimTaskRequest) GetTtl() int32 + func (x *ClaimTaskRequest) ProtoReflect() protoreflect.Message + func (x *ClaimTaskRequest) Reset() + func (x *ClaimTaskRequest) String() string + type ClaimTaskResponse struct + Claimed bool + Mesg *Mesg + func (*ClaimTaskResponse) Descriptor() ([]byte, []int) + func (*ClaimTaskResponse) ProtoMessage() + func (x *ClaimTaskResponse) GetClaimed() bool + func (x *ClaimTaskResponse) GetMesg() *Mesg + func (x *ClaimTaskResponse) ProtoReflect() protoreflect.Message + func (x *ClaimTaskResponse) Reset() + func (x *ClaimTaskResponse) String() string + type CompleteTaskRequest struct + Counter int32 + Id string + RequestId string + func (*CompleteTaskRequest) Descriptor() ([]byte, []int) + func (*CompleteTaskRequest) ProtoMessage() + func (x *CompleteTaskRequest) GetCounter() int32 + func (x *CompleteTaskRequest) GetId() string + func (x *CompleteTaskRequest) GetRequestId() string + func (x *CompleteTaskRequest) ProtoReflect() protoreflect.Message + func (x *CompleteTaskRequest) Reset() + func (x *CompleteTaskRequest) String() string + type CompleteTaskResponse struct + Completed bool + func (*CompleteTaskResponse) Descriptor() ([]byte, []int) + func (*CompleteTaskResponse) ProtoMessage() + func (x *CompleteTaskResponse) GetCompleted() bool + func (x *CompleteTaskResponse) ProtoReflect() protoreflect.Message + func (x *CompleteTaskResponse) Reset() + func (x *CompleteTaskResponse) String() string + type CreateCallbackRequest struct + Id string + PromiseId string + Recv *Recv + RequestId string + RootPromiseId string + Timeout int64 + func (*CreateCallbackRequest) Descriptor() ([]byte, []int) + func (*CreateCallbackRequest) ProtoMessage() + func (x *CreateCallbackRequest) GetId() string + func (x *CreateCallbackRequest) GetPromiseId() string + func (x *CreateCallbackRequest) GetRecv() *Recv + func (x *CreateCallbackRequest) GetRequestId() string + func (x *CreateCallbackRequest) GetRootPromiseId() string + func (x *CreateCallbackRequest) GetTimeout() int64 + func (x *CreateCallbackRequest) ProtoReflect() protoreflect.Message + func (x *CreateCallbackRequest) Reset() + func (x *CreateCallbackRequest) String() string + type CreateCallbackResponse struct + Callback *Callback + Noop bool + Promise *Promise + func (*CreateCallbackResponse) Descriptor() ([]byte, []int) + func (*CreateCallbackResponse) ProtoMessage() + func (x *CreateCallbackResponse) GetCallback() *Callback + func (x *CreateCallbackResponse) GetNoop() bool + func (x *CreateCallbackResponse) GetPromise() *Promise + func (x *CreateCallbackResponse) ProtoReflect() protoreflect.Message + func (x *CreateCallbackResponse) Reset() + func (x *CreateCallbackResponse) String() string + type CreatePromiseAndCallbackRequest struct + Callback *CreatePromiseCallbackRequest + Promise *CreatePromiseRequest + func (*CreatePromiseAndCallbackRequest) Descriptor() ([]byte, []int) + func (*CreatePromiseAndCallbackRequest) ProtoMessage() + func (x *CreatePromiseAndCallbackRequest) GetCallback() *CreatePromiseCallbackRequest + func (x *CreatePromiseAndCallbackRequest) GetPromise() *CreatePromiseRequest + func (x *CreatePromiseAndCallbackRequest) ProtoReflect() protoreflect.Message + func (x *CreatePromiseAndCallbackRequest) Reset() + func (x *CreatePromiseAndCallbackRequest) String() string + type CreatePromiseAndCallbackResponse struct + Noop bool + Promise *Promise + func (*CreatePromiseAndCallbackResponse) Descriptor() ([]byte, []int) + func (*CreatePromiseAndCallbackResponse) ProtoMessage() + func (x *CreatePromiseAndCallbackResponse) GetNoop() bool + func (x *CreatePromiseAndCallbackResponse) GetPromise() *Promise + func (x *CreatePromiseAndCallbackResponse) ProtoReflect() protoreflect.Message + func (x *CreatePromiseAndCallbackResponse) Reset() + func (x *CreatePromiseAndCallbackResponse) String() string + type CreatePromiseAndTaskRequest struct + Promise *CreatePromiseRequest + Task *CreatePromiseTaskRequest + func (*CreatePromiseAndTaskRequest) Descriptor() ([]byte, []int) + func (*CreatePromiseAndTaskRequest) ProtoMessage() + func (x *CreatePromiseAndTaskRequest) GetPromise() *CreatePromiseRequest + func (x *CreatePromiseAndTaskRequest) GetTask() *CreatePromiseTaskRequest + func (x *CreatePromiseAndTaskRequest) ProtoReflect() protoreflect.Message + func (x *CreatePromiseAndTaskRequest) Reset() + func (x *CreatePromiseAndTaskRequest) String() string + type CreatePromiseAndTaskResponse struct + Noop bool + Promise *Promise + func (*CreatePromiseAndTaskResponse) Descriptor() ([]byte, []int) + func (*CreatePromiseAndTaskResponse) ProtoMessage() + func (x *CreatePromiseAndTaskResponse) GetNoop() bool + func (x *CreatePromiseAndTaskResponse) GetPromise() *Promise + func (x *CreatePromiseAndTaskResponse) ProtoReflect() protoreflect.Message + func (x *CreatePromiseAndTaskResponse) Reset() + func (x *CreatePromiseAndTaskResponse) String() string + type CreatePromiseCallbackRequest struct + Id string + Recv *Recv + RootPromiseId string + Timeout int64 + func (*CreatePromiseCallbackRequest) Descriptor() ([]byte, []int) + func (*CreatePromiseCallbackRequest) ProtoMessage() + func (x *CreatePromiseCallbackRequest) GetId() string + func (x *CreatePromiseCallbackRequest) GetRecv() *Recv + func (x *CreatePromiseCallbackRequest) GetRootPromiseId() string + func (x *CreatePromiseCallbackRequest) GetTimeout() int64 + func (x *CreatePromiseCallbackRequest) ProtoReflect() protoreflect.Message + func (x *CreatePromiseCallbackRequest) Reset() + func (x *CreatePromiseCallbackRequest) String() string + type CreatePromiseRequest struct + Id string + IdempotencyKey string + Param *Value + RequestId string + Strict bool + Tags map[string]string + Timeout int64 + func (*CreatePromiseRequest) Descriptor() ([]byte, []int) + func (*CreatePromiseRequest) ProtoMessage() + func (x *CreatePromiseRequest) GetId() string + func (x *CreatePromiseRequest) GetIdempotencyKey() string + func (x *CreatePromiseRequest) GetParam() *Value + func (x *CreatePromiseRequest) GetRequestId() string + func (x *CreatePromiseRequest) GetStrict() bool + func (x *CreatePromiseRequest) GetTags() map[string]string + func (x *CreatePromiseRequest) GetTimeout() int64 + func (x *CreatePromiseRequest) ProtoReflect() protoreflect.Message + func (x *CreatePromiseRequest) Reset() + func (x *CreatePromiseRequest) String() string + type CreatePromiseResponse struct + Noop bool + Promise *Promise + func (*CreatePromiseResponse) Descriptor() ([]byte, []int) + func (*CreatePromiseResponse) ProtoMessage() + func (x *CreatePromiseResponse) GetNoop() bool + func (x *CreatePromiseResponse) GetPromise() *Promise + func (x *CreatePromiseResponse) ProtoReflect() protoreflect.Message + func (x *CreatePromiseResponse) Reset() + func (x *CreatePromiseResponse) String() string + type CreatePromiseTaskRequest struct + ProcessId string + Recv *Recv + Ttl int32 + func (*CreatePromiseTaskRequest) Descriptor() ([]byte, []int) + func (*CreatePromiseTaskRequest) ProtoMessage() + func (x *CreatePromiseTaskRequest) GetProcessId() string + func (x *CreatePromiseTaskRequest) GetRecv() *Recv + func (x *CreatePromiseTaskRequest) GetTtl() int32 + func (x *CreatePromiseTaskRequest) ProtoReflect() protoreflect.Message + func (x *CreatePromiseTaskRequest) Reset() + func (x *CreatePromiseTaskRequest) String() string + type CreateScheduleRequest struct + Cron string + Description string + Id string + IdempotencyKey string + PromiseId string + PromiseParam *Value + PromiseTags map[string]string + PromiseTimeout int64 + RequestId string + Tags map[string]string + func (*CreateScheduleRequest) Descriptor() ([]byte, []int) + func (*CreateScheduleRequest) ProtoMessage() + func (x *CreateScheduleRequest) GetCron() string + func (x *CreateScheduleRequest) GetDescription() string + func (x *CreateScheduleRequest) GetId() string + func (x *CreateScheduleRequest) GetIdempotencyKey() string + func (x *CreateScheduleRequest) GetPromiseId() string + func (x *CreateScheduleRequest) GetPromiseParam() *Value + func (x *CreateScheduleRequest) GetPromiseTags() map[string]string + func (x *CreateScheduleRequest) GetPromiseTimeout() int64 + func (x *CreateScheduleRequest) GetRequestId() string + func (x *CreateScheduleRequest) GetTags() map[string]string + func (x *CreateScheduleRequest) ProtoReflect() protoreflect.Message + func (x *CreateScheduleRequest) Reset() + func (x *CreateScheduleRequest) String() string + type CreatedScheduleResponse struct + Noop bool + Schedule *Schedule + func (*CreatedScheduleResponse) Descriptor() ([]byte, []int) + func (*CreatedScheduleResponse) ProtoMessage() + func (x *CreatedScheduleResponse) GetNoop() bool + func (x *CreatedScheduleResponse) GetSchedule() *Schedule + func (x *CreatedScheduleResponse) ProtoReflect() protoreflect.Message + func (x *CreatedScheduleResponse) Reset() + func (x *CreatedScheduleResponse) String() string + type DeleteScheduleRequest struct + Id string + RequestId string + func (*DeleteScheduleRequest) Descriptor() ([]byte, []int) + func (*DeleteScheduleRequest) ProtoMessage() + func (x *DeleteScheduleRequest) GetId() string + func (x *DeleteScheduleRequest) GetRequestId() string + func (x *DeleteScheduleRequest) ProtoReflect() protoreflect.Message + func (x *DeleteScheduleRequest) Reset() + func (x *DeleteScheduleRequest) String() string + type DeleteScheduleResponse struct + func (*DeleteScheduleResponse) Descriptor() ([]byte, []int) + func (*DeleteScheduleResponse) ProtoMessage() + func (x *DeleteScheduleResponse) ProtoReflect() protoreflect.Message + func (x *DeleteScheduleResponse) Reset() + func (x *DeleteScheduleResponse) String() string + type HeartbeatLocksRequest struct + ProcessId string + RequestId string + func (*HeartbeatLocksRequest) Descriptor() ([]byte, []int) + func (*HeartbeatLocksRequest) ProtoMessage() + func (x *HeartbeatLocksRequest) GetProcessId() string + func (x *HeartbeatLocksRequest) GetRequestId() string + func (x *HeartbeatLocksRequest) ProtoReflect() protoreflect.Message + func (x *HeartbeatLocksRequest) Reset() + func (x *HeartbeatLocksRequest) String() string + type HeartbeatLocksResponse struct + LocksAffected int32 + func (*HeartbeatLocksResponse) Descriptor() ([]byte, []int) + func (*HeartbeatLocksResponse) ProtoMessage() + func (x *HeartbeatLocksResponse) GetLocksAffected() int32 + func (x *HeartbeatLocksResponse) ProtoReflect() protoreflect.Message + func (x *HeartbeatLocksResponse) Reset() + func (x *HeartbeatLocksResponse) String() string + type HeartbeatTasksRequest struct + ProcessId string + RequestId string + func (*HeartbeatTasksRequest) Descriptor() ([]byte, []int) + func (*HeartbeatTasksRequest) ProtoMessage() + func (x *HeartbeatTasksRequest) GetProcessId() string + func (x *HeartbeatTasksRequest) GetRequestId() string + func (x *HeartbeatTasksRequest) ProtoReflect() protoreflect.Message + func (x *HeartbeatTasksRequest) Reset() + func (x *HeartbeatTasksRequest) String() string + type HeartbeatTasksResponse struct + TasksAffected int64 + func (*HeartbeatTasksResponse) Descriptor() ([]byte, []int) + func (*HeartbeatTasksResponse) ProtoMessage() + func (x *HeartbeatTasksResponse) GetTasksAffected() int64 + func (x *HeartbeatTasksResponse) ProtoReflect() protoreflect.Message + func (x *HeartbeatTasksResponse) Reset() + func (x *HeartbeatTasksResponse) String() string + type LocksClient interface + AcquireLock func(ctx context.Context, in *AcquireLockRequest, opts ...grpc.CallOption) (*AcquireLockResponse, error) + HeartbeatLocks func(ctx context.Context, in *HeartbeatLocksRequest, opts ...grpc.CallOption) (*HeartbeatLocksResponse, error) + ReleaseLock func(ctx context.Context, in *ReleaseLockRequest, opts ...grpc.CallOption) (*ReleaseLockResponse, error) + func NewLocksClient(cc grpc.ClientConnInterface) LocksClient + type LocksServer interface + AcquireLock func(context.Context, *AcquireLockRequest) (*AcquireLockResponse, error) + HeartbeatLocks func(context.Context, *HeartbeatLocksRequest) (*HeartbeatLocksResponse, error) + ReleaseLock func(context.Context, *ReleaseLockRequest) (*ReleaseLockResponse, error) + type Mesg struct + Promises map[string]*MesgPromise + Type string + func (*Mesg) Descriptor() ([]byte, []int) + func (*Mesg) ProtoMessage() + func (x *Mesg) GetPromises() map[string]*MesgPromise + func (x *Mesg) GetType() string + func (x *Mesg) ProtoReflect() protoreflect.Message + func (x *Mesg) Reset() + func (x *Mesg) String() string + type MesgPromise struct + Data *Promise + Href string + Id string + func (*MesgPromise) Descriptor() ([]byte, []int) + func (*MesgPromise) ProtoMessage() + func (x *MesgPromise) GetData() *Promise + func (x *MesgPromise) GetHref() string + func (x *MesgPromise) GetId() string + func (x *MesgPromise) ProtoReflect() protoreflect.Message + func (x *MesgPromise) Reset() + func (x *MesgPromise) String() string + type PhysicalRecv struct + Data []byte + Type string + func (*PhysicalRecv) Descriptor() ([]byte, []int) + func (*PhysicalRecv) ProtoMessage() + func (x *PhysicalRecv) GetData() []byte + func (x *PhysicalRecv) GetType() string + func (x *PhysicalRecv) ProtoReflect() protoreflect.Message + func (x *PhysicalRecv) Reset() + func (x *PhysicalRecv) String() string + type Promise struct + CompletedOn int64 + CreatedOn int64 + Id string + IdempotencyKeyForComplete string + IdempotencyKeyForCreate string + Param *Value + State State + Tags map[string]string + Timeout int64 + Value *Value + func (*Promise) Descriptor() ([]byte, []int) + func (*Promise) ProtoMessage() + func (x *Promise) GetCompletedOn() int64 + func (x *Promise) GetCreatedOn() int64 + func (x *Promise) GetId() string + func (x *Promise) GetIdempotencyKeyForComplete() string + func (x *Promise) GetIdempotencyKeyForCreate() string + func (x *Promise) GetParam() *Value + func (x *Promise) GetState() State + func (x *Promise) GetTags() map[string]string + func (x *Promise) GetTimeout() int64 + func (x *Promise) GetValue() *Value + func (x *Promise) ProtoReflect() protoreflect.Message + func (x *Promise) Reset() + func (x *Promise) String() string + type PromisesClient interface + CancelPromise func(ctx context.Context, in *CancelPromiseRequest, opts ...grpc.CallOption) (*CancelPromiseResponse, error) + CreatePromise func(ctx context.Context, in *CreatePromiseRequest, opts ...grpc.CallOption) (*CreatePromiseResponse, error) + CreatePromiseAndCallback func(ctx context.Context, in *CreatePromiseAndCallbackRequest, ...) (*CreatePromiseAndCallbackResponse, error) + CreatePromiseAndTask func(ctx context.Context, in *CreatePromiseAndTaskRequest, opts ...grpc.CallOption) (*CreatePromiseAndTaskResponse, error) + ReadPromise func(ctx context.Context, in *ReadPromiseRequest, opts ...grpc.CallOption) (*ReadPromiseResponse, error) + RejectPromise func(ctx context.Context, in *RejectPromiseRequest, opts ...grpc.CallOption) (*RejectPromiseResponse, error) + ResolvePromise func(ctx context.Context, in *ResolvePromiseRequest, opts ...grpc.CallOption) (*ResolvePromiseResponse, error) + SearchPromises func(ctx context.Context, in *SearchPromisesRequest, opts ...grpc.CallOption) (*SearchPromisesResponse, error) + func NewPromisesClient(cc grpc.ClientConnInterface) PromisesClient + type PromisesServer interface + CancelPromise func(context.Context, *CancelPromiseRequest) (*CancelPromiseResponse, error) + CreatePromise func(context.Context, *CreatePromiseRequest) (*CreatePromiseResponse, error) + CreatePromiseAndCallback func(context.Context, *CreatePromiseAndCallbackRequest) (*CreatePromiseAndCallbackResponse, error) + CreatePromiseAndTask func(context.Context, *CreatePromiseAndTaskRequest) (*CreatePromiseAndTaskResponse, error) + ReadPromise func(context.Context, *ReadPromiseRequest) (*ReadPromiseResponse, error) + RejectPromise func(context.Context, *RejectPromiseRequest) (*RejectPromiseResponse, error) + ResolvePromise func(context.Context, *ResolvePromiseRequest) (*ResolvePromiseResponse, error) + SearchPromises func(context.Context, *SearchPromisesRequest) (*SearchPromisesResponse, error) + type ReadPromiseRequest struct + Id string + RequestId string + func (*ReadPromiseRequest) Descriptor() ([]byte, []int) + func (*ReadPromiseRequest) ProtoMessage() + func (x *ReadPromiseRequest) GetId() string + func (x *ReadPromiseRequest) GetRequestId() string + func (x *ReadPromiseRequest) ProtoReflect() protoreflect.Message + func (x *ReadPromiseRequest) Reset() + func (x *ReadPromiseRequest) String() string + type ReadPromiseResponse struct + Promise *Promise + func (*ReadPromiseResponse) Descriptor() ([]byte, []int) + func (*ReadPromiseResponse) ProtoMessage() + func (x *ReadPromiseResponse) GetPromise() *Promise + func (x *ReadPromiseResponse) ProtoReflect() protoreflect.Message + func (x *ReadPromiseResponse) Reset() + func (x *ReadPromiseResponse) String() string + type ReadScheduleRequest struct + Id string + RequestId string + func (*ReadScheduleRequest) Descriptor() ([]byte, []int) + func (*ReadScheduleRequest) ProtoMessage() + func (x *ReadScheduleRequest) GetId() string + func (x *ReadScheduleRequest) GetRequestId() string + func (x *ReadScheduleRequest) ProtoReflect() protoreflect.Message + func (x *ReadScheduleRequest) Reset() + func (x *ReadScheduleRequest) String() string + type ReadScheduleResponse struct + Schedule *Schedule + func (*ReadScheduleResponse) Descriptor() ([]byte, []int) + func (*ReadScheduleResponse) ProtoMessage() + func (x *ReadScheduleResponse) GetSchedule() *Schedule + func (x *ReadScheduleResponse) ProtoReflect() protoreflect.Message + func (x *ReadScheduleResponse) Reset() + func (x *ReadScheduleResponse) String() string + type Recv struct + Recv isRecv_Recv + func (*Recv) Descriptor() ([]byte, []int) + func (*Recv) ProtoMessage() + func (m *Recv) GetRecv() isRecv_Recv + func (x *Recv) GetLogical() string + func (x *Recv) GetPhysical() *PhysicalRecv + func (x *Recv) ProtoReflect() protoreflect.Message + func (x *Recv) Reset() + func (x *Recv) String() string + type Recv_Logical struct + Logical string + type Recv_Physical struct + Physical *PhysicalRecv + type RejectPromiseRequest struct + Id string + IdempotencyKey string + RequestId string + Strict bool + Value *Value + func (*RejectPromiseRequest) Descriptor() ([]byte, []int) + func (*RejectPromiseRequest) ProtoMessage() + func (x *RejectPromiseRequest) GetId() string + func (x *RejectPromiseRequest) GetIdempotencyKey() string + func (x *RejectPromiseRequest) GetRequestId() string + func (x *RejectPromiseRequest) GetStrict() bool + func (x *RejectPromiseRequest) GetValue() *Value + func (x *RejectPromiseRequest) ProtoReflect() protoreflect.Message + func (x *RejectPromiseRequest) Reset() + func (x *RejectPromiseRequest) String() string + type RejectPromiseResponse struct + Noop bool + Promise *Promise + func (*RejectPromiseResponse) Descriptor() ([]byte, []int) + func (*RejectPromiseResponse) ProtoMessage() + func (x *RejectPromiseResponse) GetNoop() bool + func (x *RejectPromiseResponse) GetPromise() *Promise + func (x *RejectPromiseResponse) ProtoReflect() protoreflect.Message + func (x *RejectPromiseResponse) Reset() + func (x *RejectPromiseResponse) String() string + type ReleaseLockRequest struct + ExecutionId string + RequestId string + ResourceId string + func (*ReleaseLockRequest) Descriptor() ([]byte, []int) + func (*ReleaseLockRequest) ProtoMessage() + func (x *ReleaseLockRequest) GetExecutionId() string + func (x *ReleaseLockRequest) GetRequestId() string + func (x *ReleaseLockRequest) GetResourceId() string + func (x *ReleaseLockRequest) ProtoReflect() protoreflect.Message + func (x *ReleaseLockRequest) Reset() + func (x *ReleaseLockRequest) String() string + type ReleaseLockResponse struct + Released bool + func (*ReleaseLockResponse) Descriptor() ([]byte, []int) + func (*ReleaseLockResponse) ProtoMessage() + func (x *ReleaseLockResponse) GetReleased() bool + func (x *ReleaseLockResponse) ProtoReflect() protoreflect.Message + func (x *ReleaseLockResponse) Reset() + func (x *ReleaseLockResponse) String() string + type ResolvePromiseRequest struct + Id string + IdempotencyKey string + RequestId string + Strict bool + Value *Value + func (*ResolvePromiseRequest) Descriptor() ([]byte, []int) + func (*ResolvePromiseRequest) ProtoMessage() + func (x *ResolvePromiseRequest) GetId() string + func (x *ResolvePromiseRequest) GetIdempotencyKey() string + func (x *ResolvePromiseRequest) GetRequestId() string + func (x *ResolvePromiseRequest) GetStrict() bool + func (x *ResolvePromiseRequest) GetValue() *Value + func (x *ResolvePromiseRequest) ProtoReflect() protoreflect.Message + func (x *ResolvePromiseRequest) Reset() + func (x *ResolvePromiseRequest) String() string + type ResolvePromiseResponse struct + Noop bool + Promise *Promise + func (*ResolvePromiseResponse) Descriptor() ([]byte, []int) + func (*ResolvePromiseResponse) ProtoMessage() + func (x *ResolvePromiseResponse) GetNoop() bool + func (x *ResolvePromiseResponse) GetPromise() *Promise + func (x *ResolvePromiseResponse) ProtoReflect() protoreflect.Message + func (x *ResolvePromiseResponse) Reset() + func (x *ResolvePromiseResponse) String() string + type Schedule struct + CreatedOn int64 + Cron string + Description string + Id string + IdempotencyKey string + LastRunTime int64 + NextRunTime int64 + PromiseId string + PromiseParam *Value + PromiseTags map[string]string + PromiseTimeout int64 + Tags map[string]string + func (*Schedule) Descriptor() ([]byte, []int) + func (*Schedule) ProtoMessage() + func (x *Schedule) GetCreatedOn() int64 + func (x *Schedule) GetCron() string + func (x *Schedule) GetDescription() string + func (x *Schedule) GetId() string + func (x *Schedule) GetIdempotencyKey() string + func (x *Schedule) GetLastRunTime() int64 + func (x *Schedule) GetNextRunTime() int64 + func (x *Schedule) GetPromiseId() string + func (x *Schedule) GetPromiseParam() *Value + func (x *Schedule) GetPromiseTags() map[string]string + func (x *Schedule) GetPromiseTimeout() int64 + func (x *Schedule) GetTags() map[string]string + func (x *Schedule) ProtoReflect() protoreflect.Message + func (x *Schedule) Reset() + func (x *Schedule) String() string + type SchedulesClient interface + CreateSchedule func(ctx context.Context, in *CreateScheduleRequest, opts ...grpc.CallOption) (*CreatedScheduleResponse, error) + DeleteSchedule func(ctx context.Context, in *DeleteScheduleRequest, opts ...grpc.CallOption) (*DeleteScheduleResponse, error) + ReadSchedule func(ctx context.Context, in *ReadScheduleRequest, opts ...grpc.CallOption) (*ReadScheduleResponse, error) + SearchSchedules func(ctx context.Context, in *SearchSchedulesRequest, opts ...grpc.CallOption) (*SearchSchedulesResponse, error) + func NewSchedulesClient(cc grpc.ClientConnInterface) SchedulesClient + type SchedulesServer interface + CreateSchedule func(context.Context, *CreateScheduleRequest) (*CreatedScheduleResponse, error) + DeleteSchedule func(context.Context, *DeleteScheduleRequest) (*DeleteScheduleResponse, error) + ReadSchedule func(context.Context, *ReadScheduleRequest) (*ReadScheduleResponse, error) + SearchSchedules func(context.Context, *SearchSchedulesRequest) (*SearchSchedulesResponse, error) + type SearchPromisesRequest struct + Cursor string + Id string + Limit int32 + RequestId string + State SearchState + Tags map[string]string + func (*SearchPromisesRequest) Descriptor() ([]byte, []int) + func (*SearchPromisesRequest) ProtoMessage() + func (x *SearchPromisesRequest) GetCursor() string + func (x *SearchPromisesRequest) GetId() string + func (x *SearchPromisesRequest) GetLimit() int32 + func (x *SearchPromisesRequest) GetRequestId() string + func (x *SearchPromisesRequest) GetState() SearchState + func (x *SearchPromisesRequest) GetTags() map[string]string + func (x *SearchPromisesRequest) ProtoReflect() protoreflect.Message + func (x *SearchPromisesRequest) Reset() + func (x *SearchPromisesRequest) String() string + type SearchPromisesResponse struct + Cursor string + Promises []*Promise + func (*SearchPromisesResponse) Descriptor() ([]byte, []int) + func (*SearchPromisesResponse) ProtoMessage() + func (x *SearchPromisesResponse) GetCursor() string + func (x *SearchPromisesResponse) GetPromises() []*Promise + func (x *SearchPromisesResponse) ProtoReflect() protoreflect.Message + func (x *SearchPromisesResponse) Reset() + func (x *SearchPromisesResponse) String() string + type SearchSchedulesRequest struct + Cursor string + Id string + Limit int32 + RequestId string + Tags map[string]string + func (*SearchSchedulesRequest) Descriptor() ([]byte, []int) + func (*SearchSchedulesRequest) ProtoMessage() + func (x *SearchSchedulesRequest) GetCursor() string + func (x *SearchSchedulesRequest) GetId() string + func (x *SearchSchedulesRequest) GetLimit() int32 + func (x *SearchSchedulesRequest) GetRequestId() string + func (x *SearchSchedulesRequest) GetTags() map[string]string + func (x *SearchSchedulesRequest) ProtoReflect() protoreflect.Message + func (x *SearchSchedulesRequest) Reset() + func (x *SearchSchedulesRequest) String() string + type SearchSchedulesResponse struct + Cursor string + Schedules []*Schedule + func (*SearchSchedulesResponse) Descriptor() ([]byte, []int) + func (*SearchSchedulesResponse) ProtoMessage() + func (x *SearchSchedulesResponse) GetCursor() string + func (x *SearchSchedulesResponse) GetSchedules() []*Schedule + func (x *SearchSchedulesResponse) ProtoReflect() protoreflect.Message + func (x *SearchSchedulesResponse) Reset() + func (x *SearchSchedulesResponse) String() string + type SearchState int32 + const SearchState_SEARCH_ALL + const SearchState_SEARCH_PENDING + const SearchState_SEARCH_REJECTED + const SearchState_SEARCH_RESOLVED + func (SearchState) Descriptor() protoreflect.EnumDescriptor + func (SearchState) EnumDescriptor() ([]byte, []int) + func (SearchState) Type() protoreflect.EnumType + func (x SearchState) Enum() *SearchState + func (x SearchState) Number() protoreflect.EnumNumber + func (x SearchState) String() string + type State int32 + const State_PENDING + const State_REJECTED + const State_REJECTED_CANCELED + const State_REJECTED_TIMEDOUT + const State_RESOLVED + func (State) Descriptor() protoreflect.EnumDescriptor + func (State) EnumDescriptor() ([]byte, []int) + func (State) Type() protoreflect.EnumType + func (x State) Enum() *State + func (x State) Number() protoreflect.EnumNumber + func (x State) String() string + type TasksClient interface + ClaimTask func(ctx context.Context, in *ClaimTaskRequest, opts ...grpc.CallOption) (*ClaimTaskResponse, error) + CompleteTask func(ctx context.Context, in *CompleteTaskRequest, opts ...grpc.CallOption) (*CompleteTaskResponse, error) + HeartbeatTasks func(ctx context.Context, in *HeartbeatTasksRequest, opts ...grpc.CallOption) (*HeartbeatTasksResponse, error) + func NewTasksClient(cc grpc.ClientConnInterface) TasksClient + type TasksServer interface + ClaimTask func(context.Context, *ClaimTaskRequest) (*ClaimTaskResponse, error) + CompleteTask func(context.Context, *CompleteTaskRequest) (*CompleteTaskResponse, error) + HeartbeatTasks func(context.Context, *HeartbeatTasksRequest) (*HeartbeatTasksResponse, error) + type UnimplementedCallbacksServer struct + func (UnimplementedCallbacksServer) CreateCallback(context.Context, *CreateCallbackRequest) (*CreateCallbackResponse, error) + type UnimplementedLocksServer struct + func (UnimplementedLocksServer) AcquireLock(context.Context, *AcquireLockRequest) (*AcquireLockResponse, error) + func (UnimplementedLocksServer) HeartbeatLocks(context.Context, *HeartbeatLocksRequest) (*HeartbeatLocksResponse, error) + func (UnimplementedLocksServer) ReleaseLock(context.Context, *ReleaseLockRequest) (*ReleaseLockResponse, error) + type UnimplementedPromisesServer struct + func (UnimplementedPromisesServer) CancelPromise(context.Context, *CancelPromiseRequest) (*CancelPromiseResponse, error) + func (UnimplementedPromisesServer) CreatePromise(context.Context, *CreatePromiseRequest) (*CreatePromiseResponse, error) + func (UnimplementedPromisesServer) CreatePromiseAndCallback(context.Context, *CreatePromiseAndCallbackRequest) (*CreatePromiseAndCallbackResponse, error) + func (UnimplementedPromisesServer) CreatePromiseAndTask(context.Context, *CreatePromiseAndTaskRequest) (*CreatePromiseAndTaskResponse, error) + func (UnimplementedPromisesServer) ReadPromise(context.Context, *ReadPromiseRequest) (*ReadPromiseResponse, error) + func (UnimplementedPromisesServer) RejectPromise(context.Context, *RejectPromiseRequest) (*RejectPromiseResponse, error) + func (UnimplementedPromisesServer) ResolvePromise(context.Context, *ResolvePromiseRequest) (*ResolvePromiseResponse, error) + func (UnimplementedPromisesServer) SearchPromises(context.Context, *SearchPromisesRequest) (*SearchPromisesResponse, error) + type UnimplementedSchedulesServer struct + func (UnimplementedSchedulesServer) CreateSchedule(context.Context, *CreateScheduleRequest) (*CreatedScheduleResponse, error) + func (UnimplementedSchedulesServer) DeleteSchedule(context.Context, *DeleteScheduleRequest) (*DeleteScheduleResponse, error) + func (UnimplementedSchedulesServer) ReadSchedule(context.Context, *ReadScheduleRequest) (*ReadScheduleResponse, error) + func (UnimplementedSchedulesServer) SearchSchedules(context.Context, *SearchSchedulesRequest) (*SearchSchedulesResponse, error) + type UnimplementedTasksServer struct + func (UnimplementedTasksServer) ClaimTask(context.Context, *ClaimTaskRequest) (*ClaimTaskResponse, error) + func (UnimplementedTasksServer) CompleteTask(context.Context, *CompleteTaskRequest) (*CompleteTaskResponse, error) + func (UnimplementedTasksServer) HeartbeatTasks(context.Context, *HeartbeatTasksRequest) (*HeartbeatTasksResponse, error) + type UnsafeCallbacksServer interface + type UnsafeLocksServer interface + type UnsafePromisesServer interface + type UnsafeSchedulesServer interface + type UnsafeTasksServer interface + type Value struct + Data []byte + Headers map[string]string + func (*Value) Descriptor() ([]byte, []int) + func (*Value) ProtoMessage() + func (x *Value) GetData() []byte + func (x *Value) GetHeaders() map[string]string + func (x *Value) ProtoReflect() protoreflect.Message + func (x *Value) Reset() + func (x *Value) String() string
Go to main page