pubsub

package

Go to main page

Versions in this module

v0

v0.6.0

Dec 10, 2016

v0.5.0

Nov 30, 2016

Changes in this version

type StringIterator

+ InternalFetch func(pageSize int, pageToken string) (results []string, nextPageToken string, err error)

type SubscriptionIterator

+ InternalFetch func(pageSize int, pageToken string) (results []*pubsubpb.Subscription, nextPageToken string, err error)

type TopicIterator

+ InternalFetch func(pageSize int, pageToken string) (results []*pubsubpb.Topic, nextPageToken string, err error)

v0.4.0

Nov 1, 2016

Changes in this version

type PublisherClient

+ func (c *PublisherClient) SubscriptionIAM(subscription *pubsubpb.Subscription) *iam.Handle

+ func (c *PublisherClient) TopicIAM(topic *pubsubpb.Topic) *iam.Handle

type SubscriberClient

+ func (c *SubscriberClient) SubscriptionIAM(subscription *pubsubpb.Subscription) *iam.Handle

+ func (c *SubscriberClient) TopicIAM(topic *pubsubpb.Topic) *iam.Handle

v0.3.0

Oct 14, 2016

Changes in this version

type PublisherCallOptions

+ GetIamPolicy []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

type PublisherClient

+ func (c *PublisherClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest) (*iampb.Policy, error)

+ func (c *PublisherClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest) (*iampb.Policy, error)

+ func (c *PublisherClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest) (*iampb.TestIamPermissionsResponse, error)

type StringIterator

+ func (it *StringIterator) PageInfo() *iterator.PageInfo

type SubscriberCallOptions

+ GetIamPolicy []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

type SubscriberClient

+ func (c *SubscriberClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest) (*iampb.Policy, error)

+ func (c *SubscriberClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest) (*iampb.Policy, error)

+ func (c *SubscriberClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest) (*iampb.TestIamPermissionsResponse, error)

type SubscriptionIterator

+ func (it *SubscriptionIterator) PageInfo() *iterator.PageInfo

type TopicIterator

+ func (it *TopicIterator) PageInfo() *iterator.PageInfo

v0.2.0

Oct 3, 2016

Changes in this version

+ var Done = errors.New("iterator done")

+ func PublisherProjectPath(project string) string

+ func PublisherTopicPath(project string, topic string) string

+ func SubscriberProjectPath(project string) string

+ func SubscriberSubscriptionPath(project string, subscription string) string

+ func SubscriberTopicPath(project string, topic string) string

+ type PublisherCallOptions struct

+ CreateTopic []gax.CallOption

+ DeleteTopic []gax.CallOption

+ GetTopic []gax.CallOption

+ ListTopicSubscriptions []gax.CallOption

+ ListTopics []gax.CallOption

+ Publish []gax.CallOption

+ type PublisherClient struct

+ CallOptions *PublisherCallOptions

+ func NewPublisherClient(ctx context.Context, opts ...option.ClientOption) (*PublisherClient, error)

+ func (c *PublisherClient) Close() error

+ func (c *PublisherClient) Connection() *grpc.ClientConn

+ func (c *PublisherClient) CreateTopic(ctx context.Context, req *pubsubpb.Topic) (*pubsubpb.Topic, error)

+ func (c *PublisherClient) DeleteTopic(ctx context.Context, req *pubsubpb.DeleteTopicRequest) error

+ func (c *PublisherClient) GetTopic(ctx context.Context, req *pubsubpb.GetTopicRequest) (*pubsubpb.Topic, error)

+ func (c *PublisherClient) ListTopicSubscriptions(ctx context.Context, req *pubsubpb.ListTopicSubscriptionsRequest) *StringIterator

+ func (c *PublisherClient) ListTopics(ctx context.Context, req *pubsubpb.ListTopicsRequest) *TopicIterator

+ func (c *PublisherClient) Publish(ctx context.Context, req *pubsubpb.PublishRequest) (*pubsubpb.PublishResponse, error)

+ func (c *PublisherClient) SetGoogleClientInfo(name, version string)

+ type StringIterator struct

+ func (it *StringIterator) Next() (string, error)

+ func (it *StringIterator) NextPage() ([]string, error)

+ func (it *StringIterator) NextPageToken() string

+ func (it *StringIterator) PageSize() int

+ func (it *StringIterator) SetPageSize(pageSize int)

+ func (it *StringIterator) SetPageToken(token string)

+ type SubscriberCallOptions struct

+ Acknowledge []gax.CallOption

+ CreateSubscription []gax.CallOption

+ DeleteSubscription []gax.CallOption

+ GetSubscription []gax.CallOption

+ ListSubscriptions []gax.CallOption

+ ModifyAckDeadline []gax.CallOption

+ ModifyPushConfig []gax.CallOption

+ Pull []gax.CallOption

+ type SubscriberClient struct

+ CallOptions *SubscriberCallOptions

+ func NewSubscriberClient(ctx context.Context, opts ...option.ClientOption) (*SubscriberClient, error)

+ func (c *SubscriberClient) Acknowledge(ctx context.Context, req *pubsubpb.AcknowledgeRequest) error

+ func (c *SubscriberClient) Close() error

+ func (c *SubscriberClient) Connection() *grpc.ClientConn

+ func (c *SubscriberClient) CreateSubscription(ctx context.Context, req *pubsubpb.Subscription) (*pubsubpb.Subscription, error)

+ func (c *SubscriberClient) DeleteSubscription(ctx context.Context, req *pubsubpb.DeleteSubscriptionRequest) error

+ func (c *SubscriberClient) GetSubscription(ctx context.Context, req *pubsubpb.GetSubscriptionRequest) (*pubsubpb.Subscription, error)

+ func (c *SubscriberClient) ListSubscriptions(ctx context.Context, req *pubsubpb.ListSubscriptionsRequest) *SubscriptionIterator

+ func (c *SubscriberClient) ModifyAckDeadline(ctx context.Context, req *pubsubpb.ModifyAckDeadlineRequest) error

+ func (c *SubscriberClient) ModifyPushConfig(ctx context.Context, req *pubsubpb.ModifyPushConfigRequest) error

+ func (c *SubscriberClient) Pull(ctx context.Context, req *pubsubpb.PullRequest) (*pubsubpb.PullResponse, error)

+ func (c *SubscriberClient) SetGoogleClientInfo(name, version string)

+ type SubscriptionIterator struct

+ func (it *SubscriptionIterator) Next() (*pubsubpb.Subscription, error)

+ func (it *SubscriptionIterator) NextPage() ([]*pubsubpb.Subscription, error)

+ func (it *SubscriptionIterator) NextPageToken() string

+ func (it *SubscriptionIterator) PageSize() int

+ func (it *SubscriptionIterator) SetPageSize(pageSize int)

+ func (it *SubscriptionIterator) SetPageToken(token string)

+ type TopicIterator struct

+ func (it *TopicIterator) Next() (*pubsubpb.Topic, error)

+ func (it *TopicIterator) NextPage() ([]*pubsubpb.Topic, error)

+ func (it *TopicIterator) NextPageToken() string

+ func (it *TopicIterator) PageSize() int

+ func (it *TopicIterator) SetPageSize(pageSize int)

+ func (it *TopicIterator) SetPageToken(token string)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL