replidb

package

v0.0.0-...-15b7eb6 Latest Latest Go to latest Published: Nov 7, 2018 License: MIT Imports: 11 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/maxymania/gonbase

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func BytesComparator(a, b interface{}) int
func Decode(b []byte) (i uint64)
func Encode(V uint64) []byte
func PairComparator(a, b interface{}) int
func SplitOff(b []byte) (n, r []byte)
func SplitOffSecond(b []byte) (n, r []byte)
type Action
type LoggedSequence
- func (l *LoggedSequence) Commit() error
- func (l *LoggedSequence) Create(pair Pair)
- func (l *LoggedSequence) Delete(pair Pair)
- func (l *LoggedSequence) GetSequence(name []byte) uint64
- func (l *LoggedSequence) Lowest(name []byte) (uint64, bool)
- func (l *LoggedSequence) OnReceive(repl []byte) error
- func (l *LoggedSequence) SetSequence(pair Pair)
- func (l *LoggedSequence) Startup() error
type Pair
- func (p *Pair) Copy()
type RowEvent
- func (r *RowEvent) DecodeMsgpack(dec *msgpack.Decoder) error
- func (r *RowEvent) EncodeMsgpack(enc *msgpack.Encoder) error
type Sequence
- func (s *Sequence) BGFlush() error
- func (s *Sequence) Create(pair Pair)
- func (s *Sequence) Delete(pair Pair)
- func (s *Sequence) GetSequence(name []byte) uint64
- func (s *Sequence) Init()
- func (s *Sequence) Lowest(name []byte) (uint64, bool)
- func (s *Sequence) SetSequence(pair Pair)
type SequenceWorker
- func (sw *SequenceWorker) Start()
- func (sw *SequenceWorker) Stop()
- func (sw *SequenceWorker) Submit(a *Action)
type UIntBuffer
- func NewUIntBuffer() *UIntBuffer
- func (u *UIntBuffer) Encode(V uint64) []byte
- func (u *UIntBuffer) Free()

Constants ¶

View Source

const (
	Act_Allocate uint = iota
	Act_Rollback
)

View Source

const (
	Op_Create uint = iota
	Op_Delete
	Op_SetSequence
)

Variables ¶

View Source

var ENoTarget = errors.New("NoTarget")

View Source

var EStartupRecoverFailed = errors.New("StartupRecoverFailed")

Functions ¶

func BytesComparator ¶

func BytesComparator(a, b interface{}) int

func Decode ¶

func Decode(b []byte) (i uint64)

func Encode ¶

func Encode(V uint64) []byte

func PairComparator ¶

func PairComparator(a, b interface{}) int

func SplitOff ¶

func SplitOff(b []byte) (n, r []byte)

func SplitOffSecond ¶

func SplitOffSecond(b []byte) (n, r []byte)

Types ¶

type Action ¶

type Action struct {
	Act    uint
	Name   []byte
	Number uint64
	Error  error
	WG     *sync.WaitGroup
	Free   func(a *Action)
}

type LoggedSequence ¶

type LoggedSequence struct {
	Seq  *Sequence
	Path string

	/* Replication outbound. */
	Replicator func(b []byte) error

	MaxLogBeforeMerge int64
	// contains filtered or unexported fields
}

func (*LoggedSequence) Commit ¶

func (l *LoggedSequence) Commit() error

func (*LoggedSequence) Create ¶

func (l *LoggedSequence) Create(pair Pair)

func (*LoggedSequence) Delete ¶

func (l *LoggedSequence) Delete(pair Pair)

func (*LoggedSequence) GetSequence ¶

func (l *LoggedSequence) GetSequence(name []byte) uint64

func (*LoggedSequence) Lowest ¶

func (l *LoggedSequence) Lowest(name []byte) (uint64, bool)

func (*LoggedSequence) OnReceive ¶

func (l *LoggedSequence) OnReceive(repl []byte) error

Replication inbound.

func (*LoggedSequence) SetSequence ¶

func (l *LoggedSequence) SetSequence(pair Pair)

func (*LoggedSequence) Startup ¶

func (l *LoggedSequence) Startup() error

type Pair ¶

type Pair struct {
	Name []byte
	Num  uint64
}

func (*Pair) Copy ¶

func (p *Pair) Copy()

type RowEvent ¶

type RowEvent struct {
	Pair
	Op uint
}

func (*RowEvent) DecodeMsgpack ¶

func (r *RowEvent) DecodeMsgpack(dec *msgpack.Decoder) error

func (*RowEvent) EncodeMsgpack ¶

func (r *RowEvent) EncodeMsgpack(enc *msgpack.Encoder) error

type Sequence ¶

type Sequence struct {
	DB    *bolt.DB
	Table []byte

	Exist     *avl.Tree
	DontExist *avl.Tree
	Seqs      *avl.Tree
	// contains filtered or unexported fields
}

func (*Sequence) BGFlush ¶

func (s *Sequence) BGFlush() error

Background-Flush function.

func (*Sequence) Create ¶

func (s *Sequence) Create(pair Pair)

func (*Sequence) Delete ¶

func (s *Sequence) Delete(pair Pair)

func (*Sequence) GetSequence ¶

func (s *Sequence) GetSequence(name []byte) uint64

func (*Sequence) Init ¶

func (s *Sequence) Init()

func (*Sequence) Lowest ¶

func (s *Sequence) Lowest(name []byte) (uint64, bool)

func (*Sequence) SetSequence ¶

func (s *Sequence) SetSequence(pair Pair)

type SequenceWorker ¶

type SequenceWorker struct {
	LS *LoggedSequence
	B  batcher.Batcher
}

func (*SequenceWorker) Start ¶

func (sw *SequenceWorker) Start()

func (*SequenceWorker) Stop ¶

func (sw *SequenceWorker) Stop()

func (*SequenceWorker) Submit ¶

func (sw *SequenceWorker) Submit(a *Action)

type UIntBuffer ¶

type UIntBuffer [9]byte

func NewUIntBuffer ¶

func NewUIntBuffer() *UIntBuffer

func (*UIntBuffer) Encode ¶

func (u *UIntBuffer) Encode(V uint64) []byte

func (*UIntBuffer) Free ¶

func (u *UIntBuffer) Free()

Source Files ¶

View all Source files

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