util

Documentation

Index

• func BytesToUint64(b []byte) uint64
• func GetGID() uint64
• func IsSyncMapEmpty(m *sync.Map) bool
• func LenSyncMap(m *sync.Map) int
• func NewConnectionCache(cip ClusterInfoProvider) *connCache
• func NowUnixUtc() uint64
• func OutboundIP() net.IP
• func RandomRaftId() uint64
• func TrackTime(logger *log.Entry, name string, start time.Time)
• func Uint64ToBytes(u uint64) []byte
• func Uint64ToBytesInto(u uint64, buf []byte) error
• func Uint64ToString(i uint64) string
• type ClusterInfoProvider
  • func NewClusterInfoProvider(ownNodeID uint64, pathToClusterInfo string) ClusterInfoProvider
• type ConnectionCache
• type DataStoreTxn
• type DataStoreTxnProvider
• type PartitionedDataStore

Functions

func BytesToUint64

func BytesToUint64(b []byte) uint64

converts bytes to an unsinged 64 bit integer

func GetGID

func GetGID() uint64

func IsSyncMapEmpty

func IsSyncMapEmpty(m *sync.Map) bool

func LenSyncMap

func LenSyncMap(m *sync.Map) int

func NewConnectionCache

func NewConnectionCache(cip ClusterInfoProvider) *connCache

func NowUnixUtc

func NowUnixUtc() uint64

func OutboundIP

func OutboundIP() net.IP

get preferred outbound ip of this machine

func RandomRaftId

func RandomRaftId() uint64

func TrackTime

func TrackTime(logger *log.Entry, name string, start time.Time)

func Uint64ToBytes

func Uint64ToBytes(u uint64) []byte

converts a uint64 to a byte slice

func Uint64ToBytesInto

func Uint64ToBytesInto(u uint64, buf []byte) error

func Uint64ToString

func Uint64ToString(i uint64) string

Types

type ClusterInfoProvider

type ClusterInfoProvider interface {
	FindOwnerForKey(key []byte) uint64
	FindPartitionForKey(key []byte) int
	IsLocal(key []byte) bool
	AmIWriter(writerNodes []uint64) bool
	GetAddressFor(nodeID uint64) string
	MyPartitions() []int
	FindOwnerForPartition(partitionID int) uint64
}

func NewClusterInfoProvider

func NewClusterInfoProvider(ownNodeID uint64, pathToClusterInfo string) ClusterInfoProvider

type ConnectionCache

type ConnectionCache interface {
	GetLowIsolationReadClient(nodeID uint64) (pb.LowIsolationReadClient, error)
	GetRemoteReadClient(nodeID uint64) (pb.RemoteReadClient, error)
	GetRaftTransportClient(nodeID uint64) (pb.RaftTransportClient, error)
	Close()
}

type DataStoreTxn

type DataStoreTxn interface {
	Get(key []byte) []byte
	Set(key []byte, value []byte) error
	Commit() error
	Rollback() error
}

type DataStoreTxnProvider

type DataStoreTxnProvider interface {
	StartTxn(writable bool) (DataStoreTxn, error)
	Snapshot(w io.Writer) error
	Close()
	Delete()
}

type PartitionedDataStore

type PartitionedDataStore interface {
	CreatePartition(partitionID int) (DataStoreTxnProvider, error)
	GetPartition(partitionID int) (DataStoreTxnProvider, error)
	Snapshot(w io.Writer) error
	Close()
}