coolbeans_api_v1

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
}

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
}

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
}

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
}

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
}

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
}

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)
}

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)
}

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
}

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

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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)
}

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)
}

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

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

type JobStateProto int32

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
}

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
}

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
}

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
}

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
}

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

type OpType int32

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
}

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
}

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
}

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
}

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
}

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
}

type ReservationStatus int32

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
}

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
}

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
}

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
}

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
}

type ResultCode int32

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
}

type TickResponse struct {

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

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
}

type UnimplementedClusterServer struct {
}

type UnimplementedJobStateMachineServer struct {
}