Documentation ¶
Index ¶
- Constants
- type NSQ
- func (nm *NSQ) Close() error
- func (nm *NSQ) Fetch(target string) ([][]byte, error)
- func (nm *NSQ) Listen(target string) error
- func (nm *NSQ) Open() error
- func (nm *NSQ) Publish(target string, payload []byte) error
- func (nm *NSQ) PublishFromFile(target string, fileName string) error
- func (nm *NSQ) Ready() error
- func (nm *NSQ) Reset() error
Constants ¶
View Source
const ( DefaultWaitDuration = time.Millisecond * 50 // suffix for nsq topic/channel to make them ephemeral Ephemeral = "#ephemeral" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NSQ ¶
func (*NSQ) PublishFromFile ¶ added in v1.4.1
PublishFromFile attempts to publish a message read from a file to the passed target
Click to show internal directories.
Click to hide internal directories.