Versions in this module Expand all Collapse all v1 v1.0.0 Dec 28, 2024 Changes in this version + type Pubsub struct + func New(watchExpiryTimeout time.Duration, logger dubbogoLogger.Logger) *Pubsub + func (pb *Pubsub) Close() + func (pb *Pubsub) Dump(t resource.ResourceType) map[string]resource.UpdateWithMD + func (pb *Pubsub) NewClusters(updates map[string]resource.ClusterUpdateErrTuple, ...) + func (pb *Pubsub) NewConnectionError(err error) + func (pb *Pubsub) NewEndpoints(updates map[string]resource.EndpointsUpdateErrTuple, ...) + func (pb *Pubsub) NewListeners(updates map[string]resource.ListenerUpdateErrTuple, ...) + func (pb *Pubsub) NewRouteConfigs(updates map[string]resource.RouteConfigUpdateErrTuple, ...) + func (pb *Pubsub) WatchCluster(clusterName string, cb func(resource.ClusterUpdate, error)) (first bool, cancel func() bool) + func (pb *Pubsub) WatchEndpoints(clusterName string, cb func(resource.EndpointsUpdate, error)) (first bool, cancel func() bool) + func (pb *Pubsub) WatchListener(serviceName string, cb func(resource.ListenerUpdate, error)) (first bool, cancel func() bool) + func (pb *Pubsub) WatchRouteConfig(routeName string, cb func(resource.RouteConfigUpdate, error)) (first bool, cancel func() bool) + type UpdateHandler interface + NewClusters func(map[string]resource.ClusterUpdateErrTuple, resource.UpdateMetadata) + NewConnectionError func(err error) + NewEndpoints func(map[string]resource.EndpointsUpdateErrTuple, resource.UpdateMetadata) + NewListeners func(map[string]resource.ListenerUpdateErrTuple, resource.UpdateMetadata) + NewRouteConfigs func(map[string]resource.RouteConfigUpdateErrTuple, resource.UpdateMetadata)
Go to main page