stream

type Action func() error

type AutoModeStats struct {
	NodesObserved          uint64 // gauge (not reset)
	PollErrors             uint64 // reset each report
	RotationsDetected      uint64 // reset each report
	RotationRecoveries     uint64 // reset each report
	RotationRecoveryErrors uint64 // reset each report
	RotationGaps           uint64 // reset each report
}

type Config struct {
	ClusterCreds           string
	ClusterName            string // Optional: cluster name for self-managed clusters
	HttpsProxy             string
	OnboardingClientID     string
	OnboardingClientSecret string
	OnboardingEndpoint     string
	PodNamespace           string
	StatsLogPeriod         time.Duration
	SuccessPeriods         SuccessPeriods
	TlsSkipVerify          bool
	TokenEndpoint          string
}

type FactoryConfig struct {
	// Stream factories - manager is oblivious to specific implementations
	Factories []ManagedFactory

	// Shared components
	Stats *Stats

	// Configuration
	SuccessPeriods SuccessPeriods
	StatsLogPeriod time.Duration
}

type ManagedFactory struct {
	Factory         StreamClientFactory
	KeepalivePeriod time.Duration
}

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

type StreamClient interface {
	// Run sends/receives messages over a gRPC stream until the stream is closed
	// or the context is canceled. This is the main loop for the stream.
	Run(ctx context.Context) error

	// SendKeepalive sends a keepalive message over the gRPC stream.
	SendKeepalive(ctx context.Context) error

	// Close gracefully closes the stream.
	Close() error
}

type StreamClientFactory interface {
	// NewStreamClient creates a new StreamClient connected to the given gRPC connection.
	// Each factory creates its own service client from the connection as needed.
	NewStreamClient(ctx context.Context, grpcConn grpc.ClientConnInterface) (StreamClient, error)

	// Name returns the name of the stream for logging purposes.
	Name() string
}

type SuccessPeriods struct {
	Auth    time.Duration
	Connect time.Duration
}