Versions in this module Expand all Collapse all v0 v0.5.0 Nov 3, 2015 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, id 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 Client struct + func NewClient(ctx context.Context, projectID string, opts ...cloud.ClientOption) (*Client, error) + type Message struct + AckID string + Attributes map[string]string + Data []byte + ID string + func Pull(ctx context.Context, sub string, n int) ([]*Message, error) + func PullWait(ctx context.Context, sub string, n int) ([]*Message, error) v0.5.0-rc4 Oct 29, 2015
Go to main page