storage

package

Go to main page

Versions in this module

v0

v0.0.3

Sep 9, 2022

Changes in this version

type File — linux/amd64

+ func OpenFile(filename string, readonly bool) (File, error)

v0.0.2

Aug 10, 2022

Changes in this version

+ var ErrIntOverflowProto = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthProto = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupProto = fmt.Errorf("proto: unexpected end of group")

+ var Op_name = map[int32]string

+ var Op_value = map[string]int32

+ type FileHeader struct

+ EntryNum int64

+ FileEnd int64

+ Id string

+ LastEntryId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FileHeader) Descriptor() ([]byte, []int)

+ func (*FileHeader) ProtoMessage()

+ func (m *FileHeader) GetEntryNum() int64

+ func (m *FileHeader) GetFileEnd() int64

+ func (m *FileHeader) GetId() string

+ func (m *FileHeader) GetLastEntryId() string

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

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

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

+ func (m *FileHeader) Reset()

+ func (m *FileHeader) Size() (n int)

+ func (m *FileHeader) String() string

+ func (m *FileHeader) Unmarshal(dAtA []byte) error

+ func (m *FileHeader) XXX_DiscardUnknown()

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

+ func (m *FileHeader) XXX_Merge(src proto.Message)

+ func (m *FileHeader) XXX_Size() int

+ func (m *FileHeader) XXX_Unmarshal(b []byte) error

+ type LogEntry struct

+ Ops []*LogOperation

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogEntry) Descriptor() ([]byte, []int)

+ func (*LogEntry) ProtoMessage()

+ func (m *LogEntry) GetOps() []*LogOperation

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

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

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

+ func (m *LogEntry) Reset()

+ func (m *LogEntry) Size() (n int)

+ func (m *LogEntry) String() string

+ func (m *LogEntry) Unmarshal(dAtA []byte) error

+ func (m *LogEntry) XXX_DiscardUnknown()

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

+ func (m *LogEntry) XXX_Merge(src proto.Message)

+ func (m *LogEntry) XXX_Size() int

+ func (m *LogEntry) XXX_Unmarshal(b []byte) error

+ type LogOperation struct

+ Changes map[string]int32

+ Gid string

+ Key string

+ MachineId string

+ Num int64

+ Op int32

+ PrevGid string

+ PrevMachineId string

+ PrevNum int64

+ PrevValue string

+ Seq uint64

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LogOperation) ProtoMessage()

+ func (m *LogOperation) GetChanges() map[string]int32

+ func (m *LogOperation) GetGid() string

+ func (m *LogOperation) GetKey() string

+ func (m *LogOperation) GetMachineId() string

+ func (m *LogOperation) GetNum() int64

+ func (m *LogOperation) GetOp() int32

+ func (m *LogOperation) GetPrevGid() string

+ func (m *LogOperation) GetPrevMachineId() string

+ func (m *LogOperation) GetPrevNum() int64

+ func (m *LogOperation) GetPrevValue() string

+ func (m *LogOperation) GetSeq() uint64

+ func (m *LogOperation) GetValue() string

+ 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 (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

+ type Op int32

+ const Op_Del

+ const Op_Discard

+ const Op_Modify

+ const Op_None

+ func (Op) EnumDescriptor() ([]byte, []int)

+ func (x Op) String() string

v0.0.1

Jul 26, 2022

Changes in this version

+ const DBFileName

+ const Error

+ const HeaderSize

+ const Info

+ const Silent

+ const SyncInterval

+ const WalFileName

+ const Warn

+ func GenUUID() (string, error)

+ func IsDir(filename string) bool

+ func IsFile(filename string) bool

+ func SetLogger(l Logger)

+ func ToAbs(p string) (string, error)

+ type BinLog struct

+ func (l *BinLog) AppendEntry(f File, pos int64, entry *LogEntry) (int64, error)

+ func (l *BinLog) IsValidFile(f File) (bool, error)

+ func (l *BinLog) ReadEntry(f File, pos int64, entry *LogEntry) (int64, error)

+ func (l *BinLog) ReadHeader(f File) (*FileHeader, error)

+ func (l *BinLog) WriteHeader(f File, header *FileHeader) error

+ type ChangeCount map[string]int32

+ func (n *ChangeCount) Scan(value any) error

+ func (n ChangeCount) Value() (driver.Value, error)

+ type DBRecord struct

+ CreatedAt time.Time

+ CurrentLogGid string

+ DeletedAt sql.NullTime

+ IsDeleted bool

+ IsDiscarded bool

+ Key string

+ MachineChangeCount ChangeCount

+ MachineID string

+ Num int64

+ Offset int64

+ PrevLogGid string

+ PrevMachineID string

+ PrevNum int64

+ Seq uint64

+ UpdatedAt time.Time

+ Value string

+ func (r *DBRecord) AddChange(machineID string, changes int32) map[string]int32

+ func (r *DBRecord) Changes(machineID string) int32

+ func (r *DBRecord) Visible() bool

+ type File interface

+ Flush func() error

+ Path func() string

+ func OpenFile(filename string, readonly bool) (File, error)

+ type Iterator interface

+ Next func() bool

+ type JsonLog struct

+ func (l *JsonLog) AppendEntry(f File, pos int64, entry *LogEntry) (int64, error)

+ func (l *JsonLog) IsValidFile(f File) (bool, error)

+ func (l *JsonLog) ReadEntry(f File, pos int64, entry *LogEntry) (int64, error)

+ func (l *JsonLog) ReadHeader(f File) (*FileHeader, error)

+ func (l *JsonLog) WriteHeader(f File, header *FileHeader) error

+ type LogFormat interface

+ AppendEntry func(f File, pos int64, entry *LogEntry) (int64, error)

+ IsValidFile func(f File) (bool, error)

+ ReadEntry func(f File, pos int64, entry *LogEntry) (int64, error)

+ ReadHeader func(f File) (*FileHeader, error)

+ WriteHeader func(f File, header *FileHeader) error

+ type LogInput struct

+ type LogProgress struct

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ Gid string

+ MachineID string

+ Num int64

+ Offset int64

+ UpdatedAt time.Time

+ type LogProgressMgr struct

+ func (m *LogProgressMgr) Get(machineID string) *LogProgress

+ func (m *LogProgressMgr) Init(progress ...*LogProgress)

+ func (m *LogProgressMgr) Set(machineID string, progress *LogProgress)

+ type LogRunner struct

+ func (r *LogRunner) Init(machineID string, s NodeStorage) error

+ func (r *LogRunner) Run(i ...*LogInput) (*RunLogResult, error)

+ type Logger interface

+ AddSkip func(skip int) Logger

+ Category func(catetory string) Logger

+ Error func(format string, args ...interface{})

+ Info func(format string, args ...interface{})

+ SetLevel func(level int) Logger

+ Warn func(format string, args ...interface{})

+ type MmapFile struct — windows/amd64

+ func (f *MmapFile) AsSlice() []byte

+ func (f *MmapFile) Close()

+ func (f *MmapFile) Flush() error

+ func (f *MmapFile) Init(filename string) (err error)

+ type NetworkInfo struct

+ func (n *NetworkInfo) Add(name string) *ParticipantInfo

+ func (n *NetworkInfo) Init(wd string) error

+ type NodeStorage interface

+ Add func(record *DBRecord) error

+ Merge func(other ReadOnlyNodeStorage) error

+ Replace func(old string, new *DBRecord) error

+ type NodeStorageImpl struct

+ func (n *NodeStorageImpl) Add(record *DBRecord) error

+ func (n *NodeStorageImpl) AllNodes() ([]*DBRecord, error)

+ func (n *NodeStorageImpl) GetByGid(gid string) (*DBRecord, error)

+ func (n *NodeStorageImpl) GetByKey(key string) ([]*DBRecord, error)

+ func (n *NodeStorageImpl) Init()

+ func (n *NodeStorageImpl) Merge(other ReadOnlyNodeStorage) error

+ func (n *NodeStorageImpl) Replace(old string, new *DBRecord) error

+ type Participant struct

+ func (p *Participant) Accept(v *Value, seq int) error

+ func (p *Participant) All() ([]*Value, error)

+ func (p *Participant) AllConflicts() ([]*Value, error)

+ func (p *Participant) Close()

+ func (p *Participant) Del(key string) error

+ func (p *Participant) Has(key string) (bool, error)

+ func (p *Participant) Init(wd string, machineID string) (err error)

+ func (p *Participant) Load(key string) (*Value, error)

+ func (p *Participant) Save(key string, value string) error

+ type ParticipantInfo struct

+ func (p *ParticipantInfo) Init(wd string, name string, n *NetworkInfo)

+ type ReadOnlyNodeStorage interface

+ AllNodes func() ([]*DBRecord, error)

+ GetByGid func(gid string) (*DBRecord, error)

+ GetByKey func(key string) ([]*DBRecord, error)

+ type RunLogContext struct

+ func (c *RunLogContext) Init(i ...*LogInput)

+ func (c *RunLogContext) Progress(machineID string) *LogProgress

+ type RunLogError struct

+ func (e *RunLogError) Error() string

+ type RunLogResult struct

+ func (r *RunLogResult) Error() error

+ func (r *RunLogResult) Init(s map[string]*LogProgress, e *RunLogError)

+ func (r *RunLogResult) Process(machineID string) *LogProgress

+ type RunLogWorker struct

+ type SqliteAdapter struct

+ func (s *SqliteAdapter) Add(record *DBRecord) error

+ func (s *SqliteAdapter) AllNodes() ([]*DBRecord, error)

+ func (s *SqliteAdapter) Close() error

+ func (s *SqliteAdapter) GetByGid(gid string) (*DBRecord, error)

+ func (s *SqliteAdapter) GetByKey(key string) ([]*DBRecord, error)

+ func (s *SqliteAdapter) Has(gid string) (bool, error)

+ func (s *SqliteAdapter) Init(dbFile string) error

+ func (s *SqliteAdapter) Merge(other ReadOnlyNodeStorage) error

+ func (s *SqliteAdapter) Processes() ([]*LogProgress, error)

+ func (s *SqliteAdapter) Replace(old string, new *DBRecord) error

+ func (s *SqliteAdapter) Transaction(f func(s *SqliteAdapter) error) error

+ type Storage interface

+ Accept func(v *Value, seq int) error

+ All func() ([]*Value, error)

+ Del func(key string) error

+ Has func(key string) (bool, error)

+ Load func(key string) (val *Value, err error)

+ Save func(key string, value string) error

+ type Value struct

+ func (v *Value) Branches() []*ValueVersion

+ func (v *Value) Main() *ValueVersion

+ func (v *Value) String() string

+ func (v *Value) ValidSeq(seq int) bool

+ func (v *Value) Versions() []*ValueVersion

+ type ValueVersion struct

+ func (v *ValueVersion) String() string

+ type Wal struct

+ func (w *Wal) Append(logOp ...*LogOperation) (string, int64, error)

+ func (w *Wal) AppendRaw(logOp ...*LogOperation) error

+ func (w *Wal) Close() error

+ func (w *Wal) Flush() error

+ func (w *Wal) Init(filename string, l LogFormat, readonly bool) (err error)

+ func (w *Wal) Iterator() *WalIterator

+ func (w *Wal) IteratorFrom(start string, inclusive bool) (*WalIterator, error)

+ func (w *Wal) IteratorOffset(offset int64) *WalIterator

+ func (w *Wal) Offset() int64

+ func (w *Wal) RangeIterator(start string, end string, includeStart bool, includeEnd bool) (*WalIterator, error)

+ type WalHelper struct

+ func (w *WalHelper) Append(logOp ...*LogOperation) (string, int64, error)

+ func (w *WalHelper) Close()

+ func (w *WalHelper) Init(filename string, l LogFormat, writeCount int)

+ func (w *WalHelper) Offset() (int64, error)

+ type WalIterator struct

+ func (i *WalIterator) Init(w *Wal)

+ func (i *WalIterator) InitWithOffset(w *Wal, offset int64)

+ func (i *WalIterator) LogOp() *LogOperation

+ func (i *WalIterator) Next() (hasNext bool)

+ func (i *WalIterator) Offset() int64

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