atlas

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 30, 2025 License: AGPL-3.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddOwner added in v0.1.0

func AddOwner(ctx context.Context, key []byte, owner string) error

func AddReader added in v0.1.0

func AddReader(ctx context.Context, key []byte, reader string) error

func AddWriter added in v0.1.0

func AddWriter(ctx context.Context, key []byte, writer string) error

func GetKey

func GetKey(ctx context.Context, key []byte) ([]byte, error)

func PrefixScan added in v0.1.0

func PrefixScan(ctx context.Context, keyPrefix []byte) ([]string, error)

PrefixScan performs a distributed prefix scan across all nodes in the cluster. It returns all keys matching the prefix that are owned by any node.

func RevokeOwner added in v0.1.0

func RevokeOwner(ctx context.Context, key []byte, owner string) error

func RevokeReader added in v0.1.0

func RevokeReader(ctx context.Context, key []byte, reader string) error

func RevokeWriter added in v0.1.0

func RevokeWriter(ctx context.Context, key []byte, writer string) error

func WriteKey

func WriteKey(ctx context.Context, key []byte, value []byte) error

Types

type Node

type Node struct {
	Id      int
	Address string
	Port    int
	Region  int
}

type Param

type Param struct {
	Name  string
	Value any
}

Directories

Path Synopsis
Package cache provides a lock-free adaptive in-memory LRU cache implementation.
Package cache provides a lock-free adaptive in-memory LRU cache implementation.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL