Documentation
¶
Index ¶
- func ControlPlane() *corev3.ControlPlane
- func MessageToAny(msg proto.Message) *anypb.Any
- func MessageToAnyWithError(msg proto.Message) (*anypb.Any, error)
- type DeltaStream
- type IstioControlPlaneInstance
- type SendQueue
- type Server
- func (s *Server) DeltaAggregatedResources(stream discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
- func (s *Server) Send(stream DeltaStream, ch chan *SendQueue, log logr.Logger)
- func (s *Server) StreamAggregatedResources(stream discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
- func (s *Server) StreamDeltas(stream DeltaStream) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ControlPlane ¶
func ControlPlane() *corev3.ControlPlane
ControlPlane identifies the instance and Istio version.
func MessageToAny ¶
MessageToAny converts from proto message to proto Any
Types ¶
type DeltaStream ¶
type DeltaStream discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer
type IstioControlPlaneInstance ¶
type IstioControlPlaneInstance struct {
// The Istio component type (e.g. "istiod")
Component string
// The ID of the component instance
ID string
// The Istio version
Info istioversion.BuildInfo
}
IstioControlPlaneInstance defines the format Istio uses for when creating Envoy config.core.v3.ControlPlane.identifier
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) DeltaAggregatedResources ¶
func (s *Server) DeltaAggregatedResources(stream discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
func (*Server) Send ¶
func (s *Server) Send(stream DeltaStream, ch chan *SendQueue, log logr.Logger)
func (*Server) StreamAggregatedResources ¶
func (s *Server) StreamAggregatedResources(stream discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
func (*Server) StreamDeltas ¶
func (s *Server) StreamDeltas(stream DeltaStream) error
Source Files
Click to show internal directories.
Click to hide internal directories.