coordination

package

v0.2.0 Latest Latest Go to latest Published: Jun 30, 2026 License: Apache-2.0 Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/sealdb/neoha

Links

Open Source Insights

Documentation ¶

Overview ¶

Package coordination defines the L2 cluster coordination abstraction. See docs/architecture.md.

Constants ¶

View Source

const (
	ProviderRaft       = "raft"
	ProviderEtcd       = "etcd"
	ProviderConsul     = "consul"
	ProviderKubernetes = "kubernetes"
	ProviderZooKeeper  = "zookeeper"
)

Variables ¶

View Source

var (
	ErrProviderNotImplemented = errors.New("coordination provider not implemented")
	ErrNotSupported           = errors.New("operation not supported by this coordinator")
)

Functions ¶

This section is empty.

Types ¶

type ClusterView ¶

type ClusterView struct {
	LeaderID       string
	LeaderDatabase DatabaseEndpoint
	Members        []Member
	Epoch          uint64
	ViewID         uint64
}

ClusterView is a snapshot of coordination state.

type Coordinator ¶

type Coordinator interface {
	Start(ctx context.Context) error
	Stop() error

	LocalID() string
	IsLeader() bool
	ClusterView(ctx context.Context) (ClusterView, error)
	Watch(ctx context.Context) (<-chan ClusterView, error)

	AddMember(ctx context.Context, id string) error
	RemoveMember(ctx context.Context, id string) error

	// Dynamic cluster config blob — schema TBD (docs/architecture.md §4.1).
	GetClusterConfig(ctx context.Context) ([]byte, error)
	SetClusterConfig(ctx context.Context, cfg []byte) error
}

Coordinator abstracts cluster membership and leadership regardless of backend (embedded Raft, etcd, …).

type DatabaseEndpoint ¶

type DatabaseEndpoint struct {
	Host string
	Port int
}

DatabaseEndpoint is the replication target for the current primary mysqld/postgres.

type Member ¶

type Member struct {
	ID       string
	Name     string
	Database string // mysql | postgresql
	Tags     map[string]bool
	Meta     map[string]string
}

Member is a registered cluster member (NeoHA agent).

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
etcd Package etcd provides an etcd-backed coordination.Coordinator (Patroni-style leader lease).	Package etcd provides an etcd-backed coordination.Coordinator (Patroni-style leader lease).
raftadapter Package raftadapter wraps internal/election/raft as coordination.Coordinator.	Package raftadapter wraps internal/election/raft as coordination.Coordinator.
wire Package wire constructs coordination.Coordinator implementations from config.	Package wire constructs coordination.Coordinator implementations from config.

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