kvass

Documentation

Index

• Constants
• func Delete(p *SqlitePersistance, key string) error
• func RunServer(p *SqlitePersistance, bind string)
• func Set(p *SqlitePersistance, key string, value ValueType) error
• type KvEntry
  • func (e KvEntry) Max(other KvEntry) KvEntry
• type SqlitePersistance
  • func NewSqlitePersistance(path string) (*SqlitePersistance, error)
  • func (s *SqlitePersistance) Close() error
  • func (s *SqlitePersistance) CommitState() error
  • func (s *SqlitePersistance) DecryptData(data []byte) ([]byte, error)
  • func (s *SqlitePersistance) Encrypt(data []byte) ([]byte, error)
  • func (s *SqlitePersistance) GetCounter() (uint64, error)
  • func (s *SqlitePersistance) GetEntry(key string) (*KvEntry, error)
  • func (s *SqlitePersistance) GetKeys() ([]string, error)
  • func (s *SqlitePersistance) GetProcessID() (uint32, error)
  • func (p *SqlitePersistance) GetRemoteUpdates() (err error)
  • func (s *SqlitePersistance) GetUpdates(req UpdateRequest) ([]KvEntry, error)
  • func (p *SqlitePersistance) Push() error
  • func (s *SqlitePersistance) UpdateOn(entry KvEntry) error
• type SqliteState
• type UpdateRequest
• type ValueType

Constants

const ReservedProcessID = 0

Functions

func Delete

func Delete(p *SqlitePersistance, key string) error

func RunServer

func RunServer(p *SqlitePersistance, bind string)

func Set

func Set(p *SqlitePersistance, key string, value ValueType) error

Types

type KvEntry

type KvEntry struct {
	Key                string
	Value              ValueType
	TimestampUnixMicro int64
	ProcessID          uint32
	Counter            uint64
	UrlToken           string
}

func (KvEntry) Max

func (e KvEntry) Max(other KvEntry) KvEntry

type SqlitePersistance

type SqlitePersistance struct {
	State SqliteState
	// contains filtered or unexported fields
}

func NewSqlitePersistance

func NewSqlitePersistance(path string) (*SqlitePersistance, error)

func (*SqlitePersistance) Close

func (s *SqlitePersistance) Close() error

func (*SqlitePersistance) CommitState

func (s *SqlitePersistance) CommitState() error

func (*SqlitePersistance) DecryptData

func (s *SqlitePersistance) DecryptData(data []byte) ([]byte, error)

func (*SqlitePersistance) Encrypt

func (s *SqlitePersistance) Encrypt(data []byte) ([]byte, error)

func (*SqlitePersistance) GetCounter

func (s *SqlitePersistance) GetCounter() (uint64, error)

func (*SqlitePersistance) GetEntry

func (s *SqlitePersistance) GetEntry(key string) (*KvEntry, error)

func (*SqlitePersistance) GetKeys

func (s *SqlitePersistance) GetKeys() ([]string, error)

func (*SqlitePersistance) GetProcessID

func (s *SqlitePersistance) GetProcessID() (uint32, error)

func (*SqlitePersistance) GetRemoteUpdates

func (p *SqlitePersistance) GetRemoteUpdates() (err error)

func (*SqlitePersistance) GetUpdates

func (s *SqlitePersistance) GetUpdates(req UpdateRequest) ([]KvEntry, error)

func (*SqlitePersistance) Push

func (p *SqlitePersistance) Push() error

func (*SqlitePersistance) UpdateOn

func (s *SqlitePersistance) UpdateOn(entry KvEntry) error

type SqliteState

type SqliteState struct {
	Counter        uint64
	Pid            uint32
	Key            string
	RemoteHostname string
	RemoteCounter  uint64
}

type UpdateRequest

type UpdateRequest struct {
	Counter   uint64
	ProcessID uint32
}

type ValueType

type ValueType = []byte