grpchelper

type CircuitState int

type Client interface {
	Close() error
}

type ConnManager[C Client] struct {
	// contains filtered or unexported fields
}

type ConnManagerConfig[C Client] struct {
	Handler            ConnectionHandler[C]
	Logger             *logger.Logger
	RetryPolicy        string
	ExtraDialOpts      []grpc.DialOption
	MaxRecvMsgSize     int
	HealthCheckTimeout time.Duration
}

type ConnectionHandler[C Client] interface {
	// AddressOf extracts the gRPC address from a node.
	AddressOf(node *databasev1.Node) string
	// GetDialOptions returns gRPC dial options for the given address.
	GetDialOptions() ([]grpc.DialOption, error)
	// NewClient creates a client from a gRPC connection and node.
	NewClient(conn *grpc.ClientConn, node *databasev1.Node) (C, error)
	// OnActive is called when a node transitions to active.
	OnActive(name string, client C)
	// OnInactive is called when a node leaves active.
	OnInactive(name string, client C)
}