consensus

type ErrStealTableOwnershipFailed struct {
	Table *Table
}

type HealthChecker struct {
	// contains filtered or unexported fields
}

type HealthStats struct {
	TotalNodes    int64            `json:"total_nodes"`
	ActiveNodes   int64            `json:"active_nodes"`
	FailedNodes   int64            `json:"failed_nodes"`
	RegionStats   map[string]int64 `json:"region_stats"`
	AverageRTT    time.Duration    `json:"average_rtt"`
	LastCheckTime time.Time        `json:"last_check_time"`
}

type KVConsensusAdapter struct {
	// contains filtered or unexported fields
}

type ManagedNode struct {
	*Node
	// contains filtered or unexported fields
}

type MigrationRepository interface {
	// GetUncommittedMigrations returns all uncommitted migrations -- from when this node was part of a previous quorum -- for a given table.
	GetUncommittedMigrations(table *Table) ([]*Migration, error)
	// AddMigration adds a migration to the migration table.
	AddMigration(migration *Migration) error
	// GetMigrationVersion returns all migrations for a given version.
	GetMigrationVersion(version *MigrationVersion) ([]*Migration, error)
	// CommitAllMigrations commits all migrations for a given table.
	CommitAllMigrations(table string) error
	// CommitMigrationExact commits a migration for a given version.
	CommitMigrationExact(version *MigrationVersion) error
	// AddGossipMigration adds a migration to the migration table as a gossiped migration.
	AddGossipMigration(migration *Migration) error
	// GetNextVersion returns the next version for a given table.
	GetNextVersion(table string) (int64, error)
}

type MigrationRepositoryKV struct {
	// contains filtered or unexported fields
}

type NodeConnectionManager struct {
	// contains filtered or unexported fields
}

type NodeRepository interface {
	GetNodeById(id int64) (*Node, error)
	GetNodeByAddress(address string, port uint) (*Node, error)
	GetNodesByRegion(region string) ([]*Node, error)
	GetRegions() ([]*Region, error)
	Iterate(fn func(*Node) error) error
	TotalCount() (int64, error)
	GetRandomNodes(num int64, excluding ...int64) ([]*Node, error)
}

type NodeRepositoryKV struct {
	// contains filtered or unexported fields
}

type NodeStatus int

type NodeStorageModel struct {
	ID        int64     `json:"id"`
	Address   string    `json:"address"`
	Port      int64     `json:"port"`
	Region    string    `json:"region"`
	Active    bool      `json:"active"`
	RTT       int64     `json:"rtt_nanoseconds"`
	CreatedAt time.Time `json:"created_at"`
}

type NodeStorageModelKV struct {
	ID        int64     `json:"id"`
	Address   string    `json:"address"`
	Port      int64     `json:"port"`
	Region    string    `json:"region"`
	Active    bool      `json:"active"`
	RTT       int64     `json:"rtt_nanoseconds"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type Quorum interface {
	ConsensusClient
	CurrentNodeInReplicationQuorum() bool
	CurrentNodeInMigrationQuorum() bool
}

type QuorumManager interface {
	GetQuorum(ctx context.Context, table string) (Quorum, error)
	AddNode(ctx context.Context, node *Node) error
	RemoveNode(nodeID int64) error
	Send(node *Node, do func(quorumNode *QuorumNode) (interface{}, error)) (interface{}, error)
}

type QuorumNode struct {
	*Node
	// contains filtered or unexported fields
}

type RegionName string

type Server struct {
	UnimplementedConsensusServer
}

type TableRepository interface {
	// GetTable returns a table by name.
	GetTable(name string) (*Table, error)
	// UpdateTable updates a table.
	UpdateTable(*Table) error
	// InsertTable inserts a table.
	InsertTable(*Table) error
	// GetGroup returns a group by name.
	GetGroup(string) (*TableGroup, error)
	// UpdateGroup updates a group.
	UpdateGroup(*TableGroup) error
	// InsertGroup inserts a group.
	InsertGroup(*TableGroup) error
	// GetShard returns a shard of a table, given the principal.
	GetShard(*Table, []*Principal) (*Shard, error)
	// UpdateShard updates a shard metadata.
	UpdateShard(*Shard) error
	// InsertShard inserts a shard metadata.
	// Ensure principals are set and the shard meta-name will be updated before inserting.
	InsertShard(*Shard) error
}

type TableRepositoryKV struct {
	// contains filtered or unexported fields
}

type TableStorageModel struct {
	Name              string            `json:"name"`
	Version           int64             `json:"version"`
	ReplicationLevel  string            `json:"replication_level"`
	AllowedRegions    []string          `json:"allowed_regions"`
	RestrictedRegions []string          `json:"restricted_regions"`
	OwnerNodeID       *int64            `json:"owner_node_id"`
	CreatedAt         time.Time         `json:"created_at"`
	GroupID           string            `json:"group_id,omitempty"`
	TableType         string            `json:"table_type"`
	ShardPrincipals   []string          `json:"shard_principals"`
	Owner             *NodeStorageModel `json:"owner,omitempty"`
}