Versions in this module Expand all Collapse all v0 v0.0.10 Feb 17, 2016 v0.0.9 Feb 2, 2016 Changes in this version + const ScopeCloudPlatform + const ScopePubSub + func Ack(ctx context.Context, sub string, id ...string) error + func CreateSub(ctx context.Context, name string, topic string, deadline time.Duration, ...) error + func CreateTopic(ctx context.Context, name string) error + func DeleteSub(ctx context.Context, name string) error + func DeleteTopic(ctx context.Context, name string) error + func ModifyAckDeadline(ctx context.Context, sub string, deadline time.Duration) error + func ModifyPushEndpoint(ctx context.Context, sub, endpoint string) error + func Publish(ctx context.Context, topic string, msgs ...*Message) ([]string, error) + func SubExists(ctx context.Context, name string) (bool, error) + func TopicExists(ctx context.Context, name string) (bool, error) + type Message struct + AckID string + Data []byte + ID string + Labels map[string]string + func Pull(ctx context.Context, sub string, n int) ([]*Message, error) + func PullWait(ctx context.Context, sub string, n int) ([]*Message, error)
Go to main page