raft_log

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Jan 17, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RaftCommand_name = map[int32]string{
		0: "RAFT_COMMAND_UNKNOWN",
		1: "RAFT_COMMAND_ADD_BLOCK_METADATA",
		2: "RAFT_COMMAND_GET_COMPACTION_PLAN_UPDATE",
		3: "RAFT_COMMAND_UPDATE_COMPACTION_PLAN",
	}
	RaftCommand_value = map[string]int32{
		"RAFT_COMMAND_UNKNOWN":                    0,
		"RAFT_COMMAND_ADD_BLOCK_METADATA":         1,
		"RAFT_COMMAND_GET_COMPACTION_PLAN_UPDATE": 2,
		"RAFT_COMMAND_UPDATE_COMPACTION_PLAN":     3,
	}
)

Enum value maps for RaftCommand.

View Source 
var File_metastore_v1_raft_log_raft_log_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AddBlockMetadataRequest 

type AddBlockMetadataRequest struct {
	Metadata *v1.BlockMeta `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*AddBlockMetadataRequest) CloneMessageVT 

func (m *AddBlockMetadataRequest) CloneMessageVT() proto.Message

func (*AddBlockMetadataRequest) CloneVT 

func (m *AddBlockMetadataRequest) CloneVT() *AddBlockMetadataRequest

func (*AddBlockMetadataRequest) Descriptor deprecated 

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

Deprecated: Use AddBlockMetadataRequest.ProtoReflect.Descriptor instead.

func (*AddBlockMetadataRequest) EqualMessageVT 

func (this *AddBlockMetadataRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*AddBlockMetadataRequest) EqualVT 

func (this *AddBlockMetadataRequest) EqualVT(that *AddBlockMetadataRequest) bool

func (*AddBlockMetadataRequest) GetMetadata 

func (x *AddBlockMetadataRequest) GetMetadata() *v1.BlockMeta

func (*AddBlockMetadataRequest) MarshalToSizedBufferVT 

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

func (*AddBlockMetadataRequest) MarshalToVT 

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

func (*AddBlockMetadataRequest) MarshalVT 

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

func (*AddBlockMetadataRequest) ProtoMessage 

func (*AddBlockMetadataRequest) ProtoMessage()

func (*AddBlockMetadataRequest) ProtoReflect 

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

func (*AddBlockMetadataRequest) Reset 

func (x *AddBlockMetadataRequest) Reset()

func (*AddBlockMetadataRequest) SizeVT 

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

func (*AddBlockMetadataRequest) String 

func (x *AddBlockMetadataRequest) String() string

func (*AddBlockMetadataRequest) UnmarshalVT 

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

type AddBlockMetadataResponse 

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

func (*AddBlockMetadataResponse) CloneMessageVT 

func (m *AddBlockMetadataResponse) CloneMessageVT() proto.Message

func (*AddBlockMetadataResponse) CloneVT 

func (m *AddBlockMetadataResponse) CloneVT() *AddBlockMetadataResponse

func (*AddBlockMetadataResponse) Descriptor deprecated 

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

Deprecated: Use AddBlockMetadataResponse.ProtoReflect.Descriptor instead.

func (*AddBlockMetadataResponse) EqualMessageVT 

func (this *AddBlockMetadataResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*AddBlockMetadataResponse) EqualVT 

func (this *AddBlockMetadataResponse) EqualVT(that *AddBlockMetadataResponse) bool

func (*AddBlockMetadataResponse) MarshalToSizedBufferVT 

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

func (*AddBlockMetadataResponse) MarshalToVT 

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

func (*AddBlockMetadataResponse) MarshalVT 

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

func (*AddBlockMetadataResponse) ProtoMessage 

func (*AddBlockMetadataResponse) ProtoMessage()

func (*AddBlockMetadataResponse) ProtoReflect 

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

func (*AddBlockMetadataResponse) Reset 

func (x *AddBlockMetadataResponse) Reset()

func (*AddBlockMetadataResponse) SizeVT 

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

func (*AddBlockMetadataResponse) String 

func (x *AddBlockMetadataResponse) String() string

func (*AddBlockMetadataResponse) UnmarshalVT 

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

type AssignedCompactionJob 

type AssignedCompactionJob struct {
	State *CompactionJobState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Plan  *CompactionJobPlan  `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	// contains filtered or unexported fields
}

func (*AssignedCompactionJob) CloneMessageVT 

func (m *AssignedCompactionJob) CloneMessageVT() proto.Message

func (*AssignedCompactionJob) CloneVT 

func (m *AssignedCompactionJob) CloneVT() *AssignedCompactionJob

func (*AssignedCompactionJob) Descriptor deprecated 

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

Deprecated: Use AssignedCompactionJob.ProtoReflect.Descriptor instead.

func (*AssignedCompactionJob) EqualMessageVT 

func (this *AssignedCompactionJob) EqualMessageVT(thatMsg proto.Message) bool

func (*AssignedCompactionJob) EqualVT 

func (this *AssignedCompactionJob) EqualVT(that *AssignedCompactionJob) bool

func (*AssignedCompactionJob) GetPlan 

func (x *AssignedCompactionJob) GetPlan() *CompactionJobPlan

func (*AssignedCompactionJob) GetState 

func (x *AssignedCompactionJob) GetState() *CompactionJobState

func (*AssignedCompactionJob) MarshalToSizedBufferVT 

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

func (*AssignedCompactionJob) MarshalToVT 

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

func (*AssignedCompactionJob) MarshalVT 

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

func (*AssignedCompactionJob) ProtoMessage 

func (*AssignedCompactionJob) ProtoMessage()

func (*AssignedCompactionJob) ProtoReflect 

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

func (*AssignedCompactionJob) Reset 

func (x *AssignedCompactionJob) Reset()

func (*AssignedCompactionJob) SizeVT 

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

func (*AssignedCompactionJob) String 

func (x *AssignedCompactionJob) String() string

func (*AssignedCompactionJob) UnmarshalVT 

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

type CompactionJobPlan 

type CompactionJobPlan struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Blocks to be compacted.
	Tenant          string   `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Shard           uint32   `protobuf:"varint,3,opt,name=shard,proto3" json:"shard,omitempty"`
	CompactionLevel uint32   `protobuf:"varint,4,opt,name=compaction_level,json=compactionLevel,proto3" json:"compaction_level,omitempty"`
	SourceBlocks    []string `protobuf:"bytes,5,rep,name=source_blocks,json=sourceBlocks,proto3" json:"source_blocks,omitempty"`
	// Objects to be deleted.
	Tombstones []*v1.Tombstones `protobuf:"bytes,6,rep,name=tombstones,proto3" json:"tombstones,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionJobPlan) CloneMessageVT 

func (m *CompactionJobPlan) CloneMessageVT() proto.Message

func (*CompactionJobPlan) CloneVT 

func (m *CompactionJobPlan) CloneVT() *CompactionJobPlan

func (*CompactionJobPlan) Descriptor deprecated 

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

Deprecated: Use CompactionJobPlan.ProtoReflect.Descriptor instead.

func (*CompactionJobPlan) EqualMessageVT 

func (this *CompactionJobPlan) EqualMessageVT(thatMsg proto.Message) bool

func (*CompactionJobPlan) EqualVT 

func (this *CompactionJobPlan) EqualVT(that *CompactionJobPlan) bool

func (*CompactionJobPlan) GetCompactionLevel 

func (x *CompactionJobPlan) GetCompactionLevel() uint32

func (*CompactionJobPlan) GetName 

func (x *CompactionJobPlan) GetName() string

func (*CompactionJobPlan) GetShard 

func (x *CompactionJobPlan) GetShard() uint32

func (*CompactionJobPlan) GetSourceBlocks 

func (x *CompactionJobPlan) GetSourceBlocks() []string

func (*CompactionJobPlan) GetTenant 

func (x *CompactionJobPlan) GetTenant() string

func (*CompactionJobPlan) GetTombstones 

func (x *CompactionJobPlan) GetTombstones() []*v1.Tombstones

func (*CompactionJobPlan) MarshalToSizedBufferVT 

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

func (*CompactionJobPlan) MarshalToVT 

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

func (*CompactionJobPlan) MarshalVT 

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

func (*CompactionJobPlan) ProtoMessage 

func (*CompactionJobPlan) ProtoMessage()

func (*CompactionJobPlan) ProtoReflect 

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

func (*CompactionJobPlan) Reset 

func (x *CompactionJobPlan) Reset()

func (*CompactionJobPlan) SizeVT 

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

func (*CompactionJobPlan) String 

func (x *CompactionJobPlan) String() string

func (*CompactionJobPlan) UnmarshalVT 

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

type CompactionJobState 

type CompactionJobState struct {
	Name            string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CompactionLevel uint32                 `protobuf:"varint,2,opt,name=compaction_level,json=compactionLevel,proto3" json:"compaction_level,omitempty"`
	Status          v1.CompactionJobStatus `protobuf:"varint,3,opt,name=status,proto3,enum=metastore.v1.CompactionJobStatus" json:"status,omitempty"`
	Token           uint64                 `protobuf:"varint,4,opt,name=token,proto3" json:"token,omitempty"`
	LeaseExpiresAt  int64                  `protobuf:"varint,5,opt,name=lease_expires_at,json=leaseExpiresAt,proto3" json:"lease_expires_at,omitempty"`
	AddedAt         int64                  `protobuf:"varint,6,opt,name=added_at,json=addedAt,proto3" json:"added_at,omitempty"`
	Failures        uint32                 `protobuf:"varint,7,opt,name=failures,proto3" json:"failures,omitempty"`
	// contains filtered or unexported fields
}

CompactionJobState is produced in response to the compaction worker status update request.

Compaction level and other attributes that affect the scheduling order or status update handling should be included into the message.

func (*CompactionJobState) CloneMessageVT 

func (m *CompactionJobState) CloneMessageVT() proto.Message

func (*CompactionJobState) CloneVT 

func (m *CompactionJobState) CloneVT() *CompactionJobState

func (*CompactionJobState) Descriptor deprecated 

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

Deprecated: Use CompactionJobState.ProtoReflect.Descriptor instead.

func (*CompactionJobState) EqualMessageVT 

func (this *CompactionJobState) EqualMessageVT(thatMsg proto.Message) bool

func (*CompactionJobState) EqualVT 

func (this *CompactionJobState) EqualVT(that *CompactionJobState) bool

func (*CompactionJobState) GetAddedAt 

func (x *CompactionJobState) GetAddedAt() int64

func (*CompactionJobState) GetCompactionLevel 

func (x *CompactionJobState) GetCompactionLevel() uint32

func (*CompactionJobState) GetFailures 

func (x *CompactionJobState) GetFailures() uint32

func (*CompactionJobState) GetLeaseExpiresAt 

func (x *CompactionJobState) GetLeaseExpiresAt() int64

func (*CompactionJobState) GetName 

func (x *CompactionJobState) GetName() string

func (*CompactionJobState) GetStatus 

func (x *CompactionJobState) GetStatus() v1.CompactionJobStatus

func (*CompactionJobState) GetToken 

func (x *CompactionJobState) GetToken() uint64

func (*CompactionJobState) MarshalToSizedBufferVT 

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

func (*CompactionJobState) MarshalToVT 

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

func (*CompactionJobState) MarshalVT 

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

func (*CompactionJobState) ProtoMessage 

func (*CompactionJobState) ProtoMessage()

func (*CompactionJobState) ProtoReflect 

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

func (*CompactionJobState) Reset 

func (x *CompactionJobState) Reset()

func (*CompactionJobState) SizeVT 

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

func (*CompactionJobState) String 

func (x *CompactionJobState) String() string

func (*CompactionJobState) UnmarshalVT 

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

type CompactionJobStatusUpdate 

type CompactionJobStatusUpdate struct {
	Name   string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Token  uint64                 `protobuf:"varint,2,opt,name=token,proto3" json:"token,omitempty"`
	Status v1.CompactionJobStatus `protobuf:"varint,3,opt,name=status,proto3,enum=metastore.v1.CompactionJobStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionJobStatusUpdate) CloneMessageVT 

func (m *CompactionJobStatusUpdate) CloneMessageVT() proto.Message

func (*CompactionJobStatusUpdate) CloneVT 

func (m *CompactionJobStatusUpdate) CloneVT() *CompactionJobStatusUpdate

func (*CompactionJobStatusUpdate) Descriptor deprecated 

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

Deprecated: Use CompactionJobStatusUpdate.ProtoReflect.Descriptor instead.

func (*CompactionJobStatusUpdate) EqualMessageVT 

func (this *CompactionJobStatusUpdate) EqualMessageVT(thatMsg proto.Message) bool

func (*CompactionJobStatusUpdate) EqualVT 

func (this *CompactionJobStatusUpdate) EqualVT(that *CompactionJobStatusUpdate) bool

func (*CompactionJobStatusUpdate) GetName 

func (x *CompactionJobStatusUpdate) GetName() string

func (*CompactionJobStatusUpdate) GetStatus 

func (x *CompactionJobStatusUpdate) GetStatus() v1.CompactionJobStatus

func (*CompactionJobStatusUpdate) GetToken 

func (x *CompactionJobStatusUpdate) GetToken() uint64

func (*CompactionJobStatusUpdate) MarshalToSizedBufferVT 

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

func (*CompactionJobStatusUpdate) MarshalToVT 

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

func (*CompactionJobStatusUpdate) MarshalVT 

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

func (*CompactionJobStatusUpdate) ProtoMessage 

func (*CompactionJobStatusUpdate) ProtoMessage()

func (*CompactionJobStatusUpdate) ProtoReflect 

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

func (*CompactionJobStatusUpdate) Reset 

func (x *CompactionJobStatusUpdate) Reset()

func (*CompactionJobStatusUpdate) SizeVT 

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

func (*CompactionJobStatusUpdate) String 

func (x *CompactionJobStatusUpdate) String() string

func (*CompactionJobStatusUpdate) UnmarshalVT 

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

type CompactionPlanUpdate 

type CompactionPlanUpdate struct {
	NewJobs       []*NewCompactionJob       `protobuf:"bytes,1,rep,name=new_jobs,json=newJobs,proto3" json:"new_jobs,omitempty"`
	AssignedJobs  []*AssignedCompactionJob  `protobuf:"bytes,2,rep,name=assigned_jobs,json=assignedJobs,proto3" json:"assigned_jobs,omitempty"`
	UpdatedJobs   []*UpdatedCompactionJob   `protobuf:"bytes,3,rep,name=updated_jobs,json=updatedJobs,proto3" json:"updated_jobs,omitempty"`
	CompletedJobs []*CompletedCompactionJob `protobuf:"bytes,4,rep,name=completed_jobs,json=completedJobs,proto3" json:"completed_jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionPlanUpdate) CloneMessageVT 

func (m *CompactionPlanUpdate) CloneMessageVT() proto.Message

func (*CompactionPlanUpdate) CloneVT 

func (m *CompactionPlanUpdate) CloneVT() *CompactionPlanUpdate

func (*CompactionPlanUpdate) Descriptor deprecated 

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

Deprecated: Use CompactionPlanUpdate.ProtoReflect.Descriptor instead.

func (*CompactionPlanUpdate) EqualMessageVT 

func (this *CompactionPlanUpdate) EqualMessageVT(thatMsg proto.Message) bool

func (*CompactionPlanUpdate) EqualVT 

func (this *CompactionPlanUpdate) EqualVT(that *CompactionPlanUpdate) bool

func (*CompactionPlanUpdate) GetAssignedJobs 

func (x *CompactionPlanUpdate) GetAssignedJobs() []*AssignedCompactionJob

func (*CompactionPlanUpdate) GetCompletedJobs 

func (x *CompactionPlanUpdate) GetCompletedJobs() []*CompletedCompactionJob

func (*CompactionPlanUpdate) GetNewJobs 

func (x *CompactionPlanUpdate) GetNewJobs() []*NewCompactionJob

func (*CompactionPlanUpdate) GetUpdatedJobs 

func (x *CompactionPlanUpdate) GetUpdatedJobs() []*UpdatedCompactionJob

func (*CompactionPlanUpdate) MarshalToSizedBufferVT 

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

func (*CompactionPlanUpdate) MarshalToVT 

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

func (*CompactionPlanUpdate) MarshalVT 

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

func (*CompactionPlanUpdate) ProtoMessage 

func (*CompactionPlanUpdate) ProtoMessage()

func (*CompactionPlanUpdate) ProtoReflect 

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

func (*CompactionPlanUpdate) Reset 

func (x *CompactionPlanUpdate) Reset()

func (*CompactionPlanUpdate) SizeVT 

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

func (*CompactionPlanUpdate) String 

func (x *CompactionPlanUpdate) String() string

func (*CompactionPlanUpdate) UnmarshalVT 

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

type CompletedCompactionJob 

type CompletedCompactionJob struct {
	State           *CompactionJobState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	CompactedBlocks *v1.CompactedBlocks `protobuf:"bytes,2,opt,name=compacted_blocks,json=compactedBlocks,proto3" json:"compacted_blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*CompletedCompactionJob) CloneMessageVT 

func (m *CompletedCompactionJob) CloneMessageVT() proto.Message

func (*CompletedCompactionJob) CloneVT 

func (m *CompletedCompactionJob) CloneVT() *CompletedCompactionJob

func (*CompletedCompactionJob) Descriptor deprecated 

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

Deprecated: Use CompletedCompactionJob.ProtoReflect.Descriptor instead.

func (*CompletedCompactionJob) EqualMessageVT 

func (this *CompletedCompactionJob) EqualMessageVT(thatMsg proto.Message) bool

func (*CompletedCompactionJob) EqualVT 

func (this *CompletedCompactionJob) EqualVT(that *CompletedCompactionJob) bool

func (*CompletedCompactionJob) GetCompactedBlocks 

func (x *CompletedCompactionJob) GetCompactedBlocks() *v1.CompactedBlocks

func (*CompletedCompactionJob) GetState 

func (x *CompletedCompactionJob) GetState() *CompactionJobState

func (*CompletedCompactionJob) MarshalToSizedBufferVT 

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

func (*CompletedCompactionJob) MarshalToVT 

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

func (*CompletedCompactionJob) MarshalVT 

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

func (*CompletedCompactionJob) ProtoMessage 

func (*CompletedCompactionJob) ProtoMessage()

func (*CompletedCompactionJob) ProtoReflect 

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

func (*CompletedCompactionJob) Reset 

func (x *CompletedCompactionJob) Reset()

func (*CompletedCompactionJob) SizeVT 

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

func (*CompletedCompactionJob) String 

func (x *CompletedCompactionJob) String() string

func (*CompletedCompactionJob) UnmarshalVT 

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

type GetCompactionPlanUpdateRequest 

type GetCompactionPlanUpdateRequest struct {

	// CompactionJobStatusUpdate is a change
	// requested by the compaction worker.
	StatusUpdates []*CompactionJobStatusUpdate `protobuf:"bytes,1,rep,name=status_updates,json=statusUpdates,proto3" json:"status_updates,omitempty"`
	AssignJobsMax uint32                       `protobuf:"varint,2,opt,name=assign_jobs_max,json=assignJobsMax,proto3" json:"assign_jobs_max,omitempty"`
	// contains filtered or unexported fields
}

GetCompactionPlanUpdateRequest requests CompactionPlanUpdate. The resulting plan should be proposed to the raft members. This is a read-only operation: it MUST NOT alter the state.

func (*GetCompactionPlanUpdateRequest) CloneMessageVT 

func (m *GetCompactionPlanUpdateRequest) CloneMessageVT() proto.Message

func (*GetCompactionPlanUpdateRequest) CloneVT 

func (m *GetCompactionPlanUpdateRequest) CloneVT() *GetCompactionPlanUpdateRequest

func (*GetCompactionPlanUpdateRequest) Descriptor deprecated 

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

Deprecated: Use GetCompactionPlanUpdateRequest.ProtoReflect.Descriptor instead.

func (*GetCompactionPlanUpdateRequest) EqualMessageVT 

func (this *GetCompactionPlanUpdateRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*GetCompactionPlanUpdateRequest) EqualVT 

func (this *GetCompactionPlanUpdateRequest) EqualVT(that *GetCompactionPlanUpdateRequest) bool

func (*GetCompactionPlanUpdateRequest) GetAssignJobsMax 

func (x *GetCompactionPlanUpdateRequest) GetAssignJobsMax() uint32

func (*GetCompactionPlanUpdateRequest) GetStatusUpdates 

func (x *GetCompactionPlanUpdateRequest) GetStatusUpdates() []*CompactionJobStatusUpdate

func (*GetCompactionPlanUpdateRequest) MarshalToSizedBufferVT 

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

func (*GetCompactionPlanUpdateRequest) MarshalToVT 

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

func (*GetCompactionPlanUpdateRequest) MarshalVT 

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

func (*GetCompactionPlanUpdateRequest) ProtoMessage 

func (*GetCompactionPlanUpdateRequest) ProtoMessage()

func (*GetCompactionPlanUpdateRequest) ProtoReflect 

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

func (*GetCompactionPlanUpdateRequest) Reset 

func (x *GetCompactionPlanUpdateRequest) Reset()

func (*GetCompactionPlanUpdateRequest) SizeVT 

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

func (*GetCompactionPlanUpdateRequest) String 

func (x *GetCompactionPlanUpdateRequest) String() string

func (*GetCompactionPlanUpdateRequest) UnmarshalVT 

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

type GetCompactionPlanUpdateResponse 

type GetCompactionPlanUpdateResponse struct {
	Term       uint64                `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	PlanUpdate *CompactionPlanUpdate `protobuf:"bytes,2,opt,name=plan_update,json=planUpdate,proto3" json:"plan_update,omitempty"`
	// contains filtered or unexported fields
}

GetCompactionPlanUpdateResponse includes the planned change. The plan should be proposed to the raft members.

func (*GetCompactionPlanUpdateResponse) CloneMessageVT 

func (m *GetCompactionPlanUpdateResponse) CloneMessageVT() proto.Message

func (*GetCompactionPlanUpdateResponse) CloneVT 

func (m *GetCompactionPlanUpdateResponse) CloneVT() *GetCompactionPlanUpdateResponse

func (*GetCompactionPlanUpdateResponse) Descriptor deprecated 

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

Deprecated: Use GetCompactionPlanUpdateResponse.ProtoReflect.Descriptor instead.

func (*GetCompactionPlanUpdateResponse) EqualMessageVT 

func (this *GetCompactionPlanUpdateResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*GetCompactionPlanUpdateResponse) EqualVT 

func (this *GetCompactionPlanUpdateResponse) EqualVT(that *GetCompactionPlanUpdateResponse) bool

func (*GetCompactionPlanUpdateResponse) GetPlanUpdate 

func (x *GetCompactionPlanUpdateResponse) GetPlanUpdate() *CompactionPlanUpdate

func (*GetCompactionPlanUpdateResponse) GetTerm 

func (x *GetCompactionPlanUpdateResponse) GetTerm() uint64

func (*GetCompactionPlanUpdateResponse) MarshalToSizedBufferVT 

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

func (*GetCompactionPlanUpdateResponse) MarshalToVT 

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

func (*GetCompactionPlanUpdateResponse) MarshalVT 

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

func (*GetCompactionPlanUpdateResponse) ProtoMessage 

func (*GetCompactionPlanUpdateResponse) ProtoMessage()

func (*GetCompactionPlanUpdateResponse) ProtoReflect 

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

func (*GetCompactionPlanUpdateResponse) Reset 

func (x *GetCompactionPlanUpdateResponse) Reset()

func (*GetCompactionPlanUpdateResponse) SizeVT 

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

func (*GetCompactionPlanUpdateResponse) String 

func (x *GetCompactionPlanUpdateResponse) String() string

func (*GetCompactionPlanUpdateResponse) UnmarshalVT 

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

type NewCompactionJob 

type NewCompactionJob struct {
	State *CompactionJobState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Plan  *CompactionJobPlan  `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	// contains filtered or unexported fields
}

func (*NewCompactionJob) CloneMessageVT 

func (m *NewCompactionJob) CloneMessageVT() proto.Message

func (*NewCompactionJob) CloneVT 

func (m *NewCompactionJob) CloneVT() *NewCompactionJob

func (*NewCompactionJob) Descriptor deprecated 

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

Deprecated: Use NewCompactionJob.ProtoReflect.Descriptor instead.

func (*NewCompactionJob) EqualMessageVT 

func (this *NewCompactionJob) EqualMessageVT(thatMsg proto.Message) bool

func (*NewCompactionJob) EqualVT 

func (this *NewCompactionJob) EqualVT(that *NewCompactionJob) bool

func (*NewCompactionJob) GetPlan 

func (x *NewCompactionJob) GetPlan() *CompactionJobPlan

func (*NewCompactionJob) GetState 

func (x *NewCompactionJob) GetState() *CompactionJobState

func (*NewCompactionJob) MarshalToSizedBufferVT 

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

func (*NewCompactionJob) MarshalToVT 

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

func (*NewCompactionJob) MarshalVT 

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

func (*NewCompactionJob) ProtoMessage 

func (*NewCompactionJob) ProtoMessage()

func (*NewCompactionJob) ProtoReflect 

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

func (*NewCompactionJob) Reset 

func (x *NewCompactionJob) Reset()

func (*NewCompactionJob) SizeVT 

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

func (*NewCompactionJob) String 

func (x *NewCompactionJob) String() string

func (*NewCompactionJob) UnmarshalVT 

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

type RaftCommand 

type RaftCommand int32
const (
	RaftCommand_RAFT_COMMAND_UNKNOWN                    RaftCommand = 0
	RaftCommand_RAFT_COMMAND_ADD_BLOCK_METADATA         RaftCommand = 1
	RaftCommand_RAFT_COMMAND_GET_COMPACTION_PLAN_UPDATE RaftCommand = 2
	RaftCommand_RAFT_COMMAND_UPDATE_COMPACTION_PLAN     RaftCommand = 3
)

func (RaftCommand) Descriptor 

func (RaftCommand) Descriptor() protoreflect.EnumDescriptor

func (RaftCommand) Enum 

func (x RaftCommand) Enum() *RaftCommand

func (RaftCommand) EnumDescriptor deprecated 

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

Deprecated: Use RaftCommand.Descriptor instead.

func (RaftCommand) Number 

func (x RaftCommand) Number() protoreflect.EnumNumber

func (RaftCommand) String 

func (x RaftCommand) String() string

func (RaftCommand) Type 

func (RaftCommand) Type() protoreflect.EnumType

type UpdateCompactionPlanRequest 

type UpdateCompactionPlanRequest struct {
	Term       uint64                `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	PlanUpdate *CompactionPlanUpdate `protobuf:"bytes,2,opt,name=plan_update,json=planUpdate,proto3" json:"plan_update,omitempty"`
	// contains filtered or unexported fields
}

UpdateCompactionPlanRequest proposes compaction plan changes.

func (*UpdateCompactionPlanRequest) CloneMessageVT 

func (m *UpdateCompactionPlanRequest) CloneMessageVT() proto.Message

func (*UpdateCompactionPlanRequest) CloneVT 

func (m *UpdateCompactionPlanRequest) CloneVT() *UpdateCompactionPlanRequest

func (*UpdateCompactionPlanRequest) Descriptor deprecated 

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

Deprecated: Use UpdateCompactionPlanRequest.ProtoReflect.Descriptor instead.

func (*UpdateCompactionPlanRequest) EqualMessageVT 

func (this *UpdateCompactionPlanRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*UpdateCompactionPlanRequest) EqualVT 

func (this *UpdateCompactionPlanRequest) EqualVT(that *UpdateCompactionPlanRequest) bool

func (*UpdateCompactionPlanRequest) GetPlanUpdate 

func (x *UpdateCompactionPlanRequest) GetPlanUpdate() *CompactionPlanUpdate

func (*UpdateCompactionPlanRequest) GetTerm 

func (x *UpdateCompactionPlanRequest) GetTerm() uint64

func (*UpdateCompactionPlanRequest) MarshalToSizedBufferVT 

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

func (*UpdateCompactionPlanRequest) MarshalToVT 

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

func (*UpdateCompactionPlanRequest) MarshalVT 

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

func (*UpdateCompactionPlanRequest) ProtoMessage 

func (*UpdateCompactionPlanRequest) ProtoMessage()

func (*UpdateCompactionPlanRequest) ProtoReflect 

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

func (*UpdateCompactionPlanRequest) Reset 

func (x *UpdateCompactionPlanRequest) Reset()

func (*UpdateCompactionPlanRequest) SizeVT 

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

func (*UpdateCompactionPlanRequest) String 

func (x *UpdateCompactionPlanRequest) String() string

func (*UpdateCompactionPlanRequest) UnmarshalVT 

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

type UpdateCompactionPlanResponse 

type UpdateCompactionPlanResponse struct {
	PlanUpdate *CompactionPlanUpdate `protobuf:"bytes,1,opt,name=plan_update,json=planUpdate,proto3" json:"plan_update,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateCompactionPlanResponse) CloneMessageVT 

func (m *UpdateCompactionPlanResponse) CloneMessageVT() proto.Message

func (*UpdateCompactionPlanResponse) CloneVT 

func (m *UpdateCompactionPlanResponse) CloneVT() *UpdateCompactionPlanResponse

func (*UpdateCompactionPlanResponse) Descriptor deprecated 

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

Deprecated: Use UpdateCompactionPlanResponse.ProtoReflect.Descriptor instead.

func (*UpdateCompactionPlanResponse) EqualMessageVT 

func (this *UpdateCompactionPlanResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*UpdateCompactionPlanResponse) EqualVT 

func (this *UpdateCompactionPlanResponse) EqualVT(that *UpdateCompactionPlanResponse) bool

func (*UpdateCompactionPlanResponse) GetPlanUpdate 

func (x *UpdateCompactionPlanResponse) GetPlanUpdate() *CompactionPlanUpdate

func (*UpdateCompactionPlanResponse) MarshalToSizedBufferVT 

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

func (*UpdateCompactionPlanResponse) MarshalToVT 

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

func (*UpdateCompactionPlanResponse) MarshalVT 

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

func (*UpdateCompactionPlanResponse) ProtoMessage 

func (*UpdateCompactionPlanResponse) ProtoMessage()

func (*UpdateCompactionPlanResponse) ProtoReflect 

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

func (*UpdateCompactionPlanResponse) Reset 

func (x *UpdateCompactionPlanResponse) Reset()

func (*UpdateCompactionPlanResponse) SizeVT 

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

func (*UpdateCompactionPlanResponse) String 

func (x *UpdateCompactionPlanResponse) String() string

func (*UpdateCompactionPlanResponse) UnmarshalVT 

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

type UpdatedCompactionJob 

type UpdatedCompactionJob struct {
	State *CompactionJobState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdatedCompactionJob) CloneMessageVT 

func (m *UpdatedCompactionJob) CloneMessageVT() proto.Message

func (*UpdatedCompactionJob) CloneVT 

func (m *UpdatedCompactionJob) CloneVT() *UpdatedCompactionJob

func (*UpdatedCompactionJob) Descriptor deprecated 

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

Deprecated: Use UpdatedCompactionJob.ProtoReflect.Descriptor instead.

func (*UpdatedCompactionJob) EqualMessageVT 

func (this *UpdatedCompactionJob) EqualMessageVT(thatMsg proto.Message) bool

func (*UpdatedCompactionJob) EqualVT 

func (this *UpdatedCompactionJob) EqualVT(that *UpdatedCompactionJob) bool

func (*UpdatedCompactionJob) GetState 

func (x *UpdatedCompactionJob) GetState() *CompactionJobState

func (*UpdatedCompactionJob) MarshalToSizedBufferVT 

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

func (*UpdatedCompactionJob) MarshalToVT 

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

func (*UpdatedCompactionJob) MarshalVT 

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

func (*UpdatedCompactionJob) ProtoMessage 

func (*UpdatedCompactionJob) ProtoMessage()

func (*UpdatedCompactionJob) ProtoReflect 

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

func (*UpdatedCompactionJob) Reset 

func (x *UpdatedCompactionJob) Reset()

func (*UpdatedCompactionJob) SizeVT 

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

func (*UpdatedCompactionJob) String 

func (x *UpdatedCompactionJob) String() string

func (*UpdatedCompactionJob) UnmarshalVT 

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

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.