messaging

Documentation

Index

• type Message
  • func NewPubSub(project, topic string) (*Message, error)
  • func NewPubSubWithOpts(project, topic string, opts *Opts) (*Message, error)
  • func NewSubscription(project, subName string) (*Message, error)
  • func (m *Message) Receive(callback func(ctx context.Context, msg *pubsub.Message)) error
  • func (m *Message) Send(msg []byte) bool
  • func (m *Message) SendBackground(msg []byte)
  • func (m *Message) SendWithID(msg []byte) (string, error)
  • func (m *Message) Stop()
• type Opts

Types

type Message

type Message struct {
	Project   string
	SubName   string
	TopicName string

	Timeout int
	// 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

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

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

func NewSubscription

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

NewSubscription method will create a subscription

func (*Message) Receive

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

Receive method will create a receiver for the subscription

func (*Message) Send

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

Send will check whether message delivery was acknowledged by the service

func (*Message) SendBackground

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

SendBackground delivers the message in background

func (*Message) SendWithID

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

SendWithID will check whether message delivery was acknowledged by the service

func (*Message) Stop

func (m *Message) Stop()

Stop method will stop all the go-routines

type Opts

type Opts struct {
	CredentialsFile string
	Timeout         int
	CredentialsJson []byte
}