messaging

package

v1.1.16 Latest Latest Go to latest Published: May 7, 2024 License: MIT Imports: 4 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.

This section is empty.

This section is empty.

type Message struct {
	Project   string
	SubName   string
	TopicName string
	// contains filtered or unexported fields
}

Message struct holds the information which is required to send message to messaging services like pub/sub or kafka

func NewPubSub(project, topic string) (*Message, error)

NewPubSub function creates an instance of message which will send the data to service using the google cloud pub sub library

func NewPubSubWithOpts(project, topic string, opts *Opts) (*Message, error)

func NewSubscription(project, subName string) (*Message, error)

NewSubscription method will create a subscription

func (m *Message) Receive(callback func(ctx context.Context, msg *pubsub.Message)) error

Receive method will create a receiver for the subscription

func (m *Message) Send(msg []byte) bool

Send will check whether message delivery was acknowledged by the service

func (m *Message) SendBackground(msg []byte)

SendBackground delivers the message in background

func (m *Message) SendWithID(msg []byte) (string, error)

SendWithID will check whether message delivery was acknowledged by the service

func (m *Message) Stop()

Stop method will stop all the go-routines

type Opts struct {
	CredentialsFile string
	CredentialsJson []byte
}