Versions in this module Expand all Collapse all v2 v2.1.4 Oct 1, 2025 Changes in this version + var ErrStatusInvalidConnection = status.Error(codes.Unauthenticated, "invalid connection") + type AgentConnectionsTracker struct + func (c *AgentConnectionsTracker) GetConnection(key string) Connection + func (c *AgentConnectionsTracker) RemoveConnection(key string) + func (c *AgentConnectionsTracker) SetInstanceID(key, id string) + func (c *AgentConnectionsTracker) Track(key string, conn Connection) + type Connection struct + InstanceID string + Parent types.NamespacedName + PodName string + func (c *Connection) Ready() bool + type ConnectionsTracker interface + GetConnection func(key string) Connection + RemoveConnection func(key string) + SetInstanceID func(key, id string) + Track func(key string, conn Connection) + func NewConnectionsTracker() ConnectionsTracker + type Interceptor interface + Stream func(logr.Logger) grpc.StreamServerInterceptor + Unary func(logr.Logger) grpc.UnaryServerInterceptor + type Server struct + func NewServer(logger logr.Logger, port int, registerSvcs []func(*grpc.Server), ...) *Server + func (g *Server) Start(ctx context.Context) error
Go to main page