Versions in this module Expand all Collapse all v2 v2.5.0 Jan 15, 2020 Changes in this version + var DefaultPlugin = *NewPlugin() + type Deps struct + ServiceLabel servicelabel.ReaderAPI + StatusCheck statuscheck.PluginStatusWriter + type Option func(*Plugin) + func UseDeps(cb func(*Deps)) Option + type Plugin struct + func FromExistingMux(mux *mux.Multiplexer) *Plugin + func NewPlugin(opts ...Option) *Plugin + func (p *Plugin) AfterInit() error + func (p *Plugin) Close() error + func (p *Plugin) Disabled() (disabled bool) + func (p *Plugin) Init() (err error) + func (p *Plugin) NewAsyncPublisher(connectionName string, topic string, successClb func(messaging.ProtoMessage), ...) (messaging.ProtoPublisher, error) + func (p *Plugin) NewAsyncPublisherToPartition(connectionName string, topic string, partition int32, ...) (messaging.ProtoPublisher, error) + func (p *Plugin) NewBytesConnection(name string) *mux.BytesConnectionStr + func (p *Plugin) NewBytesConnectionToPartition(name string) *mux.BytesManualConnectionStr + func (p *Plugin) NewPartitionWatcher(name string) messaging.ProtoPartitionWatcher + func (p *Plugin) NewProtoConnection(name string) mux.Connection + func (p *Plugin) NewProtoManualConnection(name string) mux.ManualConnection + func (p *Plugin) NewSyncPublisher(connectionName string, topic string) (messaging.ProtoPublisher, error) + func (p *Plugin) NewSyncPublisherToPartition(connectionName string, topic string, partition int32) (messaging.ProtoPublisher, error) + func (p *Plugin) NewWatcher(name string) messaging.ProtoWatcher v2.5.0-alpha Dec 13, 2019 Other modules containing this package go.ligato.io/cn-infra
Go to main page