coolbeans_api_v1

package
Version: v0.1.11 Latest Latest
Warning

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

Go to latest
Published: May 27, 2020 License: AGPL-3.0-only Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	JobStateProto_name = map[int32]string{
		0: "INITIAL",
		1: "READY",
		2: "RESERVED",
		3: "BURIED",
		4: "DELAYED",
		5: "DELETED",
	}
	JobStateProto_value = map[string]int32{
		"INITIAL":  0,
		"READY":    1,
		"RESERVED": 2,
		"BURIED":   3,
		"DELAYED":  4,
		"DELETED":  5,
	}
)

Enum value maps for JobStateProto.

View Source
var (
	ReservationStatus_name = map[int32]string{
		0: "UnknownRS",
		1: "Queued",
		2: "DeadlineSoon",
		3: "Matched",
		4: "Timeout",
		5: "Error",
	}
	ReservationStatus_value = map[string]int32{
		"UnknownRS":    0,
		"Queued":       1,
		"DeadlineSoon": 2,
		"Matched":      3,
		"Timeout":      4,
		"Error":        5,
	}
)

Enum value maps for ReservationStatus.

View Source
var (
	OpType_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "PUT",
		2:  "RESERVE",
		3:  "TICK",
		4:  "DELETE",
		5:  "RELEASE",
		6:  "CHECK_CLIENT_STATE",
		7:  "BURY",
		8:  "KICK",
		9:  "KICKN",
		10: "TOUCH",
		11: "GET_JOB",
		12: "PEEK_READY",
		13: "PEEK_BURIED",
		14: "PEEK_DELAYED",
		15: "STATS_JOB_YAML",
		16: "STATS_TUBE_YAML",
		17: "STATS_YAML",
		18: "LIST_TUBES",
	}
	OpType_value = map[string]int32{
		"UNKNOWN":            0,
		"PUT":                1,
		"RESERVE":            2,
		"TICK":               3,
		"DELETE":             4,
		"RELEASE":            5,
		"CHECK_CLIENT_STATE": 6,
		"BURY":               7,
		"KICK":               8,
		"KICKN":              9,
		"TOUCH":              10,
		"GET_JOB":            11,
		"PEEK_READY":         12,
		"PEEK_BURIED":        13,
		"PEEK_DELAYED":       14,
		"STATS_JOB_YAML":     15,
		"STATS_TUBE_YAML":    16,
		"STATS_YAML":         17,
		"LIST_TUBES":         18,
	}
)

Enum value maps for OpType.

View Source
var (
	ResultCode_name = map[int32]string{
		0:  "OK",
		1:  "Canceled",
		2:  "Unknown",
		3:  "InvalidArgument",
		4:  "DeadlineExceeded",
		5:  "NotFound",
		6:  "AlreadyExists",
		7:  "PermissionDenied",
		8:  "ResourceExhausted",
		9:  "FailedPrecondition",
		10: "Aborted",
		11: "OutOfRange",
		12: "Unimplemented",
		13: "Internal",
		14: "Unavailable",
		15: "DataLoss",
		16: "Unauthenticated",
	}
	ResultCode_value = map[string]int32{
		"OK":                 0,
		"Canceled":           1,
		"Unknown":            2,
		"InvalidArgument":    3,
		"DeadlineExceeded":   4,
		"NotFound":           5,
		"AlreadyExists":      6,
		"PermissionDenied":   7,
		"ResourceExhausted":  8,
		"FailedPrecondition": 9,
		"Aborted":            10,
		"OutOfRange":         11,
		"Unimplemented":      12,
		"Internal":           13,
		"Unavailable":        14,
		"DataLoss":           15,
		"Unauthenticated":    16,
	}
)

Enum value maps for ResultCode.

View Source
var File_client_proto protoreflect.FileDescriptor
View Source
var File_cluster_proto protoreflect.FileDescriptor
View Source
var File_empty_proto protoreflect.FileDescriptor

Functions

func RegisterClusterServer

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

func RegisterJobStateMachineServer

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

Types

type ApplyOpRequest

type ApplyOpRequest struct {

	// Indicates the type of operation
	Op OpType `protobuf:"varint,1,opt,name=op,proto3,enum=coolbeans.api.v1.OpType" json:"op,omitempty"`
	// time in seconds from epoch this request is made
	NowSecs int64 `protobuf:"varint,2,opt,name=now_secs,json=nowSecs,proto3" json:"now_secs,omitempty"`
	// The operation request body
	Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyOpRequest) Descriptor deprecated

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

Deprecated: Use ApplyOpRequest.ProtoReflect.Descriptor instead.

func (*ApplyOpRequest) GetBody

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

func (*ApplyOpRequest) GetNowSecs

func (x *ApplyOpRequest) GetNowSecs() int64

func (*ApplyOpRequest) GetOp

func (x *ApplyOpRequest) GetOp() OpType

func (*ApplyOpRequest) ProtoMessage

func (*ApplyOpRequest) ProtoMessage()

func (*ApplyOpRequest) ProtoReflect

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

func (*ApplyOpRequest) Reset

func (x *ApplyOpRequest) Reset()

func (*ApplyOpRequest) String

func (x *ApplyOpRequest) String() string

type ApplyOpResponse

type ApplyOpResponse struct {

	// error code
	ErrorCode ResultCode `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3,enum=coolbeans.api.v1.ResultCode" json:"error_code,omitempty"`
	// error message (typically set if error_code > 0
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// The response body
	Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyOpResponse) Descriptor deprecated

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

Deprecated: Use ApplyOpResponse.ProtoReflect.Descriptor instead.

func (*ApplyOpResponse) GetBody

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

func (*ApplyOpResponse) GetErrorCode

func (x *ApplyOpResponse) GetErrorCode() ResultCode

func (*ApplyOpResponse) GetErrorMessage

func (x *ApplyOpResponse) GetErrorMessage() string

func (*ApplyOpResponse) ProtoMessage

func (*ApplyOpResponse) ProtoMessage()

func (*ApplyOpResponse) ProtoReflect

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

func (*ApplyOpResponse) Reset

func (x *ApplyOpResponse) Reset()

func (*ApplyOpResponse) String

func (x *ApplyOpResponse) String() string

type BuryRequest

type BuryRequest struct {

	// The job identifier of the job to be buried
	JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Refer Job.priority, the new priority for the job
	Priority uint32 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	// Client id of the request
	ClientId string `protobuf:"bytes,3,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// proxy_id is the id of the proxy server that forwarded this  request
	ProxyId string `protobuf:"bytes,4,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BuryRequest) Descriptor deprecated

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

Deprecated: Use BuryRequest.ProtoReflect.Descriptor instead.

func (*BuryRequest) GetClientId

func (x *BuryRequest) GetClientId() string

func (*BuryRequest) GetJobId

func (x *BuryRequest) GetJobId() int64

func (*BuryRequest) GetPriority

func (x *BuryRequest) GetPriority() uint32

func (*BuryRequest) GetProxyId

func (x *BuryRequest) GetProxyId() string

func (*BuryRequest) ProtoMessage

func (*BuryRequest) ProtoMessage()

func (*BuryRequest) ProtoReflect

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

func (*BuryRequest) Reset

func (x *BuryRequest) Reset()

func (*BuryRequest) String

func (x *BuryRequest) String() string

type CheckClientStateRequest

type CheckClientStateRequest struct {

	// proxy_id is the id of the proxy server that
	// forwarded this  request
	ProxyId string `protobuf:"bytes,1,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id,omitempty"`
	// Array of all client_ids
	ClientIds []string `protobuf:"bytes,2,rep,name=client_ids,json=clientIds,proto3" json:"client_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckClientStateRequest) Descriptor deprecated

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

Deprecated: Use CheckClientStateRequest.ProtoReflect.Descriptor instead.

func (*CheckClientStateRequest) GetClientIds

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

func (*CheckClientStateRequest) GetProxyId

func (x *CheckClientStateRequest) GetProxyId() string

func (*CheckClientStateRequest) ProtoMessage

func (*CheckClientStateRequest) ProtoMessage()

func (*CheckClientStateRequest) ProtoReflect

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

func (*CheckClientStateRequest) Reset

func (x *CheckClientStateRequest) Reset()

func (*CheckClientStateRequest) String

func (x *CheckClientStateRequest) String() string

type CheckClientStateResponse

type CheckClientStateResponse struct {

	// proxy_id is the id of the proxy server that
	// forwarded this  request
	ProxyId string `protobuf:"bytes,1,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id,omitempty"`
	// Array of all client_ids waiting for reservations
	WaitingClientIds []string `protobuf:"bytes,2,rep,name=waiting_client_ids,json=waitingClientIds,proto3" json:"waiting_client_ids,omitempty"`
	// Array of all client_ids not waiting for reservations
	NotWaitingClientIds []string `protobuf:"bytes,3,rep,name=not_waiting_client_ids,json=notWaitingClientIds,proto3" json:"not_waiting_client_ids,omitempty"`
	// Array of all client_ids unknown or missing on the server
	MissingClientIds []string `protobuf:"bytes,4,rep,name=missing_client_ids,json=missingClientIds,proto3" json:"missing_client_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckClientStateResponse) Descriptor deprecated

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

Deprecated: Use CheckClientStateResponse.ProtoReflect.Descriptor instead.

func (*CheckClientStateResponse) GetMissingClientIds

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

func (*CheckClientStateResponse) GetNotWaitingClientIds

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

func (*CheckClientStateResponse) GetProxyId

func (x *CheckClientStateResponse) GetProxyId() string

func (*CheckClientStateResponse) GetWaitingClientIds

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

func (*CheckClientStateResponse) ProtoMessage

func (*CheckClientStateResponse) ProtoMessage()

func (*CheckClientStateResponse) ProtoReflect

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

func (*CheckClientStateResponse) Reset

func (x *CheckClientStateResponse) Reset()

func (*CheckClientStateResponse) String

func (x *CheckClientStateResponse) String() string

type ClientResvEntryProto

type ClientResvEntryProto struct {

	// identifier of the client that requested a reservation
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// reservation deadline at (clock time)
	ResvDeadlineAt int64 `protobuf:"varint,2,opt,name=resv_deadline_at,json=resvDeadlineAt,proto3" json:"resv_deadline_at,omitempty"`
	// boolean indicating if the client is waiting for a reservation
	IsWaitingForResv bool `protobuf:"varint,3,opt,name=is_waiting_for_resv,json=isWaitingForResv,proto3" json:"is_waiting_for_resv,omitempty"`
	// clock time at which the client needs some processing
	TickAt int64 `protobuf:"varint,4,opt,name=tick_at,json=tickAt,proto3" json:"tick_at,omitempty"`
	// request id of the current reservation request
	ReqId string `protobuf:"bytes,5,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	// heap index value for this client reservation
	HeapIndex int32 `protobuf:"varint,6,opt,name=heap_index,json=heapIndex,proto3" json:"heap_index,omitempty"`
	// names of the tubes current watched for resrervations
	WatchedTube []string `protobuf:"bytes,7,rep,name=watched_tube,json=watchedTube,proto3" json:"watched_tube,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientResvEntryProto) Descriptor deprecated

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

Deprecated: Use ClientResvEntryProto.ProtoReflect.Descriptor instead.

func (*ClientResvEntryProto) GetClientId

func (x *ClientResvEntryProto) GetClientId() string

func (*ClientResvEntryProto) GetHeapIndex

func (x *ClientResvEntryProto) GetHeapIndex() int32

func (*ClientResvEntryProto) GetIsWaitingForResv

func (x *ClientResvEntryProto) GetIsWaitingForResv() bool

func (*ClientResvEntryProto) GetReqId

func (x *ClientResvEntryProto) GetReqId() string

func (*ClientResvEntryProto) GetResvDeadlineAt

func (x *ClientResvEntryProto) GetResvDeadlineAt() int64

func (*ClientResvEntryProto) GetTickAt

func (x *ClientResvEntryProto) GetTickAt() int64

func (*ClientResvEntryProto) GetWatchedTube

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

func (*ClientResvEntryProto) ProtoMessage

func (*ClientResvEntryProto) ProtoMessage()

func (*ClientResvEntryProto) ProtoReflect

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

func (*ClientResvEntryProto) Reset

func (x *ClientResvEntryProto) Reset()

func (*ClientResvEntryProto) String

func (x *ClientResvEntryProto) String() string

type ClusterClient

type ClusterClient interface {
	// Join, allows a calling node to make a request to join
	// this cluster.
	//
	// It is required that the node that this is called into is a leader node.
	// Refer: the specific implementation for error codes
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*Empty, error)
	// Leave, allows a calling node to leave the cluster.
	//
	// It is required that the node that this is called into is a leader node.
	// Refer: the specific implementation for error codes
	Leave(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*Empty, error)
	// IsNodeLeader, Check if this current node is a leader
	IsNodeLeader(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*IsNodeLeaderResponse, error)
	// Snaoshot, requests the server to return a user defined snapshot of
	// the specific node.
	Snapshot(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
}

ClusterClient is the client API for Cluster service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClusterClient

func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

type ClusterServer

type ClusterServer interface {
	// Join, allows a calling node to make a request to join
	// this cluster.
	//
	// It is required that the node that this is called into is a leader node.
	// Refer: the specific implementation for error codes
	Join(context.Context, *JoinRequest) (*Empty, error)
	// Leave, allows a calling node to leave the cluster.
	//
	// It is required that the node that this is called into is a leader node.
	// Refer: the specific implementation for error codes
	Leave(context.Context, *LeaveRequest) (*Empty, error)
	// IsNodeLeader, Check if this current node is a leader
	IsNodeLeader(context.Context, *Empty) (*IsNodeLeaderResponse, error)
	// Snaoshot, requests the server to return a user defined snapshot of
	// the specific node.
	Snapshot(context.Context, *Empty) (*Empty, error)
}

ClusterServer is the server API for Cluster service.

type DeleteRequest

type DeleteRequest struct {

	// The job identifier of the job to be deleted
	JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// the proxy identifier forwarding the client's request
	ProxyId string `protobuf:"bytes,2,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id,omitempty"`
	// the client identifier of the client (deleting this job)
	ClientId string `protobuf:"bytes,3,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetClientId

func (x *DeleteRequest) GetClientId() string

func (*DeleteRequest) GetJobId

func (x *DeleteRequest) GetJobId() int64

func (*DeleteRequest) GetProxyId

func (x *DeleteRequest) GetProxyId() string

func (*DeleteRequest) ProtoMessage

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect

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

func (*DeleteRequest) Reset

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String

func (x *DeleteRequest) String() string

type Empty

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

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type GetJobRequest

type GetJobRequest struct {

	// Id of the job to get
	JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobRequest) Descriptor deprecated

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetJobId

func (x *GetJobRequest) GetJobId() int64

func (*GetJobRequest) ProtoMessage

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect

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

func (*GetJobRequest) Reset

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String

func (x *GetJobRequest) String() string

type GetJobResponse

type GetJobResponse struct {

	// An optional job if set.
	Job *JobProto `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobResponse) Descriptor deprecated

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

Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

func (*GetJobResponse) GetJob

func (x *GetJobResponse) GetJob() *JobProto

func (*GetJobResponse) ProtoMessage

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect

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

func (*GetJobResponse) Reset

func (x *GetJobResponse) Reset()

func (*GetJobResponse) String

func (x *GetJobResponse) String() string

type GetStatsJobYamlRequest

type GetStatsJobYamlRequest struct {

	// Id of the job to get
	JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatsJobYamlRequest) Descriptor deprecated

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

Deprecated: Use GetStatsJobYamlRequest.ProtoReflect.Descriptor instead.

func (*GetStatsJobYamlRequest) GetJobId

func (x *GetStatsJobYamlRequest) GetJobId() int64

func (*GetStatsJobYamlRequest) ProtoMessage

func (*GetStatsJobYamlRequest) ProtoMessage()

func (*GetStatsJobYamlRequest) ProtoReflect

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

func (*GetStatsJobYamlRequest) Reset

func (x *GetStatsJobYamlRequest) Reset()

func (*GetStatsJobYamlRequest) String

func (x *GetStatsJobYamlRequest) String() string

type GetStatsJobYamlResponse

type GetStatsJobYamlResponse struct {

	// Yaml representation stats (key-value pairs)
	StatsYaml []byte `protobuf:"bytes,1,opt,name=stats_yaml,json=statsYaml,proto3" json:"stats_yaml,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatsJobYamlResponse) Descriptor deprecated

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

Deprecated: Use GetStatsJobYamlResponse.ProtoReflect.Descriptor instead.

func (*GetStatsJobYamlResponse) GetStatsYaml

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

func (*GetStatsJobYamlResponse) ProtoMessage

func (*GetStatsJobYamlResponse) ProtoMessage()

func (*GetStatsJobYamlResponse) ProtoReflect

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

func (*GetStatsJobYamlResponse) Reset

func (x *GetStatsJobYamlResponse) Reset()

func (*GetStatsJobYamlResponse) String

func (x *GetStatsJobYamlResponse) String() string

type GetStatsTubeYamlRequest

type GetStatsTubeYamlRequest struct {

	// name of the tube
	TubeName string `protobuf:"bytes,1,opt,name=tube_name,json=tubeName,proto3" json:"tube_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatsTubeYamlRequest) Descriptor deprecated

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

Deprecated: Use GetStatsTubeYamlRequest.ProtoReflect.Descriptor instead.

func (*GetStatsTubeYamlRequest) GetTubeName

func (x *GetStatsTubeYamlRequest) GetTubeName() string

func (*GetStatsTubeYamlRequest) ProtoMessage

func (*GetStatsTubeYamlRequest) ProtoMessage()

func (*GetStatsTubeYamlRequest) ProtoReflect

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

func (*GetStatsTubeYamlRequest) Reset

func (x *GetStatsTubeYamlRequest) Reset()

func (*GetStatsTubeYamlRequest) String

func (x *GetStatsTubeYamlRequest) String() string

type GetStatsTubeYamlResponse

type GetStatsTubeYamlResponse struct {

	// Yaml representation stats (key-value pairs)
	StatsYaml []byte `protobuf:"bytes,1,opt,name=stats_yaml,json=statsYaml,proto3" json:"stats_yaml,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatsTubeYamlResponse) Descriptor deprecated

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

Deprecated: Use GetStatsTubeYamlResponse.ProtoReflect.Descriptor instead.

func (*GetStatsTubeYamlResponse) GetStatsYaml

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

func (*GetStatsTubeYamlResponse) ProtoMessage

func (*GetStatsTubeYamlResponse) ProtoMessage()

func (*GetStatsTubeYamlResponse) ProtoReflect

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

func (*GetStatsTubeYamlResponse) Reset

func (x *GetStatsTubeYamlResponse) Reset()

func (*GetStatsTubeYamlResponse) String

func (x *GetStatsTubeYamlResponse) String() string

type GetStatsYamlResponse

type GetStatsYamlResponse struct {

	// Yaml representation stats (key-value pairs)
	StatsYaml []byte `protobuf:"bytes,1,opt,name=stats_yaml,json=statsYaml,proto3" json:"stats_yaml,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatsYamlResponse) Descriptor deprecated

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

Deprecated: Use GetStatsYamlResponse.ProtoReflect.Descriptor instead.

func (*GetStatsYamlResponse) GetStatsYaml

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

func (*GetStatsYamlResponse) ProtoMessage

func (*GetStatsYamlResponse) ProtoMessage()

func (*GetStatsYamlResponse) ProtoReflect

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

func (*GetStatsYamlResponse) Reset

func (x *GetStatsYamlResponse) Reset()

func (*GetStatsYamlResponse) String

func (x *GetStatsYamlResponse) String() string

type IsNodeLeaderResponse

type IsNodeLeaderResponse struct {

	// is_leader is a boolean value indicating if this current node is a leader or not
	IsLeader bool `protobuf:"varint,1,opt,name=is_leader,json=isLeader,proto3" json:"is_leader,omitempty"`
	// contains filtered or unexported fields
}

func (*IsNodeLeaderResponse) Descriptor deprecated

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

Deprecated: Use IsNodeLeaderResponse.ProtoReflect.Descriptor instead.

func (*IsNodeLeaderResponse) GetIsLeader

func (x *IsNodeLeaderResponse) GetIsLeader() bool

func (*IsNodeLeaderResponse) ProtoMessage

func (*IsNodeLeaderResponse) ProtoMessage()

func (*IsNodeLeaderResponse) ProtoReflect

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

func (*IsNodeLeaderResponse) Reset

func (x *IsNodeLeaderResponse) Reset()

func (*IsNodeLeaderResponse) String

func (x *IsNodeLeaderResponse) String() string

type JobProto

type JobProto struct {

	// Unique identifier for job
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Priority is an integer < 2**32. Jobs with smaller priority values will be
	// scheduled before jobs with larger priorities. The most urgent priority is 0;
	// the least urgent priority is 4,294,967,295.
	Priority uint32 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	// delay is an integer number of seconds to wait before putting the job in
	// the ready queue. The job will be in the "delayed" state during this time.
	// Maximum delay is 2**32-1.
	Delay int64 `protobuf:"varint,3,opt,name=delay,proto3" json:"delay,omitempty"`
	// TTR/time to run -- is an integer number of seconds to allow a worker
	// to run this job. This time is counted from the moment a worker reserves
	// this job. If the worker does not delete, release, or bury the job within
	// <ttr> seconds, the job will time out and the server will release the job.
	// The minimum ttr is 1. If the client sends 0, the server will silently
	// increase the ttr to 1. Maximum ttr is 2**32-1.
	Ttr int32 `protobuf:"varint,4,opt,name=ttr,proto3" json:"ttr,omitempty"`
	// tube_name is the name of the tube associated with this job
	TubeName string `protobuf:"bytes,5,opt,name=tube_name,json=tubeName,proto3" json:"tube_name,omitempty"`
	// created is the time in UTC the job is created
	CreatedAt int64 `protobuf:"varint,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// ready_at is the time in UTC the job is ready
	ReadyAt int64 `protobuf:"varint,7,opt,name=ready_at,json=readyAt,proto3" json:"ready_at,omitempty"`
	// expires_at is the time in UTC, when current reservation expires
	ExpiresAt int64 `protobuf:"varint,8,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// state is the current state of this job
	State JobStateProto `protobuf:"varint,9,opt,name=state,proto3,enum=coolbeans.api.v1.JobStateProto" json:"state,omitempty"`
	// reserved_by is the identifier of the client which has
	// reserved this job, the value is empty if un-reserved
	ReservedBy string `protobuf:"bytes,10,opt,name=reserved_by,json=reservedBy,proto3" json:"reserved_by,omitempty"`
	// body_size is an integer indicating the size of the job body, not including the
	// trailing "\r\n". This value must be less than max-job-size (default: 2**16)
	BodySize int32 `protobuf:"varint,11,opt,name=body_size,json=bodySize,proto3" json:"body_size,omitempty"`
	// body is the job body -- a sequence of bytes of length BodySize
	Body []byte `protobuf:"bytes,12,opt,name=body,proto3" json:"body,omitempty"`
	// buried_at the clock time when the job is buried
	BuriedAt int64 `protobuf:"varint,13,opt,name=buried_at,json=buriedAt,proto3" json:"buried_at,omitempty"`
	//  reserve_count is the number of times this job has been reserved.
	ReserveCount uint32 `protobuf:"varint,14,opt,name=reserve_count,json=reserveCount,proto3" json:"reserve_count,omitempty"`
	// timeoutCount is the number of times this job has timed out during a reservation.
	TimeoutCount uint32 `protobuf:"varint,15,opt,name=timeout_count,json=timeoutCount,proto3" json:"timeout_count,omitempty"`
	// release_count is the number of times a client has released this job from a reservation.
	ReleaseCount uint32 `protobuf:"varint,16,opt,name=release_count,json=releaseCount,proto3" json:"release_count,omitempty"`
	//  bury_count is the number of times this job has been buried.
	BuryCount uint32 `protobuf:"varint,17,opt,name=bury_count,json=buryCount,proto3" json:"bury_count,omitempty"`
	// kick_count is the number of times this job has been kicked
	KickCount uint32 `protobuf:"varint,18,opt,name=kick_count,json=kickCount,proto3" json:"kick_count,omitempty"`
	// contains filtered or unexported fields
}

func (*JobProto) Descriptor deprecated

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

Deprecated: Use JobProto.ProtoReflect.Descriptor instead.

func (*JobProto) GetBody

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

func (*JobProto) GetBodySize

func (x *JobProto) GetBodySize() int32

func (*JobProto) GetBuriedAt

func (x *JobProto) GetBuriedAt() int64

func (*JobProto) GetBuryCount

func (x *JobProto) GetBuryCount() uint32

func (*JobProto) GetCreatedAt

func (x *JobProto) GetCreatedAt() int64

func (*JobProto) GetDelay

func (x *JobProto) GetDelay() int64

func (*JobProto) GetExpiresAt

func (x *JobProto) GetExpiresAt() int64

func (*JobProto) GetId

func (x *JobProto) GetId() int64

func (*JobProto) GetKickCount

func (x *JobProto) GetKickCount() uint32

func (*JobProto) GetPriority

func (x *JobProto) GetPriority() uint32

func (*JobProto) GetReadyAt

func (x *JobProto) GetReadyAt() int64

func (*JobProto) GetReleaseCount

func (x *JobProto) GetReleaseCount() uint32

func (*JobProto) GetReserveCount

func (x *JobProto) GetReserveCount() uint32

func (*JobProto) GetReservedBy

func (x *JobProto) GetReservedBy() string

func (*JobProto) GetState

func (x *JobProto) GetState() JobStateProto

func (*JobProto) GetTimeoutCount

func (x *JobProto) GetTimeoutCount() uint32

func (*JobProto) GetTtr

func (x *JobProto) GetTtr() int32

func (*JobProto) GetTubeName

func (x *JobProto) GetTubeName() string

func (*JobProto) ProtoMessage

func (*JobProto) ProtoMessage()

func (*JobProto) ProtoReflect

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

func (*JobProto) Reset

func (x *JobProto) Reset()

func (*JobProto) String

func (x *JobProto) String() string

type JobStateMachineClient

type JobStateMachineClient interface {
	// Put creates a new job with the provided job parameters
	//
	// The response contains the identifier of the job created
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	// Delete a job with the provided job id
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*Empty, error)
	// Reserve is a request to reserve a channel for a client by this proxy
	Reserve(ctx context.Context, in *ReserveRequest, opts ...grpc.CallOption) (*ReserveResponse, error)
	// StreamReserveUpdates is a streaming RPC from the server back to client
	//
	// Reservations are streamed as they are available for this proxy
	StreamReserveUpdates(ctx context.Context, in *ReserveUpdateRequest, opts ...grpc.CallOption) (JobStateMachine_StreamReserveUpdatesClient, error)
	// CheckClientState queries the job state machine whether the provided list of clientIds are waiting for reservations.
	CheckClientState(ctx context.Context, in *CheckClientStateRequest, opts ...grpc.CallOption) (*CheckClientStateResponse, error)
	// Release a reserved job back to either a Ready or a Delayed state
	Release(ctx context.Context, in *ReleaseRequest, opts ...grpc.CallOption) (*Empty, error)
	// Extend a reserved job's reservation TTL by its TTR (time-to-run)
	Touch(ctx context.Context, in *TouchRequest, opts ...grpc.CallOption) (*Empty, error)
	// Bury this job, if this job is in the reserved state
	Bury(ctx context.Context, in *BuryRequest, opts ...grpc.CallOption) (*Empty, error)
	// Kick this job, if this job is in a buried stated to ready state
	Kick(ctx context.Context, in *KickRequest, opts ...grpc.CallOption) (*Empty, error)
	// Kick at-most n jobs in this tube,
	KickN(ctx context.Context, in *KickNRequest, opts ...grpc.CallOption) (*KickNResponse, error)
	// Peek a specific job (by the JobID)
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
	// Peek a tube's buried jobs
	PeekBuried(ctx context.Context, in *PeekRequest, opts ...grpc.CallOption) (*PeekResponse, error)
	// Peek a tube's delayed jobs
	PeekDelayed(ctx context.Context, in *PeekRequest, opts ...grpc.CallOption) (*PeekResponse, error)
	// Peek a tube's ready jobs
	PeekReady(ctx context.Context, in *PeekRequest, opts ...grpc.CallOption) (*PeekResponse, error)
	// Retrieve a job statistics
	GetStatsJobYaml(ctx context.Context, in *GetStatsJobYamlRequest, opts ...grpc.CallOption) (*GetStatsJobYamlResponse, error)
	// Retrieve a tube's statistics
	GetStatsTubeYaml(ctx context.Context, in *GetStatsTubeYamlRequest, opts ...grpc.CallOption) (*GetStatsTubeYamlResponse, error)
	// Retrieve overall statistics
	GetStatsYaml(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetStatsYamlResponse, error)
	// Retreive a list of all Tubes
	ListTubes(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListTubesResponse, error)
}

JobStateMachineClient is the client API for JobStateMachine service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type JobStateMachineServer

type JobStateMachineServer interface {
	// Put creates a new job with the provided job parameters
	//
	// The response contains the identifier of the job created
	Put(context.Context, *PutRequest) (*PutResponse, error)
	// Delete a job with the provided job id
	Delete(context.Context, *DeleteRequest) (*Empty, error)
	// Reserve is a request to reserve a channel for a client by this proxy
	Reserve(context.Context, *ReserveRequest) (*ReserveResponse, error)
	// StreamReserveUpdates is a streaming RPC from the server back to client
	//
	// Reservations are streamed as they are available for this proxy
	StreamReserveUpdates(*ReserveUpdateRequest, JobStateMachine_StreamReserveUpdatesServer) error
	// CheckClientState queries the job state machine whether the provided list of clientIds are waiting for reservations.
	CheckClientState(context.Context, *CheckClientStateRequest) (*CheckClientStateResponse, error)
	// Release a reserved job back to either a Ready or a Delayed state
	Release(context.Context, *ReleaseRequest) (*Empty, error)
	// Extend a reserved job's reservation TTL by its TTR (time-to-run)
	Touch(context.Context, *TouchRequest) (*Empty, error)
	// Bury this job, if this job is in the reserved state
	Bury(context.Context, *BuryRequest) (*Empty, error)
	// Kick this job, if this job is in a buried stated to ready state
	Kick(context.Context, *KickRequest) (*Empty, error)
	// Kick at-most n jobs in this tube,
	KickN(context.Context, *KickNRequest) (*KickNResponse, error)
	// Peek a specific job (by the JobID)
	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
	// Peek a tube's buried jobs
	PeekBuried(context.Context, *PeekRequest) (*PeekResponse, error)
	// Peek a tube's delayed jobs
	PeekDelayed(context.Context, *PeekRequest) (*PeekResponse, error)
	// Peek a tube's ready jobs
	PeekReady(context.Context, *PeekRequest) (*PeekResponse, error)
	// Retrieve a job statistics
	GetStatsJobYaml(context.Context, *GetStatsJobYamlRequest) (*GetStatsJobYamlResponse, error)
	// Retrieve a tube's statistics
	GetStatsTubeYaml(context.Context, *GetStatsTubeYamlRequest) (*GetStatsTubeYamlResponse, error)
	// Retrieve overall statistics
	GetStatsYaml(context.Context, *Empty) (*GetStatsYamlResponse, error)
	// Retreive a list of all Tubes
	ListTubes(context.Context, *Empty) (*ListTubesResponse, error)
}

JobStateMachineServer is the server API for JobStateMachine service.

type JobStateMachine_StreamReserveUpdatesClient

type JobStateMachine_StreamReserveUpdatesClient interface {
	Recv() (*ReserveResponse, error)
	grpc.ClientStream
}

type JobStateMachine_StreamReserveUpdatesServer

type JobStateMachine_StreamReserveUpdatesServer interface {
	Send(*ReserveResponse) error
	grpc.ServerStream
}

type JobStateProto

type JobStateProto int32
const (
	JobStateProto_INITIAL  JobStateProto = 0
	JobStateProto_READY    JobStateProto = 1
	JobStateProto_RESERVED JobStateProto = 2
	JobStateProto_BURIED   JobStateProto = 3
	JobStateProto_DELAYED  JobStateProto = 4
	JobStateProto_DELETED  JobStateProto = 5
)

func (JobStateProto) Descriptor

func (JobStateProto) Enum

func (x JobStateProto) Enum() *JobStateProto

func (JobStateProto) EnumDescriptor deprecated

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

Deprecated: Use JobStateProto.Descriptor instead.

func (JobStateProto) Number

func (JobStateProto) String

func (x JobStateProto) String() string

func (JobStateProto) Type

type JoinRequest

type JoinRequest struct {

	// Node ID of the node interested in joining
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Address of the replica interested in joining
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinRequest) Descriptor deprecated

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

Deprecated: Use JoinRequest.ProtoReflect.Descriptor instead.

func (*JoinRequest) GetAddr

func (x *JoinRequest) GetAddr() string

func (*JoinRequest) GetNodeId

func (x *JoinRequest) GetNodeId() string

func (*JoinRequest) ProtoMessage

func (*JoinRequest) ProtoMessage()

func (*JoinRequest) ProtoReflect

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

func (*JoinRequest) Reset

func (x *JoinRequest) Reset()

func (*JoinRequest) String

func (x *JoinRequest) String() string

type KickNRequest

type KickNRequest struct {

	// Refer Job.tube_name
	TubeName string `protobuf:"bytes,1,opt,name=tube_name,json=tubeName,proto3" json:"tube_name,omitempty"`
	// bound is the maximum number of jobs to kick
	Bound int32 `protobuf:"varint,2,opt,name=bound,proto3" json:"bound,omitempty"`
	// contains filtered or unexported fields
}

func (*KickNRequest) Descriptor deprecated

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

Deprecated: Use KickNRequest.ProtoReflect.Descriptor instead.

func (*KickNRequest) GetBound

func (x *KickNRequest) GetBound() int32

func (*KickNRequest) GetTubeName

func (x *KickNRequest) GetTubeName() string

func (*KickNRequest) ProtoMessage

func (*KickNRequest) ProtoMessage()

func (*KickNRequest) ProtoReflect

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

func (*KickNRequest) Reset

func (x *KickNRequest) Reset()

func (*KickNRequest) String

func (x *KickNRequest) String() string

type KickNResponse

type KickNResponse struct {

	// The actual number of jobs kicked
	JobsKicked int32 `protobuf:"varint,1,opt,name=jobs_kicked,json=jobsKicked,proto3" json:"jobs_kicked,omitempty"`
	// contains filtered or unexported fields
}

func (*KickNResponse) Descriptor deprecated

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

Deprecated: Use KickNResponse.ProtoReflect.Descriptor instead.

func (*KickNResponse) GetJobsKicked

func (x *KickNResponse) GetJobsKicked() int32

func (*KickNResponse) ProtoMessage

func (*KickNResponse) ProtoMessage()

func (*KickNResponse) ProtoReflect

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

func (*KickNResponse) Reset

func (x *KickNResponse) Reset()

func (*KickNResponse) String

func (x *KickNResponse) String() string

type KickRequest

type KickRequest struct {

	// The job identifier of the job to be Kicked
	JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*KickRequest) Descriptor deprecated

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

Deprecated: Use KickRequest.ProtoReflect.Descriptor instead.

func (*KickRequest) GetJobId

func (x *KickRequest) GetJobId() int64

func (*KickRequest) ProtoMessage

func (*KickRequest) ProtoMessage()

func (*KickRequest) ProtoReflect

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

func (*KickRequest) Reset

func (x *KickRequest) Reset()

func (*KickRequest) String

func (x *KickRequest) String() string

type LeaveRequest

type LeaveRequest struct {

	// Node ID of the node requested to leave
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaveRequest) Descriptor deprecated

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

Deprecated: Use LeaveRequest.ProtoReflect.Descriptor instead.

func (*LeaveRequest) GetNodeId

func (x *LeaveRequest) GetNodeId() string

func (*LeaveRequest) ProtoMessage

func (*LeaveRequest) ProtoMessage()

func (*LeaveRequest) ProtoReflect

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

func (*LeaveRequest) Reset

func (x *LeaveRequest) Reset()

func (*LeaveRequest) String

func (x *LeaveRequest) String() string

type ListTubesResponse

type ListTubesResponse struct {
	Tubes []string `protobuf:"bytes,1,rep,name=tubes,proto3" json:"tubes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTubesResponse) Descriptor deprecated

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

Deprecated: Use ListTubesResponse.ProtoReflect.Descriptor instead.

func (*ListTubesResponse) GetTubes

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

func (*ListTubesResponse) ProtoMessage

func (*ListTubesResponse) ProtoMessage()

func (*ListTubesResponse) ProtoReflect

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

func (*ListTubesResponse) Reset

func (x *ListTubesResponse) Reset()

func (*ListTubesResponse) String

func (x *ListTubesResponse) String() string

type OpType

type OpType int32
const (
	OpType_UNKNOWN            OpType = 0
	OpType_PUT                OpType = 1
	OpType_RESERVE            OpType = 2
	OpType_TICK               OpType = 3
	OpType_DELETE             OpType = 4
	OpType_RELEASE            OpType = 5
	OpType_CHECK_CLIENT_STATE OpType = 6
	OpType_BURY               OpType = 7
	OpType_KICK               OpType = 8
	OpType_KICKN              OpType = 9
	OpType_TOUCH              OpType = 10
	OpType_GET_JOB            OpType = 11
	OpType_PEEK_READY         OpType = 12
	OpType_PEEK_BURIED        OpType = 13
	OpType_PEEK_DELAYED       OpType = 14
	OpType_STATS_JOB_YAML     OpType = 15
	OpType_STATS_TUBE_YAML    OpType = 16
	OpType_STATS_YAML         OpType = 17
	OpType_LIST_TUBES         OpType = 18
)

func (OpType) Descriptor

func (OpType) Descriptor() protoreflect.EnumDescriptor

func (OpType) Enum

func (x OpType) Enum() *OpType

func (OpType) EnumDescriptor deprecated

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

Deprecated: Use OpType.Descriptor instead.

func (OpType) Number

func (x OpType) Number() protoreflect.EnumNumber

func (OpType) String

func (x OpType) String() string

func (OpType) Type

func (OpType) Type() protoreflect.EnumType

type PeekRequest

type PeekRequest struct {

	// the name of the tube
	TubeName string `protobuf:"bytes,1,opt,name=tube_name,json=tubeName,proto3" json:"tube_name,omitempty"`
	// contains filtered or unexported fields
}

func (*PeekRequest) Descriptor deprecated

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

Deprecated: Use PeekRequest.ProtoReflect.Descriptor instead.

func (*PeekRequest) GetTubeName

func (x *PeekRequest) GetTubeName() string

func (*PeekRequest) ProtoMessage

func (*PeekRequest) ProtoMessage()

func (*PeekRequest) ProtoReflect

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

func (*PeekRequest) Reset

func (x *PeekRequest) Reset()

func (*PeekRequest) String

func (x *PeekRequest) String() string

type PeekResponse

type PeekResponse struct {

	// An optional job if set.
	Job *JobProto `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*PeekResponse) Descriptor deprecated

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

Deprecated: Use PeekResponse.ProtoReflect.Descriptor instead.

func (*PeekResponse) GetJob

func (x *PeekResponse) GetJob() *JobProto

func (*PeekResponse) ProtoMessage

func (*PeekResponse) ProtoMessage()

func (*PeekResponse) ProtoReflect

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

func (*PeekResponse) Reset

func (x *PeekResponse) Reset()

func (*PeekResponse) String

func (x *PeekResponse) String() string

type PutRequest

type PutRequest struct {

	// Refer Job.priority
	Priority uint32 `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`
	// Refer Job.delay
	Delay int64 `protobuf:"varint,2,opt,name=delay,proto3" json:"delay,omitempty"`
	// Refer Job.ttr
	Ttr int32 `protobuf:"varint,3,opt,name=ttr,proto3" json:"ttr,omitempty"`
	// Refer Job.tube_na,e
	TubeName string `protobuf:"bytes,4,opt,name=tube_name,json=tubeName,proto3" json:"tube_name,omitempty"`
	// Refer Job.body_size
	BodySize int32 `protobuf:"varint,5,opt,name=body_size,json=bodySize,proto3" json:"body_size,omitempty"`
	// Refer Job.body
	Body []byte `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetBody

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

func (*PutRequest) GetBodySize

func (x *PutRequest) GetBodySize() int32

func (*PutRequest) GetDelay

func (x *PutRequest) GetDelay() int64

func (*PutRequest) GetPriority

func (x *PutRequest) GetPriority() uint32

func (*PutRequest) GetTtr

func (x *PutRequest) GetTtr() int32

func (*PutRequest) GetTubeName

func (x *PutRequest) GetTubeName() string

func (*PutRequest) ProtoMessage

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect

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

func (*PutRequest) Reset

func (x *PutRequest) Reset()

func (*PutRequest) String

func (x *PutRequest) String() string

type PutResponse

type PutResponse struct {

	// The job identifier of the new job created
	JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResponse) Descriptor deprecated

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetJobId

func (x *PutResponse) GetJobId() int64

func (*PutResponse) ProtoMessage

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect

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

func (*PutResponse) Reset

func (x *PutResponse) Reset()

func (*PutResponse) String

func (x *PutResponse) String() string

type ReleaseRequest

type ReleaseRequest struct {

	// The job identifier of the job to be released
	JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// The identifier of the client asking for the release
	ClientId string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// proxy_id is the id of the proxy server that
	// forwarded this  request
	ProxyId string `protobuf:"bytes,3,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id,omitempty"`
	// A delay if set to a value > 0 marks the job as delayed
	Delay int64 `protobuf:"varint,4,opt,name=delay,proto3" json:"delay,omitempty"`
	// the new priority with which this job is released
	Priority uint32 `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseRequest) Descriptor deprecated

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

Deprecated: Use ReleaseRequest.ProtoReflect.Descriptor instead.

func (*ReleaseRequest) GetClientId

func (x *ReleaseRequest) GetClientId() string

func (*ReleaseRequest) GetDelay

func (x *ReleaseRequest) GetDelay() int64

func (*ReleaseRequest) GetJobId

func (x *ReleaseRequest) GetJobId() int64

func (*ReleaseRequest) GetPriority

func (x *ReleaseRequest) GetPriority() uint32

func (*ReleaseRequest) GetProxyId

func (x *ReleaseRequest) GetProxyId() string

func (*ReleaseRequest) ProtoMessage

func (*ReleaseRequest) ProtoMessage()

func (*ReleaseRequest) ProtoReflect

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

func (*ReleaseRequest) Reset

func (x *ReleaseRequest) Reset()

func (*ReleaseRequest) String

func (x *ReleaseRequest) String() string

type Reservation

type Reservation struct {

	// request_id associated with this reservation
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// client id assinged to this reservation
	ClientId string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// Result of this reservation
	Status ReservationStatus `protobuf:"varint,3,opt,name=Status,proto3,enum=coolbeans.api.v1.ReservationStatus" json:"Status,omitempty"`
	// job id (assigned) if Status is matched
	JobId int64 `protobuf:"varint,4,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// job body size (assigned) if Status is matched
	BodySize int32 `protobuf:"varint,5,opt,name=body_size,json=bodySize,proto3" json:"body_size,omitempty"`
	// job body  (assigned) if Status is matched
	Body []byte `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"`
	// error message (assigned) if Status is error
	ErrorMsg string `protobuf:"bytes,7,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// proxy_id is the id of the proxy server that
	// forwarded this reservation request
	ProxyId string `protobuf:"bytes,8,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Reservation) Descriptor deprecated

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

Deprecated: Use Reservation.ProtoReflect.Descriptor instead.

func (*Reservation) GetBody

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

func (*Reservation) GetBodySize

func (x *Reservation) GetBodySize() int32

func (*Reservation) GetClientId

func (x *Reservation) GetClientId() string

func (*Reservation) GetErrorMsg

func (x *Reservation) GetErrorMsg() string

func (*Reservation) GetJobId

func (x *Reservation) GetJobId() int64

func (*Reservation) GetProxyId

func (x *Reservation) GetProxyId() string

func (*Reservation) GetRequestId

func (x *Reservation) GetRequestId() string

func (*Reservation) GetStatus

func (x *Reservation) GetStatus() ReservationStatus

func (*Reservation) ProtoMessage

func (*Reservation) ProtoMessage()

func (*Reservation) ProtoReflect

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

func (*Reservation) Reset

func (x *Reservation) Reset()

func (*Reservation) String

func (x *Reservation) String() string

type ReservationStatus

type ReservationStatus int32
const (
	// Unknown ~~> UnknownRS (yuck!!)
	// Note that enum values use C++ scoping rules, meaning
	// that enum values are siblings of their type, not children of it.
	// Therefore, "Unknown" must be unique within "coolbeans.api.v1",
	// not just within "ResultCode"
	ReservationStatus_UnknownRS    ReservationStatus = 0
	ReservationStatus_Queued       ReservationStatus = 1
	ReservationStatus_DeadlineSoon ReservationStatus = 2
	ReservationStatus_Matched      ReservationStatus = 3
	ReservationStatus_Timeout      ReservationStatus = 4
	ReservationStatus_Error        ReservationStatus = 5
)

func (ReservationStatus) Descriptor

func (ReservationStatus) Enum

func (ReservationStatus) EnumDescriptor deprecated

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

Deprecated: Use ReservationStatus.Descriptor instead.

func (ReservationStatus) Number

func (ReservationStatus) String

func (x ReservationStatus) String() string

func (ReservationStatus) Type

type Reservations

type Reservations struct {

	// Reservation object encapsulated in this response
	Entries []*Reservation `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*Reservations) Descriptor deprecated

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

Deprecated: Use Reservations.ProtoReflect.Descriptor instead.

func (*Reservations) GetEntries

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

func (*Reservations) ProtoMessage

func (*Reservations) ProtoMessage()

func (*Reservations) ProtoReflect

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

func (*Reservations) Reset

func (x *Reservations) Reset()

func (*Reservations) String

func (x *Reservations) String() string

type ReserveRequest

type ReserveRequest struct {

	// client id of the reservation
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// request id identify this reservation
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// reservation timeout in seconds
	TimeoutSecs int32 `protobuf:"varint,3,opt,name=timeout_secs,json=timeoutSecs,proto3" json:"timeout_secs,omitempty"`
	// array of tubes to watch
	WatchedTubes []string `protobuf:"bytes,4,rep,name=watched_tubes,json=watchedTubes,proto3" json:"watched_tubes,omitempty"`
	// the proxy identifier forwarding the client's request
	ProxyId string `protobuf:"bytes,5,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ReserveRequest) Descriptor deprecated

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

Deprecated: Use ReserveRequest.ProtoReflect.Descriptor instead.

func (*ReserveRequest) GetClientId

func (x *ReserveRequest) GetClientId() string

func (*ReserveRequest) GetProxyId

func (x *ReserveRequest) GetProxyId() string

func (*ReserveRequest) GetRequestId

func (x *ReserveRequest) GetRequestId() string

func (*ReserveRequest) GetTimeoutSecs

func (x *ReserveRequest) GetTimeoutSecs() int32

func (*ReserveRequest) GetWatchedTubes

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

func (*ReserveRequest) ProtoMessage

func (*ReserveRequest) ProtoMessage()

func (*ReserveRequest) ProtoReflect

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

func (*ReserveRequest) Reset

func (x *ReserveRequest) Reset()

func (*ReserveRequest) String

func (x *ReserveRequest) String() string

type ReserveResponse

type ReserveResponse struct {

	// Reservation object encapsulated in this response
	Reservation *Reservation `protobuf:"bytes,1,opt,name=reservation,proto3" json:"reservation,omitempty"`
	// contains filtered or unexported fields
}

func (*ReserveResponse) Descriptor deprecated

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

Deprecated: Use ReserveResponse.ProtoReflect.Descriptor instead.

func (*ReserveResponse) GetReservation

func (x *ReserveResponse) GetReservation() *Reservation

func (*ReserveResponse) ProtoMessage

func (*ReserveResponse) ProtoMessage()

func (*ReserveResponse) ProtoReflect

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

func (*ReserveResponse) Reset

func (x *ReserveResponse) Reset()

func (*ReserveResponse) String

func (x *ReserveResponse) String() string

type ReserveUpdateRequest

type ReserveUpdateRequest struct {

	// the proxy identifier requesting reservation update
	ProxyId string `protobuf:"bytes,1,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ReserveUpdateRequest) Descriptor deprecated

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

Deprecated: Use ReserveUpdateRequest.ProtoReflect.Descriptor instead.

func (*ReserveUpdateRequest) GetProxyId

func (x *ReserveUpdateRequest) GetProxyId() string

func (*ReserveUpdateRequest) ProtoMessage

func (*ReserveUpdateRequest) ProtoMessage()

func (*ReserveUpdateRequest) ProtoReflect

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

func (*ReserveUpdateRequest) Reset

func (x *ReserveUpdateRequest) Reset()

func (*ReserveUpdateRequest) String

func (x *ReserveUpdateRequest) String() string

type ReserveUpdateResponse

type ReserveUpdateResponse struct {

	// Reservations  encapsulated in this response
	Reservation *Reservation `protobuf:"bytes,1,opt,name=reservation,proto3" json:"reservation,omitempty"`
	// contains filtered or unexported fields
}

func (*ReserveUpdateResponse) Descriptor deprecated

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

Deprecated: Use ReserveUpdateResponse.ProtoReflect.Descriptor instead.

func (*ReserveUpdateResponse) GetReservation

func (x *ReserveUpdateResponse) GetReservation() *Reservation

func (*ReserveUpdateResponse) ProtoMessage

func (*ReserveUpdateResponse) ProtoMessage()

func (*ReserveUpdateResponse) ProtoReflect

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

func (*ReserveUpdateResponse) Reset

func (x *ReserveUpdateResponse) Reset()

func (*ReserveUpdateResponse) String

func (x *ReserveUpdateResponse) String() string

type ResultCode

type ResultCode int32

C & P from GRPC error codes https://github.com/grpc/grpc-go/blob/master/codes/codes.go

const (
	// OK is returned on success.
	ResultCode_OK ResultCode = 0
	// Canceled indicates the operation was canceled (typically by the caller).
	ResultCode_Canceled ResultCode = 1
	// Unknown error. An example of where this error may be returned is
	// if a Status value received from another address space belongs to
	// an error-space that is not known in this address space. Also
	// errors raised by APIs that do not return enough error information
	// may be converted to this error.
	ResultCode_Unknown ResultCode = 2
	// InvalidArgument indicates client specified an invalid argument.
	// Note that this differs from FailedPrecondition. It indicates arguments
	// that are problematic regardless of the state of the system
	// (e.g., a malformed file name).
	ResultCode_InvalidArgument ResultCode = 3
	// DeadlineExceeded means operation expired before completion.
	// For operations that change the state of the system, this error may be
	// returned even if the operation has completed successfully. For
	// example, a successful response from a server could have been delayed
	// long enough for the deadline to expire.
	ResultCode_DeadlineExceeded ResultCode = 4
	// NotFound means some requested entity (e.g., file or directory) was
	// not found.
	ResultCode_NotFound ResultCode = 5
	// AlreadyExists means an attempt to create an entity failed because one
	// already exists.
	ResultCode_AlreadyExists ResultCode = 6
	// PermissionDenied indicates the caller does not have permission to
	// execute the specified operation. It must not be used for rejections
	// caused by exhausting some resource (use ResourceExhausted
	// instead for those errors). It must not be
	// used if the caller cannot be identified (use Unauthenticated
	// instead for those errors).
	ResultCode_PermissionDenied ResultCode = 7
	// ResourceExhausted indicates some resource has been exhausted, perhaps
	// a per-user quota, or perhaps the entire file system is out of space.
	ResultCode_ResourceExhausted ResultCode = 8
	// FailedPrecondition indicates operation was rejected because the
	// system is not in a state required for the operation's execution.
	// For example, directory to be deleted may be non-empty, an rmdir
	// operation is applied to a non-directory, etc.
	//
	// A litmus test that may help a service implementor in deciding
	// between FailedPrecondition, Aborted, and Unavailable:
	//  (a) Use Unavailable if the client can retry just the failing call.
	//  (b) Use Aborted if the client should retry at a higher-level
	//      (e.g., restarting a read-modify-write sequence).
	//  (c) Use FailedPrecondition if the client should not retry until
	//      the system state has been explicitly fixed. E.g., if an "rmdir"
	//      fails because the directory is non-empty, FailedPrecondition
	//      should be returned since the client should not retry unless
	//      they have first fixed up the directory by deleting files from it.
	//  (d) Use FailedPrecondition if the client performs conditional
	//      REST Get/Update/Delete on a resource and the resource on the
	//      server does not match the condition. E.g., conflicting
	//      read-modify-write on the same resource.
	ResultCode_FailedPrecondition ResultCode = 9
	// Aborted indicates the operation was aborted, typically due to a
	// concurrency issue like sequencer check failures, transaction aborts,
	// etc.
	//
	// See litmus test above for deciding between FailedPrecondition,
	// Aborted, and Unavailable.
	ResultCode_Aborted ResultCode = 10
	// OutOfRange means operation was attempted past the valid range.
	// E.g., seeking or reading past end of file.
	//
	// Unlike InvalidArgument, this error indicates a problem that may
	// be fixed if the system state changes. For example, a 32-bit file
	// system will generate InvalidArgument if asked to read at an
	// offset that is not in the range [0,2^32-1], but it will generate
	// OutOfRange if asked to read from an offset past the current
	// file size.
	//
	// There is a fair bit of overlap between FailedPrecondition and
	// OutOfRange. We recommend using OutOfRange (the more specific
	// error) when it applies so that callers who are iterating through
	// a space can easily look for an OutOfRange error to detect when
	// they are done.
	ResultCode_OutOfRange ResultCode = 11
	// Unimplemented indicates operation is not implemented or not
	// supported/enabled in this service.
	ResultCode_Unimplemented ResultCode = 12
	// Internal errors. Means some invariants expected by underlying
	// system has been broken. If you see one of these errors,
	// something is very broken.
	ResultCode_Internal ResultCode = 13
	// Unavailable indicates the service is currently unavailable.
	// This is a most likely a transient condition and may be corrected
	// by retrying with a backoff. Note that it is not always safe to retry
	// non-idempotent operations.
	//
	// See litmus test above for deciding between FailedPrecondition,
	// Aborted, and Unavailable.
	ResultCode_Unavailable ResultCode = 14
	// DataLoss indicates unrecoverable data loss or corruption.
	ResultCode_DataLoss ResultCode = 15
	// Unauthenticated indicates the request does not have valid
	// authentication credentials for the operation.
	ResultCode_Unauthenticated ResultCode = 16
)

func (ResultCode) Descriptor

func (ResultCode) Descriptor() protoreflect.EnumDescriptor

func (ResultCode) Enum

func (x ResultCode) Enum() *ResultCode

func (ResultCode) EnumDescriptor deprecated

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

Deprecated: Use ResultCode.Descriptor instead.

func (ResultCode) Number

func (x ResultCode) Number() protoreflect.EnumNumber

func (ResultCode) String

func (x ResultCode) String() string

func (ResultCode) Type

type SnapshotProto

type SnapshotProto struct {

	// Array of all jobs currently in the system
	Jobs []*JobProto `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// Arrayy of all client reservation entries in the system
	Reservations []*ClientResvEntryProto `protobuf:"bytes,2,rep,name=reservations,proto3" json:"reservations,omitempty"`
	// contains filtered or unexported fields
}

Encapsulates a snap of the entire system

func (*SnapshotProto) Descriptor deprecated

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

Deprecated: Use SnapshotProto.ProtoReflect.Descriptor instead.

func (*SnapshotProto) GetJobs

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

func (*SnapshotProto) GetReservations

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

func (*SnapshotProto) ProtoMessage

func (*SnapshotProto) ProtoMessage()

func (*SnapshotProto) ProtoReflect

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

func (*SnapshotProto) Reset

func (x *SnapshotProto) Reset()

func (*SnapshotProto) String

func (x *SnapshotProto) String() string

type TickResponse

type TickResponse struct {

	// Reservations grouped by proxy id
	ProxyReservations map[string]*Reservations `` /* 200-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TickResponse) Descriptor deprecated

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

Deprecated: Use TickResponse.ProtoReflect.Descriptor instead.

func (*TickResponse) GetProxyReservations

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

func (*TickResponse) ProtoMessage

func (*TickResponse) ProtoMessage()

func (*TickResponse) ProtoReflect

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

func (*TickResponse) Reset

func (x *TickResponse) Reset()

func (*TickResponse) String

func (x *TickResponse) String() string

type TouchRequest

type TouchRequest struct {

	// The job identifier of the job to be touched
	JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// The identifier of the client asking for the release
	ClientId string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// proxy_id is the id of the proxy server that
	// forwarded this  request
	ProxyId string `protobuf:"bytes,3,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TouchRequest) Descriptor deprecated

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

Deprecated: Use TouchRequest.ProtoReflect.Descriptor instead.

func (*TouchRequest) GetClientId

func (x *TouchRequest) GetClientId() string

func (*TouchRequest) GetJobId

func (x *TouchRequest) GetJobId() int64

func (*TouchRequest) GetProxyId

func (x *TouchRequest) GetProxyId() string

func (*TouchRequest) ProtoMessage

func (*TouchRequest) ProtoMessage()

func (*TouchRequest) ProtoReflect

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

func (*TouchRequest) Reset

func (x *TouchRequest) Reset()

func (*TouchRequest) String

func (x *TouchRequest) String() string

type UnimplementedClusterServer

type UnimplementedClusterServer struct {
}

UnimplementedClusterServer can be embedded to have forward compatible implementations.

func (*UnimplementedClusterServer) IsNodeLeader

func (*UnimplementedClusterServer) Join

func (*UnimplementedClusterServer) Leave

func (*UnimplementedClusterServer) Snapshot

type UnimplementedJobStateMachineServer

type UnimplementedJobStateMachineServer struct {
}

UnimplementedJobStateMachineServer can be embedded to have forward compatible implementations.

func (*UnimplementedJobStateMachineServer) Bury

func (*UnimplementedJobStateMachineServer) CheckClientState

func (*UnimplementedJobStateMachineServer) Delete

func (*UnimplementedJobStateMachineServer) GetJob

func (*UnimplementedJobStateMachineServer) GetStatsJobYaml

func (*UnimplementedJobStateMachineServer) GetStatsTubeYaml

func (*UnimplementedJobStateMachineServer) GetStatsYaml

func (*UnimplementedJobStateMachineServer) Kick

func (*UnimplementedJobStateMachineServer) KickN

func (*UnimplementedJobStateMachineServer) ListTubes

func (*UnimplementedJobStateMachineServer) PeekBuried

func (*UnimplementedJobStateMachineServer) PeekDelayed

func (*UnimplementedJobStateMachineServer) PeekReady

func (*UnimplementedJobStateMachineServer) Put

func (*UnimplementedJobStateMachineServer) Release

func (*UnimplementedJobStateMachineServer) Reserve

func (*UnimplementedJobStateMachineServer) StreamReserveUpdates

func (*UnimplementedJobStateMachineServer) Touch

Jump to

Keyboard shortcuts

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