raftlogpb

Documentation

Index

• Variables
• type CommandType
  • func (CommandType) EnumDescriptor() ([]byte, []int)
  • func (x CommandType) String() string
• type RaftLogEntry
  • func (*RaftLogEntry) Descriptor() ([]byte, []int)
  • func (this *RaftLogEntry) Equal(that interface{}) bool
  • func (m *RaftLogEntry) GetPayload() []byte
  • func (m *RaftLogEntry) GetType() CommandType
  • func (this *RaftLogEntry) GoString() string
  • func (m *RaftLogEntry) Marshal() (dAtA []byte, err error)
  • func (m *RaftLogEntry) MarshalTo(dAtA []byte) (int, error)
  • func (m *RaftLogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RaftLogEntry) ProtoMessage()
  • func (m *RaftLogEntry) Reset()
  • func (m *RaftLogEntry) Size() (n int)
  • func (this *RaftLogEntry) String() string
  • func (m *RaftLogEntry) Unmarshal(dAtA []byte) error
  • func (m *RaftLogEntry) XXX_DiscardUnknown()
  • func (m *RaftLogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RaftLogEntry) XXX_Merge(src proto.Message)
  • func (m *RaftLogEntry) XXX_Size() int
  • func (m *RaftLogEntry) XXX_Unmarshal(b []byte) error
• type TruncateCommand
  • func (*TruncateCommand) Descriptor() ([]byte, []int)
  • func (this *TruncateCommand) Equal(that interface{}) bool
  • func (m *TruncateCommand) GetTimestamp() uint64
  • func (this *TruncateCommand) GoString() string
  • func (m *TruncateCommand) Marshal() (dAtA []byte, err error)
  • func (m *TruncateCommand) MarshalTo(dAtA []byte) (int, error)
  • func (m *TruncateCommand) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TruncateCommand) ProtoMessage()
  • func (m *TruncateCommand) Reset()
  • func (m *TruncateCommand) Size() (n int)
  • func (this *TruncateCommand) String() string
  • func (m *TruncateCommand) Unmarshal(dAtA []byte) error
  • func (m *TruncateCommand) XXX_DiscardUnknown()
  • func (m *TruncateCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TruncateCommand) XXX_Merge(src proto.Message)
  • func (m *TruncateCommand) XXX_Size() int
  • func (m *TruncateCommand) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthRaflog = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaflog   = fmt.Errorf("proto: integer overflow")
)

var CommandType_name = map[int32]string{
	0:    "COMMAND_TYPE_UNKNOWN",
	1:    "COMMAND_TYPE_ADD_BLOCK",
	4196: "COMMAND_TYPE_TRUNCATE",
}

var CommandType_value = map[string]int32{
	"COMMAND_TYPE_UNKNOWN":   0,
	"COMMAND_TYPE_ADD_BLOCK": 1,
	"COMMAND_TYPE_TRUNCATE":  4196,
}

Types

type CommandType

type CommandType int32

const (
	COMMAND_TYPE_UNKNOWN   CommandType = 0
	COMMAND_TYPE_ADD_BLOCK CommandType = 1
	// This is a temporary solution.
	COMMAND_TYPE_TRUNCATE CommandType = 4196
)

func (CommandType) EnumDescriptor

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

func (CommandType) String

func (x CommandType) String() string

type RaftLogEntry

type RaftLogEntry struct {
	Type    CommandType `protobuf:"varint,1,opt,name=type,proto3,enum=raftlogpb.CommandType" json:"type,omitempty"`
	Payload []byte      `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*RaftLogEntry) Descriptor

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

func (*RaftLogEntry) Equal

func (this *RaftLogEntry) Equal(that interface{}) bool

func (*RaftLogEntry) GetPayload

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

func (*RaftLogEntry) GetType

func (m *RaftLogEntry) GetType() CommandType

func (*RaftLogEntry) GoString

func (this *RaftLogEntry) GoString() string

func (*RaftLogEntry) Marshal

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

func (*RaftLogEntry) MarshalTo

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

func (*RaftLogEntry) MarshalToSizedBuffer

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

func (*RaftLogEntry) ProtoMessage

func (*RaftLogEntry) ProtoMessage()

func (*RaftLogEntry) Reset

func (m *RaftLogEntry) Reset()

func (*RaftLogEntry) Size

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

func (*RaftLogEntry) String

func (this *RaftLogEntry) String() string

func (*RaftLogEntry) Unmarshal

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

func (*RaftLogEntry) XXX_DiscardUnknown

func (m *RaftLogEntry) XXX_DiscardUnknown()

func (*RaftLogEntry) XXX_Marshal

func (m *RaftLogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RaftLogEntry) XXX_Merge

func (m *RaftLogEntry) XXX_Merge(src proto.Message)

func (*RaftLogEntry) XXX_Size

func (m *RaftLogEntry) XXX_Size() int

func (*RaftLogEntry) XXX_Unmarshal

func (m *RaftLogEntry) XXX_Unmarshal(b []byte) error

type TruncateCommand

type TruncateCommand struct {
	Timestamp uint64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*TruncateCommand) Descriptor

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

func (*TruncateCommand) Equal

func (this *TruncateCommand) Equal(that interface{}) bool

func (*TruncateCommand) GetTimestamp

func (m *TruncateCommand) GetTimestamp() uint64

func (*TruncateCommand) GoString

func (this *TruncateCommand) GoString() string

func (*TruncateCommand) Marshal

func (m *TruncateCommand) Marshal() (dAtA []byte, err error)

func (*TruncateCommand) MarshalTo

func (m *TruncateCommand) MarshalTo(dAtA []byte) (int, error)

func (*TruncateCommand) MarshalToSizedBuffer

func (m *TruncateCommand) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TruncateCommand) ProtoMessage

func (*TruncateCommand) ProtoMessage()

func (*TruncateCommand) Reset

func (m *TruncateCommand) Reset()

func (*TruncateCommand) Size

func (m *TruncateCommand) Size() (n int)

func (*TruncateCommand) String

func (this *TruncateCommand) String() string

func (*TruncateCommand) Unmarshal

func (m *TruncateCommand) Unmarshal(dAtA []byte) error

func (*TruncateCommand) XXX_DiscardUnknown

func (m *TruncateCommand) XXX_DiscardUnknown()

func (*TruncateCommand) XXX_Marshal

func (m *TruncateCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TruncateCommand) XXX_Merge

func (m *TruncateCommand) XXX_Merge(src proto.Message)

func (*TruncateCommand) XXX_Size

func (m *TruncateCommand) XXX_Size() int

func (*TruncateCommand) XXX_Unmarshal

func (m *TruncateCommand) XXX_Unmarshal(b []byte) error