service

Documentation

Index

• type EnvoyAdminFn
• type EnvoyAdminProcessor
  • func NewEnvoyAdminProcessor(resManager core_manager.ReadOnlyResourceManager, configDumpFn EnvoyAdminFn, ...) EnvoyAdminProcessor
• type EnvoyAdminRPCs
  • func NewEnvoyAdminRPCs() EnvoyAdminRPCs
• type GlobalKDSServiceServer
  • 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

Types

type EnvoyAdminFn

type EnvoyAdminFn = func(ctx context.Context, proxy core_model.ResourceWithAddress) ([]byte, error)

type EnvoyAdminProcessor

type EnvoyAdminProcessor interface {
	StartProcessingXDSConfigs(stream mesh_proto.GlobalKDSService_StreamXDSConfigsClient, errorCh chan error)
	StartProcessingStats(stream mesh_proto.GlobalKDSService_StreamStatsClient, errorCh chan error)
	StartProcessingClusters(stream mesh_proto.GlobalKDSService_StreamClustersClient, errorCh chan error)
}

func NewEnvoyAdminProcessor

func NewEnvoyAdminProcessor(
	resManager core_manager.ReadOnlyResourceManager,
	configDumpFn EnvoyAdminFn,
	statsFn EnvoyAdminFn,
	clustersFn EnvoyAdminFn,
) EnvoyAdminProcessor

type EnvoyAdminRPCs

type EnvoyAdminRPCs struct {
	XDSConfigDump util_grpc.ReverseUnaryRPCs
	Stats         util_grpc.ReverseUnaryRPCs
	Clusters      util_grpc.ReverseUnaryRPCs
}

func NewEnvoyAdminRPCs

func NewEnvoyAdminRPCs() EnvoyAdminRPCs

type GlobalKDSServiceServer

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

func NewGlobalKDSServiceServer

func NewGlobalKDSServiceServer(envoyAdminRPCs EnvoyAdminRPCs) *GlobalKDSServiceServer

func (*GlobalKDSServiceServer) StreamClusters

func (g *GlobalKDSServiceServer) StreamClusters(stream mesh_proto.GlobalKDSService_StreamClustersServer) error

func (*GlobalKDSServiceServer) StreamStats

func (g *GlobalKDSServiceServer) StreamStats(stream mesh_proto.GlobalKDSService_StreamStatsServer) error

func (*GlobalKDSServiceServer) StreamXDSConfigs

func (g *GlobalKDSServiceServer) StreamXDSConfigs(stream mesh_proto.GlobalKDSService_StreamXDSConfigsServer) error