Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

coolbeans_api_v1

package

Go to main page

Versions in this module

v0

v0.1.11

May 27, 2020

v0.1.10

May 26, 2020

v0.1.9

May 26, 2020

v0.1.7

May 25, 2020

v0.1.6

May 25, 2020

Changes in this version

+ var File_client_proto protoreflect.FileDescriptor

+ var File_cluster_proto protoreflect.FileDescriptor

+ var File_empty_proto protoreflect.FileDescriptor

+ var File_job_proto protoreflect.FileDescriptor

+ var File_jsm_proto protoreflect.FileDescriptor

+ var JobStateProto_name = map[int32]string

+ var JobStateProto_value = map[string]int32

+ var OpType_name = map[int32]string

+ var OpType_value = map[string]int32

+ var ReservationStatus_name = map[int32]string

+ var ReservationStatus_value = map[string]int32

+ var ResultCode_name = map[int32]string

+ var ResultCode_value = map[string]int32

+ func RegisterClusterServer(s *grpc.Server, srv ClusterServer)

+ func RegisterJobStateMachineServer(s *grpc.Server, srv JobStateMachineServer)

+ type ApplyOpRequest struct

+ Body []byte

+ NowSecs int64

+ Op OpType

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

+ func (*ApplyOpRequest) ProtoMessage()

+ func (x *ApplyOpRequest) GetBody() []byte

+ func (x *ApplyOpRequest) GetNowSecs() int64

+ func (x *ApplyOpRequest) GetOp() OpType

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

+ func (x *ApplyOpRequest) Reset()

+ func (x *ApplyOpRequest) String() string

+ type ApplyOpResponse struct

+ Body []byte

+ ErrorCode ResultCode

+ ErrorMessage string

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

+ func (*ApplyOpResponse) ProtoMessage()

+ func (x *ApplyOpResponse) GetBody() []byte

+ func (x *ApplyOpResponse) GetErrorCode() ResultCode

+ func (x *ApplyOpResponse) GetErrorMessage() string

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

+ func (x *ApplyOpResponse) Reset()

+ func (x *ApplyOpResponse) String() string

+ type BuryRequest struct

+ ClientId string

+ JobId int64

+ Priority uint32

+ ProxyId string

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

+ func (*BuryRequest) ProtoMessage()

+ func (x *BuryRequest) GetClientId() string

+ func (x *BuryRequest) GetJobId() int64

+ func (x *BuryRequest) GetPriority() uint32

+ func (x *BuryRequest) GetProxyId() string

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

+ func (x *BuryRequest) Reset()

+ func (x *BuryRequest) String() string

+ type CheckClientStateRequest struct

+ ClientIds []string

+ ProxyId string

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

+ func (*CheckClientStateRequest) ProtoMessage()

+ func (x *CheckClientStateRequest) GetClientIds() []string

+ func (x *CheckClientStateRequest) GetProxyId() string

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

+ func (x *CheckClientStateRequest) Reset()

+ func (x *CheckClientStateRequest) String() string

+ type CheckClientStateResponse struct

+ MissingClientIds []string

+ NotWaitingClientIds []string

+ ProxyId string

+ WaitingClientIds []string

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

+ func (*CheckClientStateResponse) ProtoMessage()

+ func (x *CheckClientStateResponse) GetMissingClientIds() []string

+ func (x *CheckClientStateResponse) GetNotWaitingClientIds() []string

+ func (x *CheckClientStateResponse) GetProxyId() string

+ func (x *CheckClientStateResponse) GetWaitingClientIds() []string

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

+ func (x *CheckClientStateResponse) Reset()

+ func (x *CheckClientStateResponse) String() string

+ type ClientResvEntryProto struct

+ ClientId string

+ HeapIndex int32

+ IsWaitingForResv bool

+ ReqId string

+ ResvDeadlineAt int64

+ TickAt int64

+ WatchedTube []string

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

+ func (*ClientResvEntryProto) ProtoMessage()

+ func (x *ClientResvEntryProto) GetClientId() string

+ func (x *ClientResvEntryProto) GetHeapIndex() int32

+ func (x *ClientResvEntryProto) GetIsWaitingForResv() bool

+ func (x *ClientResvEntryProto) GetReqId() string

+ func (x *ClientResvEntryProto) GetResvDeadlineAt() int64

+ func (x *ClientResvEntryProto) GetTickAt() int64

+ func (x *ClientResvEntryProto) GetWatchedTube() []string

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

+ func (x *ClientResvEntryProto) Reset()

+ func (x *ClientResvEntryProto) String() string

+ type ClusterClient interface

+ IsNodeLeader func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*IsNodeLeaderResponse, error)

+ Join func(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*Empty, error)

+ Leave func(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*Empty, error)

+ Snapshot func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

+ type ClusterServer interface

+ IsNodeLeader func(context.Context, *Empty) (*IsNodeLeaderResponse, error)

+ Join func(context.Context, *JoinRequest) (*Empty, error)

+ Leave func(context.Context, *LeaveRequest) (*Empty, error)

+ Snapshot func(context.Context, *Empty) (*Empty, error)

+ type DeleteRequest struct

+ ClientId string

+ JobId int64

+ ProxyId string

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

+ func (*DeleteRequest) ProtoMessage()

+ func (x *DeleteRequest) GetClientId() string

+ func (x *DeleteRequest) GetJobId() int64

+ func (x *DeleteRequest) GetProxyId() string

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

+ func (x *DeleteRequest) Reset()

+ func (x *DeleteRequest) String() string

+ type Empty struct

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

+ func (*Empty) ProtoMessage()

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

+ func (x *Empty) Reset()

+ func (x *Empty) String() string

+ type GetJobRequest struct

+ JobId int64

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

+ func (*GetJobRequest) ProtoMessage()

+ func (x *GetJobRequest) GetJobId() int64

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

+ func (x *GetJobRequest) Reset()

+ func (x *GetJobRequest) String() string

+ type GetJobResponse struct

+ Job *JobProto

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

+ func (*GetJobResponse) ProtoMessage()

+ func (x *GetJobResponse) GetJob() *JobProto

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

+ func (x *GetJobResponse) Reset()

+ func (x *GetJobResponse) String() string

+ type GetStatsJobYamlRequest struct

+ JobId int64

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

+ func (*GetStatsJobYamlRequest) ProtoMessage()

+ func (x *GetStatsJobYamlRequest) GetJobId() int64

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

+ func (x *GetStatsJobYamlRequest) Reset()

+ func (x *GetStatsJobYamlRequest) String() string

+ type GetStatsJobYamlResponse struct

+ StatsYaml []byte

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

+ func (*GetStatsJobYamlResponse) ProtoMessage()

+ func (x *GetStatsJobYamlResponse) GetStatsYaml() []byte

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

+ func (x *GetStatsJobYamlResponse) Reset()

+ func (x *GetStatsJobYamlResponse) String() string

+ type GetStatsTubeYamlRequest struct

+ TubeName string

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

+ func (*GetStatsTubeYamlRequest) ProtoMessage()

+ func (x *GetStatsTubeYamlRequest) GetTubeName() string

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

+ func (x *GetStatsTubeYamlRequest) Reset()

+ func (x *GetStatsTubeYamlRequest) String() string

+ type GetStatsTubeYamlResponse struct

+ StatsYaml []byte

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

+ func (*GetStatsTubeYamlResponse) ProtoMessage()

+ func (x *GetStatsTubeYamlResponse) GetStatsYaml() []byte

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

+ func (x *GetStatsTubeYamlResponse) Reset()

+ func (x *GetStatsTubeYamlResponse) String() string

+ type GetStatsYamlResponse struct

+ StatsYaml []byte

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

+ func (*GetStatsYamlResponse) ProtoMessage()

+ func (x *GetStatsYamlResponse) GetStatsYaml() []byte

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

+ func (x *GetStatsYamlResponse) Reset()

+ func (x *GetStatsYamlResponse) String() string

+ type IsNodeLeaderResponse struct

+ IsLeader bool

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

+ func (*IsNodeLeaderResponse) ProtoMessage()

+ func (x *IsNodeLeaderResponse) GetIsLeader() bool

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

+ func (x *IsNodeLeaderResponse) Reset()

+ func (x *IsNodeLeaderResponse) String() string

+ type JobProto struct

+ Body []byte

+ BodySize int32

+ BuriedAt int64

+ BuryCount uint32

+ CreatedAt int64

+ Delay int64

+ ExpiresAt int64

+ Id int64

+ KickCount uint32

+ Priority uint32

+ ReadyAt int64

+ ReleaseCount uint32

+ ReserveCount uint32

+ ReservedBy string

+ State JobStateProto

+ TimeoutCount uint32

+ Ttr int32

+ TubeName string

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

+ func (*JobProto) ProtoMessage()

+ func (x *JobProto) GetBody() []byte

+ func (x *JobProto) GetBodySize() int32

+ func (x *JobProto) GetBuriedAt() int64

+ func (x *JobProto) GetBuryCount() uint32

+ func (x *JobProto) GetCreatedAt() int64

+ func (x *JobProto) GetDelay() int64

+ func (x *JobProto) GetExpiresAt() int64

+ func (x *JobProto) GetId() int64

+ func (x *JobProto) GetKickCount() uint32

+ func (x *JobProto) GetPriority() uint32

+ func (x *JobProto) GetReadyAt() int64

+ func (x *JobProto) GetReleaseCount() uint32

+ func (x *JobProto) GetReserveCount() uint32

+ func (x *JobProto) GetReservedBy() string

+ func (x *JobProto) GetState() JobStateProto

+ func (x *JobProto) GetTimeoutCount() uint32

+ func (x *JobProto) GetTtr() int32

+ func (x *JobProto) GetTubeName() string

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

+ func (x *JobProto) Reset()

+ func (x *JobProto) String() string

+ type JobStateMachineClient interface

+ Bury func(ctx context.Context, in *BuryRequest, opts ...grpc.CallOption) (*Empty, error)

+ CheckClientState func(ctx context.Context, in *CheckClientStateRequest, opts ...grpc.CallOption) (*CheckClientStateResponse, error)

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*Empty, error)

+ GetJob func(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)

+ GetStatsJobYaml func(ctx context.Context, in *GetStatsJobYamlRequest, opts ...grpc.CallOption) (*GetStatsJobYamlResponse, error)

+ GetStatsTubeYaml func(ctx context.Context, in *GetStatsTubeYamlRequest, opts ...grpc.CallOption) (*GetStatsTubeYamlResponse, error)

+ GetStatsYaml func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetStatsYamlResponse, error)

+ Kick func(ctx context.Context, in *KickRequest, opts ...grpc.CallOption) (*Empty, error)

+ KickN func(ctx context.Context, in *KickNRequest, opts ...grpc.CallOption) (*KickNResponse, error)

+ ListTubes func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListTubesResponse, error)

+ PeekBuried func(ctx context.Context, in *PeekRequest, opts ...grpc.CallOption) (*PeekResponse, error)

+ PeekDelayed func(ctx context.Context, in *PeekRequest, opts ...grpc.CallOption) (*PeekResponse, error)

+ PeekReady func(ctx context.Context, in *PeekRequest, opts ...grpc.CallOption) (*PeekResponse, error)

+ Put func(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)

+ Release func(ctx context.Context, in *ReleaseRequest, opts ...grpc.CallOption) (*Empty, error)

+ Reserve func(ctx context.Context, in *ReserveRequest, opts ...grpc.CallOption) (*ReserveResponse, error)

+ StreamReserveUpdates func(ctx context.Context, in *ReserveUpdateRequest, opts ...grpc.CallOption) (JobStateMachine_StreamReserveUpdatesClient, error)

+ Touch func(ctx context.Context, in *TouchRequest, opts ...grpc.CallOption) (*Empty, error)

+ func NewJobStateMachineClient(cc grpc.ClientConnInterface) JobStateMachineClient

+ type JobStateMachineServer interface

+ Bury func(context.Context, *BuryRequest) (*Empty, error)

+ CheckClientState func(context.Context, *CheckClientStateRequest) (*CheckClientStateResponse, error)

+ Delete func(context.Context, *DeleteRequest) (*Empty, error)

+ GetJob func(context.Context, *GetJobRequest) (*GetJobResponse, error)

+ GetStatsJobYaml func(context.Context, *GetStatsJobYamlRequest) (*GetStatsJobYamlResponse, error)

+ GetStatsTubeYaml func(context.Context, *GetStatsTubeYamlRequest) (*GetStatsTubeYamlResponse, error)

+ GetStatsYaml func(context.Context, *Empty) (*GetStatsYamlResponse, error)

+ Kick func(context.Context, *KickRequest) (*Empty, error)

+ KickN func(context.Context, *KickNRequest) (*KickNResponse, error)

+ ListTubes func(context.Context, *Empty) (*ListTubesResponse, error)

+ PeekBuried func(context.Context, *PeekRequest) (*PeekResponse, error)

+ PeekDelayed func(context.Context, *PeekRequest) (*PeekResponse, error)

+ PeekReady func(context.Context, *PeekRequest) (*PeekResponse, error)

+ Put func(context.Context, *PutRequest) (*PutResponse, error)

+ Release func(context.Context, *ReleaseRequest) (*Empty, error)

+ Reserve func(context.Context, *ReserveRequest) (*ReserveResponse, error)

+ StreamReserveUpdates func(*ReserveUpdateRequest, JobStateMachine_StreamReserveUpdatesServer) error

+ Touch func(context.Context, *TouchRequest) (*Empty, error)

+ type JobStateMachine_StreamReserveUpdatesClient interface

+ Recv func() (*ReserveResponse, error)

+ type JobStateMachine_StreamReserveUpdatesServer interface

+ Send func(*ReserveResponse) error

+ type JobStateProto int32

+ const JobStateProto_BURIED

+ const JobStateProto_DELAYED

+ const JobStateProto_DELETED

+ const JobStateProto_INITIAL

+ const JobStateProto_READY

+ const JobStateProto_RESERVED

+ func (JobStateProto) Descriptor() protoreflect.EnumDescriptor

+ func (JobStateProto) EnumDescriptor() ([]byte, []int)

+ func (JobStateProto) Type() protoreflect.EnumType

+ func (x JobStateProto) Enum() *JobStateProto

+ func (x JobStateProto) Number() protoreflect.EnumNumber

+ func (x JobStateProto) String() string

+ type JoinRequest struct

+ Addr string

+ NodeId string

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

+ func (*JoinRequest) ProtoMessage()

+ func (x *JoinRequest) GetAddr() string

+ func (x *JoinRequest) GetNodeId() string

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

+ func (x *JoinRequest) Reset()

+ func (x *JoinRequest) String() string

+ type KickNRequest struct

+ Bound int32

+ TubeName string

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

+ func (*KickNRequest) ProtoMessage()

+ func (x *KickNRequest) GetBound() int32

+ func (x *KickNRequest) GetTubeName() string

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

+ func (x *KickNRequest) Reset()

+ func (x *KickNRequest) String() string

+ type KickNResponse struct

+ JobsKicked int32

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

+ func (*KickNResponse) ProtoMessage()

+ func (x *KickNResponse) GetJobsKicked() int32

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

+ func (x *KickNResponse) Reset()

+ func (x *KickNResponse) String() string

+ type KickRequest struct

+ JobId int64

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

+ func (*KickRequest) ProtoMessage()

+ func (x *KickRequest) GetJobId() int64

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

+ func (x *KickRequest) Reset()

+ func (x *KickRequest) String() string

+ type LeaveRequest struct

+ NodeId string

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

+ func (*LeaveRequest) ProtoMessage()

+ func (x *LeaveRequest) GetNodeId() string

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

+ func (x *LeaveRequest) Reset()

+ func (x *LeaveRequest) String() string

+ type ListTubesResponse struct

+ Tubes []string

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

+ func (*ListTubesResponse) ProtoMessage()

+ func (x *ListTubesResponse) GetTubes() []string

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

+ func (x *ListTubesResponse) Reset()

+ func (x *ListTubesResponse) String() string

+ type OpType int32

+ const OpType_BURY

+ const OpType_CHECK_CLIENT_STATE

+ const OpType_DELETE

+ const OpType_GET_JOB

+ const OpType_KICK

+ const OpType_KICKN

+ const OpType_LIST_TUBES

+ const OpType_PEEK_BURIED

+ const OpType_PEEK_DELAYED

+ const OpType_PEEK_READY

+ const OpType_PUT

+ const OpType_RELEASE

+ const OpType_RESERVE

+ const OpType_STATS_JOB_YAML

+ const OpType_STATS_TUBE_YAML

+ const OpType_STATS_YAML

+ const OpType_TICK

+ const OpType_TOUCH

+ const OpType_UNKNOWN

+ func (OpType) Descriptor() protoreflect.EnumDescriptor

+ func (OpType) EnumDescriptor() ([]byte, []int)

+ func (OpType) Type() protoreflect.EnumType

+ func (x OpType) Enum() *OpType

+ func (x OpType) Number() protoreflect.EnumNumber

+ func (x OpType) String() string

+ type PeekRequest struct

+ TubeName string

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

+ func (*PeekRequest) ProtoMessage()

+ func (x *PeekRequest) GetTubeName() string

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

+ func (x *PeekRequest) Reset()

+ func (x *PeekRequest) String() string

+ type PeekResponse struct

+ Job *JobProto

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

+ func (*PeekResponse) ProtoMessage()

+ func (x *PeekResponse) GetJob() *JobProto

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

+ func (x *PeekResponse) Reset()

+ func (x *PeekResponse) String() string

+ type PutRequest struct

+ Body []byte

+ BodySize int32

+ Delay int64

+ Priority uint32

+ Ttr int32

+ TubeName string

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

+ func (*PutRequest) ProtoMessage()

+ func (x *PutRequest) GetBody() []byte

+ func (x *PutRequest) GetBodySize() int32

+ func (x *PutRequest) GetDelay() int64

+ func (x *PutRequest) GetPriority() uint32

+ func (x *PutRequest) GetTtr() int32

+ func (x *PutRequest) GetTubeName() string

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

+ func (x *PutRequest) Reset()

+ func (x *PutRequest) String() string

+ type PutResponse struct

+ JobId int64

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

+ func (*PutResponse) ProtoMessage()

+ func (x *PutResponse) GetJobId() int64

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

+ func (x *PutResponse) Reset()

+ func (x *PutResponse) String() string

+ type ReleaseRequest struct

+ ClientId string

+ Delay int64

+ JobId int64

+ Priority uint32

+ ProxyId string

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

+ func (*ReleaseRequest) ProtoMessage()

+ func (x *ReleaseRequest) GetClientId() string

+ func (x *ReleaseRequest) GetDelay() int64

+ func (x *ReleaseRequest) GetJobId() int64

+ func (x *ReleaseRequest) GetPriority() uint32

+ func (x *ReleaseRequest) GetProxyId() string

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

+ func (x *ReleaseRequest) Reset()

+ func (x *ReleaseRequest) String() string

+ type Reservation struct

+ Body []byte

+ BodySize int32

+ ClientId string

+ ErrorMsg string

+ JobId int64

+ ProxyId string

+ RequestId string

+ Status ReservationStatus

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

+ func (*Reservation) ProtoMessage()

+ func (x *Reservation) GetBody() []byte

+ func (x *Reservation) GetBodySize() int32

+ func (x *Reservation) GetClientId() string

+ func (x *Reservation) GetErrorMsg() string

+ func (x *Reservation) GetJobId() int64

+ func (x *Reservation) GetProxyId() string

+ func (x *Reservation) GetRequestId() string

+ func (x *Reservation) GetStatus() ReservationStatus

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

+ func (x *Reservation) Reset()

+ func (x *Reservation) String() string

+ type ReservationStatus int32

+ const ReservationStatus_DeadlineSoon

+ const ReservationStatus_Error

+ const ReservationStatus_Matched

+ const ReservationStatus_Queued

+ const ReservationStatus_Timeout

+ const ReservationStatus_UnknownRS

+ func (ReservationStatus) Descriptor() protoreflect.EnumDescriptor

+ func (ReservationStatus) EnumDescriptor() ([]byte, []int)

+ func (ReservationStatus) Type() protoreflect.EnumType

+ func (x ReservationStatus) Enum() *ReservationStatus

+ func (x ReservationStatus) Number() protoreflect.EnumNumber

+ func (x ReservationStatus) String() string

+ type Reservations struct

+ Entries []*Reservation

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

+ func (*Reservations) ProtoMessage()

+ func (x *Reservations) GetEntries() []*Reservation

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

+ func (x *Reservations) Reset()

+ func (x *Reservations) String() string

+ type ReserveRequest struct

+ ClientId string

+ ProxyId string

+ RequestId string

+ TimeoutSecs int32

+ WatchedTubes []string

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

+ func (*ReserveRequest) ProtoMessage()

+ func (x *ReserveRequest) GetClientId() string

+ func (x *ReserveRequest) GetProxyId() string

+ func (x *ReserveRequest) GetRequestId() string

+ func (x *ReserveRequest) GetTimeoutSecs() int32

+ func (x *ReserveRequest) GetWatchedTubes() []string

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

+ func (x *ReserveRequest) Reset()

+ func (x *ReserveRequest) String() string

+ type ReserveResponse struct

+ Reservation *Reservation

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

+ func (*ReserveResponse) ProtoMessage()

+ func (x *ReserveResponse) GetReservation() *Reservation

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

+ func (x *ReserveResponse) Reset()

+ func (x *ReserveResponse) String() string

+ type ReserveUpdateRequest struct

+ ProxyId string

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

+ func (*ReserveUpdateRequest) ProtoMessage()

+ func (x *ReserveUpdateRequest) GetProxyId() string

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

+ func (x *ReserveUpdateRequest) Reset()

+ func (x *ReserveUpdateRequest) String() string

+ type ReserveUpdateResponse struct

+ Reservation *Reservation

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

+ func (*ReserveUpdateResponse) ProtoMessage()

+ func (x *ReserveUpdateResponse) GetReservation() *Reservation

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

+ func (x *ReserveUpdateResponse) Reset()

+ func (x *ReserveUpdateResponse) String() string

+ type ResultCode int32

+ const ResultCode_Aborted

+ const ResultCode_AlreadyExists

+ const ResultCode_Canceled

+ const ResultCode_DataLoss

+ const ResultCode_DeadlineExceeded

+ const ResultCode_FailedPrecondition

+ const ResultCode_Internal

+ const ResultCode_InvalidArgument

+ const ResultCode_NotFound

+ const ResultCode_OK

+ const ResultCode_OutOfRange

+ const ResultCode_PermissionDenied

+ const ResultCode_ResourceExhausted

+ const ResultCode_Unauthenticated

+ const ResultCode_Unavailable

+ const ResultCode_Unimplemented

+ const ResultCode_Unknown

+ func (ResultCode) Descriptor() protoreflect.EnumDescriptor

+ func (ResultCode) EnumDescriptor() ([]byte, []int)

+ func (ResultCode) Type() protoreflect.EnumType

+ func (x ResultCode) Enum() *ResultCode

+ func (x ResultCode) Number() protoreflect.EnumNumber

+ func (x ResultCode) String() string

+ type SnapshotProto struct

+ Jobs []*JobProto

+ Reservations []*ClientResvEntryProto

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

+ func (*SnapshotProto) ProtoMessage()

+ func (x *SnapshotProto) GetJobs() []*JobProto

+ func (x *SnapshotProto) GetReservations() []*ClientResvEntryProto

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

+ func (x *SnapshotProto) Reset()

+ func (x *SnapshotProto) String() string

+ type TickResponse struct

+ ProxyReservations map[string]*Reservations

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

+ func (*TickResponse) ProtoMessage()

+ func (x *TickResponse) GetProxyReservations() map[string]*Reservations

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

+ func (x *TickResponse) Reset()

+ func (x *TickResponse) String() string

+ type TouchRequest struct

+ ClientId string

+ JobId int64

+ ProxyId string

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

+ func (*TouchRequest) ProtoMessage()

+ func (x *TouchRequest) GetClientId() string

+ func (x *TouchRequest) GetJobId() int64

+ func (x *TouchRequest) GetProxyId() string

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

+ func (x *TouchRequest) Reset()

+ func (x *TouchRequest) String() string

+ type UnimplementedClusterServer struct

+ func (*UnimplementedClusterServer) IsNodeLeader(context.Context, *Empty) (*IsNodeLeaderResponse, error)

+ func (*UnimplementedClusterServer) Join(context.Context, *JoinRequest) (*Empty, error)

+ func (*UnimplementedClusterServer) Leave(context.Context, *LeaveRequest) (*Empty, error)

+ func (*UnimplementedClusterServer) Snapshot(context.Context, *Empty) (*Empty, error)

+ type UnimplementedJobStateMachineServer struct

+ func (*UnimplementedJobStateMachineServer) Bury(context.Context, *BuryRequest) (*Empty, error)

+ func (*UnimplementedJobStateMachineServer) CheckClientState(context.Context, *CheckClientStateRequest) (*CheckClientStateResponse, error)

+ func (*UnimplementedJobStateMachineServer) Delete(context.Context, *DeleteRequest) (*Empty, error)

+ func (*UnimplementedJobStateMachineServer) GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)

+ func (*UnimplementedJobStateMachineServer) GetStatsJobYaml(context.Context, *GetStatsJobYamlRequest) (*GetStatsJobYamlResponse, error)

+ func (*UnimplementedJobStateMachineServer) GetStatsTubeYaml(context.Context, *GetStatsTubeYamlRequest) (*GetStatsTubeYamlResponse, error)

+ func (*UnimplementedJobStateMachineServer) GetStatsYaml(context.Context, *Empty) (*GetStatsYamlResponse, error)

+ func (*UnimplementedJobStateMachineServer) Kick(context.Context, *KickRequest) (*Empty, error)

+ func (*UnimplementedJobStateMachineServer) KickN(context.Context, *KickNRequest) (*KickNResponse, error)

+ func (*UnimplementedJobStateMachineServer) ListTubes(context.Context, *Empty) (*ListTubesResponse, error)

+ func (*UnimplementedJobStateMachineServer) PeekBuried(context.Context, *PeekRequest) (*PeekResponse, error)

+ func (*UnimplementedJobStateMachineServer) PeekDelayed(context.Context, *PeekRequest) (*PeekResponse, error)

+ func (*UnimplementedJobStateMachineServer) PeekReady(context.Context, *PeekRequest) (*PeekResponse, error)

+ func (*UnimplementedJobStateMachineServer) Put(context.Context, *PutRequest) (*PutResponse, error)

+ func (*UnimplementedJobStateMachineServer) Release(context.Context, *ReleaseRequest) (*Empty, error)

+ func (*UnimplementedJobStateMachineServer) Reserve(context.Context, *ReserveRequest) (*ReserveResponse, error)

+ func (*UnimplementedJobStateMachineServer) StreamReserveUpdates(*ReserveUpdateRequest, JobStateMachine_StreamReserveUpdatesServer) error

+ func (*UnimplementedJobStateMachineServer) Touch(context.Context, *TouchRequest) (*Empty, error)