store

Documentation

Index

• type ISyncStore
• type SyncBuilder
  • func (sb *SyncBuilder) SyncFromURI(uri string, logger *logger.Logger) (isync.ISync, error)
• type SyncBuilderInterface
• type SyncStore
  • func NewSyncStore(ctx context.Context, logger *logger.Logger) *SyncStore
  • func (s *SyncStore) FetchAllFlags(ctx context.Context, key interface{}, target string) (isync.DataSync, error)
  • func (s *SyncStore) GetActiveSubscriptionsInt64() int64
  • func (s *SyncStore) RegisterSubscription(ctx context.Context, target string, key interface{}, ...)

Types

type ISyncStore

type ISyncStore 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
}

ISyncStore defines the interface for the sync store

type SyncBuilder

type SyncBuilder struct{}

func (*SyncBuilder) SyncFromURI

func (sb *SyncBuilder) SyncFromURI(uri string, logger *logger.Logger) (isync.ISync, error)

SyncFromURI builds an ISync interface from the input uri string

type SyncBuilderInterface

type SyncBuilderInterface interface {
	SyncFromURI(uri string, logger *logger.Logger) (isync.ISync, error)
}

type SyncStore

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

func NewSyncStore

func NewSyncStore(ctx context.Context, logger *logger.Logger) *SyncStore

NewSyncStore returns a new sync store

func (*SyncStore) FetchAllFlags

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

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

func (*SyncStore) GetActiveSubscriptionsInt64

func (s *SyncStore) GetActiveSubscriptionsInt64() int64

func (*SyncStore) RegisterSubscription

func (s *SyncStore) 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.