Documentation ¶
Index ¶
- func NewTickProducer(name string, seedBrokers []string) gen.ServerBehavior
- func NewWebsocketProducer(name, url string, seedBrokers []string) gen.ServerBehavior
- type TickProducer
- func (p *TickProducer) HandleCall(process *gen.ServerProcess, from gen.ServerFrom, message etf.Term) (etf.Term, gen.ServerStatus)
- func (p *TickProducer) HandleCast(process *gen.ServerProcess, message etf.Term) gen.ServerStatus
- func (p *TickProducer) Init(process *gen.ServerProcess, args ...etf.Term) error
- func (p *TickProducer) Terminate(process *gen.ServerProcess, reason string)
- type WebsocketProducer
- func (p *WebsocketProducer) HandleCall(process *gen.ServerProcess, from gen.ServerFrom, message etf.Term) (etf.Term, gen.ServerStatus)
- func (p *WebsocketProducer) HandleCast(process *gen.ServerProcess, message etf.Term) gen.ServerStatus
- func (p *WebsocketProducer) Init(process *gen.ServerProcess, args ...etf.Term) error
- func (p *WebsocketProducer) Terminate(process *gen.ServerProcess, reason string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTickProducer ¶
func NewTickProducer(name string, seedBrokers []string) gen.ServerBehavior
func NewWebsocketProducer ¶
func NewWebsocketProducer(name, url string, seedBrokers []string) gen.ServerBehavior
Types ¶
type TickProducer ¶
func (*TickProducer) HandleCall ¶
func (p *TickProducer) HandleCall(process *gen.ServerProcess, from gen.ServerFrom, message etf.Term) (etf.Term, gen.ServerStatus)
func (*TickProducer) HandleCast ¶
func (p *TickProducer) HandleCast(process *gen.ServerProcess, message etf.Term) gen.ServerStatus
func (*TickProducer) Init ¶
func (p *TickProducer) Init(process *gen.ServerProcess, args ...etf.Term) error
func (*TickProducer) Terminate ¶
func (p *TickProducer) Terminate(process *gen.ServerProcess, reason string)
type WebsocketProducer ¶
func (*WebsocketProducer) HandleCall ¶
func (p *WebsocketProducer) HandleCall(process *gen.ServerProcess, from gen.ServerFrom, message etf.Term) (etf.Term, gen.ServerStatus)
func (*WebsocketProducer) HandleCast ¶
func (p *WebsocketProducer) HandleCast(process *gen.ServerProcess, message etf.Term) gen.ServerStatus
func (*WebsocketProducer) Init ¶
func (p *WebsocketProducer) Init(process *gen.ServerProcess, args ...etf.Term) error
func (*WebsocketProducer) Terminate ¶
func (p *WebsocketProducer) Terminate(process *gen.ServerProcess, reason string)
Click to show internal directories.
Click to hide internal directories.