pubsub

package
v0.0.0-...-c66870c Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2018 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterPublisherServer 

func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)

func RegisterSubscriberServer 

func RegisterSubscriberServer(s *grpc.Server, srv SubscriberServer)

Types

type AcknowledgeRequest 

type AcknowledgeRequest struct {
	// The subscription whose message is being acknowledged.
	Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// The acknowledgment ID for the messages being acknowledged that was returned
	// by the Pub/Sub system in the Pull response. Must not be empty.
	AckIds               []string `protobuf:"bytes,2,rep,name=ack_ids,json=ackIds,proto3" json:"ack_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the Acknowledge method.

func (*AcknowledgeRequest) Descriptor 

func (*AcknowledgeRequest) Descriptor() ([]byte, []int)

func (*AcknowledgeRequest) GetAckIds 

func (m *AcknowledgeRequest) GetAckIds() []string

func (*AcknowledgeRequest) GetSubscription 

func (m *AcknowledgeRequest) GetSubscription() string

func (*AcknowledgeRequest) ProtoMessage 

func (*AcknowledgeRequest) ProtoMessage()

func (*AcknowledgeRequest) Reset 

func (m *AcknowledgeRequest) Reset()

func (*AcknowledgeRequest) String 

func (m *AcknowledgeRequest) String() string

func (*AcknowledgeRequest) XXX_DiscardUnknown 

func (m *AcknowledgeRequest) XXX_DiscardUnknown()

func (*AcknowledgeRequest) XXX_Marshal 

func (m *AcknowledgeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AcknowledgeRequest) XXX_Merge 

func (dst *AcknowledgeRequest) XXX_Merge(src proto.Message)

func (*AcknowledgeRequest) XXX_Size 

func (m *AcknowledgeRequest) XXX_Size() int

func (*AcknowledgeRequest) XXX_Unmarshal 

func (m *AcknowledgeRequest) XXX_Unmarshal(b []byte) error

type DeleteSubscriptionRequest 

type DeleteSubscriptionRequest struct {
	// The subscription to delete.
	Subscription         string   `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the DeleteSubscription method.

func (*DeleteSubscriptionRequest) Descriptor 

func (*DeleteSubscriptionRequest) Descriptor() ([]byte, []int)

func (*DeleteSubscriptionRequest) GetSubscription 

func (m *DeleteSubscriptionRequest) GetSubscription() string

func (*DeleteSubscriptionRequest) ProtoMessage 

func (*DeleteSubscriptionRequest) ProtoMessage()

func (*DeleteSubscriptionRequest) Reset 

func (m *DeleteSubscriptionRequest) Reset()

func (*DeleteSubscriptionRequest) String 

func (m *DeleteSubscriptionRequest) String() string

func (*DeleteSubscriptionRequest) XXX_DiscardUnknown 

func (m *DeleteSubscriptionRequest) XXX_DiscardUnknown()

func (*DeleteSubscriptionRequest) XXX_Marshal 

func (m *DeleteSubscriptionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSubscriptionRequest) XXX_Merge 

func (dst *DeleteSubscriptionRequest) XXX_Merge(src proto.Message)

func (*DeleteSubscriptionRequest) XXX_Size 

func (m *DeleteSubscriptionRequest) XXX_Size() int

func (*DeleteSubscriptionRequest) XXX_Unmarshal 

func (m *DeleteSubscriptionRequest) XXX_Unmarshal(b []byte) error

type DeleteTopicRequest 

type DeleteTopicRequest struct {
	// Name of the topic to delete.
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the DeleteTopic method.

func (*DeleteTopicRequest) Descriptor 

func (*DeleteTopicRequest) Descriptor() ([]byte, []int)

func (*DeleteTopicRequest) GetTopic 

func (m *DeleteTopicRequest) GetTopic() string

func (*DeleteTopicRequest) ProtoMessage 

func (*DeleteTopicRequest) ProtoMessage()

func (*DeleteTopicRequest) Reset 

func (m *DeleteTopicRequest) Reset()

func (*DeleteTopicRequest) String 

func (m *DeleteTopicRequest) String() string

func (*DeleteTopicRequest) XXX_DiscardUnknown 

func (m *DeleteTopicRequest) XXX_DiscardUnknown()

func (*DeleteTopicRequest) XXX_Marshal 

func (m *DeleteTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTopicRequest) XXX_Merge 

func (dst *DeleteTopicRequest) XXX_Merge(src proto.Message)

func (*DeleteTopicRequest) XXX_Size 

func (m *DeleteTopicRequest) XXX_Size() int

func (*DeleteTopicRequest) XXX_Unmarshal 

func (m *DeleteTopicRequest) XXX_Unmarshal(b []byte) error

type GetSubscriptionRequest 

type GetSubscriptionRequest struct {
	// The name of the subscription to get.
	Subscription         string   `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the GetSubscription method.

func (*GetSubscriptionRequest) Descriptor 

func (*GetSubscriptionRequest) Descriptor() ([]byte, []int)

func (*GetSubscriptionRequest) GetSubscription 

func (m *GetSubscriptionRequest) GetSubscription() string

func (*GetSubscriptionRequest) ProtoMessage 

func (*GetSubscriptionRequest) ProtoMessage()

func (*GetSubscriptionRequest) Reset 

func (m *GetSubscriptionRequest) Reset()

func (*GetSubscriptionRequest) String 

func (m *GetSubscriptionRequest) String() string

func (*GetSubscriptionRequest) XXX_DiscardUnknown 

func (m *GetSubscriptionRequest) XXX_DiscardUnknown()

func (*GetSubscriptionRequest) XXX_Marshal 

func (m *GetSubscriptionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSubscriptionRequest) XXX_Merge 

func (dst *GetSubscriptionRequest) XXX_Merge(src proto.Message)

func (*GetSubscriptionRequest) XXX_Size 

func (m *GetSubscriptionRequest) XXX_Size() int

func (*GetSubscriptionRequest) XXX_Unmarshal 

func (m *GetSubscriptionRequest) XXX_Unmarshal(b []byte) error

type GetTopicRequest 

type GetTopicRequest struct {
	// The name of the topic to get.
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the GetTopic method.

func (*GetTopicRequest) Descriptor 

func (*GetTopicRequest) Descriptor() ([]byte, []int)

func (*GetTopicRequest) GetTopic 

func (m *GetTopicRequest) GetTopic() string

func (*GetTopicRequest) ProtoMessage 

func (*GetTopicRequest) ProtoMessage()

func (*GetTopicRequest) Reset 

func (m *GetTopicRequest) Reset()

func (*GetTopicRequest) String 

func (m *GetTopicRequest) String() string

func (*GetTopicRequest) XXX_DiscardUnknown 

func (m *GetTopicRequest) XXX_DiscardUnknown()

func (*GetTopicRequest) XXX_Marshal 

func (m *GetTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTopicRequest) XXX_Merge 

func (dst *GetTopicRequest) XXX_Merge(src proto.Message)

func (*GetTopicRequest) XXX_Size 

func (m *GetTopicRequest) XXX_Size() int

func (*GetTopicRequest) XXX_Unmarshal 

func (m *GetTopicRequest) XXX_Unmarshal(b []byte) error

type ListSubscriptionsRequest 

type ListSubscriptionsRequest struct {
	// The name of the cloud project that subscriptions belong to.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Maximum number of subscriptions to return.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The value returned by the last ListSubscriptionsResponse; indicates that
	// this is a continuation of a prior ListSubscriptions call, and that the
	// system should return the next page of data.
	PageToken            string   `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the ListSubscriptions method.

func (*ListSubscriptionsRequest) Descriptor 

func (*ListSubscriptionsRequest) Descriptor() ([]byte, []int)

func (*ListSubscriptionsRequest) GetPageSize 

func (m *ListSubscriptionsRequest) GetPageSize() int32

func (*ListSubscriptionsRequest) GetPageToken 

func (m *ListSubscriptionsRequest) GetPageToken() string

func (*ListSubscriptionsRequest) GetProject 

func (m *ListSubscriptionsRequest) GetProject() string

func (*ListSubscriptionsRequest) ProtoMessage 

func (*ListSubscriptionsRequest) ProtoMessage()

func (*ListSubscriptionsRequest) Reset 

func (m *ListSubscriptionsRequest) Reset()

func (*ListSubscriptionsRequest) String 

func (m *ListSubscriptionsRequest) String() string

func (*ListSubscriptionsRequest) XXX_DiscardUnknown 

func (m *ListSubscriptionsRequest) XXX_DiscardUnknown()

func (*ListSubscriptionsRequest) XXX_Marshal 

func (m *ListSubscriptionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSubscriptionsRequest) XXX_Merge 

func (dst *ListSubscriptionsRequest) XXX_Merge(src proto.Message)

func (*ListSubscriptionsRequest) XXX_Size 

func (m *ListSubscriptionsRequest) XXX_Size() int

func (*ListSubscriptionsRequest) XXX_Unmarshal 

func (m *ListSubscriptionsRequest) XXX_Unmarshal(b []byte) error

type ListSubscriptionsResponse 

type ListSubscriptionsResponse struct {
	// The subscriptions that match the request.
	Subscriptions []*Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// If not empty, indicates that there may be more subscriptions that match
	// the request; this value should be passed in a new ListSubscriptionsRequest
	// to get more subscriptions.
	NextPageToken        string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for the ListSubscriptions method.

func (*ListSubscriptionsResponse) Descriptor 

func (*ListSubscriptionsResponse) Descriptor() ([]byte, []int)

func (*ListSubscriptionsResponse) GetNextPageToken 

func (m *ListSubscriptionsResponse) GetNextPageToken() string

func (*ListSubscriptionsResponse) GetSubscriptions 

func (m *ListSubscriptionsResponse) GetSubscriptions() []*Subscription

func (*ListSubscriptionsResponse) ProtoMessage 

func (*ListSubscriptionsResponse) ProtoMessage()

func (*ListSubscriptionsResponse) Reset 

func (m *ListSubscriptionsResponse) Reset()

func (*ListSubscriptionsResponse) String 

func (m *ListSubscriptionsResponse) String() string

func (*ListSubscriptionsResponse) XXX_DiscardUnknown 

func (m *ListSubscriptionsResponse) XXX_DiscardUnknown()

func (*ListSubscriptionsResponse) XXX_Marshal 

func (m *ListSubscriptionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSubscriptionsResponse) XXX_Merge 

func (dst *ListSubscriptionsResponse) XXX_Merge(src proto.Message)

func (*ListSubscriptionsResponse) XXX_Size 

func (m *ListSubscriptionsResponse) XXX_Size() int

func (*ListSubscriptionsResponse) XXX_Unmarshal 

func (m *ListSubscriptionsResponse) XXX_Unmarshal(b []byte) error

type ListTopicSubscriptionsRequest 

type ListTopicSubscriptionsRequest struct {
	// The name of the topic that subscriptions are attached to.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Maximum number of subscription names to return.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The value returned by the last ListTopicSubscriptionsResponse; indicates
	// that this is a continuation of a prior ListTopicSubscriptions call, and
	// that the system should return the next page of data.
	PageToken            string   `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the ListTopicSubscriptions method.

func (*ListTopicSubscriptionsRequest) Descriptor 

func (*ListTopicSubscriptionsRequest) Descriptor() ([]byte, []int)

func (*ListTopicSubscriptionsRequest) GetPageSize 

func (m *ListTopicSubscriptionsRequest) GetPageSize() int32

func (*ListTopicSubscriptionsRequest) GetPageToken 

func (m *ListTopicSubscriptionsRequest) GetPageToken() string

func (*ListTopicSubscriptionsRequest) GetTopic 

func (m *ListTopicSubscriptionsRequest) GetTopic() string

func (*ListTopicSubscriptionsRequest) ProtoMessage 

func (*ListTopicSubscriptionsRequest) ProtoMessage()

func (*ListTopicSubscriptionsRequest) Reset 

func (m *ListTopicSubscriptionsRequest) Reset()

func (*ListTopicSubscriptionsRequest) String 

func (m *ListTopicSubscriptionsRequest) String() string

func (*ListTopicSubscriptionsRequest) XXX_DiscardUnknown 

func (m *ListTopicSubscriptionsRequest) XXX_DiscardUnknown()

func (*ListTopicSubscriptionsRequest) XXX_Marshal 

func (m *ListTopicSubscriptionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTopicSubscriptionsRequest) XXX_Merge 

func (dst *ListTopicSubscriptionsRequest) XXX_Merge(src proto.Message)

func (*ListTopicSubscriptionsRequest) XXX_Size 

func (m *ListTopicSubscriptionsRequest) XXX_Size() int

func (*ListTopicSubscriptionsRequest) XXX_Unmarshal 

func (m *ListTopicSubscriptionsRequest) XXX_Unmarshal(b []byte) error

type ListTopicSubscriptionsResponse 

type ListTopicSubscriptionsResponse struct {
	// The names of the subscriptions that match the request.
	Subscriptions []string `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// If not empty, indicates that there may be more subscriptions that match
	// the request; this value should be passed in a new
	// ListTopicSubscriptionsRequest to get more subscriptions.
	NextPageToken        string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for the ListTopicSubscriptions method.

func (*ListTopicSubscriptionsResponse) Descriptor 

func (*ListTopicSubscriptionsResponse) Descriptor() ([]byte, []int)

func (*ListTopicSubscriptionsResponse) GetNextPageToken 

func (m *ListTopicSubscriptionsResponse) GetNextPageToken() string

func (*ListTopicSubscriptionsResponse) GetSubscriptions 

func (m *ListTopicSubscriptionsResponse) GetSubscriptions() []string

func (*ListTopicSubscriptionsResponse) ProtoMessage 

func (*ListTopicSubscriptionsResponse) ProtoMessage()

func (*ListTopicSubscriptionsResponse) Reset 

func (m *ListTopicSubscriptionsResponse) Reset()

func (*ListTopicSubscriptionsResponse) String 

func (m *ListTopicSubscriptionsResponse) String() string

func (*ListTopicSubscriptionsResponse) XXX_DiscardUnknown 

func (m *ListTopicSubscriptionsResponse) XXX_DiscardUnknown()

func (*ListTopicSubscriptionsResponse) XXX_Marshal 

func (m *ListTopicSubscriptionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTopicSubscriptionsResponse) XXX_Merge 

func (dst *ListTopicSubscriptionsResponse) XXX_Merge(src proto.Message)

func (*ListTopicSubscriptionsResponse) XXX_Size 

func (m *ListTopicSubscriptionsResponse) XXX_Size() int

func (*ListTopicSubscriptionsResponse) XXX_Unmarshal 

func (m *ListTopicSubscriptionsResponse) XXX_Unmarshal(b []byte) error

type ListTopicsRequest 

type ListTopicsRequest struct {
	// The name of the cloud project that topics belong to.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Maximum number of topics to return.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The value returned by the last ListTopicsResponse; indicates that this is
	// a continuation of a prior ListTopics call, and that the system should
	// return the next page of data.
	PageToken            string   `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the ListTopics method.

func (*ListTopicsRequest) Descriptor 

func (*ListTopicsRequest) Descriptor() ([]byte, []int)

func (*ListTopicsRequest) GetPageSize 

func (m *ListTopicsRequest) GetPageSize() int32

func (*ListTopicsRequest) GetPageToken 

func (m *ListTopicsRequest) GetPageToken() string

func (*ListTopicsRequest) GetProject 

func (m *ListTopicsRequest) GetProject() string

func (*ListTopicsRequest) ProtoMessage 

func (*ListTopicsRequest) ProtoMessage()

func (*ListTopicsRequest) Reset 

func (m *ListTopicsRequest) Reset()

func (*ListTopicsRequest) String 

func (m *ListTopicsRequest) String() string

func (*ListTopicsRequest) XXX_DiscardUnknown 

func (m *ListTopicsRequest) XXX_DiscardUnknown()

func (*ListTopicsRequest) XXX_Marshal 

func (m *ListTopicsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTopicsRequest) XXX_Merge 

func (dst *ListTopicsRequest) XXX_Merge(src proto.Message)

func (*ListTopicsRequest) XXX_Size 

func (m *ListTopicsRequest) XXX_Size() int

func (*ListTopicsRequest) XXX_Unmarshal 

func (m *ListTopicsRequest) XXX_Unmarshal(b []byte) error

type ListTopicsResponse 

type ListTopicsResponse struct {
	// The resulting topics.
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// If not empty, indicates that there may be more topics that match the
	// request; this value should be passed in a new ListTopicsRequest.
	NextPageToken        string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for the ListTopics method.

func (*ListTopicsResponse) Descriptor 

func (*ListTopicsResponse) Descriptor() ([]byte, []int)

func (*ListTopicsResponse) GetNextPageToken 

func (m *ListTopicsResponse) GetNextPageToken() string

func (*ListTopicsResponse) GetTopics 

func (m *ListTopicsResponse) GetTopics() []*Topic

func (*ListTopicsResponse) ProtoMessage 

func (*ListTopicsResponse) ProtoMessage()

func (*ListTopicsResponse) Reset 

func (m *ListTopicsResponse) Reset()

func (*ListTopicsResponse) String 

func (m *ListTopicsResponse) String() string

func (*ListTopicsResponse) XXX_DiscardUnknown 

func (m *ListTopicsResponse) XXX_DiscardUnknown()

func (*ListTopicsResponse) XXX_Marshal 

func (m *ListTopicsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTopicsResponse) XXX_Merge 

func (dst *ListTopicsResponse) XXX_Merge(src proto.Message)

func (*ListTopicsResponse) XXX_Size 

func (m *ListTopicsResponse) XXX_Size() int

func (*ListTopicsResponse) XXX_Unmarshal 

func (m *ListTopicsResponse) XXX_Unmarshal(b []byte) error

type ModifyAckDeadlineRequest 

type ModifyAckDeadlineRequest struct {
	// The name of the subscription.
	Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// The acknowledgment ID.
	AckId string `protobuf:"bytes,2,opt,name=ack_id,json=ackId,proto3" json:"ack_id,omitempty"`
	// The new ack deadline with respect to the time this request was sent to the
	// Pub/Sub system. Must be >= 0. For example, if the value is 10, the new ack
	// deadline will expire 10 seconds after the ModifyAckDeadline call was made.
	// Specifying zero may immediately make the message available for another pull
	// request.
	AckDeadlineSeconds   int32    `protobuf:"varint,3,opt,name=ack_deadline_seconds,json=ackDeadlineSeconds,proto3" json:"ack_deadline_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the ModifyAckDeadline method.

func (*ModifyAckDeadlineRequest) Descriptor 

func (*ModifyAckDeadlineRequest) Descriptor() ([]byte, []int)

func (*ModifyAckDeadlineRequest) GetAckDeadlineSeconds 

func (m *ModifyAckDeadlineRequest) GetAckDeadlineSeconds() int32

func (*ModifyAckDeadlineRequest) GetAckId 

func (m *ModifyAckDeadlineRequest) GetAckId() string

func (*ModifyAckDeadlineRequest) GetSubscription 

func (m *ModifyAckDeadlineRequest) GetSubscription() string

func (*ModifyAckDeadlineRequest) ProtoMessage 

func (*ModifyAckDeadlineRequest) ProtoMessage()

func (*ModifyAckDeadlineRequest) Reset 

func (m *ModifyAckDeadlineRequest) Reset()

func (*ModifyAckDeadlineRequest) String 

func (m *ModifyAckDeadlineRequest) String() string

func (*ModifyAckDeadlineRequest) XXX_DiscardUnknown 

func (m *ModifyAckDeadlineRequest) XXX_DiscardUnknown()

func (*ModifyAckDeadlineRequest) XXX_Marshal 

func (m *ModifyAckDeadlineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModifyAckDeadlineRequest) XXX_Merge 

func (dst *ModifyAckDeadlineRequest) XXX_Merge(src proto.Message)

func (*ModifyAckDeadlineRequest) XXX_Size 

func (m *ModifyAckDeadlineRequest) XXX_Size() int

func (*ModifyAckDeadlineRequest) XXX_Unmarshal 

func (m *ModifyAckDeadlineRequest) XXX_Unmarshal(b []byte) error

type ModifyPushConfigRequest 

type ModifyPushConfigRequest struct {
	// The name of the subscription.
	Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// The push configuration for future deliveries.
	//
	// An empty pushConfig indicates that the Pub/Sub system should
	// stop pushing messages from the given subscription and allow
	// messages to be pulled and acknowledged - effectively pausing
	// the subscription if Pull is not called.
	PushConfig           *PushConfig `protobuf:"bytes,2,opt,name=push_config,json=pushConfig,proto3" json:"push_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Request for the ModifyPushConfig method.

func (*ModifyPushConfigRequest) Descriptor 

func (*ModifyPushConfigRequest) Descriptor() ([]byte, []int)

func (*ModifyPushConfigRequest) GetPushConfig 

func (m *ModifyPushConfigRequest) GetPushConfig() *PushConfig

func (*ModifyPushConfigRequest) GetSubscription 

func (m *ModifyPushConfigRequest) GetSubscription() string

func (*ModifyPushConfigRequest) ProtoMessage 

func (*ModifyPushConfigRequest) ProtoMessage()

func (*ModifyPushConfigRequest) Reset 

func (m *ModifyPushConfigRequest) Reset()

func (*ModifyPushConfigRequest) String 

func (m *ModifyPushConfigRequest) String() string

func (*ModifyPushConfigRequest) XXX_DiscardUnknown 

func (m *ModifyPushConfigRequest) XXX_DiscardUnknown()

func (*ModifyPushConfigRequest) XXX_Marshal 

func (m *ModifyPushConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModifyPushConfigRequest) XXX_Merge 

func (dst *ModifyPushConfigRequest) XXX_Merge(src proto.Message)

func (*ModifyPushConfigRequest) XXX_Size 

func (m *ModifyPushConfigRequest) XXX_Size() int

func (*ModifyPushConfigRequest) XXX_Unmarshal 

func (m *ModifyPushConfigRequest) XXX_Unmarshal(b []byte) error

type PublishRequest 

type PublishRequest struct {
	// The messages in the request will be published on this topic.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// The messages to publish.
	Messages             []*PubsubMessage `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Request for the Publish method.

func (*PublishRequest) Descriptor 

func (*PublishRequest) Descriptor() ([]byte, []int)

func (*PublishRequest) GetMessages 

func (m *PublishRequest) GetMessages() []*PubsubMessage

func (*PublishRequest) GetTopic 

func (m *PublishRequest) GetTopic() string

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset 

func (m *PublishRequest) Reset()

func (*PublishRequest) String 

func (m *PublishRequest) String() string

func (*PublishRequest) XXX_DiscardUnknown 

func (m *PublishRequest) XXX_DiscardUnknown()

func (*PublishRequest) XXX_Marshal 

func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishRequest) XXX_Merge 

func (dst *PublishRequest) XXX_Merge(src proto.Message)

func (*PublishRequest) XXX_Size 

func (m *PublishRequest) XXX_Size() int

func (*PublishRequest) XXX_Unmarshal 

func (m *PublishRequest) XXX_Unmarshal(b []byte) error

type PublishResponse 

type PublishResponse struct {
	// The server-assigned ID of each published message, in the same order as
	// the messages in the request. IDs are guaranteed to be unique within
	// the topic.
	MessageIds           []string `protobuf:"bytes,1,rep,name=message_ids,json=messageIds,proto3" json:"message_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for the Publish method.

func (*PublishResponse) Descriptor 

func (*PublishResponse) Descriptor() ([]byte, []int)

func (*PublishResponse) GetMessageIds 

func (m *PublishResponse) GetMessageIds() []string

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) Reset 

func (m *PublishResponse) Reset()

func (*PublishResponse) String 

func (m *PublishResponse) String() string

func (*PublishResponse) XXX_DiscardUnknown 

func (m *PublishResponse) XXX_DiscardUnknown()

func (*PublishResponse) XXX_Marshal 

func (m *PublishResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishResponse) XXX_Merge 

func (dst *PublishResponse) XXX_Merge(src proto.Message)

func (*PublishResponse) XXX_Size 

func (m *PublishResponse) XXX_Size() int

func (*PublishResponse) XXX_Unmarshal 

func (m *PublishResponse) XXX_Unmarshal(b []byte) error

type PublisherClient 

type PublisherClient interface {
	// Creates the given topic with the given name.
	CreateTopic(ctx context.Context, in *Topic, opts ...grpc.CallOption) (*Topic, error)
	// Adds one or more messages to the topic. Returns NOT_FOUND if the topic does
	// not exist.
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	// Gets the configuration of a topic.
	GetTopic(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*Topic, error)
	// Lists matching topics.
	ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)
	// Lists the name of the subscriptions for this topic.
	ListTopicSubscriptions(ctx context.Context, in *ListTopicSubscriptionsRequest, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error)
	// Deletes the topic with the given name. Returns NOT_FOUND if the topic does
	// not exist. After a topic is deleted, a new topic may be created with the
	// same name; this is an entirely new topic with none of the old
	// configuration or subscriptions. Existing subscriptions to this topic are
	// not deleted.
	DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

PublisherClient is the client API for Publisher service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPublisherClient 

func NewPublisherClient(cc *grpc.ClientConn) PublisherClient

type PublisherServer 

type PublisherServer interface {
	// Creates the given topic with the given name.
	CreateTopic(context.Context, *Topic) (*Topic, error)
	// Adds one or more messages to the topic. Returns NOT_FOUND if the topic does
	// not exist.
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	// Gets the configuration of a topic.
	GetTopic(context.Context, *GetTopicRequest) (*Topic, error)
	// Lists matching topics.
	ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)
	// Lists the name of the subscriptions for this topic.
	ListTopicSubscriptions(context.Context, *ListTopicSubscriptionsRequest) (*ListTopicSubscriptionsResponse, error)
	// Deletes the topic with the given name. Returns NOT_FOUND if the topic does
	// not exist. After a topic is deleted, a new topic may be created with the
	// same name; this is an entirely new topic with none of the old
	// configuration or subscriptions. Existing subscriptions to this topic are
	// not deleted.
	DeleteTopic(context.Context, *DeleteTopicRequest) (*empty.Empty, error)
}

PublisherServer is the server API for Publisher service.

type PubsubMessage 

type PubsubMessage struct {
	// The message payload. For JSON requests, the value of this field must be
	// base64-encoded.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Optional attributes for this message.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// ID of this message assigned by the server at publication time. Guaranteed
	// to be unique within the topic. This value may be read by a subscriber
	// that receives a PubsubMessage via a Pull call or a push delivery. It must
	// not be populated by a publisher in a Publish call.
	MessageId            string   `protobuf:"bytes,3,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A message data and its attributes.

func (*PubsubMessage) Descriptor 

func (*PubsubMessage) Descriptor() ([]byte, []int)

func (*PubsubMessage) GetAttributes 

func (m *PubsubMessage) GetAttributes() map[string]string

func (*PubsubMessage) GetData 

func (m *PubsubMessage) GetData() []byte

func (*PubsubMessage) GetMessageId 

func (m *PubsubMessage) GetMessageId() string

func (*PubsubMessage) ProtoMessage 

func (*PubsubMessage) ProtoMessage()

func (*PubsubMessage) Reset 

func (m *PubsubMessage) Reset()

func (*PubsubMessage) String 

func (m *PubsubMessage) String() string

func (*PubsubMessage) XXX_DiscardUnknown 

func (m *PubsubMessage) XXX_DiscardUnknown()

func (*PubsubMessage) XXX_Marshal 

func (m *PubsubMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubsubMessage) XXX_Merge 

func (dst *PubsubMessage) XXX_Merge(src proto.Message)

func (*PubsubMessage) XXX_Size 

func (m *PubsubMessage) XXX_Size() int

func (*PubsubMessage) XXX_Unmarshal 

func (m *PubsubMessage) XXX_Unmarshal(b []byte) error

type PullRequest 

type PullRequest struct {
	// The subscription from which messages should be pulled.
	Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// If this is specified as true the system will respond immediately even if
	// it is not able to return a message in the Pull response. Otherwise the
	// system is allowed to wait until at least one message is available rather
	// than returning no messages. The client may cancel the request if it does
	// not wish to wait any longer for the response.
	ReturnImmediately bool `protobuf:"varint,2,opt,name=return_immediately,json=returnImmediately,proto3" json:"return_immediately,omitempty"`
	// The maximum number of messages returned for this request. The Pub/Sub
	// system may return fewer than the number specified.
	MaxMessages          int32    `protobuf:"varint,3,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the Pull method.

func (*PullRequest) Descriptor 

func (*PullRequest) Descriptor() ([]byte, []int)

func (*PullRequest) GetMaxMessages 

func (m *PullRequest) GetMaxMessages() int32

func (*PullRequest) GetReturnImmediately 

func (m *PullRequest) GetReturnImmediately() bool

func (*PullRequest) GetSubscription 

func (m *PullRequest) GetSubscription() string

func (*PullRequest) ProtoMessage 

func (*PullRequest) ProtoMessage()

func (*PullRequest) Reset 

func (m *PullRequest) Reset()

func (*PullRequest) String 

func (m *PullRequest) String() string

func (*PullRequest) XXX_DiscardUnknown 

func (m *PullRequest) XXX_DiscardUnknown()

func (*PullRequest) XXX_Marshal 

func (m *PullRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullRequest) XXX_Merge 

func (dst *PullRequest) XXX_Merge(src proto.Message)

func (*PullRequest) XXX_Size 

func (m *PullRequest) XXX_Size() int

func (*PullRequest) XXX_Unmarshal 

func (m *PullRequest) XXX_Unmarshal(b []byte) error

type PullResponse 

type PullResponse struct {
	// Received Pub/Sub messages. The Pub/Sub system will return zero messages if
	// there are no more available in the backlog. The Pub/Sub system may return
	// fewer than the maxMessages requested even if there are more messages
	// available in the backlog.
	ReceivedMessages     []*ReceivedMessage `protobuf:"bytes,1,rep,name=received_messages,json=receivedMessages,proto3" json:"received_messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Response for the Pull method.

func (*PullResponse) Descriptor 

func (*PullResponse) Descriptor() ([]byte, []int)

func (*PullResponse) GetReceivedMessages 

func (m *PullResponse) GetReceivedMessages() []*ReceivedMessage

func (*PullResponse) ProtoMessage 

func (*PullResponse) ProtoMessage()

func (*PullResponse) Reset 

func (m *PullResponse) Reset()

func (*PullResponse) String 

func (m *PullResponse) String() string

func (*PullResponse) XXX_DiscardUnknown 

func (m *PullResponse) XXX_DiscardUnknown()

func (*PullResponse) XXX_Marshal 

func (m *PullResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullResponse) XXX_Merge 

func (dst *PullResponse) XXX_Merge(src proto.Message)

func (*PullResponse) XXX_Size 

func (m *PullResponse) XXX_Size() int

func (*PullResponse) XXX_Unmarshal 

func (m *PullResponse) XXX_Unmarshal(b []byte) error

type PushConfig 

type PushConfig struct {
	// A URL locating the endpoint to which messages should be pushed.
	// For example, a Webhook endpoint might use "https://example.com/push".
	PushEndpoint string `protobuf:"bytes,1,opt,name=push_endpoint,json=pushEndpoint,proto3" json:"push_endpoint,omitempty"`
	// Endpoint configuration attributes.
	//
	// Every endpoint has a set of API supported attributes that can be used to
	// control different aspects of the message delivery.
	//
	// The currently supported attribute is `x-goog-version`, which you can
	// use to change the format of the push message. This attribute
	// indicates the version of the data expected by the endpoint. This
	// controls the shape of the envelope (i.e. its fields and metadata).
	// The endpoint version is based on the version of the Pub/Sub
	// API.
	//
	// If not present during the CreateSubscription call, it will default to
	// the version of the API used to make such call. If not present during a
	// ModifyPushConfig call, its value will not be changed. GetSubscription
	// calls will always return a valid version, even if the subscription was
	// created without this attribute.
	//
	// The possible values for this attribute are:
	//
	// * `v1beta1`: uses the push format defined in the v1beta1 Pub/Sub API.
	// * `v1beta2`: uses the push format defined in the v1beta2 Pub/Sub API.
	//
	Attributes           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Configuration for a push delivery endpoint.

func (*PushConfig) Descriptor 

func (*PushConfig) Descriptor() ([]byte, []int)

func (*PushConfig) GetAttributes 

func (m *PushConfig) GetAttributes() map[string]string

func (*PushConfig) GetPushEndpoint 

func (m *PushConfig) GetPushEndpoint() string

func (*PushConfig) ProtoMessage 

func (*PushConfig) ProtoMessage()

func (*PushConfig) Reset 

func (m *PushConfig) Reset()

func (*PushConfig) String 

func (m *PushConfig) String() string

func (*PushConfig) XXX_DiscardUnknown 

func (m *PushConfig) XXX_DiscardUnknown()

func (*PushConfig) XXX_Marshal 

func (m *PushConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushConfig) XXX_Merge 

func (dst *PushConfig) XXX_Merge(src proto.Message)

func (*PushConfig) XXX_Size 

func (m *PushConfig) XXX_Size() int

func (*PushConfig) XXX_Unmarshal 

func (m *PushConfig) XXX_Unmarshal(b []byte) error

type ReceivedMessage 

type ReceivedMessage struct {
	// This ID can be used to acknowledge the received message.
	AckId string `protobuf:"bytes,1,opt,name=ack_id,json=ackId,proto3" json:"ack_id,omitempty"`
	// The message.
	Message              *PubsubMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

A message and its corresponding acknowledgment ID.

func (*ReceivedMessage) Descriptor 

func (*ReceivedMessage) Descriptor() ([]byte, []int)

func (*ReceivedMessage) GetAckId 

func (m *ReceivedMessage) GetAckId() string

func (*ReceivedMessage) GetMessage 

func (m *ReceivedMessage) GetMessage() *PubsubMessage

func (*ReceivedMessage) ProtoMessage 

func (*ReceivedMessage) ProtoMessage()

func (*ReceivedMessage) Reset 

func (m *ReceivedMessage) Reset()

func (*ReceivedMessage) String 

func (m *ReceivedMessage) String() string

func (*ReceivedMessage) XXX_DiscardUnknown 

func (m *ReceivedMessage) XXX_DiscardUnknown()

func (*ReceivedMessage) XXX_Marshal 

func (m *ReceivedMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReceivedMessage) XXX_Merge 

func (dst *ReceivedMessage) XXX_Merge(src proto.Message)

func (*ReceivedMessage) XXX_Size 

func (m *ReceivedMessage) XXX_Size() int

func (*ReceivedMessage) XXX_Unmarshal 

func (m *ReceivedMessage) XXX_Unmarshal(b []byte) error

type SubscriberClient 

type SubscriberClient interface {
	// Creates a subscription to a given topic for a given subscriber.
	// If the subscription already exists, returns ALREADY_EXISTS.
	// If the corresponding topic doesn't exist, returns NOT_FOUND.
	//
	// If the name is not provided in the request, the server will assign a random
	// name for this subscription on the same project as the topic.
	CreateSubscription(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*Subscription, error)
	// Gets the configuration details of a subscription.
	GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)
	// Lists matching subscriptions.
	ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)
	// Deletes an existing subscription. All pending messages in the subscription
	// are immediately dropped. Calls to Pull after deletion will return
	// NOT_FOUND. After a subscription is deleted, a new one may be created with
	// the same name, but the new one has no association with the old
	// subscription, or its topic unless the same topic is specified.
	DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Modifies the ack deadline for a specific message. This method is useful to
	// indicate that more time is needed to process a message by the subscriber,
	// or to make the message available for redelivery if the processing was
	// interrupted.
	ModifyAckDeadline(ctx context.Context, in *ModifyAckDeadlineRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Acknowledges the messages associated with the ack tokens in the
	// AcknowledgeRequest. The Pub/Sub system can remove the relevant messages
	// from the subscription.
	//
	// Acknowledging a message whose ack deadline has expired may succeed,
	// but such a message may be redelivered later. Acknowledging a message more
	// than once will not result in an error.
	Acknowledge(ctx context.Context, in *AcknowledgeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Pulls messages from the server. Returns an empty list if there are no
	// messages available in the backlog. The server may return UNAVAILABLE if
	// there are too many concurrent pull requests pending for the given
	// subscription.
	Pull(ctx context.Context, in *PullRequest, opts ...grpc.CallOption) (*PullResponse, error)
	// Modifies the PushConfig for a specified subscription.
	//
	// This may be used to change a push subscription to a pull one (signified
	// by an empty PushConfig) or vice versa, or change the endpoint URL and other
	// attributes of a push subscription. Messages will accumulate for
	// delivery continuously through the call regardless of changes to the
	// PushConfig.
	ModifyPushConfig(ctx context.Context, in *ModifyPushConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

SubscriberClient is the client API for Subscriber service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSubscriberClient 

func NewSubscriberClient(cc *grpc.ClientConn) SubscriberClient

type SubscriberServer 

type SubscriberServer interface {
	// Creates a subscription to a given topic for a given subscriber.
	// If the subscription already exists, returns ALREADY_EXISTS.
	// If the corresponding topic doesn't exist, returns NOT_FOUND.
	//
	// If the name is not provided in the request, the server will assign a random
	// name for this subscription on the same project as the topic.
	CreateSubscription(context.Context, *Subscription) (*Subscription, error)
	// Gets the configuration details of a subscription.
	GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error)
	// Lists matching subscriptions.
	ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
	// Deletes an existing subscription. All pending messages in the subscription
	// are immediately dropped. Calls to Pull after deletion will return
	// NOT_FOUND. After a subscription is deleted, a new one may be created with
	// the same name, but the new one has no association with the old
	// subscription, or its topic unless the same topic is specified.
	DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*empty.Empty, error)
	// Modifies the ack deadline for a specific message. This method is useful to
	// indicate that more time is needed to process a message by the subscriber,
	// or to make the message available for redelivery if the processing was
	// interrupted.
	ModifyAckDeadline(context.Context, *ModifyAckDeadlineRequest) (*empty.Empty, error)
	// Acknowledges the messages associated with the ack tokens in the
	// AcknowledgeRequest. The Pub/Sub system can remove the relevant messages
	// from the subscription.
	//
	// Acknowledging a message whose ack deadline has expired may succeed,
	// but such a message may be redelivered later. Acknowledging a message more
	// than once will not result in an error.
	Acknowledge(context.Context, *AcknowledgeRequest) (*empty.Empty, error)
	// Pulls messages from the server. Returns an empty list if there are no
	// messages available in the backlog. The server may return UNAVAILABLE if
	// there are too many concurrent pull requests pending for the given
	// subscription.
	Pull(context.Context, *PullRequest) (*PullResponse, error)
	// Modifies the PushConfig for a specified subscription.
	//
	// This may be used to change a push subscription to a pull one (signified
	// by an empty PushConfig) or vice versa, or change the endpoint URL and other
	// attributes of a push subscription. Messages will accumulate for
	// delivery continuously through the call regardless of changes to the
	// PushConfig.
	ModifyPushConfig(context.Context, *ModifyPushConfigRequest) (*empty.Empty, error)
}

SubscriberServer is the server API for Subscriber service.

type Subscription 

type Subscription struct {
	// Name of the subscription.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The name of the topic from which this subscription is receiving messages.
	// This will be present if and only if the subscription has not been detached
	// from its topic.
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// If push delivery is used with this subscription, this field is
	// used to configure it. An empty pushConfig signifies that the subscriber
	// will pull and ack messages using API methods.
	PushConfig *PushConfig `protobuf:"bytes,4,opt,name=push_config,json=pushConfig,proto3" json:"push_config,omitempty"`
	// This value is the maximum time after a subscriber receives a message
	// before the subscriber should acknowledge the message. After message
	// delivery but before the ack deadline expires and before the message is
	// acknowledged, it is an outstanding message and will not be delivered
	// again during that time (on a best-effort basis).
	//
	// For pull delivery this value
	// is used as the initial value for the ack deadline. It may be overridden
	// for a specific message by calling ModifyAckDeadline.
	//
	// For push delivery, this value is also used to set the request timeout for
	// the call to the push endpoint.
	//
	// If the subscriber never acknowledges the message, the Pub/Sub
	// system will eventually redeliver the message.
	AckDeadlineSeconds   int32    `protobuf:"varint,5,opt,name=ack_deadline_seconds,json=ackDeadlineSeconds,proto3" json:"ack_deadline_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A subscription resource.

func (*Subscription) Descriptor 

func (*Subscription) Descriptor() ([]byte, []int)

func (*Subscription) GetAckDeadlineSeconds 

func (m *Subscription) GetAckDeadlineSeconds() int32

func (*Subscription) GetName 

func (m *Subscription) GetName() string

func (*Subscription) GetPushConfig 

func (m *Subscription) GetPushConfig() *PushConfig

func (*Subscription) GetTopic 

func (m *Subscription) GetTopic() string

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) Reset 

func (m *Subscription) Reset()

func (*Subscription) String 

func (m *Subscription) String() string

func (*Subscription) XXX_DiscardUnknown 

func (m *Subscription) XXX_DiscardUnknown()

func (*Subscription) XXX_Marshal 

func (m *Subscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Subscription) XXX_Merge 

func (dst *Subscription) XXX_Merge(src proto.Message)

func (*Subscription) XXX_Size 

func (m *Subscription) XXX_Size() int

func (*Subscription) XXX_Unmarshal 

func (m *Subscription) XXX_Unmarshal(b []byte) error

type Topic 

type Topic struct {
	// Name of the topic.
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A topic resource.

func (*Topic) Descriptor 

func (*Topic) Descriptor() ([]byte, []int)

func (*Topic) GetName 

func (m *Topic) GetName() string

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) Reset 

func (m *Topic) Reset()

func (*Topic) String 

func (m *Topic) String() string

func (*Topic) XXX_DiscardUnknown 

func (m *Topic) XXX_DiscardUnknown()

func (*Topic) XXX_Marshal 

func (m *Topic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Topic) XXX_Merge 

func (dst *Topic) XXX_Merge(src proto.Message)

func (*Topic) XXX_Size 

func (m *Topic) XXX_Size() int

func (*Topic) XXX_Unmarshal 

func (m *Topic) XXX_Unmarshal(b []byte) error

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.