atlas

package

v0.1.0 Latest Latest Go to latest Published: Oct 5, 2025 License: AGPL-3.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

func AddOwner(ctx context.Context, builder *kv.KeyBuilder, owner string) error

func AddReader(ctx context.Context, builder *kv.KeyBuilder, reader string) error

func AddWriter(ctx context.Context, builder *kv.KeyBuilder, writer string) error

func DeleteKey(ctx context.Context, builder *kv.KeyBuilder) error

DeleteKey performs a distributed delete of the provided key using the same migration-based consensus path used for writes.

func GetKey(ctx context.Context, builder *kv.KeyBuilder) ([]byte, error)

func PrefixScan(ctx context.Context, tablePrefix, rowPrefix string) ([]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(ctx context.Context, builder *kv.KeyBuilder, owner string) error

func RevokeReader(ctx context.Context, builder *kv.KeyBuilder, reader string) error

func RevokeWriter(ctx context.Context, builder *kv.KeyBuilder, writer string) error

func WriteKey(ctx context.Context, builder *kv.KeyBuilder, value []byte) error

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

type Param struct {
	Name  string
	Value any
}