cluster

Documentation

Index

• Variables
• type Cluster
  • func NewEtcdCluster(ctx context.Context, cfg config.EtcdConfig) (Cluster, error)
  • func NewRedisCluster(ctx context.Context, cfg config.RedisConfig, ttl int) (Cluster, error)
• type ClusterRole
• type Election
• type RoleInfo

Variables

var (
	ErrNoLeader  = errors.New("no leader")
	ErrNotLeader = errors.New("not a leader")
)

Types

type Cluster

type Cluster interface {
	Close() error
	NewElection(ctx context.Context, electionKey string, id string) Election
	Register(ctx context.Context, serviceName string, instanceID string) error
	Discover(ctx context.Context, serviceName string) ([]string, error)
}

func NewEtcdCluster

func NewEtcdCluster(ctx context.Context, cfg config.EtcdConfig) (Cluster, error)

func NewRedisCluster

func NewRedisCluster(ctx context.Context, cfg config.RedisConfig, ttl int) (Cluster, error)

type ClusterRole

type ClusterRole int

const (
	RoleCandidate ClusterRole = iota
	RoleFollower  ClusterRole = iota
	RoleLeader    ClusterRole = iota
)

type Election

type Election interface {
	Renew(context.Context) error
	Leader(context.Context) (*RoleInfo, error)
	Campaign(context.Context) (ClusterRole, error)
	Resign(context.Context) error
}

type RoleInfo

type RoleInfo struct {
	Address string
	Role    ClusterRole
}