producer

package

v1.1.0 Latest Latest Go to latest Published: Dec 24, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	// TPC - protocol
	TPC = "tcp"
	// HTTP - protocol
	HTTP = "http"
)

View Source

var (
	Queue  NSQ
	Config Configs
	Logger = log.New(os.Stderr, "", log.Flags())
)

func ConnHTTP(c Configs)

ConnHTTP -

func ConnTCP(c Configs) error

ConnTCP -

type Configs struct {
	Protocol string
	URL      string
	Retry    int
	Timeout  time.Duration
	LogLevel nsq.LogLevel
	Topic    string
}

Configs -

type Hconnecter struct {
	URL string
}

Hconnecter - Http

func (t *Hconnecter) Publish(topic string, d []byte) error

Publish - HTTP

func (t *Hconnecter) PublishStop()

PublishStop -

type NSQ interface {
	Publish(topic string, d []byte) error
	PublishStop()
}

NSQ - interface

type Tconnecter struct {
	URL      string
	Producer *nsq.Producer
}

Tconnecter - TPC

func (t *Tconnecter) Publish(topic string, d []byte) error

Publish - TPC

func (t *Tconnecter) PublishStop()

PublishStop -