Documentation
¶
Index ¶
- Constants
- type Plugin
- func (p *Plugin) Available()
- func (p *Plugin) Init(log logger.Logger) error
- func (p *Plugin) Name() string
- func (p *Plugin) Next() (*message.Message, error)
- func (p *Plugin) Publish(messages []byte) error
- func (p *Plugin) PublishAsync(messages []byte)
- func (p *Plugin) Subscribe(topics ...string) error
- func (p *Plugin) Unsubscribe(topics ...string) error
Constants ¶
View Source
const (
PluginName string = "memory"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Plugin ¶
type Plugin struct {
// contains filtered or unexported fields
}
func (*Plugin) Available ¶ added in v2.4.0
func (p *Plugin) Available()
Available interface implementation for the plugin
func (*Plugin) PublishAsync ¶
func (*Plugin) Unsubscribe ¶
Source Files
Click to show internal directories.
Click to hide internal directories.