pubsub

package

Go to main page

Versions in this module

v1

v1.37.0

Mar 7, 2024

v1.37.0-beta.otel.trace2

Apr 9, 2024

v1.37.0-beta.otel.trace

Mar 13, 2024

v1.36.2

Feb 29, 2024

v1.36.1

Jan 30, 2024

v1.36.0

Jan 26, 2024

v1.35.0

Jan 25, 2024

v1.34.0

Jan 19, 2024

v1.33.0

Jul 24, 2023

v1.32.0

Jun 27, 2023

v1.31.0

May 24, 2023

v1.30.1

May 3, 2023

v1.30.0

Mar 23, 2023

v1.29.0

Mar 13, 2023

Changes in this version

type PublisherClient

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

type SchemaCallOptions

+ CommitSchema []gax.CallOption

+ DeleteSchemaRevision []gax.CallOption

+ ListSchemaRevisions []gax.CallOption

+ RollbackSchema []gax.CallOption

type SchemaClient

+ func NewSchemaRESTClient(ctx context.Context, opts ...option.ClientOption) (*SchemaClient, error)

+ func (c *SchemaClient) CommitSchema(ctx context.Context, req *pubsubpb.CommitSchemaRequest, opts ...gax.CallOption) (*pubsubpb.Schema, error)

+ func (c *SchemaClient) DeleteSchemaRevision(ctx context.Context, req *pubsubpb.DeleteSchemaRevisionRequest, ...) (*pubsubpb.Schema, error)

+ func (c *SchemaClient) ListSchemaRevisions(ctx context.Context, req *pubsubpb.ListSchemaRevisionsRequest, ...) *SchemaIterator

+ func (c *SchemaClient) RollbackSchema(ctx context.Context, req *pubsubpb.RollbackSchemaRequest, ...) (*pubsubpb.Schema, error)

type SubscriberClient

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

v1.28.0

Dec 5, 2022

v1.27.1

Dec 2, 2022

v1.27.0

Nov 30, 2022

v1.26.0

Oct 24, 2022

v1.25.1

Aug 24, 2022

v1.25.0

Aug 23, 2022

v1.24.0

Jul 18, 2022

v1.23.1

Jul 1, 2022

v1.23.0

Jun 23, 2022

v1.22.2

Jun 3, 2022

v1.22.1

Jun 2, 2022

v1.22.0

May 31, 2022

v1.21.1

May 4, 2022

v1.21.0

Apr 26, 2022

v1.20.0

Apr 11, 2022

v1.19.0

Mar 7, 2022

v1.18.0

Feb 8, 2022

v1.17.1

Oct 25, 2021

v1.17.0

Sep 9, 2021

v1.16.0

Aug 25, 2021

v1.15.0

Aug 13, 2021

v1.14.0

Aug 9, 2021

v1.13.0

Jul 20, 2021

v1.12.2

Jul 8, 2021

v1.12.1

Jul 1, 2021

v1.12.0

Jun 24, 2021

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, opts ...gax.CallOption) (*iampb.Policy, error)

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

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

type SchemaCallOptions

+ GetIamPolicy []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

type SchemaClient

+ func (c *SchemaClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *SchemaClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

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

type SubscriberCallOptions

+ GetIamPolicy []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

type SubscriberClient

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

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

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

v1.11.0

May 27, 2021

v1.11.0-beta.schemas

Mar 29, 2021

v1.10.3

Apr 26, 2021

v1.10.2

Apr 12, 2021

v1.10.1

Mar 4, 2021

v1.10.0

Feb 11, 2021

Changes in this version

+ type SchemaCallOptions struct

+ CreateSchema []gax.CallOption

+ DeleteSchema []gax.CallOption

+ GetSchema []gax.CallOption

+ ListSchemas []gax.CallOption

+ ValidateMessage []gax.CallOption

+ ValidateSchema []gax.CallOption

+ type SchemaClient struct

+ CallOptions *SchemaCallOptions

+ func NewSchemaClient(ctx context.Context, opts ...option.ClientOption) (*SchemaClient, error)

+ func (c *SchemaClient) Close() error

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

+ func (c *SchemaClient) CreateSchema(ctx context.Context, req *pubsubpb.CreateSchemaRequest, opts ...gax.CallOption) (*pubsubpb.Schema, error)

+ func (c *SchemaClient) DeleteSchema(ctx context.Context, req *pubsubpb.DeleteSchemaRequest, opts ...gax.CallOption) error

+ func (c *SchemaClient) GetSchema(ctx context.Context, req *pubsubpb.GetSchemaRequest, opts ...gax.CallOption) (*pubsubpb.Schema, error)

+ func (c *SchemaClient) ListSchemas(ctx context.Context, req *pubsubpb.ListSchemasRequest, opts ...gax.CallOption) *SchemaIterator

+ func (c *SchemaClient) ValidateMessage(ctx context.Context, req *pubsubpb.ValidateMessageRequest, ...) (*pubsubpb.ValidateMessageResponse, error)

+ func (c *SchemaClient) ValidateSchema(ctx context.Context, req *pubsubpb.ValidateSchemaRequest, ...) (*pubsubpb.ValidateSchemaResponse, error)

+ type SchemaIterator struct

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

+ Response interface{}

+ func (it *SchemaIterator) Next() (*pubsubpb.Schema, error)

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

v1.9.1

Dec 10, 2020

v1.9.0

Dec 3, 2020

v1.8.3

Nov 10, 2020

v1.8.2

Oct 21, 2020

v1.8.1

Oct 2, 2020

v1.8.0

Sep 29, 2020

v1.7.0

Sep 25, 2020

v1.6.2

Sep 21, 2020

v1.6.1

Jul 28, 2020

v1.6.0

Jul 22, 2020

v1.5.0

Jul 7, 2020

v1.4.0

May 28, 2020

Changes in this version

type PublisherCallOptions

+ DetachSubscription []gax.CallOption

type PublisherClient

+ func (c *PublisherClient) DetachSubscription(ctx context.Context, req *pubsubpb.DetachSubscriptionRequest, ...) (*pubsubpb.DetachSubscriptionResponse, error)

v1.3.1

Mar 12, 2020

v1.3.0

Mar 5, 2020

Changes in this version

type PublisherCallOptions

+ ListTopicSnapshots []gax.CallOption

type PublisherClient

+ func (c *PublisherClient) ListTopicSnapshots(ctx context.Context, req *pubsubpb.ListTopicSnapshotsRequest, ...) *StringIterator

type SnapshotIterator

+ Response interface{}

type StringIterator

+ Response interface{}

type SubscriberCallOptions

+ GetSnapshot []gax.CallOption

type SubscriberClient

+ func (c *SubscriberClient) GetSnapshot(ctx context.Context, req *pubsubpb.GetSnapshotRequest, opts ...gax.CallOption) (*pubsubpb.Snapshot, error)

type SubscriptionIterator

+ Response interface{}

type TopicIterator

+ Response interface{}

v1.2.0

Feb 4, 2020

v1.1.0

Nov 18, 2019

v1.1.0-beta.ordered.keys

Oct 10, 2019

v1.0.1

Sep 4, 2019

v1.0.1-beta.ordered.keys

Oct 10, 2019

v1.0.0

Sep 4, 2019

Changes in this version

+ func DefaultAuthScopes() []string

+ func PublisherProjectPath(project string) string

+ func PublisherTopicPath(project, topic string) string

+ func SubscriberProjectPath(project string) string

+ func SubscriberSnapshotPath(project, snapshot string) string

+ func SubscriberSubscriptionPath(project, subscription string) string

+ func SubscriberTopicPath(project, topic string) string

+ type PublisherCallOptions struct

+ CreateTopic []gax.CallOption

+ DeleteTopic []gax.CallOption

+ GetTopic []gax.CallOption

+ ListTopicSubscriptions []gax.CallOption

+ ListTopics []gax.CallOption

+ Publish []gax.CallOption

+ UpdateTopic []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, opts ...gax.CallOption) (*pubsubpb.Topic, error)

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

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

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

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

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

+ func (c *PublisherClient) SetGoogleClientInfo(keyval ...string)

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

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

+ func (c *PublisherClient) UpdateTopic(ctx context.Context, req *pubsubpb.UpdateTopicRequest, opts ...gax.CallOption) (*pubsubpb.Topic, error)

+ type SnapshotIterator struct

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

+ func (it *SnapshotIterator) Next() (*pubsubpb.Snapshot, error)

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

+ type StringIterator struct

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

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

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

+ type SubscriberCallOptions struct

+ Acknowledge []gax.CallOption

+ CreateSnapshot []gax.CallOption

+ CreateSubscription []gax.CallOption

+ DeleteSnapshot []gax.CallOption

+ DeleteSubscription []gax.CallOption

+ GetSubscription []gax.CallOption

+ ListSnapshots []gax.CallOption

+ ListSubscriptions []gax.CallOption

+ ModifyAckDeadline []gax.CallOption

+ ModifyPushConfig []gax.CallOption

+ Pull []gax.CallOption

+ Seek []gax.CallOption

+ StreamingPull []gax.CallOption

+ UpdateSnapshot []gax.CallOption

+ UpdateSubscription []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, opts ...gax.CallOption) error

+ func (c *SubscriberClient) Close() error

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

+ func (c *SubscriberClient) CreateSnapshot(ctx context.Context, req *pubsubpb.CreateSnapshotRequest, ...) (*pubsubpb.Snapshot, error)

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

+ func (c *SubscriberClient) DeleteSnapshot(ctx context.Context, req *pubsubpb.DeleteSnapshotRequest, ...) 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) ListSnapshots(ctx context.Context, req *pubsubpb.ListSnapshotsRequest, ...) *SnapshotIterator

+ 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, opts ...gax.CallOption) (*pubsubpb.PullResponse, error)

+ func (c *SubscriberClient) Seek(ctx context.Context, req *pubsubpb.SeekRequest, opts ...gax.CallOption) (*pubsubpb.SeekResponse, error)

+ func (c *SubscriberClient) SetGoogleClientInfo(keyval ...string)

+ func (c *SubscriberClient) StreamingPull(ctx context.Context, opts ...gax.CallOption) (pubsubpb.Subscriber_StreamingPullClient, error)

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

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

+ func (c *SubscriberClient) UpdateSnapshot(ctx context.Context, req *pubsubpb.UpdateSnapshotRequest, ...) (*pubsubpb.Snapshot, error)

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

+ type SubscriptionIterator struct

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

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

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

+ type TopicIterator struct

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

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

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

Other modules containing this package

cloud.google.com/go

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