consumer

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

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

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

type Options struct {
	Channel string `flag:"channel"`

	ConsumerOpts             []string      `flag:"consumer-opt"`
	MaxInFlight              int           `flag:"max-in-flight"`
	HTTPClientConnectTimeout time.Duration `flag:"http-client-connect-timeout"`
	HTTPClientRequestTimeout time.Duration `flag:"http-client-request-timeout"`

	LogPrefix string `flag:"log-prefix"`
	LogLevel  string `flag:"log-level"`
	OutputDir string `flag:"output-dir"`
	WorkDir   string `flag:"work-dir"`
	// DatetimeFormat string        `flag:"datetime-format"`
	SyncInterval time.Duration `flag:"sync-interval"`
}