Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NSQClient ¶
type NSQClient struct { Publisher bus.Publisher Endpoints *bus.Endpoints // contains filtered or unexported fields }
NSQClient is a type to request NSQ related tasks such as creation of topics.
func InitTestPublisher ¶
func NewNSQ ¶
func NewNSQ(publisherConfig *bus.PublisherConfig, logger *slog.Logger, publisherProvider PublisherProvider) NSQClient
NewNSQ create a new NSQClient.
func (*NSQClient) CreateEndpoints ¶ added in v0.7.4
func (NSQClient) CreateTopic ¶
CreateTopic creates a topic with given name.
func (*NSQClient) WaitForPublisher ¶
func (n *NSQClient) WaitForPublisher()
WaitForPublisher blocks until the given provider is able to provide a non nil publisher.
func (NSQClient) WaitForTopicsCreated ¶
func (n NSQClient) WaitForTopicsCreated(partitions metal.Partitions, topics []metal.NSQTopic)
WaitForTopicsCreated blocks until the topices are created within the given partitions.
type PublisherProvider ¶
Click to show internal directories.
Click to hide internal directories.