journal_entry

package
Version: v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Jul 16, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	State_name = map[int32]string{
		0: "PRESENT",
		1: "ABSENT",
	}
	State_value = map[string]int32{
		"PRESENT": 0,
		"ABSENT":  1,
	}
)

Enum value maps for State.

View Source
var File_entry_proto protoreflect.FileDescriptor

Functions

func ToMgrEntry

func ToMgrEntry(mentry *mgr_entry.MapEntry, e *FileMapEntry)

func ToSheetCell

func ToSheetCell(scell *sheetfile.Cell, e *CellEntry)

func ToSheetChunk

func ToSheetChunk(schunk *sheetfile.Chunk, e *ChunkEntry)

Types

type CellEntry

type CellEntry struct {
	TargetState State  `protobuf:"varint,1,opt,name=target_state,json=targetState,proto3,enum=common_journal.State" json:"target_state,omitempty"`
	CellId      int64  `protobuf:"varint,2,opt,name=cell_id,json=cellId,proto3" json:"cell_id,omitempty"`
	Offset      uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Size        uint64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	ChunkId     uint64 `protobuf:"varint,5,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"`
	SheetName   string `protobuf:"bytes,6,opt,name=sheet_name,json=sheetName,proto3" json:"sheet_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CellEntry) Descriptor deprecated

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

Deprecated: Use CellEntry.ProtoReflect.Descriptor instead.

func (*CellEntry) GetCellId

func (x *CellEntry) GetCellId() int64

func (*CellEntry) GetChunkId

func (x *CellEntry) GetChunkId() uint64

func (*CellEntry) GetOffset

func (x *CellEntry) GetOffset() uint64

func (*CellEntry) GetSheetName

func (x *CellEntry) GetSheetName() string

func (*CellEntry) GetSize

func (x *CellEntry) GetSize() uint64

func (*CellEntry) GetTargetState

func (x *CellEntry) GetTargetState() State

func (*CellEntry) ProtoMessage

func (*CellEntry) ProtoMessage()

func (*CellEntry) ProtoReflect

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

func (*CellEntry) Reset

func (x *CellEntry) Reset()

func (*CellEntry) String

func (x *CellEntry) String() string

type ChunkEntry

type ChunkEntry struct {
	TargetState State  `protobuf:"varint,1,opt,name=target_state,json=targetState,proto3,enum=common_journal.State" json:"target_state,omitempty"`
	Id          uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Version     uint64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	Datanode    string `protobuf:"bytes,4,opt,name=datanode,proto3" json:"datanode,omitempty"`
	// contains filtered or unexported fields
}

func (*ChunkEntry) Descriptor deprecated

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

Deprecated: Use ChunkEntry.ProtoReflect.Descriptor instead.

func (*ChunkEntry) GetDatanode

func (x *ChunkEntry) GetDatanode() string

func (*ChunkEntry) GetId

func (x *ChunkEntry) GetId() uint64

func (*ChunkEntry) GetTargetState

func (x *ChunkEntry) GetTargetState() State

func (*ChunkEntry) GetVersion

func (x *ChunkEntry) GetVersion() uint64

func (*ChunkEntry) ProtoMessage

func (*ChunkEntry) ProtoMessage()

func (*ChunkEntry) ProtoReflect

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

func (*ChunkEntry) Reset

func (x *ChunkEntry) Reset()

func (*ChunkEntry) String

func (x *ChunkEntry) String() string

type Empty

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

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type FileMapEntry

type FileMapEntry struct {
	TargetState       State  `protobuf:"varint,1,opt,name=target_state,json=targetState,proto3,enum=common_journal.State" json:"target_state,omitempty"`
	Filename          string `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`
	CellsTableName    string `protobuf:"bytes,3,opt,name=cells_table_name,json=cellsTableName,proto3" json:"cells_table_name,omitempty"`
	Recycled          bool   `protobuf:"varint,4,opt,name=recycled,proto3" json:"recycled,omitempty"`
	RecycledTimestamp int64  `protobuf:"varint,5,opt,name=recycled_timestamp,json=recycledTimestamp,proto3" json:"recycled_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*FileMapEntry) Descriptor deprecated

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

Deprecated: Use FileMapEntry.ProtoReflect.Descriptor instead.

func (*FileMapEntry) GetCellsTableName

func (x *FileMapEntry) GetCellsTableName() string

func (*FileMapEntry) GetFilename

func (x *FileMapEntry) GetFilename() string

func (*FileMapEntry) GetRecycled

func (x *FileMapEntry) GetRecycled() bool

func (*FileMapEntry) GetRecycledTimestamp

func (x *FileMapEntry) GetRecycledTimestamp() int64

func (*FileMapEntry) GetTargetState

func (x *FileMapEntry) GetTargetState() State

func (*FileMapEntry) ProtoMessage

func (*FileMapEntry) ProtoMessage()

func (*FileMapEntry) ProtoReflect

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

func (*FileMapEntry) Reset

func (x *FileMapEntry) Reset()

func (*FileMapEntry) String

func (x *FileMapEntry) String() string

type InvalidJournalEntryError

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

func NewInvalidJournalEntryError

func NewInvalidJournalEntryError(entry *MasterEntry) *InvalidJournalEntryError

func (*InvalidJournalEntryError) Error

func (i *InvalidJournalEntryError) Error() string

type MasterEntry

type MasterEntry struct {

	// Types that are assignable to XCell:
	//	*MasterEntry_E1
	//	*MasterEntry_Cell
	XCell isMasterEntry_XCell `protobuf_oneof:"_Cell"`
	// Types that are assignable to XChunk:
	//	*MasterEntry_E2
	//	*MasterEntry_Chunk
	XChunk isMasterEntry_XChunk `protobuf_oneof:"_Chunk"`
	// Types that are assignable to XFileMap:
	//	*MasterEntry_E3
	//	*MasterEntry_MapEntry
	XFileMap isMasterEntry_XFileMap `protobuf_oneof:"_FileMap"`
	// contains filtered or unexported fields
}

func (*MasterEntry) Descriptor deprecated

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

Deprecated: Use MasterEntry.ProtoReflect.Descriptor instead.

func (*MasterEntry) GetCell

func (x *MasterEntry) GetCell() *CellEntry

func (*MasterEntry) GetChunk

func (x *MasterEntry) GetChunk() *ChunkEntry

func (*MasterEntry) GetE1

func (x *MasterEntry) GetE1() *Empty

func (*MasterEntry) GetE2

func (x *MasterEntry) GetE2() *Empty

func (*MasterEntry) GetE3

func (x *MasterEntry) GetE3() *Empty

func (*MasterEntry) GetMapEntry

func (x *MasterEntry) GetMapEntry() *FileMapEntry

func (*MasterEntry) GetXCell

func (m *MasterEntry) GetXCell() isMasterEntry_XCell

func (*MasterEntry) GetXChunk

func (m *MasterEntry) GetXChunk() isMasterEntry_XChunk

func (*MasterEntry) GetXFileMap

func (m *MasterEntry) GetXFileMap() isMasterEntry_XFileMap

func (*MasterEntry) ProtoMessage

func (*MasterEntry) ProtoMessage()

func (*MasterEntry) ProtoReflect

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

func (*MasterEntry) Reset

func (x *MasterEntry) Reset()

func (*MasterEntry) String

func (x *MasterEntry) String() string

type MasterEntry_Cell

type MasterEntry_Cell struct {
	Cell *CellEntry `protobuf:"bytes,2,opt,name=cell,proto3,oneof"`
}

func FromSheetCell

func FromSheetCell(c *sheetfile.Cell) *MasterEntry_Cell

type MasterEntry_Chunk

type MasterEntry_Chunk struct {
	Chunk *ChunkEntry `protobuf:"bytes,4,opt,name=chunk,proto3,oneof"`
}

func FromSheetChunk

func FromSheetChunk(c *sheetfile.Chunk) *MasterEntry_Chunk

type MasterEntry_E1

type MasterEntry_E1 struct {
	E1 *Empty `protobuf:"bytes,1,opt,name=e1,proto3,oneof"`
}

func FromEmptySheetCell

func FromEmptySheetCell() *MasterEntry_E1

type MasterEntry_E2

type MasterEntry_E2 struct {
	E2 *Empty `protobuf:"bytes,3,opt,name=e2,proto3,oneof"`
}

func FromEmptyChunk

func FromEmptyChunk() *MasterEntry_E2

type MasterEntry_E3

type MasterEntry_E3 struct {
	E3 *Empty `protobuf:"bytes,5,opt,name=e3,proto3,oneof"`
}

func FromEmptyMgrEntry

func FromEmptyMgrEntry() *MasterEntry_E3

type MasterEntry_MapEntry

type MasterEntry_MapEntry struct {
	MapEntry *FileMapEntry `protobuf:"bytes,6,opt,name=map_entry,json=mapEntry,proto3,oneof"`
}

func FromMgrEntry

func FromMgrEntry(mentry *mgr_entry.MapEntry) *MasterEntry_MapEntry

type State

type State int32
const (
	State_PRESENT State = 0
	State_ABSENT  State = 1
)

func (State) Descriptor

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum

func (x State) Enum() *State

func (State) EnumDescriptor deprecated

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

Deprecated: Use State.Descriptor instead.

func (State) Number

func (x State) Number() protoreflect.EnumNumber

func (State) String

func (x State) String() string

func (State) Type

func (State) Type() protoreflect.EnumType

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL