common

type CiliumEtcdConfig struct {
	HostAliases []HostAlias `json:"cilium-host-aliases" yaml:"cilium-host-aliases"`
}

type ClusterMesh interface {
	cell.HookInterface

	// ForEachRemoteCluster calls the provided function for each remote cluster
	// in the ClusterMesh.
	ForEachRemoteCluster(fn func(RemoteCluster) error) error
	// NumReadyClusters returns the number of remote clusters to which a connection
	// has been established
	NumReadyClusters() int
}

type Config struct {
	// ClusterMeshConfig is the path to the clustermesh configuration directory.
	ClusterMeshConfig string

	// ClusterMeshCacheTTL is the time to live for the cache of a remote cluster after connectivity
	// is lost. If the connection is not re-established within this duration, the cached data is
	// revoked to prevent stale state. If not specified or set to 0s, the cache is never revoked.
	ClusterMeshCacheTTL time.Duration
}

type Configuration struct {
	Logger *slog.Logger

	Config

	// ClusterInfo is the id/name of the local cluster.
	ClusterInfo types.ClusterInfo

	// RemoteClientFactory is the factory to create new backend instances.
	RemoteClientFactory RemoteClientFactoryFn

	// NewRemoteCluster is a function returning a new implementation of the remote cluster business logic.
	NewRemoteCluster RemoteClusterCreatorFunc

	// ClusterSizeDependantInterval allows to calculate intervals based on cluster size.
	ClusterSizeDependantInterval kvstore.ClusterSizeDependantIntervalFunc

	// Resolvers, if provided, are used to create a custom dialer to connect to etcd.
	Resolvers []dial.Resolver

	// Metrics holds the different clustermesh metrics.
	Metrics Metrics
}

type GlobalService struct {
	ClusterServices map[string]*serviceStore.ClusterService
}

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

type HostAlias struct {
	Hostname string       `json:"hostname" yaml:"hostname"`
	IPs      []netip.Addr `json:"ips" yaml:"ips"`
}

type Metrics struct {
	// TotalRemoteClusters tracks the total number of remote clusters.
	TotalRemoteClusters metric.Gauge
	// LastFailureTimestamp tracks the last failure timestamp.
	LastFailureTimestamp metric.Vec[metric.Gauge]
	// ReadinessStatus tracks the readiness status of remote clusters.
	ReadinessStatus metric.Vec[metric.Gauge]
	// TotalFailure tracks the number of failures when connecting to remote clusters.
	TotalFailures metric.Vec[metric.Gauge]
	// TotalCacheRevocations tracks the number of cache revocations for a remote cluster.
	TotalCacheRevocations metric.Vec[metric.Gauge]
}

type RemoteClientFactoryFn func(ctx context.Context, logger *slog.Logger,
	cfgpath string, extra kvstore.ExtraOptions) (kvstore.BackendOperations, chan error)

type RemoteCluster interface {
	// Run implements the actual business logic once the connection to the remote cluster has been established.
	// The ready channel shall be closed when the initialization tasks completed, possibly returning an error.
	Run(ctx context.Context, backend kvstore.BackendOperations, config types.CiliumClusterConfig, ready chan<- error)

	Stop()
	Remove(ctx context.Context)
	RevokeCache(ctx context.Context)
}

type RemoteClusterCreatorFunc func(name string, status StatusFunc) RemoteCluster

type StatusFunc func() *models.RemoteCluster