subscription

package

v25.5.0 Latest Latest Go to latest Published: Oct 13, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Poller struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Poller is used to poll user subscription query.

func NewPoller(globalEpoch *uint64, resolver *resolve.RequestResolver) *Poller

NewPoller returns Poller.

func (p *Poller) AddSubscriber(req *schema.Request) (*SubscriberResponse, error)

func (p *Poller) TerminateSubscription(bucketID, subscriptionID uint64)

type SubscriberResponse struct {
	BucketID       uint64
	SubscriptionID uint64
	UpdateCh       chan interface{}
}

SubscriberResponse holds the meta data about subscriber.