Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EtcdClient ¶
type EtcdPubSub ¶
type EtcdPubSub struct { EtcdClient Channel string }
func (*EtcdPubSub) Close ¶
func (ePubSub *EtcdPubSub) Close() error
func (*EtcdPubSub) Publish ¶
func (ePubSub *EtcdPubSub) Publish(msg string) error
func (*EtcdPubSub) ReceiveMessage ¶
func (ePubSub *EtcdPubSub) ReceiveMessage() chan string
func (*EtcdPubSub) SetChannel ¶
func (ePubSub *EtcdPubSub) SetChannel(channel string) i.IPubSub
type EtcdQueue ¶
type EtcdQueue struct { EtcdClient Topic string }
Click to show internal directories.
Click to hide internal directories.