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

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

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
}