raftlogpb

Documentation

Index

• Variables
• type CleanBlocksRequest
  • func (*CleanBlocksRequest) Descriptor() ([]byte, []int)
  • func (x *CleanBlocksRequest) GetRequestId() string
  • func (m *CleanBlocksRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *CleanBlocksRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *CleanBlocksRequest) MarshalVT() (dAtA []byte, err error)
  • func (*CleanBlocksRequest) ProtoMessage()
  • func (x *CleanBlocksRequest) ProtoReflect() protoreflect.Message
  • func (x *CleanBlocksRequest) Reset()
  • func (m *CleanBlocksRequest) SizeVT() (n int)
  • func (x *CleanBlocksRequest) String() string
  • func (m *CleanBlocksRequest) UnmarshalVT(dAtA []byte) error
• type CommandType
  • func (CommandType) Descriptor() protoreflect.EnumDescriptor
  • func (x CommandType) Enum() *CommandType
  • func (CommandType) EnumDescriptor() ([]byte, []int)
  • func (x CommandType) Number() protoreflect.EnumNumber
  • func (x CommandType) String() string
  • func (CommandType) Type() protoreflect.EnumType
• type RaftLogEntry
  • func (*RaftLogEntry) Descriptor() ([]byte, []int)
  • func (x *RaftLogEntry) GetPayload() []byte
  • func (x *RaftLogEntry) GetType() CommandType
  • func (m *RaftLogEntry) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *RaftLogEntry) MarshalToVT(dAtA []byte) (int, error)
  • func (m *RaftLogEntry) MarshalVT() (dAtA []byte, err error)
  • func (*RaftLogEntry) ProtoMessage()
  • func (x *RaftLogEntry) ProtoReflect() protoreflect.Message
  • func (x *RaftLogEntry) Reset()
  • func (m *RaftLogEntry) SizeVT() (n int)
  • func (x *RaftLogEntry) String() string
  • func (m *RaftLogEntry) UnmarshalVT(dAtA []byte) error

Variables

var (
	CommandType_name = map[int32]string{
		0: "COMMAND_TYPE_UNKNOWN",
		1: "COMMAND_TYPE_ADD_BLOCK",
		2: "COMMAND_TYPE_POLL_COMPACTION_JOBS_STATUS",
		3: "COMMAND_TYPE_CLEAN_BLOCKS",
	}
	CommandType_value = map[string]int32{
		"COMMAND_TYPE_UNKNOWN":                     0,
		"COMMAND_TYPE_ADD_BLOCK":                   1,
		"COMMAND_TYPE_POLL_COMPACTION_JOBS_STATUS": 2,
		"COMMAND_TYPE_CLEAN_BLOCKS":                3,
	}
)

Enum value maps for CommandType.

var File_experiment_metastore_raftlogpb_raflog_proto protoreflect.FileDescriptor

Types

type CleanBlocksRequest

type CleanBlocksRequest struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CleanBlocksRequest) Descriptor

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

Deprecated: Use CleanBlocksRequest.ProtoReflect.Descriptor instead.

func (*CleanBlocksRequest) GetRequestId

func (x *CleanBlocksRequest) GetRequestId() string

func (*CleanBlocksRequest) MarshalToSizedBufferVT

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

func (*CleanBlocksRequest) MarshalToVT

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

func (*CleanBlocksRequest) MarshalVT

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

func (*CleanBlocksRequest) ProtoMessage

func (*CleanBlocksRequest) ProtoMessage()

func (*CleanBlocksRequest) ProtoReflect

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

func (*CleanBlocksRequest) Reset

func (x *CleanBlocksRequest) Reset()

func (*CleanBlocksRequest) SizeVT

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

func (*CleanBlocksRequest) String

func (x *CleanBlocksRequest) String() string

func (*CleanBlocksRequest) UnmarshalVT

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

type CommandType

type CommandType int32

const (
	CommandType_COMMAND_TYPE_UNKNOWN                     CommandType = 0
	CommandType_COMMAND_TYPE_ADD_BLOCK                   CommandType = 1
	CommandType_COMMAND_TYPE_POLL_COMPACTION_JOBS_STATUS CommandType = 2
	CommandType_COMMAND_TYPE_CLEAN_BLOCKS                CommandType = 3
)

func (CommandType) Descriptor

func (CommandType) Descriptor() protoreflect.EnumDescriptor

func (CommandType) Enum

func (x CommandType) Enum() *CommandType

func (CommandType) EnumDescriptor

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

Deprecated: Use CommandType.Descriptor instead.

func (CommandType) Number

func (x CommandType) Number() protoreflect.EnumNumber

func (CommandType) String

func (x CommandType) String() string

func (CommandType) Type

func (CommandType) Type() protoreflect.EnumType

type RaftLogEntry

type RaftLogEntry struct {
	Type    CommandType `protobuf:"varint,1,opt,name=type,proto3,enum=raft_log.CommandType" json:"type,omitempty"`
	Payload []byte      `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftLogEntry) Descriptor

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

Deprecated: Use RaftLogEntry.ProtoReflect.Descriptor instead.

func (*RaftLogEntry) GetPayload

func (x *RaftLogEntry) GetPayload() []byte

func (*RaftLogEntry) GetType

func (x *RaftLogEntry) GetType() CommandType

func (*RaftLogEntry) MarshalToSizedBufferVT

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

func (*RaftLogEntry) MarshalToVT

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

func (*RaftLogEntry) MarshalVT

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

func (*RaftLogEntry) ProtoMessage

func (*RaftLogEntry) ProtoMessage()

func (*RaftLogEntry) ProtoReflect

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

func (*RaftLogEntry) Reset

func (x *RaftLogEntry) Reset()

func (*RaftLogEntry) SizeVT

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

func (*RaftLogEntry) String

func (x *RaftLogEntry) String() string

func (*RaftLogEntry) UnmarshalVT

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