broadcast

README

broadcast

RRv2 Broadcast plugin

Documentation

Index

• Constants
• type Config
• type Plugin
  • func (p *Plugin) CollectPublishers(name endure.Named, constructor pubsub.Constructor)
  • func (p *Plugin) Collects() []any
  • func (p *Plugin) GetDriver(key string) (pubsub.SubReader, error)
  • func (p *Plugin) Init(cfg config.Configurer, log *zap.Logger) error
  • func (p *Plugin) Name() string
  • func (p *Plugin) Publish(m *pubsub.Message) error
  • func (p *Plugin) PublishAsync(m *pubsub.Message)
  • func (p *Plugin) RPC() any
  • func (p *Plugin) Serve() chan error
  • func (p *Plugin) Stop() error

Constants

const (
	PluginName string = "broadcast"
)

Types

type Config

type Config struct {
	Data map[string]any `mapstructure:"broadcast"`
}

Config ...

type Plugin

type Plugin struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Plugin) CollectPublishers

func (p *Plugin) CollectPublishers(name endure.Named, constructor pubsub.Constructor)

CollectPublishers collect all plugins who implement pubsub.Publisher interface

func (*Plugin) Collects

func (p *Plugin) Collects() []any

func (*Plugin) GetDriver

func (p *Plugin) GetDriver(key string) (pubsub.SubReader, error)

func (*Plugin) Init

func (p *Plugin) Init(cfg config.Configurer, log *zap.Logger) error

func (*Plugin) Name

func (p *Plugin) Name() string

func (*Plugin) Publish

func (p *Plugin) Publish(m *pubsub.Message) error

Publish is an entry point to the websocket PUBSUB

func (*Plugin) PublishAsync

func (p *Plugin) PublishAsync(m *pubsub.Message)

func (*Plugin) RPC

func (p *Plugin) RPC() any

func (*Plugin) Serve

func (p *Plugin) Serve() chan error

func (*Plugin) Stop

func (p *Plugin) Stop() error