topic

Documentation

Index

• func Create(topicName string) error
• func CreateSubscription(topicName string, subName string)
• func Delete(topicName string) (bool, error)
• func Exists(topicName string) (bool, error)
• func Init(clientId string)
• func Publish(topicName string, message interface{}) (bool, error)
• func Receive(subName string) ([]topicres.Receive, error)
• func Subscriptions(topicName string) (topicres.Subscriptions, error)
• func Topics() topicres.Topics

Functions

func Create

func Create(topicName string) error

Create a new topic in project

func CreateSubscription

func CreateSubscription(topicName string, subName string)

CreateSubscription a new sub in project

func Delete

func Delete(topicName string) (bool, error)

Delete topic in project

func Exists

func Exists(topicName string) (bool, error)

Exists topic control in project

func Init

func Init(clientId string)

Init must call one time every operation

func Publish

func Publish(topicName string, message interface{}) (bool, error)

Publish a new message to sub

func Receive

func Receive(subName string) ([]topicres.Receive, error)

Receive get message to sub

func Subscriptions

func Subscriptions(topicName string) (topicres.Subscriptions, error)

Subscriptions list in a project

func Topics

func Topics() topicres.Topics

Topics list in project