subscriptions

Documentation

Index

• type Coordinator
  • func NewManager(ctx context.Context, logger *logger.Logger) *Coordinator
  • func (s *Coordinator) FetchAllFlags(ctx context.Context, key interface{}, target string) (isync.DataSync, error)
  • func (s *Coordinator) GetActiveSubscriptionsInt64() int64
  • func (s *Coordinator) RegisterSubscription(ctx context.Context, target string, key interface{}, ...)
• type Manager

Types

type Coordinator

type Coordinator struct {
	// contains filtered or unexported fields
}

Coordinator coordinates subscriptions by aggregating subscribers for the same target, and keeping them up to date for any updates that have happened for those targets.

func NewManager

func NewManager(ctx context.Context, logger *logger.Logger) *Coordinator

NewManager returns a new subscription manager

func (*Coordinator) FetchAllFlags

func (s *Coordinator) FetchAllFlags(ctx context.Context, key interface{}, target string) (isync.DataSync, error)

FetchAllFlags returns a DataSync containing the full set of flag configurations from the Coordinator. This will either occur via triggering a resync, or through setting up a new subscription to the resource

func (*Coordinator) GetActiveSubscriptionsInt64

func (s *Coordinator) GetActiveSubscriptionsInt64() int64

func (*Coordinator) RegisterSubscription

func (s *Coordinator) RegisterSubscription(
	ctx context.Context,
	target string,
	key interface{},
	dataSync chan isync.DataSync,
	errChan chan error,
)

RegisterSubscription starts a new subscription to the target resource. Once the subscription is set an ALL sync event will be received via the DataSync chan.

type Manager

type Manager interface {
	FetchAllFlags(
		ctx context.Context,
		key interface{},
		target string,
	) (isync.DataSync, error)
	RegisterSubscription(
		ctx context.Context,
		target string,
		key interface{},
		dataSync chan isync.DataSync,
		errChan chan error,
	)

	// metrics hooks
	GetActiveSubscriptionsInt64() int64
}

Manager defines the interface for the subscription management