kvstore

Documentation

Index

• func GetDataBuf(size int) []byte
• func RecycleDataBuf(b []byte)
• type KV
  • func NewPrimary(dir string) *KV
  • func NewSecondary(dir string, onStore func(collection string, id uint64, data []byte), ...) *KV
  • func (kv *KV) CleanBefore(seconds int64)
  • func (kv *KV) Close()
  • func (kv *KV) Delete(collection string, id uint64)
  • func (kv *KV) Iterate(collection string, each func(id uint64, data []byte))
  • func (kv *KV) LogInfo() (info LogInfo)
  • func (kv *KV) MaxSeqNum() (seqNum uint64)
  • func (kv *KV) Primary() bool
  • func (kv *KV) Store(collection string, id uint64, data []byte)
  • func (kv *KV) SyncRecv(conn net.Conn)
  • func (kv *KV) SyncSend(conn net.Conn)
• type LogInfo

Functions

func GetDataBuf

func GetDataBuf(size int) []byte

func RecycleDataBuf

func RecycleDataBuf(b []byte)

Types

type KV

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

func NewPrimary

func NewPrimary(dir string) *KV

func NewSecondary

func NewSecondary(
	dir string,
	onStore func(collection string, id uint64, data []byte),
	onDelete func(collection string, id uint64),
) *KV

func (*KV) CleanBefore

func (kv *KV) CleanBefore(seconds int64)

func (*KV) Close

func (kv *KV) Close()

func (*KV) Delete

func (kv *KV) Delete(collection string, id uint64)

func (*KV) Iterate

func (kv *KV) Iterate(collection string, each func(id uint64, data []byte))

func (*KV) LogInfo

func (kv *KV) LogInfo() (info LogInfo)

func (*KV) MaxSeqNum

func (kv *KV) MaxSeqNum() (seqNum uint64)

func (*KV) Primary

func (kv *KV) Primary() bool

func (*KV) Store

func (kv *KV) Store(collection string, id uint64, data []byte)

func (*KV) SyncRecv

func (kv *KV) SyncRecv(conn net.Conn)

func (*KV) SyncSend

func (kv *KV) SyncSend(conn net.Conn)

type LogInfo

type LogInfo struct {
	MaxSeqNum    uint64
	MaxCreatedAt uint64
}