nsqx

type Consumer struct {
	Topic   string
	Channel string
	Method  string
	// contains filtered or unexported fields
}

type ConsumerConfiguration struct {
	NSQ           *nsq.Config
	LookupAddress []string
	Concurrency   int
	MaxInFlight   int
	MaxAttempts   uint16
}

type ConsumerController struct {
	// contains filtered or unexported fields
}

type ConsumerHandler func(ctx context.Context, consumer *Consumer) error

type ConsumerInterceptor func(ctx context.Context, consumer *Consumer, handler ConsumerHandler) error

type ConsumerItf interface {
	Handle(ctx context.Context, message *nsq.Message) error
}

type ConsumerParam struct {
	Topic    string
	Channel  string
	Config   *ConsumerConfiguration
	Consumer ConsumerItf
}

type FuncConsumer func(ctx context.Context, message *nsq.Message) error

type MockConsumerItf struct {
	// contains filtered or unexported fields
}

type MockConsumerItfMockRecorder struct {
	// contains filtered or unexported fields
}

type MockProducerItf struct {
	// contains filtered or unexported fields
}

type MockProducerItfMockRecorder struct {
	// contains filtered or unexported fields
}

type Producer struct {
	// contains filtered or unexported fields
}

type ProducerConfiguration struct {
	NSQ           *nsq.Config
	DaemonAddress string
	MaxAttempt    int
}

type ProducerItf interface {
	// Publish sends data to nsq.
	// Data should be json bytes but the struct or map.
	Publish(ctx context.Context, topic string, data interface{}) error

	// DeferredPublish sends data to nsq after certain delay.
	DeferredPublish(ctx context.Context, topic string, delay time.Duration, data interface{}) error
}