google_pub_sub

Documentation

Index

• type GooglePubSub
  • func (k *GooglePubSub) GetName() string
  • func (k *GooglePubSub) Initialize(configuration util.Configuration, prefix string) (err error)
  • func (k *GooglePubSub) SendMessage(key string, message proto.Message) (err error)

Types

type GooglePubSub

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

func (*GooglePubSub) GetName

func (k *GooglePubSub) GetName() string

func (*GooglePubSub) Initialize

func (k *GooglePubSub) Initialize(configuration util.Configuration, prefix string) (err error)

func (*GooglePubSub) SendMessage

func (k *GooglePubSub) SendMessage(key string, message proto.Message) (err error)