compactorv1

type CompactionJob struct {

	// Unique name of the job.
	Name    string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Options *CompactionOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// List of the input blocks.
	Blocks []*v1.BlockMeta      `protobuf:"bytes,3,rep,name=blocks,proto3" json:"blocks,omitempty"`
	Status *CompactionJobStatus `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// Fencing token.
	RaftLogIndex uint64 `protobuf:"varint,5,opt,name=raft_log_index,json=raftLogIndex,proto3" json:"raft_log_index,omitempty"`
	// Shard the blocks belong to.
	Shard uint32 `protobuf:"varint,6,opt,name=shard,proto3" json:"shard,omitempty"`
	// Optional, empty for compaction level 0.
	TenantId        string `protobuf:"bytes,7,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	CompactionLevel uint32 `protobuf:"varint,8,opt,name=compaction_level,json=compactionLevel,proto3" json:"compaction_level,omitempty"`
	// contains filtered or unexported fields
}

type CompactionJobStatus struct {
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// Status update allows the planner to keep
	// track of the job ownership and compaction
	// progress:
	//   - If the job status is other than IN_PROGRESS,
	//     the ownership of the job is revoked.
	//   - FAILURE must only be sent if the failure is
	//     persistent and the compaction can't be accomplished.
	//   - completed_job must be empty if the status is
	//     other than SUCCESS, and vice-versa.
	//   - UNSPECIFIED must be sent if the worker rejects
	//     or cancels the compaction job.
	//
	// Partial results/status is not allowed.
	Status       CompactionStatus `protobuf:"varint,2,opt,name=status,proto3,enum=compactor.v1.CompactionStatus" json:"status,omitempty"`
	CompletedJob *CompletedJob    `protobuf:"bytes,3,opt,name=completed_job,json=completedJob,proto3" json:"completed_job,omitempty"`
	// Fencing token.
	RaftLogIndex uint64 `protobuf:"varint,4,opt,name=raft_log_index,json=raftLogIndex,proto3" json:"raft_log_index,omitempty"`
	// Shard the blocks belong to.
	Shard uint32 `protobuf:"varint,5,opt,name=shard,proto3" json:"shard,omitempty"`
	// Optional, empty for compaction level 0.
	TenantId string `protobuf:"bytes,6,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

type CompactionOptions struct {

	// How often the compaction worker should update
	// the job status. If overdue, the job ownership
	// is revoked.
	StatusUpdateIntervalSeconds uint64 `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CompactionPlannerClient interface {
	// Used to both retrieve jobs and update the jobs status at the same time.
	PollCompactionJobs(ctx context.Context, in *PollCompactionJobsRequest, opts ...grpc.CallOption) (*PollCompactionJobsResponse, error)
	// Used for admin purposes only.
	GetCompactionJobs(ctx context.Context, in *GetCompactionRequest, opts ...grpc.CallOption) (*GetCompactionResponse, error)
}

type CompactionPlannerServer interface {
	// Used to both retrieve jobs and update the jobs status at the same time.
	PollCompactionJobs(context.Context, *PollCompactionJobsRequest) (*PollCompactionJobsResponse, error)
	// Used for admin purposes only.
	GetCompactionJobs(context.Context, *GetCompactionRequest) (*GetCompactionResponse, error)
	// contains filtered or unexported methods
}

type CompactionStatus int32

type CompletedJob struct {
	Blocks []*v1.BlockMeta `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

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

type GetCompactionResponse struct {

	// A list of all compaction jobs
	CompactionJobs []*CompactionJob `protobuf:"bytes,1,rep,name=compaction_jobs,json=compactionJobs,proto3" json:"compaction_jobs,omitempty"`
	// contains filtered or unexported fields
}

type PollCompactionJobsRequest struct {

	// A batch of status updates for in-progress jobs from a worker.
	JobStatusUpdates []*CompactionJobStatus `protobuf:"bytes,1,rep,name=job_status_updates,json=jobStatusUpdates,proto3" json:"job_status_updates,omitempty"`
	// How many new jobs a worker can be assigned to.
	JobCapacity uint32 `protobuf:"varint,2,opt,name=job_capacity,json=jobCapacity,proto3" json:"job_capacity,omitempty"`
	// contains filtered or unexported fields
}

type PollCompactionJobsResponse struct {
	CompactionJobs []*CompactionJob `protobuf:"bytes,1,rep,name=compaction_jobs,json=compactionJobs,proto3" json:"compaction_jobs,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedCompactionPlannerServer struct {
}

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