journal_entry

package
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

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.