pubsub

Dec 16, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 25, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 24, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 10, 2023 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 8, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Nov 18, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 4, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 14, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Oct 6, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 15, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Aug 23, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 1, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jul 12, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 23, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 31, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 6, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

May 13, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 22, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Apr 22, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Feb 22, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Mar 9, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 11, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Jan 25, 2022 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 6, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Dec 14, 2021 GO-2023-2153

  GO-2023-2153: Denial of service from HTTP/2 Rapid Reset in google.golang.org/grpc

Changes in this version

+ type Pubsub struct

+ func New(watchExpiryTimeout time.Duration, logger *grpclog.PrefixLogger) *Pubsub

+ func (pb *Pubsub) Close()

+ func (pb *Pubsub) Dump(t xdsresource.ResourceType) map[string]xdsresource.UpdateWithMD

+ func (pb *Pubsub) NewClusters(updates map[string]xdsresource.ClusterUpdateErrTuple, ...)

+ func (pb *Pubsub) NewConnectionError(err error)

+ func (pb *Pubsub) NewEndpoints(updates map[string]xdsresource.EndpointsUpdateErrTuple, ...)

+ func (pb *Pubsub) NewListeners(updates map[string]xdsresource.ListenerUpdateErrTuple, ...)

+ func (pb *Pubsub) NewRouteConfigs(updates map[string]xdsresource.RouteConfigUpdateErrTuple, ...)

+ func (pb *Pubsub) WatchCluster(clusterName string, cb func(xdsresource.ClusterUpdate, error)) (first bool, cancel func() bool)

+ func (pb *Pubsub) WatchEndpoints(clusterName string, cb func(xdsresource.EndpointsUpdate, error)) (first bool, cancel func() bool)

+ func (pb *Pubsub) WatchListener(serviceName string, cb func(xdsresource.ListenerUpdate, error)) (first bool, cancel func() bool)

+ func (pb *Pubsub) WatchRouteConfig(routeName string, cb func(xdsresource.RouteConfigUpdate, error)) (first bool, cancel func() bool)

+ type UpdateHandler interface

+ NewClusters func(map[string]xdsresource.ClusterUpdateErrTuple, xdsresource.UpdateMetadata)

+ NewConnectionError func(err error)

+ NewEndpoints func(map[string]xdsresource.EndpointsUpdateErrTuple, xdsresource.UpdateMetadata)

+ NewListeners func(map[string]xdsresource.ListenerUpdateErrTuple, xdsresource.UpdateMetadata)

+ NewRouteConfigs func(map[string]xdsresource.RouteConfigUpdateErrTuple, xdsresource.UpdateMetadata)