nsq

type ConsumerClient struct {
	NSQDAddresses []string
	// contains filtered or unexported fields
}

type ConsumerConfig struct {
	Topic        string
	Channel      string
	Address      string
	Lookup       []string
	MaxInFlight  int
	Identify     nsq.IdentifyResponse
	DialTimeout  time.Duration
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	DrainTimeout time.Duration
}

type Identify struct {
	// ClientID should be set to a unique identifier representing the client.
	ClientID string `json:"client_id"`

	// Hostname represents the hostname of the client, by default it is set to
	// the value returned by os.Hostname is used.
	Hostname string `json:"hostname"`

	// UserAgent represents the type of the client, by default it is set to
	// nsq.DefaultUserAgent.
	UserAgent string `json:"user_agent"`

	// MessageTimeout can bet set to configure the server-side message timeout
	// for messages delivered to this consumer.  By default it is not sent to
	// the server.
	MessageTimeout time.Duration `json:"message_timeout"`
}

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

type ManagerConfig struct {
	Configs []*ProducerManagerConfig `json:"configs"`
}

type NodeData struct {
	RemoteAddr    string      `json:"remote_address"`
	HostName      string      `json:"hostname"`
	BroadcastAddr string      `json:"broadcast_address"`
	TCPPort       int         `json:"tcp_port"`
	HTTPPort      int         `json:"http_port"`
	Version       string      `json:"version"`
	Tombstones    interface{} `json:"tombstones"`
	Topics        interface{} `json:"topics"`
}

type NodesData struct {
	Producers []*NodeData `json:"producers"`
}

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

type ProducerConfig struct {
	FailOnConnErr  bool
	MaxConcurrency int
	Address        string
	Topic          string
	DialTimeout    time.Duration
	ReadTimeout    time.Duration
	WriteTimeout   time.Duration
}

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

type ProducerManagerConfig struct {
	Category        string            `json:"category"`
	ProducerConfigs []*ProducerConfig `json:"producerConfigs"`
	PoolSize        int
}

type PublishData struct {
	TopicName string
	Body      []byte
}