pubsub

Documentation

Index

• func CreateSub(config PubsubConfig, subID string, topicID string, ...) error
• func CreateTopic(config PubsubConfig, topicID string) error
• func DeleteSub(config PubsubConfig, subID string) error
• func GetSub(config PubsubConfig, subID string) (*pubsub.Client, *pubsub.Subscription, error)
• func GetSubPolicy(config PubsubConfig, subID string) (*pubsub.RetryPolicy, error)
• func ListSubscriptions(config PubsubConfig, topicID string) ([]*pubsub.Subscription, error)
• func ListTopics(config PubsubConfig) ([]*pubsub.Topic, error)
• func Publish(config PubsubConfig, topicID string, msg_data []byte) error
• func UpdateSubPolicy(config PubsubConfig, subID string, retryPolicy *pubsub.RetryPolicy) error
• type MessageCount
  • func Pull(config PubsubConfig, subID string, timeout int, limit int, isAck bool) (MessageCount, error)
• type PubsubConfig
  • func (psc *PubsubConfig) GetProjectId() string

Functions

func CreateSub

func CreateSub(config PubsubConfig, subID string, topicID string, retryPolicy *pubsub.RetryPolicy) error

func CreateTopic

func CreateTopic(config PubsubConfig, topicID string) error

func DeleteSub

func DeleteSub(config PubsubConfig, subID string) error

func GetSub

func GetSub(config PubsubConfig, subID string) (*pubsub.Client, *pubsub.Subscription, error)

func GetSubPolicy

func GetSubPolicy(config PubsubConfig, subID string) (*pubsub.RetryPolicy, error)

func ListSubscriptions

func ListSubscriptions(config PubsubConfig, topicID string) ([]*pubsub.Subscription, error)

func ListTopics

func ListTopics(config PubsubConfig) ([]*pubsub.Topic, error)

func Publish

func Publish(config PubsubConfig, topicID string, msg_data []byte) error

func UpdateSubPolicy

func UpdateSubPolicy(config PubsubConfig, subID string, retryPolicy *pubsub.RetryPolicy) error

Types

type MessageCount

type MessageCount struct {
	TotalRecived int32
	Inserted     int32
	Duplicate    int32
}

func Pull

func Pull(config PubsubConfig, subID string, timeout int, limit int, isAck bool) (MessageCount, error)

type PubsubConfig

type PubsubConfig struct {
	ProjectId string
}

func (*PubsubConfig) GetProjectId

func (psc *PubsubConfig) GetProjectId() string