pubsub

package
v0.0.0-...-bb6c6ed Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 13, 2015 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Overview

Package pubsub provides access to the Google Cloud Pub/Sub API.

Usage example: 

import "github.com/jfcote87/api2/pubsub/v1beta2"
...
pubsubService, err := pubsub.New(oauthHttpClient)

Index

Constants

View Source 
const (
	// View and manage your data across Google Cloud Platform services
	CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform"

	// View and manage Pub/Sub topics and subscriptions
	PubsubScope = "https://www.googleapis.com/auth/pubsub"
)

OAuth2 scopes used by this API.

Variables

This section is empty.

Functions

This section is empty.

Types

type AcknowledgeRequest 

type AcknowledgeRequest struct {
	AckIds []string `json:"ackIds,omitempty"`
}

type Empty 

type Empty struct {
}

type ListSubscriptionsResponse 

type ListSubscriptionsResponse struct {
	NextPageToken string `json:"nextPageToken,omitempty"`

	Subscriptions []*Subscription `json:"subscriptions,omitempty"`
}

type ListTopicSubscriptionsResponse 

type ListTopicSubscriptionsResponse struct {
	NextPageToken string `json:"nextPageToken,omitempty"`

	Subscriptions []string `json:"subscriptions,omitempty"`
}

type ListTopicsResponse 

type ListTopicsResponse struct {
	NextPageToken string `json:"nextPageToken,omitempty"`

	Topics []*Topic `json:"topics,omitempty"`
}

type ModifyAckDeadlineRequest 

type ModifyAckDeadlineRequest struct {
	AckDeadlineSeconds int64 `json:"ackDeadlineSeconds,omitempty"`

	AckId string `json:"ackId,omitempty"`
}

type ModifyPushConfigRequest 

type ModifyPushConfigRequest struct {
	PushConfig *PushConfig `json:"pushConfig,omitempty"`
}

type ProjectsService 

type ProjectsService struct {
	Subscriptions *ProjectsSubscriptionsService

	Topics *ProjectsTopicsService
	// contains filtered or unexported fields
}

func NewProjectsService 

func NewProjectsService(s *Service) *ProjectsService

type ProjectsSubscriptionsAcknowledgeCall 

type ProjectsSubscriptionsAcknowledgeCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsSubscriptionsAcknowledgeCall) Context 

func (c *ProjectsSubscriptionsAcknowledgeCall) Context(ctx context.Context) *ProjectsSubscriptionsAcknowledgeCall

func (*ProjectsSubscriptionsAcknowledgeCall) Do 

func (c *ProjectsSubscriptionsAcknowledgeCall) Do() (*Empty, error)

func (*ProjectsSubscriptionsAcknowledgeCall) Fields 

func (c *ProjectsSubscriptionsAcknowledgeCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsAcknowledgeCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

type ProjectsSubscriptionsCreateCall 

type ProjectsSubscriptionsCreateCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsSubscriptionsCreateCall) Context 

func (c *ProjectsSubscriptionsCreateCall) Context(ctx context.Context) *ProjectsSubscriptionsCreateCall

func (*ProjectsSubscriptionsCreateCall) Do 

func (c *ProjectsSubscriptionsCreateCall) Do() (*Subscription, error)

func (*ProjectsSubscriptionsCreateCall) Fields 

func (c *ProjectsSubscriptionsCreateCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsCreateCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

type ProjectsSubscriptionsDeleteCall 

type ProjectsSubscriptionsDeleteCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsSubscriptionsDeleteCall) Context 

func (c *ProjectsSubscriptionsDeleteCall) Context(ctx context.Context) *ProjectsSubscriptionsDeleteCall

func (*ProjectsSubscriptionsDeleteCall) Do 

func (c *ProjectsSubscriptionsDeleteCall) Do() (*Empty, error)

func (*ProjectsSubscriptionsDeleteCall) Fields 

func (c *ProjectsSubscriptionsDeleteCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsDeleteCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

type ProjectsSubscriptionsGetCall 

type ProjectsSubscriptionsGetCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsSubscriptionsGetCall) Context 

func (c *ProjectsSubscriptionsGetCall) Context(ctx context.Context) *ProjectsSubscriptionsGetCall

func (*ProjectsSubscriptionsGetCall) Do 

func (c *ProjectsSubscriptionsGetCall) Do() (*Subscription, error)

func (*ProjectsSubscriptionsGetCall) Fields 

func (c *ProjectsSubscriptionsGetCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsGetCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

type ProjectsSubscriptionsListCall 

type ProjectsSubscriptionsListCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsSubscriptionsListCall) Context 

func (c *ProjectsSubscriptionsListCall) Context(ctx context.Context) *ProjectsSubscriptionsListCall

func (*ProjectsSubscriptionsListCall) Do 

func (c *ProjectsSubscriptionsListCall) Do() (*ListSubscriptionsResponse, error)

func (*ProjectsSubscriptionsListCall) Fields 

func (c *ProjectsSubscriptionsListCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsListCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

func (*ProjectsSubscriptionsListCall) PageSize 

func (c *ProjectsSubscriptionsListCall) PageSize(pageSize int64) *ProjectsSubscriptionsListCall

PageSize sets the optional parameter "pageSize":

func (*ProjectsSubscriptionsListCall) PageToken 

func (c *ProjectsSubscriptionsListCall) PageToken(pageToken string) *ProjectsSubscriptionsListCall

PageToken sets the optional parameter "pageToken":

type ProjectsSubscriptionsModifyAckDeadlineCall 

type ProjectsSubscriptionsModifyAckDeadlineCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsSubscriptionsModifyAckDeadlineCall) Context 

func (c *ProjectsSubscriptionsModifyAckDeadlineCall) Context(ctx context.Context) *ProjectsSubscriptionsModifyAckDeadlineCall

func (*ProjectsSubscriptionsModifyAckDeadlineCall) Do 

func (c *ProjectsSubscriptionsModifyAckDeadlineCall) Do() (*Empty, error)

func (*ProjectsSubscriptionsModifyAckDeadlineCall) Fields 

func (c *ProjectsSubscriptionsModifyAckDeadlineCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsModifyAckDeadlineCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

type ProjectsSubscriptionsModifyPushConfigCall 

type ProjectsSubscriptionsModifyPushConfigCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsSubscriptionsModifyPushConfigCall) Context 

func (c *ProjectsSubscriptionsModifyPushConfigCall) Context(ctx context.Context) *ProjectsSubscriptionsModifyPushConfigCall

func (*ProjectsSubscriptionsModifyPushConfigCall) Do 

func (c *ProjectsSubscriptionsModifyPushConfigCall) Do() (*Empty, error)

func (*ProjectsSubscriptionsModifyPushConfigCall) Fields 

func (c *ProjectsSubscriptionsModifyPushConfigCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsModifyPushConfigCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

type ProjectsSubscriptionsPullCall 

type ProjectsSubscriptionsPullCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsSubscriptionsPullCall) Context 

func (c *ProjectsSubscriptionsPullCall) Context(ctx context.Context) *ProjectsSubscriptionsPullCall

func (*ProjectsSubscriptionsPullCall) Do 

func (c *ProjectsSubscriptionsPullCall) Do() (*PullResponse, error)

func (*ProjectsSubscriptionsPullCall) Fields 

func (c *ProjectsSubscriptionsPullCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsPullCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

type ProjectsSubscriptionsService 

type ProjectsSubscriptionsService struct {
	// contains filtered or unexported fields
}

func NewProjectsSubscriptionsService 

func NewProjectsSubscriptionsService(s *Service) *ProjectsSubscriptionsService

func (*ProjectsSubscriptionsService) Acknowledge 

func (r *ProjectsSubscriptionsService) Acknowledge(subscription string, acknowledgerequest *AcknowledgeRequest) *ProjectsSubscriptionsAcknowledgeCall

func (*ProjectsSubscriptionsService) Create 

func (r *ProjectsSubscriptionsService) Create(name string, subscription *Subscription) *ProjectsSubscriptionsCreateCall

func (*ProjectsSubscriptionsService) Delete 

func (r *ProjectsSubscriptionsService) Delete(subscription string) *ProjectsSubscriptionsDeleteCall

func (*ProjectsSubscriptionsService) Get 

func (r *ProjectsSubscriptionsService) Get(subscription string) *ProjectsSubscriptionsGetCall

func (*ProjectsSubscriptionsService) List 

func (r *ProjectsSubscriptionsService) List(project string) *ProjectsSubscriptionsListCall

func (*ProjectsSubscriptionsService) ModifyAckDeadline 

func (r *ProjectsSubscriptionsService) ModifyAckDeadline(subscription string, modifyackdeadlinerequest *ModifyAckDeadlineRequest) *ProjectsSubscriptionsModifyAckDeadlineCall

func (*ProjectsSubscriptionsService) ModifyPushConfig 

func (r *ProjectsSubscriptionsService) ModifyPushConfig(subscription string, modifypushconfigrequest *ModifyPushConfigRequest) *ProjectsSubscriptionsModifyPushConfigCall

func (*ProjectsSubscriptionsService) Pull 

func (r *ProjectsSubscriptionsService) Pull(subscription string, pullrequest *PullRequest) *ProjectsSubscriptionsPullCall

type ProjectsTopicsCreateCall 

type ProjectsTopicsCreateCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsTopicsCreateCall) Context 

func (c *ProjectsTopicsCreateCall) Context(ctx context.Context) *ProjectsTopicsCreateCall

func (*ProjectsTopicsCreateCall) Do 

func (c *ProjectsTopicsCreateCall) Do() (*Topic, error)

func (*ProjectsTopicsCreateCall) Fields 

func (c *ProjectsTopicsCreateCall) Fields(s ...googleapi.Field) *ProjectsTopicsCreateCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

type ProjectsTopicsDeleteCall 

type ProjectsTopicsDeleteCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsTopicsDeleteCall) Context 

func (c *ProjectsTopicsDeleteCall) Context(ctx context.Context) *ProjectsTopicsDeleteCall

func (*ProjectsTopicsDeleteCall) Do 

func (c *ProjectsTopicsDeleteCall) Do() (*Empty, error)

func (*ProjectsTopicsDeleteCall) Fields 

func (c *ProjectsTopicsDeleteCall) Fields(s ...googleapi.Field) *ProjectsTopicsDeleteCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

type ProjectsTopicsGetCall 

type ProjectsTopicsGetCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsTopicsGetCall) Context 

func (c *ProjectsTopicsGetCall) Context(ctx context.Context) *ProjectsTopicsGetCall

func (*ProjectsTopicsGetCall) Do 

func (c *ProjectsTopicsGetCall) Do() (*Topic, error)

func (*ProjectsTopicsGetCall) Fields 

func (c *ProjectsTopicsGetCall) Fields(s ...googleapi.Field) *ProjectsTopicsGetCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

type ProjectsTopicsListCall 

type ProjectsTopicsListCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsTopicsListCall) Context 

func (c *ProjectsTopicsListCall) Context(ctx context.Context) *ProjectsTopicsListCall

func (*ProjectsTopicsListCall) Do 

func (c *ProjectsTopicsListCall) Do() (*ListTopicsResponse, error)

func (*ProjectsTopicsListCall) Fields 

func (c *ProjectsTopicsListCall) Fields(s ...googleapi.Field) *ProjectsTopicsListCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

func (*ProjectsTopicsListCall) PageSize 

func (c *ProjectsTopicsListCall) PageSize(pageSize int64) *ProjectsTopicsListCall

PageSize sets the optional parameter "pageSize":

func (*ProjectsTopicsListCall) PageToken 

func (c *ProjectsTopicsListCall) PageToken(pageToken string) *ProjectsTopicsListCall

PageToken sets the optional parameter "pageToken":

type ProjectsTopicsPublishCall 

type ProjectsTopicsPublishCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsTopicsPublishCall) Context 

func (c *ProjectsTopicsPublishCall) Context(ctx context.Context) *ProjectsTopicsPublishCall

func (*ProjectsTopicsPublishCall) Do 

func (c *ProjectsTopicsPublishCall) Do() (*PublishResponse, error)

func (*ProjectsTopicsPublishCall) Fields 

func (c *ProjectsTopicsPublishCall) Fields(s ...googleapi.Field) *ProjectsTopicsPublishCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

type ProjectsTopicsService 

type ProjectsTopicsService struct {
	Subscriptions *ProjectsTopicsSubscriptionsService
	// contains filtered or unexported fields
}

func NewProjectsTopicsService 

func NewProjectsTopicsService(s *Service) *ProjectsTopicsService

func (*ProjectsTopicsService) Create 

func (r *ProjectsTopicsService) Create(name string, topic *Topic) *ProjectsTopicsCreateCall

func (*ProjectsTopicsService) Delete 

func (r *ProjectsTopicsService) Delete(topic string) *ProjectsTopicsDeleteCall

func (*ProjectsTopicsService) Get 

func (r *ProjectsTopicsService) Get(topic string) *ProjectsTopicsGetCall

func (*ProjectsTopicsService) List 

func (r *ProjectsTopicsService) List(project string) *ProjectsTopicsListCall

func (*ProjectsTopicsService) Publish 

func (r *ProjectsTopicsService) Publish(topic string, publishrequest *PublishRequest) *ProjectsTopicsPublishCall

type ProjectsTopicsSubscriptionsListCall 

type ProjectsTopicsSubscriptionsListCall struct {
	// contains filtered or unexported fields
}

func (*ProjectsTopicsSubscriptionsListCall) Context 

func (c *ProjectsTopicsSubscriptionsListCall) Context(ctx context.Context) *ProjectsTopicsSubscriptionsListCall

func (*ProjectsTopicsSubscriptionsListCall) Do 

func (c *ProjectsTopicsSubscriptionsListCall) Do() (*ListTopicSubscriptionsResponse, error)

func (*ProjectsTopicsSubscriptionsListCall) Fields 

func (c *ProjectsTopicsSubscriptionsListCall) Fields(s ...googleapi.Field) *ProjectsTopicsSubscriptionsListCall

Fields allows partial responses to be retrieved. See https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more information.

func (*ProjectsTopicsSubscriptionsListCall) PageSize 

func (c *ProjectsTopicsSubscriptionsListCall) PageSize(pageSize int64) *ProjectsTopicsSubscriptionsListCall

PageSize sets the optional parameter "pageSize":

func (*ProjectsTopicsSubscriptionsListCall) PageToken 

func (c *ProjectsTopicsSubscriptionsListCall) PageToken(pageToken string) *ProjectsTopicsSubscriptionsListCall

PageToken sets the optional parameter "pageToken":

type ProjectsTopicsSubscriptionsService 

type ProjectsTopicsSubscriptionsService struct {
	// contains filtered or unexported fields
}

func NewProjectsTopicsSubscriptionsService 

func NewProjectsTopicsSubscriptionsService(s *Service) *ProjectsTopicsSubscriptionsService

func (*ProjectsTopicsSubscriptionsService) List 

func (r *ProjectsTopicsSubscriptionsService) List(topic string) *ProjectsTopicsSubscriptionsListCall

type PublishRequest 

type PublishRequest struct {
	Messages []*PubsubMessage `json:"messages,omitempty"`
}

type PublishResponse 

type PublishResponse struct {
	MessageIds []string `json:"messageIds,omitempty"`
}

type PubsubMessage 

type PubsubMessage struct {
	Attributes map[string]string `json:"attributes,omitempty"`

	Data string `json:"data,omitempty"`

	MessageId string `json:"messageId,omitempty"`
}

type PullRequest 

type PullRequest struct {
	MaxMessages int64 `json:"maxMessages,omitempty"`

	ReturnImmediately bool `json:"returnImmediately,omitempty"`
}

type PullResponse 

type PullResponse struct {
	ReceivedMessages []*ReceivedMessage `json:"receivedMessages,omitempty"`
}

type PushConfig 

type PushConfig struct {
	Attributes map[string]string `json:"attributes,omitempty"`

	PushEndpoint string `json:"pushEndpoint,omitempty"`
}

type ReceivedMessage 

type ReceivedMessage struct {
	AckId string `json:"ackId,omitempty"`

	Message *PubsubMessage `json:"message,omitempty"`
}

type Service 

type Service struct {
	Projects *ProjectsService
	// contains filtered or unexported fields
}

func New 

func New(client *http.Client) (*Service, error)

type Subscription 

type Subscription struct {
	AckDeadlineSeconds int64 `json:"ackDeadlineSeconds,omitempty"`

	Name string `json:"name,omitempty"`

	PushConfig *PushConfig `json:"pushConfig,omitempty"`

	Topic string `json:"topic,omitempty"`
}

type Topic 

type Topic struct {
	Name string `json:"name,omitempty"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.