publisher

package

v0.0.0-...-b56df8a Latest Latest Go to latest Published: Jul 24, 2017 License: MIT Imports: 6 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

This section is empty.

View Source

var MockMessageReceiver map[string]chan []byte

MockMessageReceiver is a channel that can take []byte messages that will be sent from the mock publisher

func TurnMockModOff()

TurnMockModOff will disable the consumer New method to return with Mock struct instead of the real one. This is only for testing purpose!

func TurnMockModOn()

TurnMockModOn will enable the consumer New method to return with Mock struct instead of the real one. This is only for testing purpose!

type Options interface {
	Configure(config *config)
}

Options is the public interface when working with options

type Publisher interface {
	Publish(...[]byte) ([]string, error)
}

Publisher is the public interface when you work with the publisher package This is used to force the developer writing code that can be tested easily

func New(ctx context.Context, topicName string, opts ...Options) Publisher

New will return a new publisher object that can publish []byte messages to a given google cloud pubsub topic