raft

Documentation

Index

• Variables
• type LogData
  • func (*LogData) Descriptor() ([]byte, []int)
  • func (m *LogData) GetOperations() []*LogOperation
  • func (m *LogData) Marshal() (dAtA []byte, err error)
  • func (m *LogData) MarshalTo(dAtA []byte) (int, error)
  • func (m *LogData) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*LogData) ProtoMessage()
  • func (m *LogData) Reset()
  • func (m *LogData) Size() (n int)
  • func (m *LogData) String() string
  • func (m *LogData) Unmarshal(dAtA []byte) error
  • func (m *LogData) XXX_DiscardUnknown()
  • func (m *LogData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *LogData) XXX_Merge(src proto.Message)
  • func (m *LogData) XXX_Size() int
  • func (m *LogData) XXX_Unmarshal(b []byte) error
• type LogOperation
  • func (*LogOperation) Descriptor() ([]byte, []int)
  • func (m *LogOperation) GetArgs() [][]byte
  • func (m *LogOperation) GetKey() []byte
  • func (m *LogOperation) GetOpType() uint32
  • func (m *LogOperation) GetTab() []byte
  • func (m *LogOperation) GetVal() []byte
  • func (m *LogOperation) Marshal() (dAtA []byte, err error)
  • func (m *LogOperation) MarshalTo(dAtA []byte) (int, error)
  • func (m *LogOperation) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*LogOperation) ProtoMessage()
  • func (m *LogOperation) Reset()
  • func (m *LogOperation) Size() (n int)
  • func (m *LogOperation) String() string
  • func (m *LogOperation) Unmarshal(dAtA []byte) error
  • func (m *LogOperation) XXX_DiscardUnknown()
  • func (m *LogOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *LogOperation) XXX_Merge(src proto.Message)
  • func (m *LogOperation) XXX_Size() int
  • func (m *LogOperation) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)

Types

type LogData

type LogData struct {
	Operations           []*LogOperation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*LogData) Descriptor

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

func (*LogData) GetOperations

func (m *LogData) GetOperations() []*LogOperation

func (*LogData) Marshal

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

func (*LogData) MarshalTo

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

func (*LogData) MarshalToSizedBuffer

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

func (*LogData) ProtoMessage

func (*LogData) ProtoMessage()

func (*LogData) Reset

func (m *LogData) Reset()

func (*LogData) Size

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

func (*LogData) String

func (m *LogData) String() string

func (*LogData) Unmarshal

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

func (*LogData) XXX_DiscardUnknown

func (m *LogData) XXX_DiscardUnknown()

func (*LogData) XXX_Marshal

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

func (*LogData) XXX_Merge

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

func (*LogData) XXX_Size

func (m *LogData) XXX_Size() int

func (*LogData) XXX_Unmarshal

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

type LogOperation

type LogOperation struct {
	// OpType is the Operation type
	OpType uint32 `protobuf:"varint,1,opt,name=op_type,json=opType,proto3" json:"op_type,omitempty"`
	// table | func name
	Tab []byte `protobuf:"bytes,2,opt,name=tab,proto3" json:"tab,omitempty"`
	// Key that is being affected | func args
	Key []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Value corresponds to the key for get op_type
	Val []byte `protobuf:"bytes,4,opt,name=val,proto3" json:"val,omitempty"`
	// Addition arguments, used for Apply
	Args                 [][]byte `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogOperation) Descriptor

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

func (*LogOperation) GetArgs

func (m *LogOperation) GetArgs() [][]byte

func (*LogOperation) GetKey

func (m *LogOperation) GetKey() []byte

func (*LogOperation) GetOpType

func (m *LogOperation) GetOpType() uint32

func (*LogOperation) GetTab

func (m *LogOperation) GetTab() []byte

func (*LogOperation) GetVal

func (m *LogOperation) GetVal() []byte

func (*LogOperation) Marshal

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

func (*LogOperation) MarshalTo

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

func (*LogOperation) MarshalToSizedBuffer

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

func (*LogOperation) ProtoMessage

func (*LogOperation) ProtoMessage()

func (*LogOperation) Reset

func (m *LogOperation) Reset()

func (*LogOperation) Size

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

func (*LogOperation) String

func (m *LogOperation) String() string

func (*LogOperation) Unmarshal

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

func (*LogOperation) XXX_DiscardUnknown

func (m *LogOperation) XXX_DiscardUnknown()

func (*LogOperation) XXX_Marshal

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

func (*LogOperation) XXX_Merge

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

func (*LogOperation) XXX_Size

func (m *LogOperation) XXX_Size() int

func (*LogOperation) XXX_Unmarshal

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