broadcast

Documentation

Index

• type Broadcaster
  • func (b *Broadcaster) Subscribe(ctx context.Context, connect ConnectFunc) (chan map[string]interface{}, error)
• type ConnectFunc
• type GenericBroadcaster
  • func (b *GenericBroadcaster) Subscribe(ctx context.Context, connect GenericConnectFunc) (chan interface{}, error)
• type GenericConnectFunc

Types

type Broadcaster

type Broadcaster struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Broadcaster) Subscribe

func (b *Broadcaster) Subscribe(ctx context.Context, connect ConnectFunc) (chan map[string]interface{}, error)

type ConnectFunc

type ConnectFunc func() (chan map[string]interface{}, error)

type GenericBroadcaster

type GenericBroadcaster struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*GenericBroadcaster) Subscribe

func (b *GenericBroadcaster) Subscribe(ctx context.Context, connect GenericConnectFunc) (chan interface{}, error)

type GenericConnectFunc

type GenericConnectFunc func() (chan interface{}, error)