Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

subscriptions

package

Go to main page

Versions in this module

v0

v0.4.2

May 1, 2024

v0.4.1

Mar 12, 2024

v0.4.0

Feb 21, 2024

Changes in this version

+ func DefaultAuthScopes() []string

+ type CallOptions struct

+ CreateSubscription []gax.CallOption

+ DeleteSubscription []gax.CallOption

+ GetOperation []gax.CallOption

+ GetSubscription []gax.CallOption

+ ListSubscriptions []gax.CallOption

+ ReactivateSubscription []gax.CallOption

+ UpdateSubscription []gax.CallOption

+ type Client struct

+ CallOptions *CallOptions

+ LROClient *lroauto.OperationsClient

+ func NewClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

+ func NewRESTClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

+ func (c *Client) Close() error

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

+ func (c *Client) CreateSubscription(ctx context.Context, req *subscriptionspb.CreateSubscriptionRequest, ...) (*CreateSubscriptionOperation, error)

+ func (c *Client) CreateSubscriptionOperation(name string) *CreateSubscriptionOperation

+ func (c *Client) DeleteSubscription(ctx context.Context, req *subscriptionspb.DeleteSubscriptionRequest, ...) (*DeleteSubscriptionOperation, error)

+ func (c *Client) DeleteSubscriptionOperation(name string) *DeleteSubscriptionOperation

+ func (c *Client) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

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

+ func (c *Client) ListSubscriptions(ctx context.Context, req *subscriptionspb.ListSubscriptionsRequest, ...) *SubscriptionIterator

+ func (c *Client) ReactivateSubscription(ctx context.Context, req *subscriptionspb.ReactivateSubscriptionRequest, ...) (*ReactivateSubscriptionOperation, error)

+ func (c *Client) ReactivateSubscriptionOperation(name string) *ReactivateSubscriptionOperation

+ func (c *Client) UpdateSubscription(ctx context.Context, req *subscriptionspb.UpdateSubscriptionRequest, ...) (*UpdateSubscriptionOperation, error)

+ func (c *Client) UpdateSubscriptionOperation(name string) *UpdateSubscriptionOperation

+ type CreateSubscriptionOperation struct

+ func (op *CreateSubscriptionOperation) Done() bool

+ func (op *CreateSubscriptionOperation) Metadata() (*subscriptionspb.CreateSubscriptionMetadata, error)

+ func (op *CreateSubscriptionOperation) Name() string

+ func (op *CreateSubscriptionOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*subscriptionspb.Subscription, error)

+ func (op *CreateSubscriptionOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*subscriptionspb.Subscription, error)

+ type DeleteSubscriptionOperation struct

+ func (op *DeleteSubscriptionOperation) Done() bool

+ func (op *DeleteSubscriptionOperation) Metadata() (*subscriptionspb.DeleteSubscriptionMetadata, error)

+ func (op *DeleteSubscriptionOperation) Name() string

+ func (op *DeleteSubscriptionOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

+ func (op *DeleteSubscriptionOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

+ type ReactivateSubscriptionOperation struct

+ func (op *ReactivateSubscriptionOperation) Done() bool

+ func (op *ReactivateSubscriptionOperation) Metadata() (*subscriptionspb.ReactivateSubscriptionMetadata, error)

+ func (op *ReactivateSubscriptionOperation) Name() string

+ func (op *ReactivateSubscriptionOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*subscriptionspb.Subscription, error)

+ func (op *ReactivateSubscriptionOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*subscriptionspb.Subscription, error)

+ type SubscriptionIterator struct

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

+ Response interface{}

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

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

+ type UpdateSubscriptionOperation struct

+ func (op *UpdateSubscriptionOperation) Done() bool

+ func (op *UpdateSubscriptionOperation) Metadata() (*subscriptionspb.UpdateSubscriptionMetadata, error)

+ func (op *UpdateSubscriptionOperation) Name() string

+ func (op *UpdateSubscriptionOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*subscriptionspb.Subscription, error)

+ func (op *UpdateSubscriptionOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*subscriptionspb.Subscription, error)