Documentation ¶
Index ¶
- type CommunitiesBroker
- func (c *CommunitiesBroker) Close() error
- func (c *CommunitiesBroker) Open(ctx context.Context, brokerURL string) error
- func (c *CommunitiesBroker) PublishInput(ctx context.Context, input brokers.Input, community string) error
- func (c *CommunitiesBroker) PublishKick(ctx context.Context, kick brokers.Kick) error
- func (c *CommunitiesBroker) SubscribeToInputs(ctx context.Context, errs chan error, community string) (chan brokers.Input, func() error)
- func (c *CommunitiesBroker) SubscribeToKicks(ctx context.Context, errs chan error) (chan brokers.Kick, func() error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommunitiesBroker ¶
type CommunitiesBroker struct {
// contains filtered or unexported fields
}
func NewCommunitiesBroker ¶
func NewCommunitiesBroker() *CommunitiesBroker
func (*CommunitiesBroker) Close ¶
func (c *CommunitiesBroker) Close() error
func (*CommunitiesBroker) Open ¶
func (c *CommunitiesBroker) Open(ctx context.Context, brokerURL string) error
func (*CommunitiesBroker) PublishInput ¶
func (*CommunitiesBroker) PublishKick ¶
func (*CommunitiesBroker) SubscribeToInputs ¶
func (*CommunitiesBroker) SubscribeToKicks ¶
Click to show internal directories.
Click to hide internal directories.