common

package

v0.0.0-...-c2c101f Latest Latest Go to latest Published: Sep 30, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func GetReqId(ctx context.Context) string

func GetSpendTimeWithCtx(ctx context.Context, action string) func()

func SetUniqueContext(ctx context.Context) context.Context

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

func NewConcurrentMap(keyType, valueType reflect.Type) (*ConcurrentMap, error)

func (cm *ConcurrentMap) Delete(key interface{})

func (cm *ConcurrentMap) Load(key interface{}) (value interface{}, ok bool)

func (cm *ConcurrentMap) Range(f func(key, value interface{}) bool)

func (cm *ConcurrentMap) Store(key, value interface{})

type DeleteSegMetaResp struct {
	Err error
}

type GcMapTreeResp struct {
	Err      error
	RespInfo interface{}
}

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

HashRing to hold the nodes and indexes

func New(replicaCount int, hash hash.Hash32) *HashRing

New returns a Hash ring with provided virtual node count and hash If hash is nil, fvn32a is used instead

func (hr *HashRing) Add(node string) error

Add adds a node to Hash ring

func (hr *HashRing) Delete(node string) error

Delete deletes the nodes from hash ring

func (hr *HashRing) Locate(key string) (node string, err error)

Locate returns the node for a given key

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

func NewIdGenerator() (idGenerator *IdGenerator, err error)

func (ig *IdGenerator) GetId() string

type Segment struct {
	FsId    string
	SegId0  uint64
	SegId1  uint64
	FileEnd uint64
}

type UpdateSegResp struct {
	Err error
	Seg *Segment
}