Documentation
¶
Overview ¶
Package grpc provides a gRPC implementation of the Envoy v2 xDS API.
Index ¶
- Constants
- func NewAPI(l log.Logger, t *contour.Translator) *grpc.Server
- type CDS
- type ClusterCache
- type ClusterLoadAssignmentCache
- type EDS
- func (e *EDS) FetchEndpoints(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
- func (e *EDS) Resources() ([]*types.Any, error)
- func (e *EDS) StreamEndpoints(srv v2.EndpointDiscoveryService_StreamEndpointsServer) (err1 error)
- func (e *EDS) StreamLoadStats(srv v2.EndpointDiscoveryService_StreamLoadStatsServer) error
- func (e *EDS) TypeURL() string
- type LDS
- type ListenerCache
- type RDS
Constants ¶
const ( EndpointType = typePrefix + "ClusterLoadAssignment" ClusterType = typePrefix + "Cluster" RouteType = typePrefix + "RouteConfiguration" ListenerType = typePrefix + "Listener" )
Resource types in xDS v2.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CDS ¶
type CDS struct {
log.Logger
ClusterCache
// contains filtered or unexported fields
}
CDS implements the CDS v2 gRPC API.
func (*CDS) FetchClusters ¶
func (c *CDS) FetchClusters(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
func (*CDS) Resources ¶
Resources returns the contents of CDS"s cache as a []*types.Any. TODO(dfc) cache the results of Resources in the ClusterCache so we can avoid the error handling.
func (*CDS) StreamClusters ¶
func (c *CDS) StreamClusters(srv v2.ClusterDiscoveryService_StreamClustersServer) (err1 error)
type ClusterCache ¶
type ClusterCache interface {
// Values returns a copy of the contents of the cache.
// The slice and its contents should be treated as read-only.
Values() []*v2.Cluster
// Register registers ch to receive a value when Notify is called.
Register(chan int, int)
}
ClusterCache holds a set of computed v2.Cluster resources.
type ClusterLoadAssignmentCache ¶
type ClusterLoadAssignmentCache interface {
// Values returns a copy of the contents of the cache.
// The slice and its contents should be treated as read-only.
Values() []*v2.ClusterLoadAssignment
// Register registers ch to receive a value when Notify is called.
Register(chan int, int)
}
ClusterLoadAssignmentCache holds a set of computed v2.ClusterLoadAssignment resources.
type EDS ¶
type EDS struct {
log.Logger
ClusterLoadAssignmentCache
// contains filtered or unexported fields
}
EDS implements the EDS v2 gRPC API.
func (*EDS) FetchEndpoints ¶
func (e *EDS) FetchEndpoints(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
func (*EDS) Resources ¶
Resources returns the contents of EDS"s cache as a []*types.Any. TODO(dfc) cache the results of Resources in the ClusterLoadAssignmentCache so we can avoid the error handling.
func (*EDS) StreamEndpoints ¶
func (e *EDS) StreamEndpoints(srv v2.EndpointDiscoveryService_StreamEndpointsServer) (err1 error)
func (*EDS) StreamLoadStats ¶
func (e *EDS) StreamLoadStats(srv v2.EndpointDiscoveryService_StreamLoadStatsServer) error
type LDS ¶
type LDS struct {
log.Logger
ListenerCache
// contains filtered or unexported fields
}
LDS implements the LDS v2 gRPC API.
func (*LDS) FetchListeners ¶
func (l *LDS) FetchListeners(ctx context.Context, req *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
func (*LDS) Resources ¶
Resources returns the contents of LDS"s cache as a []*types.Any. TODO(dfc) cache the results of Resources in the ListenerCache so we can avoid the error handling.
func (*LDS) StreamListeners ¶
func (l *LDS) StreamListeners(srv v2.ListenerDiscoveryService_StreamListenersServer) (err1 error)
type ListenerCache ¶
type ListenerCache interface {
// Values returns a copy of the contents of the cache.
// The slice and its contents should be treated as read-only.
Values() []*v2.Listener
// Register registers ch to receive a value when Notify is called.
Register(chan int, int)
}
ListenerCache holds a set of computed v2.Listener resources.
type RDS ¶
type RDS struct {
log.Logger
HTTP, HTTPS values
*contour.Cond
// contains filtered or unexported fields
}
RDS implements the RDS v2 gRPC API.
func (*RDS) FetchRoutes ¶
func (r *RDS) FetchRoutes(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
func (*RDS) Resources ¶
Resources returns the contents of RDS"s cache as a []*types.Any. TODO(dfc) cache the results of Resources in the VirtualHostCache so we can avoid the error handling.
func (*RDS) StreamRoutes ¶
func (r *RDS) StreamRoutes(srv v2.RouteDiscoveryService_StreamRoutesServer) (err1 error)
Source Files