Documentation
¶
Index ¶
- type EventLabel
- type Information
- type PublisherLabel
- type SubscriberLabel
- type SupbInfoBase
- func (r *SupbInfoBase) Close() error
- func (r *SupbInfoBase) InitFlags(flags *pflag.FlagSet)
- func (r *SupbInfoBase) InitViper(viper *viper.Viper)
- func (r *SupbInfoBase) Initialize(opts ...option)
- func (r *SupbInfoBase) OptionConfig(opts ...option)
- func (r *SupbInfoBase) Publish(label PublisherLabel, event EventLabel, data Information) error
- func (r *SupbInfoBase) Subscribe(label SubscriberLabel, event EventLabel) (<-chan Information, error)
- func (r *SupbInfoBase) UnSubscribe(label SubscriberLabel, event EventLabel)
- func (r *SupbInfoBase) ViperConfig(viper *viper.Viper)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventLabel ¶
type EventLabel string
type Information ¶
type Information interface {
DeepCopy() Information
}
type PublisherLabel ¶
type PublisherLabel string
type SubscriberLabel ¶
type SubscriberLabel string
type SupbInfoBase ¶
type SupbInfoBase struct {
// contains filtered or unexported fields
}
func NewInformer ¶
func NewInformer(ctx context.Context, prefix string) *SupbInfoBase
func (*SupbInfoBase) Close ¶
func (r *SupbInfoBase) Close() error
func (*SupbInfoBase) InitFlags ¶
func (r *SupbInfoBase) InitFlags(flags *pflag.FlagSet)
func (*SupbInfoBase) InitViper ¶
func (r *SupbInfoBase) InitViper(viper *viper.Viper)
func (*SupbInfoBase) Initialize ¶
func (r *SupbInfoBase) Initialize(opts ...option)
func (*SupbInfoBase) OptionConfig ¶
func (r *SupbInfoBase) OptionConfig(opts ...option)
func (*SupbInfoBase) Publish ¶
func (r *SupbInfoBase) Publish(label PublisherLabel, event EventLabel, data Information) error
func (*SupbInfoBase) Subscribe ¶
func (r *SupbInfoBase) Subscribe(label SubscriberLabel, event EventLabel) (<-chan Information, error)
func (*SupbInfoBase) UnSubscribe ¶
func (r *SupbInfoBase) UnSubscribe(label SubscriberLabel, event EventLabel)
func (*SupbInfoBase) ViperConfig ¶
func (r *SupbInfoBase) ViperConfig(viper *viper.Viper)
Source Files
Click to show internal directories.
Click to hide internal directories.