model

type ClusterConfig struct {
	Namespaces []NamespaceConfig `json:"namespaces" yaml:"namespaces"`
	Servers    []Server          `json:"servers" yaml:"servers"`
	// ServerMetadata is a map associating server names with their corresponding metadata.
	ServerMetadata map[string]ServerMetadata `json:"serverMetadata" yaml:"serverMetadata"`
}

type ClusterStatus struct {
	Namespaces       map[string]NamespaceStatus `json:"namespaces" yaml:"namespaces"`
	ShardIdGenerator int64                      `json:"shardIdGenerator" yaml:"shardIdGenerator"`
	ServerIdx        uint32                     `json:"serverIdx" yaml:"serverIdx"`
}

type Int32HashRange struct {
	// The minimum inclusive hash that the shard can contain
	Min uint32 `json:"min"`

	// The maximum inclusive hash that the shard can contain
	Max uint32 `json:"max"`
}

type NamespaceConfig struct {
	Name                 string                       `json:"name" yaml:"name"`
	InitialShardCount    uint32                       `json:"initialShardCount" yaml:"initialShardCount"`
	ReplicationFactor    uint32                       `json:"replicationFactor" yaml:"replicationFactor"`
	NotificationsEnabled common.OptBooleanDefaultTrue `json:"notificationsEnabled" yaml:"notificationsEnabled"`
	// Policies represents additional configuration policies for the namespace, such as anti-affinity rules.
	Policies *policies.Policies `json:"policies,omitempty" yaml:"policies,omitempty"`
}

type NamespaceStatus struct {
	ReplicationFactor uint32                  `json:"replicationFactor" yaml:"replicationFactor"`
	Shards            map[int64]ShardMetadata `json:"shards" yaml:"shards"`
}

type Server struct {
	// Name is the unique identification for clusters
	Name *string `json:"name" yaml:"name"`

	// Public is the endpoint that is advertised to clients
	Public string `json:"public" yaml:"public"`

	// Internal is the endpoint for server->server RPCs
	Internal string `json:"internal" yaml:"internal"`
}

type ServerMetadata struct {
	// Labels represents a key-value map to store metadata associated with a server.
	Labels map[string]string `json:"labels" yaml:"labels"`
}

type ShardMetadata struct {
	Status         ShardStatus    `json:"status" yaml:"status"`
	Term           int64          `json:"term" yaml:"term"`
	Leader         *Server        `json:"leader" yaml:"leader"`
	Ensemble       []Server       `json:"ensemble" yaml:"ensemble"`
	RemovedNodes   []Server       `json:"removedNodes" yaml:"removedNodes"`
	Int32HashRange Int32HashRange `json:"int32HashRange" yaml:"int32HashRange"`
}

type ShardStatus uint16