Documentation ¶
Index ¶
- type ISyncService
- type Multiplexer
- func (r *Multiplexer) GetAllFlags(source string) (string, error)
- func (r *Multiplexer) Publish() error
- func (r *Multiplexer) Register(id interface{}, source string, con chan payload) error
- func (r *Multiplexer) SourcesAsMetadata() string
- func (r *Multiplexer) Unregister(id interface{}, selector string)
- type Service
- type SvcConfigurations
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ISyncService ¶
type Multiplexer ¶
type Multiplexer struct {
// contains filtered or unexported fields
}
Multiplexer abstract subscription handling and storage processing. Flag configurations will be lazy loaded using reFill logic upon the calls to publish.
func NewMux ¶
func NewMux(store *store.Flags, sources []string) (*Multiplexer, error)
NewMux creates a new sync multiplexer
func (*Multiplexer) GetAllFlags ¶
func (r *Multiplexer) GetAllFlags(source string) (string, error)
GetAllFlags per specific source
func (*Multiplexer) Publish ¶
func (r *Multiplexer) Publish() error
Publish sync updates to subscriptions
func (*Multiplexer) Register ¶
func (r *Multiplexer) Register(id interface{}, source string, con chan payload) error
Register a subscription
func (*Multiplexer) SourcesAsMetadata ¶
func (r *Multiplexer) SourcesAsMetadata() string
SourcesAsMetadata returns all known sources, comma separated to be used as service metadata
func (*Multiplexer) Unregister ¶
func (r *Multiplexer) Unregister(id interface{}, selector string)
Unregister a subscription
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewSyncService ¶
func NewSyncService(cfg SvcConfigurations) (*Service, error)
Click to show internal directories.
Click to hide internal directories.