Versions in this module Expand all Collapse all v1 v1.0.0 Oct 8, 2024 Changes in this version + var CompactionPlanner_ServiceDesc = grpc.ServiceDesc + var CompactionStatus_name = map[int32]string + var CompactionStatus_value = map[string]int32 + var File_compactor_v1_compactor_proto protoreflect.FileDescriptor + func RegisterCompactionPlannerServer(s grpc.ServiceRegistrar, srv CompactionPlannerServer) + type CompactionJob struct + Blocks []*v1.BlockMeta + CompactionLevel uint32 + Name string + Options *CompactionOptions + RaftLogIndex uint64 + Shard uint32 + Status *CompactionJobStatus + TenantId string + func (*CompactionJob) Descriptor() ([]byte, []int) + func (*CompactionJob) ProtoMessage() + func (m *CompactionJob) CloneMessageVT() proto.Message + func (m *CompactionJob) CloneVT() *CompactionJob + func (m *CompactionJob) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *CompactionJob) MarshalToVT(dAtA []byte) (int, error) + func (m *CompactionJob) MarshalVT() (dAtA []byte, err error) + func (m *CompactionJob) SizeVT() (n int) + func (m *CompactionJob) UnmarshalVT(dAtA []byte) error + func (this *CompactionJob) EqualMessageVT(thatMsg proto.Message) bool + func (this *CompactionJob) EqualVT(that *CompactionJob) bool + func (x *CompactionJob) GetBlocks() []*v1.BlockMeta + func (x *CompactionJob) GetCompactionLevel() uint32 + func (x *CompactionJob) GetName() string + func (x *CompactionJob) GetOptions() *CompactionOptions + func (x *CompactionJob) GetRaftLogIndex() uint64 + func (x *CompactionJob) GetShard() uint32 + func (x *CompactionJob) GetStatus() *CompactionJobStatus + func (x *CompactionJob) GetTenantId() string + func (x *CompactionJob) ProtoReflect() protoreflect.Message + func (x *CompactionJob) Reset() + func (x *CompactionJob) String() string + type CompactionJobStatus struct + CompletedJob *CompletedJob + JobName string + RaftLogIndex uint64 + Shard uint32 + Status CompactionStatus + TenantId string + func (*CompactionJobStatus) Descriptor() ([]byte, []int) + func (*CompactionJobStatus) ProtoMessage() + func (m *CompactionJobStatus) CloneMessageVT() proto.Message + func (m *CompactionJobStatus) CloneVT() *CompactionJobStatus + func (m *CompactionJobStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *CompactionJobStatus) MarshalToVT(dAtA []byte) (int, error) + func (m *CompactionJobStatus) MarshalVT() (dAtA []byte, err error) + func (m *CompactionJobStatus) SizeVT() (n int) + func (m *CompactionJobStatus) UnmarshalVT(dAtA []byte) error + func (this *CompactionJobStatus) EqualMessageVT(thatMsg proto.Message) bool + func (this *CompactionJobStatus) EqualVT(that *CompactionJobStatus) bool + func (x *CompactionJobStatus) GetCompletedJob() *CompletedJob + func (x *CompactionJobStatus) GetJobName() string + func (x *CompactionJobStatus) GetRaftLogIndex() uint64 + func (x *CompactionJobStatus) GetShard() uint32 + func (x *CompactionJobStatus) GetStatus() CompactionStatus + func (x *CompactionJobStatus) GetTenantId() string + func (x *CompactionJobStatus) ProtoReflect() protoreflect.Message + func (x *CompactionJobStatus) Reset() + func (x *CompactionJobStatus) String() string + type CompactionOptions struct + StatusUpdateIntervalSeconds uint64 + func (*CompactionOptions) Descriptor() ([]byte, []int) + func (*CompactionOptions) ProtoMessage() + func (m *CompactionOptions) CloneMessageVT() proto.Message + func (m *CompactionOptions) CloneVT() *CompactionOptions + func (m *CompactionOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *CompactionOptions) MarshalToVT(dAtA []byte) (int, error) + func (m *CompactionOptions) MarshalVT() (dAtA []byte, err error) + func (m *CompactionOptions) SizeVT() (n int) + func (m *CompactionOptions) UnmarshalVT(dAtA []byte) error + func (this *CompactionOptions) EqualMessageVT(thatMsg proto.Message) bool + func (this *CompactionOptions) EqualVT(that *CompactionOptions) bool + func (x *CompactionOptions) GetStatusUpdateIntervalSeconds() uint64 + func (x *CompactionOptions) ProtoReflect() protoreflect.Message + func (x *CompactionOptions) Reset() + func (x *CompactionOptions) String() string + type CompactionPlannerClient interface + GetCompactionJobs func(ctx context.Context, in *GetCompactionRequest, opts ...grpc.CallOption) (*GetCompactionResponse, error) + PollCompactionJobs func(ctx context.Context, in *PollCompactionJobsRequest, opts ...grpc.CallOption) (*PollCompactionJobsResponse, error) + func NewCompactionPlannerClient(cc grpc.ClientConnInterface) CompactionPlannerClient + type CompactionPlannerServer interface + GetCompactionJobs func(context.Context, *GetCompactionRequest) (*GetCompactionResponse, error) + PollCompactionJobs func(context.Context, *PollCompactionJobsRequest) (*PollCompactionJobsResponse, error) + type CompactionStatus int32 + const CompactionStatus_COMPACTION_STATUS_CANCELLED + const CompactionStatus_COMPACTION_STATUS_FAILURE + const CompactionStatus_COMPACTION_STATUS_IN_PROGRESS + const CompactionStatus_COMPACTION_STATUS_SUCCESS + const CompactionStatus_COMPACTION_STATUS_UNSPECIFIED + func (CompactionStatus) Descriptor() protoreflect.EnumDescriptor + func (CompactionStatus) EnumDescriptor() ([]byte, []int) + func (CompactionStatus) Type() protoreflect.EnumType + func (x CompactionStatus) Enum() *CompactionStatus + func (x CompactionStatus) Number() protoreflect.EnumNumber + func (x CompactionStatus) String() string + type CompletedJob struct + Blocks []*v1.BlockMeta + func (*CompletedJob) Descriptor() ([]byte, []int) + func (*CompletedJob) ProtoMessage() + func (m *CompletedJob) CloneMessageVT() proto.Message + func (m *CompletedJob) CloneVT() *CompletedJob + func (m *CompletedJob) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *CompletedJob) MarshalToVT(dAtA []byte) (int, error) + func (m *CompletedJob) MarshalVT() (dAtA []byte, err error) + func (m *CompletedJob) SizeVT() (n int) + func (m *CompletedJob) UnmarshalVT(dAtA []byte) error + func (this *CompletedJob) EqualMessageVT(thatMsg proto.Message) bool + func (this *CompletedJob) EqualVT(that *CompletedJob) bool + func (x *CompletedJob) GetBlocks() []*v1.BlockMeta + func (x *CompletedJob) ProtoReflect() protoreflect.Message + func (x *CompletedJob) Reset() + func (x *CompletedJob) String() string + type GetCompactionRequest struct + func (*GetCompactionRequest) Descriptor() ([]byte, []int) + func (*GetCompactionRequest) ProtoMessage() + func (m *GetCompactionRequest) CloneMessageVT() proto.Message + func (m *GetCompactionRequest) CloneVT() *GetCompactionRequest + func (m *GetCompactionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *GetCompactionRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *GetCompactionRequest) MarshalVT() (dAtA []byte, err error) + func (m *GetCompactionRequest) SizeVT() (n int) + func (m *GetCompactionRequest) UnmarshalVT(dAtA []byte) error + func (this *GetCompactionRequest) EqualMessageVT(thatMsg proto.Message) bool + func (this *GetCompactionRequest) EqualVT(that *GetCompactionRequest) bool + func (x *GetCompactionRequest) ProtoReflect() protoreflect.Message + func (x *GetCompactionRequest) Reset() + func (x *GetCompactionRequest) String() string + type GetCompactionResponse struct + CompactionJobs []*CompactionJob + func (*GetCompactionResponse) Descriptor() ([]byte, []int) + func (*GetCompactionResponse) ProtoMessage() + func (m *GetCompactionResponse) CloneMessageVT() proto.Message + func (m *GetCompactionResponse) CloneVT() *GetCompactionResponse + func (m *GetCompactionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *GetCompactionResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *GetCompactionResponse) MarshalVT() (dAtA []byte, err error) + func (m *GetCompactionResponse) SizeVT() (n int) + func (m *GetCompactionResponse) UnmarshalVT(dAtA []byte) error + func (this *GetCompactionResponse) EqualMessageVT(thatMsg proto.Message) bool + func (this *GetCompactionResponse) EqualVT(that *GetCompactionResponse) bool + func (x *GetCompactionResponse) GetCompactionJobs() []*CompactionJob + func (x *GetCompactionResponse) ProtoReflect() protoreflect.Message + func (x *GetCompactionResponse) Reset() + func (x *GetCompactionResponse) String() string + type PollCompactionJobsRequest struct + JobCapacity uint32 + JobStatusUpdates []*CompactionJobStatus + func (*PollCompactionJobsRequest) Descriptor() ([]byte, []int) + func (*PollCompactionJobsRequest) ProtoMessage() + func (m *PollCompactionJobsRequest) CloneMessageVT() proto.Message + func (m *PollCompactionJobsRequest) CloneVT() *PollCompactionJobsRequest + func (m *PollCompactionJobsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *PollCompactionJobsRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *PollCompactionJobsRequest) MarshalVT() (dAtA []byte, err error) + func (m *PollCompactionJobsRequest) SizeVT() (n int) + func (m *PollCompactionJobsRequest) UnmarshalVT(dAtA []byte) error + func (this *PollCompactionJobsRequest) EqualMessageVT(thatMsg proto.Message) bool + func (this *PollCompactionJobsRequest) EqualVT(that *PollCompactionJobsRequest) bool + func (x *PollCompactionJobsRequest) GetJobCapacity() uint32 + func (x *PollCompactionJobsRequest) GetJobStatusUpdates() []*CompactionJobStatus + func (x *PollCompactionJobsRequest) ProtoReflect() protoreflect.Message + func (x *PollCompactionJobsRequest) Reset() + func (x *PollCompactionJobsRequest) String() string + type PollCompactionJobsResponse struct + CompactionJobs []*CompactionJob + func (*PollCompactionJobsResponse) Descriptor() ([]byte, []int) + func (*PollCompactionJobsResponse) ProtoMessage() + func (m *PollCompactionJobsResponse) CloneMessageVT() proto.Message + func (m *PollCompactionJobsResponse) CloneVT() *PollCompactionJobsResponse + func (m *PollCompactionJobsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *PollCompactionJobsResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *PollCompactionJobsResponse) MarshalVT() (dAtA []byte, err error) + func (m *PollCompactionJobsResponse) SizeVT() (n int) + func (m *PollCompactionJobsResponse) UnmarshalVT(dAtA []byte) error + func (this *PollCompactionJobsResponse) EqualMessageVT(thatMsg proto.Message) bool + func (this *PollCompactionJobsResponse) EqualVT(that *PollCompactionJobsResponse) bool + func (x *PollCompactionJobsResponse) GetCompactionJobs() []*CompactionJob + func (x *PollCompactionJobsResponse) ProtoReflect() protoreflect.Message + func (x *PollCompactionJobsResponse) Reset() + func (x *PollCompactionJobsResponse) String() string + type UnimplementedCompactionPlannerServer struct + func (UnimplementedCompactionPlannerServer) GetCompactionJobs(context.Context, *GetCompactionRequest) (*GetCompactionResponse, error) + func (UnimplementedCompactionPlannerServer) PollCompactionJobs(context.Context, *PollCompactionJobsRequest) (*PollCompactionJobsResponse, error) + type UnsafeCompactionPlannerServer interface
Go to main page