nsq

type GobMarshaler struct{}

type Marshaler interface {
	Marshal(topic string, msg *message.Message) ([]byte, error)
}

type MarshalerUnmarshaler interface {
	Marshaler
	Unmarshaler
}

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

type NsqPublisherConfig struct {
	NsqD string

	// nsq config
	*stdnsq.Config

	// Marshaler is marshaler used to marshal messages to stan format.
	Marshaler Marshaler
}

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

type NsqSubscriberConfig struct {
	// nsq config
	// nsq increse MaxAttempts to avoid TestResendOnError, see github.com/ThreeDotsLabs/watermill/pubsub/tests/test_pubsub.go L54
	*nsq.Config
	LookupdAddrs []string
	NsqdAddrs    []string
	GroupName    string

	// CloseTimeout determines how long subscriber will wait for Ack/Nack on close.
	// When no Ack/Nack is received after CloseTimeout, subscriber will be closed.
	CloseTimeout time.Duration

	// How long subscriber should wait for Ack/Nack. When no Ack/Nack was received, message will be redelivered.
	// It is mapped to stan.AckWait option.
	AckWaitTimeout time.Duration

	// Requeue delay, default 1s
	//
	RequeueTimeout time.Duration

	// Unmarshaler is an unmarshaler used to unmarshaling messages from NATS format to Watermill format.
	Unmarshaler Unmarshaler
}

type Unmarshaler interface {
	Unmarshal(*nsq.Message) (*message.Message, error)
}