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
- type PubsubConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 UpdateSubPolicy ¶
func UpdateSubPolicy(config PubsubConfig, subID string, retryPolicy *pubsub.RetryPolicy) error
Types ¶
type MessageCount ¶
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
Source Files
Click to show internal directories.
Click to hide internal directories.