pb

package
v0.7.2 Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Locks_AcquireLock_FullMethodName    = "/lock.Locks/AcquireLock"
	Locks_ReleaseLock_FullMethodName    = "/lock.Locks/ReleaseLock"
	Locks_HeartbeatLocks_FullMethodName = "/lock.Locks/HeartbeatLocks"
)
View Source 
const (
	Promises_ReadPromise_FullMethodName          = "/promise.Promises/ReadPromise"
	Promises_SearchPromises_FullMethodName       = "/promise.Promises/SearchPromises"
	Promises_CreatePromise_FullMethodName        = "/promise.Promises/CreatePromise"
	Promises_CreatePromiseAndTask_FullMethodName = "/promise.Promises/CreatePromiseAndTask"
	Promises_ResolvePromise_FullMethodName       = "/promise.Promises/ResolvePromise"
	Promises_RejectPromise_FullMethodName        = "/promise.Promises/RejectPromise"
	Promises_CancelPromise_FullMethodName        = "/promise.Promises/CancelPromise"
)
View Source 
const (
	Schedules_ReadSchedule_FullMethodName    = "/schedule.Schedules/ReadSchedule"
	Schedules_SearchSchedules_FullMethodName = "/schedule.Schedules/SearchSchedules"
	Schedules_CreateSchedule_FullMethodName  = "/schedule.Schedules/CreateSchedule"
	Schedules_DeleteSchedule_FullMethodName  = "/schedule.Schedules/DeleteSchedule"
)
View Source 
const (
	Tasks_ClaimTask_FullMethodName      = "/task.Tasks/ClaimTask"
	Tasks_CompleteTask_FullMethodName   = "/task.Tasks/CompleteTask"
	Tasks_HeartbeatTasks_FullMethodName = "/task.Tasks/HeartbeatTasks"
)
View Source 
const (
	Callbacks_CreateCallback_FullMethodName = "/callback.Callbacks/CreateCallback"
)

Variables

View Source 
var (
	SearchState_name = map[int32]string{
		0: "SEARCH_ALL",
		1: "SEARCH_PENDING",
		2: "SEARCH_RESOLVED",
		3: "SEARCH_REJECTED",
	}
	SearchState_value = map[string]int32{
		"SEARCH_ALL":      0,
		"SEARCH_PENDING":  1,
		"SEARCH_RESOLVED": 2,
		"SEARCH_REJECTED": 3,
	}
)

Enum value maps for SearchState.

View Source 
var (
	State_name = map[int32]string{
		0: "PENDING",
		1: "RESOLVED",
		2: "REJECTED",
		3: "REJECTED_TIMEDOUT",
		4: "REJECTED_CANCELED",
	}
	State_value = map[string]int32{
		"PENDING":           0,
		"RESOLVED":          1,
		"REJECTED":          2,
		"REJECTED_TIMEDOUT": 3,
		"REJECTED_CANCELED": 4,
	}
)

Enum value maps for State.

View Source 
var Callbacks_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "callback.Callbacks",
	HandlerType: (*CallbacksServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCallback",
			Handler:    _Callbacks_CreateCallback_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/app/subsystems/api/grpc/pb/callback.proto",
}

Callbacks_ServiceDesc is the grpc.ServiceDesc for Callbacks 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 File_internal_app_subsystems_api_grpc_pb_callback_proto protoreflect.FileDescriptor
View Source 
var File_internal_app_subsystems_api_grpc_pb_callback_t_proto protoreflect.FileDescriptor
View Source 
var File_internal_app_subsystems_api_grpc_pb_lock_proto protoreflect.FileDescriptor
View Source 
var File_internal_app_subsystems_api_grpc_pb_promise_proto protoreflect.FileDescriptor
View Source 
var File_internal_app_subsystems_api_grpc_pb_promise_t_proto protoreflect.FileDescriptor
View Source 
var File_internal_app_subsystems_api_grpc_pb_schedule_proto protoreflect.FileDescriptor
View Source 
var File_internal_app_subsystems_api_grpc_pb_schedule_t_proto protoreflect.FileDescriptor
View Source 
var File_internal_app_subsystems_api_grpc_pb_task_proto protoreflect.FileDescriptor
View Source 
var Locks_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "lock.Locks",
	HandlerType: (*LocksServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AcquireLock",
			Handler:    _Locks_AcquireLock_Handler,
		},
		{
			MethodName: "ReleaseLock",
			Handler:    _Locks_ReleaseLock_Handler,
		},
		{
			MethodName: "HeartbeatLocks",
			Handler:    _Locks_HeartbeatLocks_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/app/subsystems/api/grpc/pb/lock.proto",
}

Locks_ServiceDesc is the grpc.ServiceDesc for Locks 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 Promises_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "promise.Promises",
	HandlerType: (*PromisesServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReadPromise",
			Handler:    _Promises_ReadPromise_Handler,
		},
		{
			MethodName: "SearchPromises",
			Handler:    _Promises_SearchPromises_Handler,
		},
		{
			MethodName: "CreatePromise",
			Handler:    _Promises_CreatePromise_Handler,
		},
		{
			MethodName: "CreatePromiseAndTask",
			Handler:    _Promises_CreatePromiseAndTask_Handler,
		},
		{
			MethodName: "ResolvePromise",
			Handler:    _Promises_ResolvePromise_Handler,
		},
		{
			MethodName: "RejectPromise",
			Handler:    _Promises_RejectPromise_Handler,
		},
		{
			MethodName: "CancelPromise",
			Handler:    _Promises_CancelPromise_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/app/subsystems/api/grpc/pb/promise.proto",
}

Promises_ServiceDesc is the grpc.ServiceDesc for Promises 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 Schedules_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "schedule.Schedules",
	HandlerType: (*SchedulesServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReadSchedule",
			Handler:    _Schedules_ReadSchedule_Handler,
		},
		{
			MethodName: "SearchSchedules",
			Handler:    _Schedules_SearchSchedules_Handler,
		},
		{
			MethodName: "CreateSchedule",
			Handler:    _Schedules_CreateSchedule_Handler,
		},
		{
			MethodName: "DeleteSchedule",
			Handler:    _Schedules_DeleteSchedule_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/app/subsystems/api/grpc/pb/schedule.proto",
}

Schedules_ServiceDesc is the grpc.ServiceDesc for Schedules 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 Tasks_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "task.Tasks",
	HandlerType: (*TasksServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ClaimTask",
			Handler:    _Tasks_ClaimTask_Handler,
		},
		{
			MethodName: "CompleteTask",
			Handler:    _Tasks_CompleteTask_Handler,
		},
		{
			MethodName: "HeartbeatTasks",
			Handler:    _Tasks_HeartbeatTasks_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/app/subsystems/api/grpc/pb/task.proto",
}

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

Functions

func RegisterCallbacksServer 

func RegisterCallbacksServer(s grpc.ServiceRegistrar, srv CallbacksServer)

func RegisterLocksServer 

func RegisterLocksServer(s grpc.ServiceRegistrar, srv LocksServer)

func RegisterPromisesServer 

func RegisterPromisesServer(s grpc.ServiceRegistrar, srv PromisesServer)

func RegisterSchedulesServer 

func RegisterSchedulesServer(s grpc.ServiceRegistrar, srv SchedulesServer)

func RegisterTasksServer 

func RegisterTasksServer(s grpc.ServiceRegistrar, srv TasksServer)

Types

type AcquireLockRequest 

type AcquireLockRequest struct {
	ResourceId  string `protobuf:"bytes,1,opt,name=resourceId,proto3" json:"resourceId,omitempty"`
	ExecutionId string `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
	ProcessId   string `protobuf:"bytes,3,opt,name=processId,proto3" json:"processId,omitempty"`
	Ttl         int64  `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
	RequestId   string `protobuf:"bytes,5,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*AcquireLockRequest) Descriptor deprecated 

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

Deprecated: Use AcquireLockRequest.ProtoReflect.Descriptor instead.

func (*AcquireLockRequest) GetExecutionId 

func (x *AcquireLockRequest) GetExecutionId() string

func (*AcquireLockRequest) GetProcessId 

func (x *AcquireLockRequest) GetProcessId() string

func (*AcquireLockRequest) GetRequestId 

func (x *AcquireLockRequest) GetRequestId() string

func (*AcquireLockRequest) GetResourceId 

func (x *AcquireLockRequest) GetResourceId() string

func (*AcquireLockRequest) GetTtl 

func (x *AcquireLockRequest) GetTtl() int64

func (*AcquireLockRequest) ProtoMessage 

func (*AcquireLockRequest) ProtoMessage()

func (*AcquireLockRequest) ProtoReflect 

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

func (*AcquireLockRequest) Reset 

func (x *AcquireLockRequest) Reset()

func (*AcquireLockRequest) String 

func (x *AcquireLockRequest) String() string

type AcquireLockResponse 

type AcquireLockResponse struct {
	Acquired bool `protobuf:"varint,1,opt,name=acquired,proto3" json:"acquired,omitempty"`
	// contains filtered or unexported fields
}

func (*AcquireLockResponse) Descriptor deprecated 

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

Deprecated: Use AcquireLockResponse.ProtoReflect.Descriptor instead.

func (*AcquireLockResponse) GetAcquired 

func (x *AcquireLockResponse) GetAcquired() bool

func (*AcquireLockResponse) ProtoMessage 

func (*AcquireLockResponse) ProtoMessage()

func (*AcquireLockResponse) ProtoReflect 

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

func (*AcquireLockResponse) Reset 

func (x *AcquireLockResponse) Reset()

func (*AcquireLockResponse) String 

func (x *AcquireLockResponse) String() string

type Callback 

type Callback struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PromiseId string `protobuf:"bytes,2,opt,name=promiseId,proto3" json:"promiseId,omitempty"`
	Timeout   int64  `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	CreatedOn int64  `protobuf:"varint,4,opt,name=createdOn,proto3" json:"createdOn,omitempty"`
	// contains filtered or unexported fields
}

func (*Callback) Descriptor deprecated 

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

Deprecated: Use Callback.ProtoReflect.Descriptor instead.

func (*Callback) GetCreatedOn 

func (x *Callback) GetCreatedOn() int64

func (*Callback) GetId 

func (x *Callback) GetId() string

func (*Callback) GetPromiseId 

func (x *Callback) GetPromiseId() string

func (*Callback) GetTimeout 

func (x *Callback) GetTimeout() int64

func (*Callback) ProtoMessage 

func (*Callback) ProtoMessage()

func (*Callback) ProtoReflect 

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

func (*Callback) Reset 

func (x *Callback) Reset()

func (*Callback) String 

func (x *Callback) String() string

type CallbacksClient 

type CallbacksClient interface {
	CreateCallback(ctx context.Context, in *CreateCallbackRequest, opts ...grpc.CallOption) (*CreateCallbackResponse, error)
}

CallbacksClient is the client API for Callbacks 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 NewCallbacksClient 

func NewCallbacksClient(cc grpc.ClientConnInterface) CallbacksClient

type CallbacksServer 

type CallbacksServer interface {
	CreateCallback(context.Context, *CreateCallbackRequest) (*CreateCallbackResponse, error)
	// contains filtered or unexported methods
}

CallbacksServer is the server API for Callbacks service. All implementations must embed UnimplementedCallbacksServer for forward compatibility.

type CancelPromiseRequest 

type CancelPromiseRequest struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	IdempotencyKey string `protobuf:"bytes,2,opt,name=idempotencyKey,proto3" json:"idempotencyKey,omitempty"`
	Strict         bool   `protobuf:"varint,3,opt,name=strict,proto3" json:"strict,omitempty"`
	Value          *Value `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	RequestId      string `protobuf:"bytes,5,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelPromiseRequest) Descriptor deprecated 

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

Deprecated: Use CancelPromiseRequest.ProtoReflect.Descriptor instead.

func (*CancelPromiseRequest) GetId 

func (x *CancelPromiseRequest) GetId() string

func (*CancelPromiseRequest) GetIdempotencyKey 

func (x *CancelPromiseRequest) GetIdempotencyKey() string

func (*CancelPromiseRequest) GetRequestId 

func (x *CancelPromiseRequest) GetRequestId() string

func (*CancelPromiseRequest) GetStrict 

func (x *CancelPromiseRequest) GetStrict() bool

func (*CancelPromiseRequest) GetValue 

func (x *CancelPromiseRequest) GetValue() *Value

func (*CancelPromiseRequest) ProtoMessage 

func (*CancelPromiseRequest) ProtoMessage()

func (*CancelPromiseRequest) ProtoReflect 

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

func (*CancelPromiseRequest) Reset 

func (x *CancelPromiseRequest) Reset()

func (*CancelPromiseRequest) String 

func (x *CancelPromiseRequest) String() string

type CancelPromiseResponse 

type CancelPromiseResponse struct {
	Noop    bool     `protobuf:"varint,1,opt,name=noop,proto3" json:"noop,omitempty"`
	Promise *Promise `protobuf:"bytes,2,opt,name=promise,proto3" json:"promise,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelPromiseResponse) Descriptor deprecated 

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

Deprecated: Use CancelPromiseResponse.ProtoReflect.Descriptor instead.

func (*CancelPromiseResponse) GetNoop 

func (x *CancelPromiseResponse) GetNoop() bool

func (*CancelPromiseResponse) GetPromise 

func (x *CancelPromiseResponse) GetPromise() *Promise

func (*CancelPromiseResponse) ProtoMessage 

func (*CancelPromiseResponse) ProtoMessage()

func (*CancelPromiseResponse) ProtoReflect 

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

func (*CancelPromiseResponse) Reset 

func (x *CancelPromiseResponse) Reset()

func (*CancelPromiseResponse) String 

func (x *CancelPromiseResponse) String() string

type ClaimTaskRequest 

type ClaimTaskRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Counter   int32  `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
	ProcessId string `protobuf:"bytes,3,opt,name=processId,proto3" json:"processId,omitempty"`
	Ttl       int32  `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
	RequestId string `protobuf:"bytes,5,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*ClaimTaskRequest) Descriptor deprecated 

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

Deprecated: Use ClaimTaskRequest.ProtoReflect.Descriptor instead.

func (*ClaimTaskRequest) GetCounter 

func (x *ClaimTaskRequest) GetCounter() int32

func (*ClaimTaskRequest) GetId 

func (x *ClaimTaskRequest) GetId() string

func (*ClaimTaskRequest) GetProcessId 

func (x *ClaimTaskRequest) GetProcessId() string

func (*ClaimTaskRequest) GetRequestId 

func (x *ClaimTaskRequest) GetRequestId() string

func (*ClaimTaskRequest) GetTtl 

func (x *ClaimTaskRequest) GetTtl() int32

func (*ClaimTaskRequest) ProtoMessage 

func (*ClaimTaskRequest) ProtoMessage()

func (*ClaimTaskRequest) ProtoReflect 

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

func (*ClaimTaskRequest) Reset 

func (x *ClaimTaskRequest) Reset()

func (*ClaimTaskRequest) String 

func (x *ClaimTaskRequest) String() string

type ClaimTaskResponse 

type ClaimTaskResponse struct {
	Claimed bool  `protobuf:"varint,1,opt,name=claimed,proto3" json:"claimed,omitempty"`
	Mesg    *Mesg `protobuf:"bytes,2,opt,name=mesg,proto3" json:"mesg,omitempty"`
	// contains filtered or unexported fields
}

func (*ClaimTaskResponse) Descriptor deprecated 

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

Deprecated: Use ClaimTaskResponse.ProtoReflect.Descriptor instead.

func (*ClaimTaskResponse) GetClaimed 

func (x *ClaimTaskResponse) GetClaimed() bool

func (*ClaimTaskResponse) GetMesg 

func (x *ClaimTaskResponse) GetMesg() *Mesg

func (*ClaimTaskResponse) ProtoMessage 

func (*ClaimTaskResponse) ProtoMessage()

func (*ClaimTaskResponse) ProtoReflect 

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

func (*ClaimTaskResponse) Reset 

func (x *ClaimTaskResponse) Reset()

func (*ClaimTaskResponse) String 

func (x *ClaimTaskResponse) String() string

type CompleteTaskRequest 

type CompleteTaskRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Counter   int32  `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
	RequestId string `protobuf:"bytes,3,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteTaskRequest) Descriptor deprecated 

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

Deprecated: Use CompleteTaskRequest.ProtoReflect.Descriptor instead.

func (*CompleteTaskRequest) GetCounter 

func (x *CompleteTaskRequest) GetCounter() int32

func (*CompleteTaskRequest) GetId 

func (x *CompleteTaskRequest) GetId() string

func (*CompleteTaskRequest) GetRequestId 

func (x *CompleteTaskRequest) GetRequestId() string

func (*CompleteTaskRequest) ProtoMessage 

func (*CompleteTaskRequest) ProtoMessage()

func (*CompleteTaskRequest) ProtoReflect 

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

func (*CompleteTaskRequest) Reset 

func (x *CompleteTaskRequest) Reset()

func (*CompleteTaskRequest) String 

func (x *CompleteTaskRequest) String() string

type CompleteTaskResponse 

type CompleteTaskResponse struct {
	Completed bool `protobuf:"varint,1,opt,name=completed,proto3" json:"completed,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteTaskResponse) Descriptor deprecated 

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

Deprecated: Use CompleteTaskResponse.ProtoReflect.Descriptor instead.

func (*CompleteTaskResponse) GetCompleted 

func (x *CompleteTaskResponse) GetCompleted() bool

func (*CompleteTaskResponse) ProtoMessage 

func (*CompleteTaskResponse) ProtoMessage()

func (*CompleteTaskResponse) ProtoReflect 

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

func (*CompleteTaskResponse) Reset 

func (x *CompleteTaskResponse) Reset()

func (*CompleteTaskResponse) String 

func (x *CompleteTaskResponse) String() string

type CreateCallbackRequest 

type CreateCallbackRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PromiseId     string `protobuf:"bytes,2,opt,name=promiseId,proto3" json:"promiseId,omitempty"`
	RootPromiseId string `protobuf:"bytes,3,opt,name=rootPromiseId,proto3" json:"rootPromiseId,omitempty"`
	Timeout       int64  `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Recv          *Recv  `protobuf:"bytes,5,opt,name=recv,proto3" json:"recv,omitempty"`
	RequestId     string `protobuf:"bytes,6,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateCallbackRequest) Descriptor deprecated 

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

Deprecated: Use CreateCallbackRequest.ProtoReflect.Descriptor instead.

func (*CreateCallbackRequest) GetId 

func (x *CreateCallbackRequest) GetId() string

func (*CreateCallbackRequest) GetPromiseId 

func (x *CreateCallbackRequest) GetPromiseId() string

func (*CreateCallbackRequest) GetRecv 

func (x *CreateCallbackRequest) GetRecv() *Recv

func (*CreateCallbackRequest) GetRequestId 

func (x *CreateCallbackRequest) GetRequestId() string

func (*CreateCallbackRequest) GetRootPromiseId 

func (x *CreateCallbackRequest) GetRootPromiseId() string

func (*CreateCallbackRequest) GetTimeout 

func (x *CreateCallbackRequest) GetTimeout() int64

func (*CreateCallbackRequest) ProtoMessage 

func (*CreateCallbackRequest) ProtoMessage()

func (*CreateCallbackRequest) ProtoReflect 

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

func (*CreateCallbackRequest) Reset 

func (x *CreateCallbackRequest) Reset()

func (*CreateCallbackRequest) String 

func (x *CreateCallbackRequest) String() string

type CreateCallbackResponse 

type CreateCallbackResponse struct {
	Noop     bool      `protobuf:"varint,1,opt,name=noop,proto3" json:"noop,omitempty"`
	Callback *Callback `protobuf:"bytes,2,opt,name=callback,proto3" json:"callback,omitempty"`
	Promise  *Promise  `protobuf:"bytes,3,opt,name=promise,proto3" json:"promise,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateCallbackResponse) Descriptor deprecated 

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

Deprecated: Use CreateCallbackResponse.ProtoReflect.Descriptor instead.

func (*CreateCallbackResponse) GetCallback 

func (x *CreateCallbackResponse) GetCallback() *Callback

func (*CreateCallbackResponse) GetNoop 

func (x *CreateCallbackResponse) GetNoop() bool

func (*CreateCallbackResponse) GetPromise 

func (x *CreateCallbackResponse) GetPromise() *Promise

func (*CreateCallbackResponse) ProtoMessage 

func (*CreateCallbackResponse) ProtoMessage()

func (*CreateCallbackResponse) ProtoReflect 

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

func (*CreateCallbackResponse) Reset 

func (x *CreateCallbackResponse) Reset()

func (*CreateCallbackResponse) String 

func (x *CreateCallbackResponse) String() string

type CreatePromiseAndTaskRequest 

type CreatePromiseAndTaskRequest struct {
	Promise *CreatePromiseRequest     `protobuf:"bytes,1,opt,name=promise,proto3" json:"promise,omitempty"`
	Task    *CreatePromiseTaskRequest `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePromiseAndTaskRequest) Descriptor deprecated 

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

Deprecated: Use CreatePromiseAndTaskRequest.ProtoReflect.Descriptor instead.

func (*CreatePromiseAndTaskRequest) GetPromise 

func (x *CreatePromiseAndTaskRequest) GetPromise() *CreatePromiseRequest

func (*CreatePromiseAndTaskRequest) GetTask 

func (x *CreatePromiseAndTaskRequest) GetTask() *CreatePromiseTaskRequest

func (*CreatePromiseAndTaskRequest) ProtoMessage 

func (*CreatePromiseAndTaskRequest) ProtoMessage()

func (*CreatePromiseAndTaskRequest) ProtoReflect 

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

func (*CreatePromiseAndTaskRequest) Reset 

func (x *CreatePromiseAndTaskRequest) Reset()

func (*CreatePromiseAndTaskRequest) String 

func (x *CreatePromiseAndTaskRequest) String() string

type CreatePromiseAndTaskResponse 

type CreatePromiseAndTaskResponse struct {
	Noop    bool     `protobuf:"varint,1,opt,name=noop,proto3" json:"noop,omitempty"`
	Promise *Promise `protobuf:"bytes,2,opt,name=promise,proto3" json:"promise,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePromiseAndTaskResponse) Descriptor deprecated 

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

Deprecated: Use CreatePromiseAndTaskResponse.ProtoReflect.Descriptor instead.

func (*CreatePromiseAndTaskResponse) GetNoop 

func (x *CreatePromiseAndTaskResponse) GetNoop() bool

func (*CreatePromiseAndTaskResponse) GetPromise 

func (x *CreatePromiseAndTaskResponse) GetPromise() *Promise

func (*CreatePromiseAndTaskResponse) ProtoMessage 

func (*CreatePromiseAndTaskResponse) ProtoMessage()

func (*CreatePromiseAndTaskResponse) ProtoReflect 

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

func (*CreatePromiseAndTaskResponse) Reset 

func (x *CreatePromiseAndTaskResponse) Reset()

func (*CreatePromiseAndTaskResponse) String 

func (x *CreatePromiseAndTaskResponse) String() string

type CreatePromiseRequest 

type CreatePromiseRequest struct {
	Id             string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	IdempotencyKey string            `protobuf:"bytes,2,opt,name=idempotencyKey,proto3" json:"idempotencyKey,omitempty"`
	Strict         bool              `protobuf:"varint,3,opt,name=strict,proto3" json:"strict,omitempty"`
	Param          *Value            `protobuf:"bytes,4,opt,name=param,proto3" json:"param,omitempty"`
	Timeout        int64             `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Tags           map[string]string `` /* 149-byte string literal not displayed */
	RequestId      string            `protobuf:"bytes,7,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePromiseRequest) Descriptor deprecated 

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

Deprecated: Use CreatePromiseRequest.ProtoReflect.Descriptor instead.

func (*CreatePromiseRequest) GetId 

func (x *CreatePromiseRequest) GetId() string

func (*CreatePromiseRequest) GetIdempotencyKey 

func (x *CreatePromiseRequest) GetIdempotencyKey() string

func (*CreatePromiseRequest) GetParam 

func (x *CreatePromiseRequest) GetParam() *Value

func (*CreatePromiseRequest) GetRequestId 

func (x *CreatePromiseRequest) GetRequestId() string

func (*CreatePromiseRequest) GetStrict 

func (x *CreatePromiseRequest) GetStrict() bool

func (*CreatePromiseRequest) GetTags 

func (x *CreatePromiseRequest) GetTags() map[string]string

func (*CreatePromiseRequest) GetTimeout 

func (x *CreatePromiseRequest) GetTimeout() int64

func (*CreatePromiseRequest) ProtoMessage 

func (*CreatePromiseRequest) ProtoMessage()

func (*CreatePromiseRequest) ProtoReflect 

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

func (*CreatePromiseRequest) Reset 

func (x *CreatePromiseRequest) Reset()

func (*CreatePromiseRequest) String 

func (x *CreatePromiseRequest) String() string

type CreatePromiseResponse 

type CreatePromiseResponse struct {
	Noop    bool     `protobuf:"varint,1,opt,name=noop,proto3" json:"noop,omitempty"`
	Promise *Promise `protobuf:"bytes,2,opt,name=promise,proto3" json:"promise,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePromiseResponse) Descriptor deprecated 

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

Deprecated: Use CreatePromiseResponse.ProtoReflect.Descriptor instead.

func (*CreatePromiseResponse) GetNoop 

func (x *CreatePromiseResponse) GetNoop() bool

func (*CreatePromiseResponse) GetPromise 

func (x *CreatePromiseResponse) GetPromise() *Promise

func (*CreatePromiseResponse) ProtoMessage 

func (*CreatePromiseResponse) ProtoMessage()

func (*CreatePromiseResponse) ProtoReflect 

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

func (*CreatePromiseResponse) Reset 

func (x *CreatePromiseResponse) Reset()

func (*CreatePromiseResponse) String 

func (x *CreatePromiseResponse) String() string

type CreatePromiseTaskRequest 

type CreatePromiseTaskRequest struct {
	ProcessId string `protobuf:"bytes,1,opt,name=processId,proto3" json:"processId,omitempty"`
	Ttl       int32  `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePromiseTaskRequest) Descriptor deprecated 

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

Deprecated: Use CreatePromiseTaskRequest.ProtoReflect.Descriptor instead.

func (*CreatePromiseTaskRequest) GetProcessId 

func (x *CreatePromiseTaskRequest) GetProcessId() string

func (*CreatePromiseTaskRequest) GetTtl 

func (x *CreatePromiseTaskRequest) GetTtl() int32

func (*CreatePromiseTaskRequest) ProtoMessage 

func (*CreatePromiseTaskRequest) ProtoMessage()

func (*CreatePromiseTaskRequest) ProtoReflect 

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

func (*CreatePromiseTaskRequest) Reset 

func (x *CreatePromiseTaskRequest) Reset()

func (*CreatePromiseTaskRequest) String 

func (x *CreatePromiseTaskRequest) String() string

type CreateScheduleRequest 

type CreateScheduleRequest struct {
	Id             string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Description    string            `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Cron           string            `protobuf:"bytes,3,opt,name=cron,proto3" json:"cron,omitempty"`
	Tags           map[string]string `` /* 149-byte string literal not displayed */
	PromiseId      string            `protobuf:"bytes,5,opt,name=promiseId,proto3" json:"promiseId,omitempty"`
	PromiseTimeout int64             `protobuf:"varint,6,opt,name=promiseTimeout,proto3" json:"promiseTimeout,omitempty"`
	PromiseParam   *Value            `protobuf:"bytes,7,opt,name=promiseParam,proto3" json:"promiseParam,omitempty"`
	PromiseTags    map[string]string `` /* 163-byte string literal not displayed */
	IdempotencyKey string            `protobuf:"bytes,9,opt,name=idempotencyKey,proto3" json:"idempotencyKey,omitempty"`
	RequestId      string            `protobuf:"bytes,10,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateScheduleRequest) Descriptor deprecated 

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

Deprecated: Use CreateScheduleRequest.ProtoReflect.Descriptor instead.

func (*CreateScheduleRequest) GetCron 

func (x *CreateScheduleRequest) GetCron() string

func (*CreateScheduleRequest) GetDescription 

func (x *CreateScheduleRequest) GetDescription() string

func (*CreateScheduleRequest) GetId 

func (x *CreateScheduleRequest) GetId() string

func (*CreateScheduleRequest) GetIdempotencyKey 

func (x *CreateScheduleRequest) GetIdempotencyKey() string

func (*CreateScheduleRequest) GetPromiseId 

func (x *CreateScheduleRequest) GetPromiseId() string

func (*CreateScheduleRequest) GetPromiseParam 

func (x *CreateScheduleRequest) GetPromiseParam() *Value

func (*CreateScheduleRequest) GetPromiseTags 

func (x *CreateScheduleRequest) GetPromiseTags() map[string]string

func (*CreateScheduleRequest) GetPromiseTimeout 

func (x *CreateScheduleRequest) GetPromiseTimeout() int64

func (*CreateScheduleRequest) GetRequestId 

func (x *CreateScheduleRequest) GetRequestId() string

func (*CreateScheduleRequest) GetTags 

func (x *CreateScheduleRequest) GetTags() map[string]string

func (*CreateScheduleRequest) ProtoMessage 

func (*CreateScheduleRequest) ProtoMessage()

func (*CreateScheduleRequest) ProtoReflect 

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

func (*CreateScheduleRequest) Reset 

func (x *CreateScheduleRequest) Reset()

func (*CreateScheduleRequest) String 

func (x *CreateScheduleRequest) String() string

type CreatedScheduleResponse 

type CreatedScheduleResponse struct {
	Noop     bool      `protobuf:"varint,1,opt,name=noop,proto3" json:"noop,omitempty"`
	Schedule *Schedule `protobuf:"bytes,2,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatedScheduleResponse) Descriptor deprecated 

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

Deprecated: Use CreatedScheduleResponse.ProtoReflect.Descriptor instead.

func (*CreatedScheduleResponse) GetNoop 

func (x *CreatedScheduleResponse) GetNoop() bool

func (*CreatedScheduleResponse) GetSchedule 

func (x *CreatedScheduleResponse) GetSchedule() *Schedule

func (*CreatedScheduleResponse) ProtoMessage 

func (*CreatedScheduleResponse) ProtoMessage()

func (*CreatedScheduleResponse) ProtoReflect 

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

func (*CreatedScheduleResponse) Reset 

func (x *CreatedScheduleResponse) Reset()

func (*CreatedScheduleResponse) String 

func (x *CreatedScheduleResponse) String() string

type DeleteScheduleRequest 

type DeleteScheduleRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RequestId string `protobuf:"bytes,2,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteScheduleRequest) Descriptor deprecated 

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

Deprecated: Use DeleteScheduleRequest.ProtoReflect.Descriptor instead.

func (*DeleteScheduleRequest) GetId 

func (x *DeleteScheduleRequest) GetId() string

func (*DeleteScheduleRequest) GetRequestId 

func (x *DeleteScheduleRequest) GetRequestId() string

func (*DeleteScheduleRequest) ProtoMessage 

func (*DeleteScheduleRequest) ProtoMessage()

func (*DeleteScheduleRequest) ProtoReflect 

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

func (*DeleteScheduleRequest) Reset 

func (x *DeleteScheduleRequest) Reset()

func (*DeleteScheduleRequest) String 

func (x *DeleteScheduleRequest) String() string

type DeleteScheduleResponse 

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

func (*DeleteScheduleResponse) Descriptor deprecated 

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

Deprecated: Use DeleteScheduleResponse.ProtoReflect.Descriptor instead.

func (*DeleteScheduleResponse) ProtoMessage 

func (*DeleteScheduleResponse) ProtoMessage()

func (*DeleteScheduleResponse) ProtoReflect 

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

func (*DeleteScheduleResponse) Reset 

func (x *DeleteScheduleResponse) Reset()

func (*DeleteScheduleResponse) String 

func (x *DeleteScheduleResponse) String() string

type HeartbeatLocksRequest 

type HeartbeatLocksRequest struct {
	ProcessId string `protobuf:"bytes,1,opt,name=processId,proto3" json:"processId,omitempty"`
	RequestId string `protobuf:"bytes,2,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatLocksRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatLocksRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatLocksRequest) GetProcessId 

func (x *HeartbeatLocksRequest) GetProcessId() string

func (*HeartbeatLocksRequest) GetRequestId 

func (x *HeartbeatLocksRequest) GetRequestId() string

func (*HeartbeatLocksRequest) ProtoMessage 

func (*HeartbeatLocksRequest) ProtoMessage()

func (*HeartbeatLocksRequest) ProtoReflect 

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

func (*HeartbeatLocksRequest) Reset 

func (x *HeartbeatLocksRequest) Reset()

func (*HeartbeatLocksRequest) String 

func (x *HeartbeatLocksRequest) String() string

type HeartbeatLocksResponse 

type HeartbeatLocksResponse struct {
	LocksAffected int32 `protobuf:"varint,1,opt,name=locksAffected,proto3" json:"locksAffected,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatLocksResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatLocksResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatLocksResponse) GetLocksAffected 

func (x *HeartbeatLocksResponse) GetLocksAffected() int32

func (*HeartbeatLocksResponse) ProtoMessage 

func (*HeartbeatLocksResponse) ProtoMessage()

func (*HeartbeatLocksResponse) ProtoReflect 

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

func (*HeartbeatLocksResponse) Reset 

func (x *HeartbeatLocksResponse) Reset()

func (*HeartbeatLocksResponse) String 

func (x *HeartbeatLocksResponse) String() string

type HeartbeatTasksRequest 

type HeartbeatTasksRequest struct {
	ProcessId string `protobuf:"bytes,1,opt,name=processId,proto3" json:"processId,omitempty"`
	RequestId string `protobuf:"bytes,2,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatTasksRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatTasksRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatTasksRequest) GetProcessId 

func (x *HeartbeatTasksRequest) GetProcessId() string

func (*HeartbeatTasksRequest) GetRequestId 

func (x *HeartbeatTasksRequest) GetRequestId() string

func (*HeartbeatTasksRequest) ProtoMessage 

func (*HeartbeatTasksRequest) ProtoMessage()

func (*HeartbeatTasksRequest) ProtoReflect 

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

func (*HeartbeatTasksRequest) Reset 

func (x *HeartbeatTasksRequest) Reset()

func (*HeartbeatTasksRequest) String 

func (x *HeartbeatTasksRequest) String() string

type HeartbeatTasksResponse 

type HeartbeatTasksResponse struct {
	TasksAffected int64 `protobuf:"varint,1,opt,name=tasksAffected,proto3" json:"tasksAffected,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatTasksResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatTasksResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatTasksResponse) GetTasksAffected 

func (x *HeartbeatTasksResponse) GetTasksAffected() int64

func (*HeartbeatTasksResponse) ProtoMessage 

func (*HeartbeatTasksResponse) ProtoMessage()

func (*HeartbeatTasksResponse) ProtoReflect 

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

func (*HeartbeatTasksResponse) Reset 

func (x *HeartbeatTasksResponse) Reset()

func (*HeartbeatTasksResponse) String 

func (x *HeartbeatTasksResponse) String() string

type LocksClient 

type LocksClient interface {
	AcquireLock(ctx context.Context, in *AcquireLockRequest, opts ...grpc.CallOption) (*AcquireLockResponse, error)
	ReleaseLock(ctx context.Context, in *ReleaseLockRequest, opts ...grpc.CallOption) (*ReleaseLockResponse, error)
	HeartbeatLocks(ctx context.Context, in *HeartbeatLocksRequest, opts ...grpc.CallOption) (*HeartbeatLocksResponse, error)
}

LocksClient is the client API for Locks 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 NewLocksClient 

func NewLocksClient(cc grpc.ClientConnInterface) LocksClient

type LocksServer 

type LocksServer interface {
	AcquireLock(context.Context, *AcquireLockRequest) (*AcquireLockResponse, error)
	ReleaseLock(context.Context, *ReleaseLockRequest) (*ReleaseLockResponse, error)
	HeartbeatLocks(context.Context, *HeartbeatLocksRequest) (*HeartbeatLocksResponse, error)
	// contains filtered or unexported methods
}

LocksServer is the server API for Locks service. All implementations must embed UnimplementedLocksServer for forward compatibility.

type Mesg 

type Mesg struct {
	Type     string                  `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Promises map[string]*MesgPromise `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Mesg) Descriptor deprecated 

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

Deprecated: Use Mesg.ProtoReflect.Descriptor instead.

func (*Mesg) GetPromises 

func (x *Mesg) GetPromises() map[string]*MesgPromise

func (*Mesg) GetType 

func (x *Mesg) GetType() string

func (*Mesg) ProtoMessage 

func (*Mesg) ProtoMessage()

func (*Mesg) ProtoReflect 

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

func (*Mesg) Reset 

func (x *Mesg) Reset()

func (*Mesg) String 

func (x *Mesg) String() string

type MesgPromise 

type MesgPromise struct {
	Id   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Href string   `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"`
	Data *Promise `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*MesgPromise) Descriptor deprecated 

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

Deprecated: Use MesgPromise.ProtoReflect.Descriptor instead.

func (*MesgPromise) GetData 

func (x *MesgPromise) GetData() *Promise

func (*MesgPromise) GetHref 

func (x *MesgPromise) GetHref() string

func (*MesgPromise) GetId 

func (x *MesgPromise) GetId() string

func (*MesgPromise) ProtoMessage 

func (*MesgPromise) ProtoMessage()

func (*MesgPromise) ProtoReflect 

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

func (*MesgPromise) Reset 

func (x *MesgPromise) Reset()

func (*MesgPromise) String 

func (x *MesgPromise) String() string

type PhysicalRecv 

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

func (*PhysicalRecv) Descriptor deprecated 

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

Deprecated: Use PhysicalRecv.ProtoReflect.Descriptor instead.

func (*PhysicalRecv) GetData 

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

func (*PhysicalRecv) GetType 

func (x *PhysicalRecv) GetType() string

func (*PhysicalRecv) ProtoMessage 

func (*PhysicalRecv) ProtoMessage()

func (*PhysicalRecv) ProtoReflect 

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

func (*PhysicalRecv) Reset 

func (x *PhysicalRecv) Reset()

func (*PhysicalRecv) String 

func (x *PhysicalRecv) String() string

type Promise 

type Promise struct {
	Id                        string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State                     State             `protobuf:"varint,2,opt,name=state,proto3,enum=promise_t.State" json:"state,omitempty"`
	Param                     *Value            `protobuf:"bytes,3,opt,name=param,proto3" json:"param,omitempty"`
	Value                     *Value            `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Timeout                   int64             `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	IdempotencyKeyForCreate   string            `protobuf:"bytes,6,opt,name=idempotencyKeyForCreate,proto3" json:"idempotencyKeyForCreate,omitempty"`
	IdempotencyKeyForComplete string            `protobuf:"bytes,7,opt,name=idempotencyKeyForComplete,proto3" json:"idempotencyKeyForComplete,omitempty"`
	Tags                      map[string]string `` /* 149-byte string literal not displayed */
	CreatedOn                 int64             `protobuf:"varint,9,opt,name=createdOn,proto3" json:"createdOn,omitempty"`
	CompletedOn               int64             `protobuf:"varint,10,opt,name=completedOn,proto3" json:"completedOn,omitempty"`
	// contains filtered or unexported fields
}

func (*Promise) Descriptor deprecated 

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

Deprecated: Use Promise.ProtoReflect.Descriptor instead.

func (*Promise) GetCompletedOn 

func (x *Promise) GetCompletedOn() int64

func (*Promise) GetCreatedOn 

func (x *Promise) GetCreatedOn() int64

func (*Promise) GetId 

func (x *Promise) GetId() string

func (*Promise) GetIdempotencyKeyForComplete 

func (x *Promise) GetIdempotencyKeyForComplete() string

func (*Promise) GetIdempotencyKeyForCreate 

func (x *Promise) GetIdempotencyKeyForCreate() string

func (*Promise) GetParam 

func (x *Promise) GetParam() *Value

func (*Promise) GetState 

func (x *Promise) GetState() State

func (*Promise) GetTags 

func (x *Promise) GetTags() map[string]string

func (*Promise) GetTimeout 

func (x *Promise) GetTimeout() int64

func (*Promise) GetValue 

func (x *Promise) GetValue() *Value

func (*Promise) ProtoMessage 

func (*Promise) ProtoMessage()

func (*Promise) ProtoReflect 

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

func (*Promise) Reset 

func (x *Promise) Reset()

func (*Promise) String 

func (x *Promise) String() string

type PromisesClient 

type PromisesClient interface {
	ReadPromise(ctx context.Context, in *ReadPromiseRequest, opts ...grpc.CallOption) (*ReadPromiseResponse, error)
	SearchPromises(ctx context.Context, in *SearchPromisesRequest, opts ...grpc.CallOption) (*SearchPromisesResponse, error)
	CreatePromise(ctx context.Context, in *CreatePromiseRequest, opts ...grpc.CallOption) (*CreatePromiseResponse, error)
	CreatePromiseAndTask(ctx context.Context, in *CreatePromiseAndTaskRequest, opts ...grpc.CallOption) (*CreatePromiseAndTaskResponse, error)
	ResolvePromise(ctx context.Context, in *ResolvePromiseRequest, opts ...grpc.CallOption) (*ResolvePromiseResponse, error)
	RejectPromise(ctx context.Context, in *RejectPromiseRequest, opts ...grpc.CallOption) (*RejectPromiseResponse, error)
	CancelPromise(ctx context.Context, in *CancelPromiseRequest, opts ...grpc.CallOption) (*CancelPromiseResponse, error)
}

PromisesClient is the client API for Promises 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 NewPromisesClient 

func NewPromisesClient(cc grpc.ClientConnInterface) PromisesClient

type PromisesServer 

type PromisesServer interface {
	ReadPromise(context.Context, *ReadPromiseRequest) (*ReadPromiseResponse, error)
	SearchPromises(context.Context, *SearchPromisesRequest) (*SearchPromisesResponse, error)
	CreatePromise(context.Context, *CreatePromiseRequest) (*CreatePromiseResponse, error)
	CreatePromiseAndTask(context.Context, *CreatePromiseAndTaskRequest) (*CreatePromiseAndTaskResponse, error)
	ResolvePromise(context.Context, *ResolvePromiseRequest) (*ResolvePromiseResponse, error)
	RejectPromise(context.Context, *RejectPromiseRequest) (*RejectPromiseResponse, error)
	CancelPromise(context.Context, *CancelPromiseRequest) (*CancelPromiseResponse, error)
	// contains filtered or unexported methods
}

PromisesServer is the server API for Promises service. All implementations must embed UnimplementedPromisesServer for forward compatibility.

type ReadPromiseRequest 

type ReadPromiseRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RequestId string `protobuf:"bytes,2,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadPromiseRequest) Descriptor deprecated 

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

Deprecated: Use ReadPromiseRequest.ProtoReflect.Descriptor instead.

func (*ReadPromiseRequest) GetId 

func (x *ReadPromiseRequest) GetId() string

func (*ReadPromiseRequest) GetRequestId 

func (x *ReadPromiseRequest) GetRequestId() string

func (*ReadPromiseRequest) ProtoMessage 

func (*ReadPromiseRequest) ProtoMessage()

func (*ReadPromiseRequest) ProtoReflect 

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

func (*ReadPromiseRequest) Reset 

func (x *ReadPromiseRequest) Reset()

func (*ReadPromiseRequest) String 

func (x *ReadPromiseRequest) String() string

type ReadPromiseResponse 

type ReadPromiseResponse struct {
	Promise *Promise `protobuf:"bytes,1,opt,name=promise,proto3" json:"promise,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadPromiseResponse) Descriptor deprecated 

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

Deprecated: Use ReadPromiseResponse.ProtoReflect.Descriptor instead.

func (*ReadPromiseResponse) GetPromise 

func (x *ReadPromiseResponse) GetPromise() *Promise

func (*ReadPromiseResponse) ProtoMessage 

func (*ReadPromiseResponse) ProtoMessage()

func (*ReadPromiseResponse) ProtoReflect 

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

func (*ReadPromiseResponse) Reset 

func (x *ReadPromiseResponse) Reset()

func (*ReadPromiseResponse) String 

func (x *ReadPromiseResponse) String() string

type ReadScheduleRequest 

type ReadScheduleRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RequestId string `protobuf:"bytes,2,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadScheduleRequest) Descriptor deprecated 

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

Deprecated: Use ReadScheduleRequest.ProtoReflect.Descriptor instead.

func (*ReadScheduleRequest) GetId 

func (x *ReadScheduleRequest) GetId() string

func (*ReadScheduleRequest) GetRequestId 

func (x *ReadScheduleRequest) GetRequestId() string

func (*ReadScheduleRequest) ProtoMessage 

func (*ReadScheduleRequest) ProtoMessage()

func (*ReadScheduleRequest) ProtoReflect 

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

func (*ReadScheduleRequest) Reset 

func (x *ReadScheduleRequest) Reset()

func (*ReadScheduleRequest) String 

func (x *ReadScheduleRequest) String() string

type ReadScheduleResponse 

type ReadScheduleResponse struct {
	Schedule *Schedule `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadScheduleResponse) Descriptor deprecated 

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

Deprecated: Use ReadScheduleResponse.ProtoReflect.Descriptor instead.

func (*ReadScheduleResponse) GetSchedule 

func (x *ReadScheduleResponse) GetSchedule() *Schedule

func (*ReadScheduleResponse) ProtoMessage 

func (*ReadScheduleResponse) ProtoMessage()

func (*ReadScheduleResponse) ProtoReflect 

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

func (*ReadScheduleResponse) Reset 

func (x *ReadScheduleResponse) Reset()

func (*ReadScheduleResponse) String 

func (x *ReadScheduleResponse) String() string

type Recv 

type Recv struct {

	// Types that are assignable to Recv:
	//
	//	*Recv_Logical
	//	*Recv_Physical
	Recv isRecv_Recv `protobuf_oneof:"recv"`
	// contains filtered or unexported fields
}

func (*Recv) Descriptor deprecated 

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

Deprecated: Use Recv.ProtoReflect.Descriptor instead.

func (*Recv) GetLogical 

func (x *Recv) GetLogical() string

func (*Recv) GetPhysical 

func (x *Recv) GetPhysical() *PhysicalRecv

func (*Recv) GetRecv 

func (m *Recv) GetRecv() isRecv_Recv

func (*Recv) ProtoMessage 

func (*Recv) ProtoMessage()

func (*Recv) ProtoReflect 

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

func (*Recv) Reset 

func (x *Recv) Reset()

func (*Recv) String 

func (x *Recv) String() string

type Recv_Logical 

type Recv_Logical struct {
	Logical string `protobuf:"bytes,1,opt,name=logical,proto3,oneof"`
}

type Recv_Physical 

type Recv_Physical struct {
	Physical *PhysicalRecv `protobuf:"bytes,2,opt,name=physical,proto3,oneof"`
}

type RejectPromiseRequest 

type RejectPromiseRequest struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	IdempotencyKey string `protobuf:"bytes,2,opt,name=idempotencyKey,proto3" json:"idempotencyKey,omitempty"`
	Strict         bool   `protobuf:"varint,3,opt,name=strict,proto3" json:"strict,omitempty"`
	Value          *Value `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	RequestId      string `protobuf:"bytes,5,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*RejectPromiseRequest) Descriptor deprecated 

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

Deprecated: Use RejectPromiseRequest.ProtoReflect.Descriptor instead.

func (*RejectPromiseRequest) GetId 

func (x *RejectPromiseRequest) GetId() string

func (*RejectPromiseRequest) GetIdempotencyKey 

func (x *RejectPromiseRequest) GetIdempotencyKey() string

func (*RejectPromiseRequest) GetRequestId 

func (x *RejectPromiseRequest) GetRequestId() string

func (*RejectPromiseRequest) GetStrict 

func (x *RejectPromiseRequest) GetStrict() bool

func (*RejectPromiseRequest) GetValue 

func (x *RejectPromiseRequest) GetValue() *Value

func (*RejectPromiseRequest) ProtoMessage 

func (*RejectPromiseRequest) ProtoMessage()

func (*RejectPromiseRequest) ProtoReflect 

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

func (*RejectPromiseRequest) Reset 

func (x *RejectPromiseRequest) Reset()

func (*RejectPromiseRequest) String 

func (x *RejectPromiseRequest) String() string

type RejectPromiseResponse 

type RejectPromiseResponse struct {
	Noop    bool     `protobuf:"varint,1,opt,name=noop,proto3" json:"noop,omitempty"`
	Promise *Promise `protobuf:"bytes,2,opt,name=promise,proto3" json:"promise,omitempty"`
	// contains filtered or unexported fields
}

func (*RejectPromiseResponse) Descriptor deprecated 

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

Deprecated: Use RejectPromiseResponse.ProtoReflect.Descriptor instead.

func (*RejectPromiseResponse) GetNoop 

func (x *RejectPromiseResponse) GetNoop() bool

func (*RejectPromiseResponse) GetPromise 

func (x *RejectPromiseResponse) GetPromise() *Promise

func (*RejectPromiseResponse) ProtoMessage 

func (*RejectPromiseResponse) ProtoMessage()

func (*RejectPromiseResponse) ProtoReflect 

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

func (*RejectPromiseResponse) Reset 

func (x *RejectPromiseResponse) Reset()

func (*RejectPromiseResponse) String 

func (x *RejectPromiseResponse) String() string

type ReleaseLockRequest 

type ReleaseLockRequest struct {
	ResourceId  string `protobuf:"bytes,1,opt,name=resourceId,proto3" json:"resourceId,omitempty"`
	ExecutionId string `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
	RequestId   string `protobuf:"bytes,3,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseLockRequest) Descriptor deprecated 

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

Deprecated: Use ReleaseLockRequest.ProtoReflect.Descriptor instead.

func (*ReleaseLockRequest) GetExecutionId 

func (x *ReleaseLockRequest) GetExecutionId() string

func (*ReleaseLockRequest) GetRequestId 

func (x *ReleaseLockRequest) GetRequestId() string

func (*ReleaseLockRequest) GetResourceId 

func (x *ReleaseLockRequest) GetResourceId() string

func (*ReleaseLockRequest) ProtoMessage 

func (*ReleaseLockRequest) ProtoMessage()

func (*ReleaseLockRequest) ProtoReflect 

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

func (*ReleaseLockRequest) Reset 

func (x *ReleaseLockRequest) Reset()

func (*ReleaseLockRequest) String 

func (x *ReleaseLockRequest) String() string

type ReleaseLockResponse 

type ReleaseLockResponse struct {
	Released bool `protobuf:"varint,1,opt,name=released,proto3" json:"released,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseLockResponse) Descriptor deprecated 

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

Deprecated: Use ReleaseLockResponse.ProtoReflect.Descriptor instead.

func (*ReleaseLockResponse) GetReleased 

func (x *ReleaseLockResponse) GetReleased() bool

func (*ReleaseLockResponse) ProtoMessage 

func (*ReleaseLockResponse) ProtoMessage()

func (*ReleaseLockResponse) ProtoReflect 

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

func (*ReleaseLockResponse) Reset 

func (x *ReleaseLockResponse) Reset()

func (*ReleaseLockResponse) String 

func (x *ReleaseLockResponse) String() string

type ResolvePromiseRequest 

type ResolvePromiseRequest struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	IdempotencyKey string `protobuf:"bytes,2,opt,name=idempotencyKey,proto3" json:"idempotencyKey,omitempty"`
	Strict         bool   `protobuf:"varint,3,opt,name=strict,proto3" json:"strict,omitempty"`
	Value          *Value `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	RequestId      string `protobuf:"bytes,5,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolvePromiseRequest) Descriptor deprecated 

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

Deprecated: Use ResolvePromiseRequest.ProtoReflect.Descriptor instead.

func (*ResolvePromiseRequest) GetId 

func (x *ResolvePromiseRequest) GetId() string

func (*ResolvePromiseRequest) GetIdempotencyKey 

func (x *ResolvePromiseRequest) GetIdempotencyKey() string

func (*ResolvePromiseRequest) GetRequestId 

func (x *ResolvePromiseRequest) GetRequestId() string

func (*ResolvePromiseRequest) GetStrict 

func (x *ResolvePromiseRequest) GetStrict() bool

func (*ResolvePromiseRequest) GetValue 

func (x *ResolvePromiseRequest) GetValue() *Value

func (*ResolvePromiseRequest) ProtoMessage 

func (*ResolvePromiseRequest) ProtoMessage()

func (*ResolvePromiseRequest) ProtoReflect 

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

func (*ResolvePromiseRequest) Reset 

func (x *ResolvePromiseRequest) Reset()

func (*ResolvePromiseRequest) String 

func (x *ResolvePromiseRequest) String() string

type ResolvePromiseResponse 

type ResolvePromiseResponse struct {
	Noop    bool     `protobuf:"varint,1,opt,name=noop,proto3" json:"noop,omitempty"`
	Promise *Promise `protobuf:"bytes,2,opt,name=promise,proto3" json:"promise,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolvePromiseResponse) Descriptor deprecated 

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

Deprecated: Use ResolvePromiseResponse.ProtoReflect.Descriptor instead.

func (*ResolvePromiseResponse) GetNoop 

func (x *ResolvePromiseResponse) GetNoop() bool

func (*ResolvePromiseResponse) GetPromise 

func (x *ResolvePromiseResponse) GetPromise() *Promise

func (*ResolvePromiseResponse) ProtoMessage 

func (*ResolvePromiseResponse) ProtoMessage()

func (*ResolvePromiseResponse) ProtoReflect 

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

func (*ResolvePromiseResponse) Reset 

func (x *ResolvePromiseResponse) Reset()

func (*ResolvePromiseResponse) String 

func (x *ResolvePromiseResponse) String() string

type Schedule 

type Schedule struct {
	Id             string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Description    string            `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Cron           string            `protobuf:"bytes,3,opt,name=cron,proto3" json:"cron,omitempty"`
	Tags           map[string]string `` /* 149-byte string literal not displayed */
	PromiseId      string            `protobuf:"bytes,5,opt,name=promiseId,proto3" json:"promiseId,omitempty"`
	PromiseTimeout int64             `protobuf:"varint,6,opt,name=promiseTimeout,proto3" json:"promiseTimeout,omitempty"`
	PromiseParam   *Value            `protobuf:"bytes,7,opt,name=promiseParam,proto3" json:"promiseParam,omitempty"`
	PromiseTags    map[string]string `` /* 163-byte string literal not displayed */
	IdempotencyKey string            `protobuf:"bytes,9,opt,name=idempotencyKey,proto3" json:"idempotencyKey,omitempty"`
	LastRunTime    int64             `protobuf:"varint,10,opt,name=lastRunTime,proto3" json:"lastRunTime,omitempty"`
	NextRunTime    int64             `protobuf:"varint,11,opt,name=nextRunTime,proto3" json:"nextRunTime,omitempty"`
	CreatedOn      int64             `protobuf:"varint,12,opt,name=createdOn,proto3" json:"createdOn,omitempty"`
	// contains filtered or unexported fields
}

func (*Schedule) Descriptor deprecated 

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

Deprecated: Use Schedule.ProtoReflect.Descriptor instead.

func (*Schedule) GetCreatedOn 

func (x *Schedule) GetCreatedOn() int64

func (*Schedule) GetCron 

func (x *Schedule) GetCron() string

func (*Schedule) GetDescription 

func (x *Schedule) GetDescription() string

func (*Schedule) GetId 

func (x *Schedule) GetId() string

func (*Schedule) GetIdempotencyKey 

func (x *Schedule) GetIdempotencyKey() string

func (*Schedule) GetLastRunTime 

func (x *Schedule) GetLastRunTime() int64

func (*Schedule) GetNextRunTime 

func (x *Schedule) GetNextRunTime() int64

func (*Schedule) GetPromiseId 

func (x *Schedule) GetPromiseId() string

func (*Schedule) GetPromiseParam 

func (x *Schedule) GetPromiseParam() *Value

func (*Schedule) GetPromiseTags 

func (x *Schedule) GetPromiseTags() map[string]string

func (*Schedule) GetPromiseTimeout 

func (x *Schedule) GetPromiseTimeout() int64

func (*Schedule) GetTags 

func (x *Schedule) GetTags() map[string]string

func (*Schedule) ProtoMessage 

func (*Schedule) ProtoMessage()

func (*Schedule) ProtoReflect 

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

func (*Schedule) Reset 

func (x *Schedule) Reset()

func (*Schedule) String 

func (x *Schedule) String() string

type SchedulesClient 

type SchedulesClient interface {
	ReadSchedule(ctx context.Context, in *ReadScheduleRequest, opts ...grpc.CallOption) (*ReadScheduleResponse, error)
	SearchSchedules(ctx context.Context, in *SearchSchedulesRequest, opts ...grpc.CallOption) (*SearchSchedulesResponse, error)
	CreateSchedule(ctx context.Context, in *CreateScheduleRequest, opts ...grpc.CallOption) (*CreatedScheduleResponse, error)
	DeleteSchedule(ctx context.Context, in *DeleteScheduleRequest, opts ...grpc.CallOption) (*DeleteScheduleResponse, error)
}

SchedulesClient is the client API for Schedules 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 NewSchedulesClient 

func NewSchedulesClient(cc grpc.ClientConnInterface) SchedulesClient

type SchedulesServer 

type SchedulesServer interface {
	ReadSchedule(context.Context, *ReadScheduleRequest) (*ReadScheduleResponse, error)
	SearchSchedules(context.Context, *SearchSchedulesRequest) (*SearchSchedulesResponse, error)
	CreateSchedule(context.Context, *CreateScheduleRequest) (*CreatedScheduleResponse, error)
	DeleteSchedule(context.Context, *DeleteScheduleRequest) (*DeleteScheduleResponse, error)
	// contains filtered or unexported methods
}

SchedulesServer is the server API for Schedules service. All implementations must embed UnimplementedSchedulesServer for forward compatibility.

type SearchPromisesRequest 

type SearchPromisesRequest struct {
	Id        string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State     SearchState       `protobuf:"varint,2,opt,name=state,proto3,enum=promise.SearchState" json:"state,omitempty"`
	Tags      map[string]string `` /* 149-byte string literal not displayed */
	Limit     int32             `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	Cursor    string            `protobuf:"bytes,5,opt,name=cursor,proto3" json:"cursor,omitempty"`
	RequestId string            `protobuf:"bytes,6,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchPromisesRequest) Descriptor deprecated 

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

Deprecated: Use SearchPromisesRequest.ProtoReflect.Descriptor instead.

func (*SearchPromisesRequest) GetCursor 

func (x *SearchPromisesRequest) GetCursor() string

func (*SearchPromisesRequest) GetId 

func (x *SearchPromisesRequest) GetId() string

func (*SearchPromisesRequest) GetLimit 

func (x *SearchPromisesRequest) GetLimit() int32

func (*SearchPromisesRequest) GetRequestId 

func (x *SearchPromisesRequest) GetRequestId() string

func (*SearchPromisesRequest) GetState 

func (x *SearchPromisesRequest) GetState() SearchState

func (*SearchPromisesRequest) GetTags 

func (x *SearchPromisesRequest) GetTags() map[string]string

func (*SearchPromisesRequest) ProtoMessage 

func (*SearchPromisesRequest) ProtoMessage()

func (*SearchPromisesRequest) ProtoReflect 

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

func (*SearchPromisesRequest) Reset 

func (x *SearchPromisesRequest) Reset()

func (*SearchPromisesRequest) String 

func (x *SearchPromisesRequest) String() string

type SearchPromisesResponse 

type SearchPromisesResponse struct {
	Promises []*Promise `protobuf:"bytes,1,rep,name=promises,proto3" json:"promises,omitempty"`
	Cursor   string     `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchPromisesResponse) Descriptor deprecated 

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

Deprecated: Use SearchPromisesResponse.ProtoReflect.Descriptor instead.

func (*SearchPromisesResponse) GetCursor 

func (x *SearchPromisesResponse) GetCursor() string

func (*SearchPromisesResponse) GetPromises 

func (x *SearchPromisesResponse) GetPromises() []*Promise

func (*SearchPromisesResponse) ProtoMessage 

func (*SearchPromisesResponse) ProtoMessage()

func (*SearchPromisesResponse) ProtoReflect 

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

func (*SearchPromisesResponse) Reset 

func (x *SearchPromisesResponse) Reset()

func (*SearchPromisesResponse) String 

func (x *SearchPromisesResponse) String() string

type SearchSchedulesRequest 

type SearchSchedulesRequest struct {
	Id        string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Tags      map[string]string `` /* 149-byte string literal not displayed */
	Limit     int32             `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Cursor    string            `protobuf:"bytes,4,opt,name=cursor,proto3" json:"cursor,omitempty"`
	RequestId string            `protobuf:"bytes,5,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchSchedulesRequest) Descriptor deprecated 

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

Deprecated: Use SearchSchedulesRequest.ProtoReflect.Descriptor instead.

func (*SearchSchedulesRequest) GetCursor 

func (x *SearchSchedulesRequest) GetCursor() string

func (*SearchSchedulesRequest) GetId 

func (x *SearchSchedulesRequest) GetId() string

func (*SearchSchedulesRequest) GetLimit 

func (x *SearchSchedulesRequest) GetLimit() int32

func (*SearchSchedulesRequest) GetRequestId 

func (x *SearchSchedulesRequest) GetRequestId() string

func (*SearchSchedulesRequest) GetTags 

func (x *SearchSchedulesRequest) GetTags() map[string]string

func (*SearchSchedulesRequest) ProtoMessage 

func (*SearchSchedulesRequest) ProtoMessage()

func (*SearchSchedulesRequest) ProtoReflect 

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

func (*SearchSchedulesRequest) Reset 

func (x *SearchSchedulesRequest) Reset()

func (*SearchSchedulesRequest) String 

func (x *SearchSchedulesRequest) String() string

type SearchSchedulesResponse 

type SearchSchedulesResponse struct {
	Schedules []*Schedule `protobuf:"bytes,1,rep,name=schedules,proto3" json:"schedules,omitempty"`
	Cursor    string      `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchSchedulesResponse) Descriptor deprecated 

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

Deprecated: Use SearchSchedulesResponse.ProtoReflect.Descriptor instead.

func (*SearchSchedulesResponse) GetCursor 

func (x *SearchSchedulesResponse) GetCursor() string

func (*SearchSchedulesResponse) GetSchedules 

func (x *SearchSchedulesResponse) GetSchedules() []*Schedule

func (*SearchSchedulesResponse) ProtoMessage 

func (*SearchSchedulesResponse) ProtoMessage()

func (*SearchSchedulesResponse) ProtoReflect 

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

func (*SearchSchedulesResponse) Reset 

func (x *SearchSchedulesResponse) Reset()

func (*SearchSchedulesResponse) String 

func (x *SearchSchedulesResponse) String() string

type SearchState 

type SearchState int32
const (
	SearchState_SEARCH_ALL      SearchState = 0
	SearchState_SEARCH_PENDING  SearchState = 1
	SearchState_SEARCH_RESOLVED SearchState = 2
	SearchState_SEARCH_REJECTED SearchState = 3
)

func (SearchState) Descriptor 

func (SearchState) Descriptor() protoreflect.EnumDescriptor

func (SearchState) Enum 

func (x SearchState) Enum() *SearchState

func (SearchState) EnumDescriptor deprecated 

func (SearchState) EnumDescriptor() ([]byte, []int)

Deprecated: Use SearchState.Descriptor instead.

func (SearchState) Number 

func (x SearchState) Number() protoreflect.EnumNumber

func (SearchState) String 

func (x SearchState) String() string

func (SearchState) Type 

func (SearchState) Type() protoreflect.EnumType

type State 

type State int32
const (
	State_PENDING           State = 0
	State_RESOLVED          State = 1
	State_REJECTED          State = 2
	State_REJECTED_TIMEDOUT State = 3
	State_REJECTED_CANCELED State = 4
)

func (State) Descriptor 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum 

func (x State) Enum() *State

func (State) EnumDescriptor deprecated 

func (State) EnumDescriptor() ([]byte, []int)

Deprecated: Use State.Descriptor instead.

func (State) Number 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

func (State) Type 

func (State) Type() protoreflect.EnumType

type TasksClient 

type TasksClient interface {
	ClaimTask(ctx context.Context, in *ClaimTaskRequest, opts ...grpc.CallOption) (*ClaimTaskResponse, error)
	CompleteTask(ctx context.Context, in *CompleteTaskRequest, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	HeartbeatTasks(ctx context.Context, in *HeartbeatTasksRequest, opts ...grpc.CallOption) (*HeartbeatTasksResponse, error)
}

TasksClient is the client API for Tasks 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 NewTasksClient 

func NewTasksClient(cc grpc.ClientConnInterface) TasksClient

type TasksServer 

type TasksServer interface {
	ClaimTask(context.Context, *ClaimTaskRequest) (*ClaimTaskResponse, error)
	CompleteTask(context.Context, *CompleteTaskRequest) (*CompleteTaskResponse, error)
	HeartbeatTasks(context.Context, *HeartbeatTasksRequest) (*HeartbeatTasksResponse, error)
	// contains filtered or unexported methods
}

TasksServer is the server API for Tasks service. All implementations must embed UnimplementedTasksServer for forward compatibility.

type UnimplementedCallbacksServer 

type UnimplementedCallbacksServer struct{}

UnimplementedCallbacksServer 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 (UnimplementedCallbacksServer) CreateCallback 

func (UnimplementedCallbacksServer) CreateCallback(context.Context, *CreateCallbackRequest) (*CreateCallbackResponse, error)

type UnimplementedLocksServer 

type UnimplementedLocksServer struct{}

UnimplementedLocksServer 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 (UnimplementedLocksServer) AcquireLock 

func (UnimplementedLocksServer) AcquireLock(context.Context, *AcquireLockRequest) (*AcquireLockResponse, error)

func (UnimplementedLocksServer) HeartbeatLocks 

func (UnimplementedLocksServer) HeartbeatLocks(context.Context, *HeartbeatLocksRequest) (*HeartbeatLocksResponse, error)

func (UnimplementedLocksServer) ReleaseLock 

func (UnimplementedLocksServer) ReleaseLock(context.Context, *ReleaseLockRequest) (*ReleaseLockResponse, error)

type UnimplementedPromisesServer 

type UnimplementedPromisesServer struct{}

UnimplementedPromisesServer 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 (UnimplementedPromisesServer) CancelPromise 

func (UnimplementedPromisesServer) CancelPromise(context.Context, *CancelPromiseRequest) (*CancelPromiseResponse, error)

func (UnimplementedPromisesServer) CreatePromise 

func (UnimplementedPromisesServer) CreatePromise(context.Context, *CreatePromiseRequest) (*CreatePromiseResponse, error)

func (UnimplementedPromisesServer) CreatePromiseAndTask 

func (UnimplementedPromisesServer) CreatePromiseAndTask(context.Context, *CreatePromiseAndTaskRequest) (*CreatePromiseAndTaskResponse, error)

func (UnimplementedPromisesServer) ReadPromise 

func (UnimplementedPromisesServer) ReadPromise(context.Context, *ReadPromiseRequest) (*ReadPromiseResponse, error)

func (UnimplementedPromisesServer) RejectPromise 

func (UnimplementedPromisesServer) RejectPromise(context.Context, *RejectPromiseRequest) (*RejectPromiseResponse, error)

func (UnimplementedPromisesServer) ResolvePromise 

func (UnimplementedPromisesServer) ResolvePromise(context.Context, *ResolvePromiseRequest) (*ResolvePromiseResponse, error)

func (UnimplementedPromisesServer) SearchPromises 

func (UnimplementedPromisesServer) SearchPromises(context.Context, *SearchPromisesRequest) (*SearchPromisesResponse, error)

type UnimplementedSchedulesServer 

type UnimplementedSchedulesServer struct{}

UnimplementedSchedulesServer 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 (UnimplementedSchedulesServer) CreateSchedule 

func (UnimplementedSchedulesServer) CreateSchedule(context.Context, *CreateScheduleRequest) (*CreatedScheduleResponse, error)

func (UnimplementedSchedulesServer) DeleteSchedule 

func (UnimplementedSchedulesServer) DeleteSchedule(context.Context, *DeleteScheduleRequest) (*DeleteScheduleResponse, error)

func (UnimplementedSchedulesServer) ReadSchedule 

func (UnimplementedSchedulesServer) ReadSchedule(context.Context, *ReadScheduleRequest) (*ReadScheduleResponse, error)

func (UnimplementedSchedulesServer) SearchSchedules 

func (UnimplementedSchedulesServer) SearchSchedules(context.Context, *SearchSchedulesRequest) (*SearchSchedulesResponse, error)

type UnimplementedTasksServer 

type UnimplementedTasksServer struct{}

UnimplementedTasksServer 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 (UnimplementedTasksServer) ClaimTask 

func (UnimplementedTasksServer) ClaimTask(context.Context, *ClaimTaskRequest) (*ClaimTaskResponse, error)

func (UnimplementedTasksServer) CompleteTask 

func (UnimplementedTasksServer) CompleteTask(context.Context, *CompleteTaskRequest) (*CompleteTaskResponse, error)

func (UnimplementedTasksServer) HeartbeatTasks 

func (UnimplementedTasksServer) HeartbeatTasks(context.Context, *HeartbeatTasksRequest) (*HeartbeatTasksResponse, error)

type UnsafeCallbacksServer 

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

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

type UnsafeLocksServer 

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

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

type UnsafePromisesServer 

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

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

type UnsafeSchedulesServer 

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

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

type UnsafeTasksServer 

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

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

type Value 

type Value struct {
	Headers map[string]string `` /* 155-byte string literal not displayed */
	Data    []byte            `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetData 

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

func (*Value) GetHeaders 

func (x *Value) GetHeaders() map[string]string

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

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

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) 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.