upstream

Jun 22, 2024

Changes in this version

type ConnUpstream

+ func (u *ConnUpstream) Forward() bool

type NodeUpstream

+ func (u *NodeUpstream) Forward() bool

type Upstream

+ Forward func() bool

Jun 9, 2024

Changes in this version

+ const TokenContextKey

+ type AuthMiddleware struct

+ func NewAuthMiddleware(verifier auth.Verifier, logger log.Logger) *AuthMiddleware

+ func (m *AuthMiddleware) VerifyEndpointToken(c *gin.Context)

+ type ConnUpstream struct

+ func NewConnUpstream(endpointID string, sess *mux.Session) *ConnUpstream

+ func (u *ConnUpstream) Dial() (net.Conn, error)

+ func (u *ConnUpstream) EndpointID() string

+ type LoadBalancedManager struct

+ func NewLoadBalancedManager(cluster *cluster.State) *LoadBalancedManager

+ func (m *LoadBalancedManager) AddConn(u Upstream)

+ func (m *LoadBalancedManager) Endpoints() map[string]int

+ func (m *LoadBalancedManager) Metrics() *Metrics

+ func (m *LoadBalancedManager) RemoveConn(u Upstream)

+ func (m *LoadBalancedManager) Select(endpointID string, allowRemote bool) (Upstream, bool)

+ func (m *LoadBalancedManager) Usage() *Usage

+ type Manager interface

+ AddConn func(u Upstream)

+ RemoveConn func(u Upstream)

+ Select func(endpointID string, allowForward bool) (Upstream, bool)

+ type Metrics struct

+ ConnectedUpstreams prometheus.Gauge

+ RegisteredEndpoints prometheus.Gauge

+ RemoteRequestsTotal *prometheus.CounterVec

+ UpstreamRequestsTotal prometheus.Counter

+ func NewMetrics() *Metrics

+ func (m *Metrics) Register(registry *prometheus.Registry)

+ type NodeUpstream struct

+ func NewNodeUpstream(endpointID string, node *cluster.Node) *NodeUpstream

+ func (u *NodeUpstream) Dial() (net.Conn, error)

+ func (u *NodeUpstream) EndpointID() string

+ type Server struct

+ func NewServer(upstreams Manager, verifier auth.Verifier, tlsConfig *tls.Config, ...) *Server

+ func (s *Server) Serve(ln net.Listener) error

+ func (s *Server) Shutdown(ctx context.Context) error

+ type Status struct

+ func NewStatus(manager *LoadBalancedManager) *Status

+ func (s *Status) Register(group *gin.RouterGroup)

+ type Upstream interface

+ Dial func() (net.Conn, error)

+ EndpointID func() string

+ type Usage struct

+ Requests *atomic.Uint64

+ Upstreams *atomic.Uint64