compactionpb

package
v1.9.1 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2024 License: AGPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CompactionStatus_name = map[int32]string{
		0: "COMPACTION_STATUS_UNSPECIFIED",
		1: "COMPACTION_STATUS_IN_PROGRESS",
		2: "COMPACTION_STATUS_SUCCESS",
		3: "COMPACTION_STATUS_FAILURE",
		4: "COMPACTION_STATUS_CANCELLED",
	}
	CompactionStatus_value = map[string]int32{
		"COMPACTION_STATUS_UNSPECIFIED": 0,
		"COMPACTION_STATUS_IN_PROGRESS": 1,
		"COMPACTION_STATUS_SUCCESS":     2,
		"COMPACTION_STATUS_FAILURE":     3,
		"COMPACTION_STATUS_CANCELLED":   4,
	}
)

Enum value maps for CompactionStatus.

View Source 
var File_experiment_metastore_compactionpb_compaction_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CompactionJob 

type CompactionJob struct {

	// Unique name of the job.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// List of the input blocks.
	Blocks []string `protobuf:"bytes,2,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// Compaction level (all blocks are the same)
	CompactionLevel uint32 `protobuf:"varint,3,opt,name=compaction_level,json=compactionLevel,proto3" json:"compaction_level,omitempty"`
	// The index of the raft command that changed the status of the job.
	// Used as a fencing token in conjunction with the lease_expires_at
	// field to manage ownership of the compaction job. Any access to the
	// job must be guarded by the check: current_index >= raft_log_index.
	// If the check fails, the access should be denied.
	//
	// The index is updated every time the job is assigned to a worker.
	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"`
	Status   CompactionStatus `protobuf:"varint,7,opt,name=status,proto3,enum=compaction.CompactionStatus" json:"status,omitempty"`
	// The time the compaction job lease expires. If a lease is expired, the
	// job is considered abandoned and can be picked up by another worker.
	// The expiration check should be done by comparing the timestamp of
	// the raft log entry (command that accesses the job) with the value of
	// this field.
	//
	// The lease is extended every time the owner reports a status update.
	LeaseExpiresAt int64 `protobuf:"varint,8,opt,name=lease_expires_at,json=leaseExpiresAt,proto3" json:"lease_expires_at,omitempty"`
	// The number of failures when processing this job. Used for retries.
	Failures          uint32 `protobuf:"varint,9,opt,name=failures,proto3" json:"failures,omitempty"`
	LastFailureReason string `protobuf:"bytes,10,opt,name=last_failure_reason,json=lastFailureReason,proto3" json:"last_failure_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionJob) Descriptor deprecated 

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

Deprecated: Use CompactionJob.ProtoReflect.Descriptor instead.

func (*CompactionJob) GetBlocks 

func (x *CompactionJob) GetBlocks() []string

func (*CompactionJob) GetCompactionLevel 

func (x *CompactionJob) GetCompactionLevel() uint32

func (*CompactionJob) GetFailures 

func (x *CompactionJob) GetFailures() uint32

func (*CompactionJob) GetLastFailureReason 

func (x *CompactionJob) GetLastFailureReason() string

func (*CompactionJob) GetLeaseExpiresAt 

func (x *CompactionJob) GetLeaseExpiresAt() int64

func (*CompactionJob) GetName 

func (x *CompactionJob) GetName() string

func (*CompactionJob) GetRaftLogIndex 

func (x *CompactionJob) GetRaftLogIndex() uint64

func (*CompactionJob) GetShard 

func (x *CompactionJob) GetShard() uint32

func (*CompactionJob) GetStatus 

func (x *CompactionJob) GetStatus() CompactionStatus

func (*CompactionJob) GetTenantId 

func (x *CompactionJob) GetTenantId() string

func (*CompactionJob) MarshalToSizedBufferVT 

func (m *CompactionJob) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CompactionJob) MarshalToVT 

func (m *CompactionJob) MarshalToVT(dAtA []byte) (int, error)

func (*CompactionJob) MarshalVT 

func (m *CompactionJob) MarshalVT() (dAtA []byte, err error)

func (*CompactionJob) ProtoMessage 

func (*CompactionJob) ProtoMessage()

func (*CompactionJob) ProtoReflect 

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

func (*CompactionJob) Reset 

func (x *CompactionJob) Reset()

func (*CompactionJob) SizeVT 

func (m *CompactionJob) SizeVT() (n int)

func (*CompactionJob) String 

func (x *CompactionJob) String() string

func (*CompactionJob) UnmarshalVT 

func (m *CompactionJob) UnmarshalVT(dAtA []byte) error

type CompactionJobBlockQueue 

type CompactionJobBlockQueue struct {
	CompactionLevel uint32   `protobuf:"varint,1,opt,name=compaction_level,json=compactionLevel,proto3" json:"compaction_level,omitempty"`
	Shard           uint32   `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Tenant          string   `protobuf:"bytes,3,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Blocks          []string `protobuf:"bytes,4,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionJobBlockQueue) Descriptor deprecated 

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

Deprecated: Use CompactionJobBlockQueue.ProtoReflect.Descriptor instead.

func (*CompactionJobBlockQueue) GetBlocks 

func (x *CompactionJobBlockQueue) GetBlocks() []string

func (*CompactionJobBlockQueue) GetCompactionLevel 

func (x *CompactionJobBlockQueue) GetCompactionLevel() uint32

func (*CompactionJobBlockQueue) GetShard 

func (x *CompactionJobBlockQueue) GetShard() uint32

func (*CompactionJobBlockQueue) GetTenant 

func (x *CompactionJobBlockQueue) GetTenant() string

func (*CompactionJobBlockQueue) MarshalToSizedBufferVT 

func (m *CompactionJobBlockQueue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CompactionJobBlockQueue) MarshalToVT 

func (m *CompactionJobBlockQueue) MarshalToVT(dAtA []byte) (int, error)

func (*CompactionJobBlockQueue) MarshalVT 

func (m *CompactionJobBlockQueue) MarshalVT() (dAtA []byte, err error)

func (*CompactionJobBlockQueue) ProtoMessage 

func (*CompactionJobBlockQueue) ProtoMessage()

func (*CompactionJobBlockQueue) ProtoReflect 

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

func (*CompactionJobBlockQueue) Reset 

func (x *CompactionJobBlockQueue) Reset()

func (*CompactionJobBlockQueue) SizeVT 

func (m *CompactionJobBlockQueue) SizeVT() (n int)

func (*CompactionJobBlockQueue) String 

func (x *CompactionJobBlockQueue) String() string

func (*CompactionJobBlockQueue) UnmarshalVT 

func (m *CompactionJobBlockQueue) UnmarshalVT(dAtA []byte) error

type CompactionStatus 

type CompactionStatus int32
const (
	CompactionStatus_COMPACTION_STATUS_UNSPECIFIED CompactionStatus = 0
	CompactionStatus_COMPACTION_STATUS_IN_PROGRESS CompactionStatus = 1
	CompactionStatus_COMPACTION_STATUS_SUCCESS     CompactionStatus = 2
	CompactionStatus_COMPACTION_STATUS_FAILURE     CompactionStatus = 3
	CompactionStatus_COMPACTION_STATUS_CANCELLED   CompactionStatus = 4
)

func (CompactionStatus) Descriptor 

func (CompactionStatus) Descriptor() protoreflect.EnumDescriptor

func (CompactionStatus) Enum 

func (x CompactionStatus) Enum() *CompactionStatus

func (CompactionStatus) EnumDescriptor deprecated 

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

Deprecated: Use CompactionStatus.Descriptor instead.

func (CompactionStatus) Number 

func (x CompactionStatus) Number() protoreflect.EnumNumber

func (CompactionStatus) String 

func (x CompactionStatus) String() string

func (CompactionStatus) Type 

func (CompactionStatus) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.