keymodels

Documentation

Index

• type ChunkedKeyInfo
• type ChunkedKeyPayload
  • func (p *ChunkedKeyPayload) Close() error
  • func (p *ChunkedKeyPayload) Read(r []byte) (n int, err error)
• type ChunkedKeySnapshot
• type KeyInfo
• type KeysDiff
  • func GetKeysDiff(srcKeys map[string]KeyInfo, srcPrefix string, dstKeys map[string]KeyInfo, ...) KeysDiff
  • func (diff *KeysDiff) IsEmpty() bool
• type Lock

Types

type ChunkedKeyInfo

type ChunkedKeyInfo struct {
	Size    int64
	Count   int64
	Version int64
}

type ChunkedKeyPayload

type ChunkedKeyPayload struct {
	Key   string
	Value io.ReadCloser
	Size  int64
}

func (*ChunkedKeyPayload) Close

func (p *ChunkedKeyPayload) Close() error

func (*ChunkedKeyPayload) Read

func (p *ChunkedKeyPayload) Read(r []byte) (n int, err error)

type ChunkedKeySnapshot

type ChunkedKeySnapshot struct {
	Info     ChunkedKeyInfo
	Revision int64
}

type KeyInfo

type KeyInfo struct {
	Key            string
	Value          string
	Version        int64
	CreateRevision int64
	ModRevision    int64
	Lease          int64
}

type KeysDiff

type KeysDiff struct {
	Upserts   map[string]string
	Deletions []string
}

func GetKeysDiff

func GetKeysDiff(srcKeys map[string]KeyInfo, srcPrefix string, dstKeys map[string]KeyInfo, dstPrefix string) KeysDiff

func (*KeysDiff) IsEmpty

func (diff *KeysDiff) IsEmpty() bool

type Lock

type Lock struct {
	Lease     clientv3.LeaseID
	Ttl       int64
	Timestamp time.Time
}