eventbus

Documentation

Index

• type NSQClient
  • func InitTestPublisher(t *testing.T) *NSQClient
  • func NewNSQ(publisherConfig *bus.PublisherConfig, logger *zap.Logger, ...) NSQClient
  • func (n *NSQClient) CreateEndpoints(lookupds ...string) error
  • func (n NSQClient) CreateTopic(partitionID, topicFQN string) error
  • func (n *NSQClient) WaitForPublisher()
  • func (n NSQClient) WaitForTopicsCreated(partitions metal.Partitions, topics []metal.NSQTopic)
• type PublisherProvider

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 InitTestPublisher(t *testing.T) *NSQClient

func NewNSQ

func NewNSQ(publisherConfig *bus.PublisherConfig, logger *zap.Logger, publisherProvider PublisherProvider) NSQClient

NewNSQ create a new NSQClient.

func (*NSQClient) CreateEndpoints

func (n *NSQClient) CreateEndpoints(lookupds ...string) error

func (NSQClient) CreateTopic

func (n NSQClient) CreateTopic(partitionID, topicFQN string) error

CreateTopic creates a topic for the given partition.

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

type PublisherProvider func(*zap.Logger, *bus.PublisherConfig) (bus.Publisher, error)