Versions in this module Expand all Collapse all v1 v1.8.1 Oct 5, 2022 Changes in this version + type EnvoyAdminFn = func(ctx context.Context, proxy core_model.ResourceWithAddress) ([]byte, error) + type EnvoyAdminProcessor interface + StartProcessingClusters func(stream mesh_proto.GlobalKDSService_StreamClustersClient, errorCh chan error) + StartProcessingStats func(stream mesh_proto.GlobalKDSService_StreamStatsClient, errorCh chan error) + StartProcessingXDSConfigs func(stream mesh_proto.GlobalKDSService_StreamXDSConfigsClient, errorCh chan error) + func NewEnvoyAdminProcessor(resManager core_manager.ReadOnlyResourceManager, configDumpFn EnvoyAdminFn, ...) EnvoyAdminProcessor + type EnvoyAdminRPCs struct + Clusters util_grpc.ReverseUnaryRPCs + Stats util_grpc.ReverseUnaryRPCs + XDSConfigDump util_grpc.ReverseUnaryRPCs + func NewEnvoyAdminRPCs() EnvoyAdminRPCs + type GlobalKDSServiceServer struct + func NewGlobalKDSServiceServer(envoyAdminRPCs EnvoyAdminRPCs) *GlobalKDSServiceServer + func (g *GlobalKDSServiceServer) StreamClusters(stream mesh_proto.GlobalKDSService_StreamClustersServer) error + func (g *GlobalKDSServiceServer) StreamStats(stream mesh_proto.GlobalKDSService_StreamStatsServer) error + func (g *GlobalKDSServiceServer) StreamXDSConfigs(stream mesh_proto.GlobalKDSService_StreamXDSConfigsServer) error
Go to main page