Versions in this module Expand all Collapse all v1 v1.0.0 Jun 17, 2026 Changes in this version + type EtcdClient struct + type EtcdPubSub struct + Channel string + func (ePubSub *EtcdPubSub) Close() error + func (ePubSub *EtcdPubSub) Publish(msg string) error + func (ePubSub *EtcdPubSub) ReceiveMessage() chan string + func (ePubSub *EtcdPubSub) SetChannel(channel string) i.IPubSub + func (ePubSub *EtcdPubSub) SetClient(iClient *i.IClient) i.IPubSub + type EtcdQueue struct + Topic string + func (eq *EtcdQueue) Dequeue() (string, error) + func (eq *EtcdQueue) Enqueue(val string) error + func (eq *EtcdQueue) SetClient(iClient *i.IClient) i.IQueue + func (eq *EtcdQueue) SetTopic(topic string) i.IQueue
Go to main page