pubsublite

package
v0.0.0-...-6cb3ea0 Latest Latest
Warning

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

 Go to latest Published: Jun 7, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Subscription_DeliveryConfig_DeliveryRequirement_name = map[int32]string{
		0: "DELIVERY_REQUIREMENT_UNSPECIFIED",
		1: "DELIVER_IMMEDIATELY",
		2: "DELIVER_AFTER_STORED",
	}
	Subscription_DeliveryConfig_DeliveryRequirement_value = map[string]int32{
		"DELIVERY_REQUIREMENT_UNSPECIFIED": 0,
		"DELIVER_IMMEDIATELY":              1,
		"DELIVER_AFTER_STORED":             2,
	}
)

Enum value maps for Subscription_DeliveryConfig_DeliveryRequirement.

View Source 
var (
	SeekRequest_NamedTarget_name = map[int32]string{
		0: "NAMED_TARGET_UNSPECIFIED",
		1: "HEAD",
		2: "COMMITTED_CURSOR",
	}
	SeekRequest_NamedTarget_value = map[string]int32{
		"NAMED_TARGET_UNSPECIFIED": 0,
		"HEAD":                     1,
		"COMMITTED_CURSOR":         2,
	}
)

Enum value maps for SeekRequest_NamedTarget.

View Source 
var File_google_cloud_pubsublite_v1_admin_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_pubsublite_v1_common_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_pubsublite_v1_cursor_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_pubsublite_v1_publisher_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_pubsublite_v1_subscriber_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_pubsublite_v1_topic_stats_proto protoreflect.FileDescriptor

Functions

func RegisterAdminServiceServer 

func RegisterAdminServiceServer(s *grpc.Server, srv AdminServiceServer)

func RegisterCursorServiceServer 

func RegisterCursorServiceServer(s *grpc.Server, srv CursorServiceServer)

func RegisterPartitionAssignmentServiceServer 

func RegisterPartitionAssignmentServiceServer(s *grpc.Server, srv PartitionAssignmentServiceServer)

func RegisterPublisherServiceServer 

func RegisterPublisherServiceServer(s *grpc.Server, srv PublisherServiceServer)

func RegisterSubscriberServiceServer 

func RegisterSubscriberServiceServer(s *grpc.Server, srv SubscriberServiceServer)

func RegisterTopicStatsServiceServer 

func RegisterTopicStatsServiceServer(s *grpc.Server, srv TopicStatsServiceServer)

Types

type AdminServiceClient 

type AdminServiceClient interface {
	// Creates a new topic.
	CreateTopic(ctx context.Context, in *CreateTopicRequest, opts ...grpc.CallOption) (*Topic, error)
	// Returns the topic configuration.
	GetTopic(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*Topic, error)
	// Returns the partition information for the requested topic.
	GetTopicPartitions(ctx context.Context, in *GetTopicPartitionsRequest, opts ...grpc.CallOption) (*TopicPartitions, error)
	// Returns the list of topics for the given project.
	ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)
	// Updates properties of the specified topic.
	UpdateTopic(ctx context.Context, in *UpdateTopicRequest, opts ...grpc.CallOption) (*Topic, error)
	// Deletes the specified topic.
	DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Lists the subscriptions attached to the specified topic.
	ListTopicSubscriptions(ctx context.Context, in *ListTopicSubscriptionsRequest, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error)
	// Creates a new subscription.
	CreateSubscription(ctx context.Context, in *CreateSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)
	// Returns the subscription configuration.
	GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)
	// Returns the list of subscriptions for the given project.
	ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)
	// Updates properties of the specified subscription.
	UpdateSubscription(ctx context.Context, in *UpdateSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)
	// Deletes the specified subscription.
	DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Creates a new reservation.
	CreateReservation(ctx context.Context, in *CreateReservationRequest, opts ...grpc.CallOption) (*Reservation, error)
	// Returns the reservation configuration.
	GetReservation(ctx context.Context, in *GetReservationRequest, opts ...grpc.CallOption) (*Reservation, error)
	// Returns the list of reservations for the given project.
	ListReservations(ctx context.Context, in *ListReservationsRequest, opts ...grpc.CallOption) (*ListReservationsResponse, error)
	// Updates properties of the specified reservation.
	UpdateReservation(ctx context.Context, in *UpdateReservationRequest, opts ...grpc.CallOption) (*Reservation, error)
	// Deletes the specified reservation.
	DeleteReservation(ctx context.Context, in *DeleteReservationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Lists the topics attached to the specified reservation.
	ListReservationTopics(ctx context.Context, in *ListReservationTopicsRequest, opts ...grpc.CallOption) (*ListReservationTopicsResponse, error)
}

AdminServiceClient is the client API for AdminService service.

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

func NewAdminServiceClient 

func NewAdminServiceClient(cc grpc.ClientConnInterface) AdminServiceClient

type AdminServiceServer 

type AdminServiceServer interface {
	// Creates a new topic.
	CreateTopic(context.Context, *CreateTopicRequest) (*Topic, error)
	// Returns the topic configuration.
	GetTopic(context.Context, *GetTopicRequest) (*Topic, error)
	// Returns the partition information for the requested topic.
	GetTopicPartitions(context.Context, *GetTopicPartitionsRequest) (*TopicPartitions, error)
	// Returns the list of topics for the given project.
	ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)
	// Updates properties of the specified topic.
	UpdateTopic(context.Context, *UpdateTopicRequest) (*Topic, error)
	// Deletes the specified topic.
	DeleteTopic(context.Context, *DeleteTopicRequest) (*emptypb.Empty, error)
	// Lists the subscriptions attached to the specified topic.
	ListTopicSubscriptions(context.Context, *ListTopicSubscriptionsRequest) (*ListTopicSubscriptionsResponse, error)
	// Creates a new subscription.
	CreateSubscription(context.Context, *CreateSubscriptionRequest) (*Subscription, error)
	// Returns the subscription configuration.
	GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error)
	// Returns the list of subscriptions for the given project.
	ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
	// Updates properties of the specified subscription.
	UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*Subscription, error)
	// Deletes the specified subscription.
	DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*emptypb.Empty, error)
	// Creates a new reservation.
	CreateReservation(context.Context, *CreateReservationRequest) (*Reservation, error)
	// Returns the reservation configuration.
	GetReservation(context.Context, *GetReservationRequest) (*Reservation, error)
	// Returns the list of reservations for the given project.
	ListReservations(context.Context, *ListReservationsRequest) (*ListReservationsResponse, error)
	// Updates properties of the specified reservation.
	UpdateReservation(context.Context, *UpdateReservationRequest) (*Reservation, error)
	// Deletes the specified reservation.
	DeleteReservation(context.Context, *DeleteReservationRequest) (*emptypb.Empty, error)
	// Lists the topics attached to the specified reservation.
	ListReservationTopics(context.Context, *ListReservationTopicsRequest) (*ListReservationTopicsResponse, error)
}

AdminServiceServer is the server API for AdminService service.

type AttributeValues 

type AttributeValues struct {

	// The list of values associated with a key.
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

The values associated with a key of an attribute.

func (*AttributeValues) Descriptor deprecated 

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

Deprecated: Use AttributeValues.ProtoReflect.Descriptor instead.

func (*AttributeValues) GetValues 

func (x *AttributeValues) GetValues() [][]byte

func (*AttributeValues) ProtoMessage 

func (*AttributeValues) ProtoMessage()

func (*AttributeValues) ProtoReflect 

func (x *AttributeValues) ProtoReflect() protoreflect.Message

func (*AttributeValues) Reset 

func (x *AttributeValues) Reset()

func (*AttributeValues) String 

func (x *AttributeValues) String() string

type CommitCursorRequest 

type CommitCursorRequest struct {

	// The subscription for which to update the cursor.
	Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// The partition for which to update the cursor. Partitions are zero indexed,
	// so `partition` must be in the range [0, topic.num_partitions).
	Partition int64 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The new value for the committed cursor.
	Cursor *Cursor `protobuf:"bytes,3,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

Request for CommitCursor.

func (*CommitCursorRequest) Descriptor deprecated 

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

Deprecated: Use CommitCursorRequest.ProtoReflect.Descriptor instead.

func (*CommitCursorRequest) GetCursor 

func (x *CommitCursorRequest) GetCursor() *Cursor

func (*CommitCursorRequest) GetPartition 

func (x *CommitCursorRequest) GetPartition() int64

func (*CommitCursorRequest) GetSubscription 

func (x *CommitCursorRequest) GetSubscription() string

func (*CommitCursorRequest) ProtoMessage 

func (*CommitCursorRequest) ProtoMessage()

func (*CommitCursorRequest) ProtoReflect 

func (x *CommitCursorRequest) ProtoReflect() protoreflect.Message

func (*CommitCursorRequest) Reset 

func (x *CommitCursorRequest) Reset()

func (*CommitCursorRequest) String 

func (x *CommitCursorRequest) String() string

type CommitCursorResponse 

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

Response for CommitCursor.

func (*CommitCursorResponse) Descriptor deprecated 

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

Deprecated: Use CommitCursorResponse.ProtoReflect.Descriptor instead.

func (*CommitCursorResponse) ProtoMessage 

func (*CommitCursorResponse) ProtoMessage()

func (*CommitCursorResponse) ProtoReflect 

func (x *CommitCursorResponse) ProtoReflect() protoreflect.Message

func (*CommitCursorResponse) Reset 

func (x *CommitCursorResponse) Reset()

func (*CommitCursorResponse) String 

func (x *CommitCursorResponse) String() string

type ComputeHeadCursorRequest 

type ComputeHeadCursorRequest struct {

	// Required. The topic for which we should compute the head cursor.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Required. The partition for which we should compute the head cursor.
	Partition int64 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

Compute the current head cursor for a partition.

func (*ComputeHeadCursorRequest) Descriptor deprecated 

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

Deprecated: Use ComputeHeadCursorRequest.ProtoReflect.Descriptor instead.

func (*ComputeHeadCursorRequest) GetPartition 

func (x *ComputeHeadCursorRequest) GetPartition() int64

func (*ComputeHeadCursorRequest) GetTopic 

func (x *ComputeHeadCursorRequest) GetTopic() string

func (*ComputeHeadCursorRequest) ProtoMessage 

func (*ComputeHeadCursorRequest) ProtoMessage()

func (*ComputeHeadCursorRequest) ProtoReflect 

func (x *ComputeHeadCursorRequest) ProtoReflect() protoreflect.Message

func (*ComputeHeadCursorRequest) Reset 

func (x *ComputeHeadCursorRequest) Reset()

func (*ComputeHeadCursorRequest) String 

func (x *ComputeHeadCursorRequest) String() string

type ComputeHeadCursorResponse 

type ComputeHeadCursorResponse struct {

	// The head cursor.
	HeadCursor *Cursor `protobuf:"bytes,1,opt,name=head_cursor,json=headCursor,proto3" json:"head_cursor,omitempty"`
	// contains filtered or unexported fields
}

Response containing the head cursor for the requested topic and partition.

func (*ComputeHeadCursorResponse) Descriptor deprecated 

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

Deprecated: Use ComputeHeadCursorResponse.ProtoReflect.Descriptor instead.

func (*ComputeHeadCursorResponse) GetHeadCursor 

func (x *ComputeHeadCursorResponse) GetHeadCursor() *Cursor

func (*ComputeHeadCursorResponse) ProtoMessage 

func (*ComputeHeadCursorResponse) ProtoMessage()

func (*ComputeHeadCursorResponse) ProtoReflect 

func (x *ComputeHeadCursorResponse) ProtoReflect() protoreflect.Message

func (*ComputeHeadCursorResponse) Reset 

func (x *ComputeHeadCursorResponse) Reset()

func (*ComputeHeadCursorResponse) String 

func (x *ComputeHeadCursorResponse) String() string

type ComputeMessageStatsRequest 

type ComputeMessageStatsRequest struct {

	// Required. The topic for which we should compute message stats.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Required. The partition for which we should compute message stats.
	Partition int64 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The inclusive start of the range.
	StartCursor *Cursor `protobuf:"bytes,3,opt,name=start_cursor,json=startCursor,proto3" json:"start_cursor,omitempty"`
	// The exclusive end of the range. The range is empty if end_cursor <=
	// start_cursor. Specifying a start_cursor before the first message and an
	// end_cursor after the last message will retrieve all messages.
	EndCursor *Cursor `protobuf:"bytes,4,opt,name=end_cursor,json=endCursor,proto3" json:"end_cursor,omitempty"`
	// contains filtered or unexported fields
}

Compute statistics about a range of messages in a given topic and partition.

func (*ComputeMessageStatsRequest) Descriptor deprecated 

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

Deprecated: Use ComputeMessageStatsRequest.ProtoReflect.Descriptor instead.

func (*ComputeMessageStatsRequest) GetEndCursor 

func (x *ComputeMessageStatsRequest) GetEndCursor() *Cursor

func (*ComputeMessageStatsRequest) GetPartition 

func (x *ComputeMessageStatsRequest) GetPartition() int64

func (*ComputeMessageStatsRequest) GetStartCursor 

func (x *ComputeMessageStatsRequest) GetStartCursor() *Cursor

func (*ComputeMessageStatsRequest) GetTopic 

func (x *ComputeMessageStatsRequest) GetTopic() string

func (*ComputeMessageStatsRequest) ProtoMessage 

func (*ComputeMessageStatsRequest) ProtoMessage()

func (*ComputeMessageStatsRequest) ProtoReflect 

func (x *ComputeMessageStatsRequest) ProtoReflect() protoreflect.Message

func (*ComputeMessageStatsRequest) Reset 

func (x *ComputeMessageStatsRequest) Reset()

func (*ComputeMessageStatsRequest) String 

func (x *ComputeMessageStatsRequest) String() string

type ComputeMessageStatsResponse 

type ComputeMessageStatsResponse struct {

	// The count of messages.
	MessageCount int64 `protobuf:"varint,1,opt,name=message_count,json=messageCount,proto3" json:"message_count,omitempty"`
	// The number of quota bytes accounted to these messages.
	MessageBytes int64 `protobuf:"varint,2,opt,name=message_bytes,json=messageBytes,proto3" json:"message_bytes,omitempty"`
	// The minimum publish timestamp across these messages. Note that publish
	// timestamps within a partition are not guaranteed to be non-decreasing. The
	// timestamp will be unset if there are no messages.
	MinimumPublishTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=minimum_publish_time,json=minimumPublishTime,proto3" json:"minimum_publish_time,omitempty"`
	// The minimum event timestamp across these messages. For the purposes of this
	// computation, if a message does not have an event time, we use the publish
	// time. The timestamp will be unset if there are no messages.
	MinimumEventTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=minimum_event_time,json=minimumEventTime,proto3" json:"minimum_event_time,omitempty"`
	// contains filtered or unexported fields
}

Response containing stats for messages in the requested topic and partition.

func (*ComputeMessageStatsResponse) Descriptor deprecated 

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

Deprecated: Use ComputeMessageStatsResponse.ProtoReflect.Descriptor instead.

func (*ComputeMessageStatsResponse) GetMessageBytes 

func (x *ComputeMessageStatsResponse) GetMessageBytes() int64

func (*ComputeMessageStatsResponse) GetMessageCount 

func (x *ComputeMessageStatsResponse) GetMessageCount() int64

func (*ComputeMessageStatsResponse) GetMinimumEventTime 

func (x *ComputeMessageStatsResponse) GetMinimumEventTime() *timestamppb.Timestamp

func (*ComputeMessageStatsResponse) GetMinimumPublishTime 

func (x *ComputeMessageStatsResponse) GetMinimumPublishTime() *timestamppb.Timestamp

func (*ComputeMessageStatsResponse) ProtoMessage 

func (*ComputeMessageStatsResponse) ProtoMessage()

func (*ComputeMessageStatsResponse) ProtoReflect 

func (x *ComputeMessageStatsResponse) ProtoReflect() protoreflect.Message

func (*ComputeMessageStatsResponse) Reset 

func (x *ComputeMessageStatsResponse) Reset()

func (*ComputeMessageStatsResponse) String 

func (x *ComputeMessageStatsResponse) String() string

type ComputeTimeCursorRequest 

type ComputeTimeCursorRequest struct {

	// Required. The topic for which we should compute the cursor.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Required. The partition for which we should compute the cursor.
	Partition int64 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// Required. The target publish or event time. Specifying a future time will return an
	// unset cursor.
	Target *TimeTarget `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

Compute the corresponding cursor for a publish or event time in a topic partition.

func (*ComputeTimeCursorRequest) Descriptor deprecated 

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

Deprecated: Use ComputeTimeCursorRequest.ProtoReflect.Descriptor instead.

func (*ComputeTimeCursorRequest) GetPartition 

func (x *ComputeTimeCursorRequest) GetPartition() int64

func (*ComputeTimeCursorRequest) GetTarget 

func (x *ComputeTimeCursorRequest) GetTarget() *TimeTarget

func (*ComputeTimeCursorRequest) GetTopic 

func (x *ComputeTimeCursorRequest) GetTopic() string

func (*ComputeTimeCursorRequest) ProtoMessage 

func (*ComputeTimeCursorRequest) ProtoMessage()

func (*ComputeTimeCursorRequest) ProtoReflect 

func (x *ComputeTimeCursorRequest) ProtoReflect() protoreflect.Message

func (*ComputeTimeCursorRequest) Reset 

func (x *ComputeTimeCursorRequest) Reset()

func (*ComputeTimeCursorRequest) String 

func (x *ComputeTimeCursorRequest) String() string

type ComputeTimeCursorResponse 

type ComputeTimeCursorResponse struct {

	// If present, the cursor references the first message with time greater than
	// or equal to the specified target time. If such a message cannot be found,
	// the cursor will be unset (i.e. `cursor` is not present).
	Cursor *Cursor `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

Response containing the cursor corresponding to a publish or event time in a topic partition.

func (*ComputeTimeCursorResponse) Descriptor deprecated 

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

Deprecated: Use ComputeTimeCursorResponse.ProtoReflect.Descriptor instead.

func (*ComputeTimeCursorResponse) GetCursor 

func (x *ComputeTimeCursorResponse) GetCursor() *Cursor

func (*ComputeTimeCursorResponse) ProtoMessage 

func (*ComputeTimeCursorResponse) ProtoMessage()

func (*ComputeTimeCursorResponse) ProtoReflect 

func (x *ComputeTimeCursorResponse) ProtoReflect() protoreflect.Message

func (*ComputeTimeCursorResponse) Reset 

func (x *ComputeTimeCursorResponse) Reset()

func (*ComputeTimeCursorResponse) String 

func (x *ComputeTimeCursorResponse) String() string

type CreateReservationRequest 

type CreateReservationRequest struct {

	// Required. The parent location in which to create the reservation.
	// Structured like `projects/{project_number}/locations/{location}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Configuration of the reservation to create. Its `name` field is ignored.
	Reservation *Reservation `protobuf:"bytes,2,opt,name=reservation,proto3" json:"reservation,omitempty"`
	// Required. The ID to use for the reservation, which will become the final component of
	// the reservation's name.
	//
	// This value is structured like: `my-reservation-name`.
	ReservationId string `protobuf:"bytes,3,opt,name=reservation_id,json=reservationId,proto3" json:"reservation_id,omitempty"`
	// contains filtered or unexported fields
}

Request for CreateReservation.

func (*CreateReservationRequest) Descriptor deprecated 

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

Deprecated: Use CreateReservationRequest.ProtoReflect.Descriptor instead.

func (*CreateReservationRequest) GetParent 

func (x *CreateReservationRequest) GetParent() string

func (*CreateReservationRequest) GetReservation 

func (x *CreateReservationRequest) GetReservation() *Reservation

func (*CreateReservationRequest) GetReservationId 

func (x *CreateReservationRequest) GetReservationId() string

func (*CreateReservationRequest) ProtoMessage 

func (*CreateReservationRequest) ProtoMessage()

func (*CreateReservationRequest) ProtoReflect 

func (x *CreateReservationRequest) ProtoReflect() protoreflect.Message

func (*CreateReservationRequest) Reset 

func (x *CreateReservationRequest) Reset()

func (*CreateReservationRequest) String 

func (x *CreateReservationRequest) String() string

type CreateSubscriptionRequest 

type CreateSubscriptionRequest struct {

	// Required. The parent location in which to create the subscription.
	// Structured like `projects/{project_number}/locations/{location}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Configuration of the subscription to create. Its `name` field is ignored.
	Subscription *Subscription `protobuf:"bytes,2,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// Required. The ID to use for the subscription, which will become the final component
	// of the subscription's name.
	//
	// This value is structured like: `my-sub-name`.
	SubscriptionId string `protobuf:"bytes,3,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// If true, the newly created subscription will only receive messages
	// published after the subscription was created. Otherwise, the entire
	// message backlog will be received on the subscription. Defaults to false.
	SkipBacklog bool `protobuf:"varint,4,opt,name=skip_backlog,json=skipBacklog,proto3" json:"skip_backlog,omitempty"`
	// contains filtered or unexported fields
}

Request for CreateSubscription.

func (*CreateSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use CreateSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*CreateSubscriptionRequest) GetParent 

func (x *CreateSubscriptionRequest) GetParent() string

func (*CreateSubscriptionRequest) GetSkipBacklog 

func (x *CreateSubscriptionRequest) GetSkipBacklog() bool

func (*CreateSubscriptionRequest) GetSubscription 

func (x *CreateSubscriptionRequest) GetSubscription() *Subscription

func (*CreateSubscriptionRequest) GetSubscriptionId 

func (x *CreateSubscriptionRequest) GetSubscriptionId() string

func (*CreateSubscriptionRequest) ProtoMessage 

func (*CreateSubscriptionRequest) ProtoMessage()

func (*CreateSubscriptionRequest) ProtoReflect 

func (x *CreateSubscriptionRequest) ProtoReflect() protoreflect.Message

func (*CreateSubscriptionRequest) Reset 

func (x *CreateSubscriptionRequest) Reset()

func (*CreateSubscriptionRequest) String 

func (x *CreateSubscriptionRequest) String() string

type CreateTopicRequest 

type CreateTopicRequest struct {

	// Required. The parent location in which to create the topic.
	// Structured like `projects/{project_number}/locations/{location}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Configuration of the topic to create. Its `name` field is ignored.
	Topic *Topic `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// Required. The ID to use for the topic, which will become the final component of
	// the topic's name.
	//
	// This value is structured like: `my-topic-name`.
	TopicId string `protobuf:"bytes,3,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	// contains filtered or unexported fields
}

Request for CreateTopic.

func (*CreateTopicRequest) Descriptor deprecated 

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

Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest) GetParent 

func (x *CreateTopicRequest) GetParent() string

func (*CreateTopicRequest) GetTopic 

func (x *CreateTopicRequest) GetTopic() *Topic

func (*CreateTopicRequest) GetTopicId 

func (x *CreateTopicRequest) GetTopicId() string

func (*CreateTopicRequest) ProtoMessage 

func (*CreateTopicRequest) ProtoMessage()

func (*CreateTopicRequest) ProtoReflect 

func (x *CreateTopicRequest) ProtoReflect() protoreflect.Message

func (*CreateTopicRequest) Reset 

func (x *CreateTopicRequest) Reset()

func (*CreateTopicRequest) String 

func (x *CreateTopicRequest) String() string

type Cursor 

type Cursor struct {

	// The offset of a message within a topic partition. Must be greater than or
	// equal 0.
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

A cursor that describes the position of a message within a topic partition.

func (*Cursor) Descriptor deprecated 

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

Deprecated: Use Cursor.ProtoReflect.Descriptor instead.

func (*Cursor) GetOffset 

func (x *Cursor) GetOffset() int64

func (*Cursor) ProtoMessage 

func (*Cursor) ProtoMessage()

func (*Cursor) ProtoReflect 

func (x *Cursor) ProtoReflect() protoreflect.Message

func (*Cursor) Reset 

func (x *Cursor) Reset()

func (*Cursor) String 

func (x *Cursor) String() string

type CursorServiceClient 

type CursorServiceClient interface {
	// Establishes a stream with the server for managing committed cursors.
	StreamingCommitCursor(ctx context.Context, opts ...grpc.CallOption) (CursorService_StreamingCommitCursorClient, error)
	// Updates the committed cursor.
	CommitCursor(ctx context.Context, in *CommitCursorRequest, opts ...grpc.CallOption) (*CommitCursorResponse, error)
	// Returns all committed cursor information for a subscription.
	ListPartitionCursors(ctx context.Context, in *ListPartitionCursorsRequest, opts ...grpc.CallOption) (*ListPartitionCursorsResponse, error)
}

CursorServiceClient is the client API for CursorService service.

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

func NewCursorServiceClient 

func NewCursorServiceClient(cc grpc.ClientConnInterface) CursorServiceClient

type CursorServiceServer 

type CursorServiceServer interface {
	// Establishes a stream with the server for managing committed cursors.
	StreamingCommitCursor(CursorService_StreamingCommitCursorServer) error
	// Updates the committed cursor.
	CommitCursor(context.Context, *CommitCursorRequest) (*CommitCursorResponse, error)
	// Returns all committed cursor information for a subscription.
	ListPartitionCursors(context.Context, *ListPartitionCursorsRequest) (*ListPartitionCursorsResponse, error)
}

CursorServiceServer is the server API for CursorService service.

type CursorService_StreamingCommitCursorClient 

type CursorService_StreamingCommitCursorClient interface {
	Send(*StreamingCommitCursorRequest) error
	Recv() (*StreamingCommitCursorResponse, error)
	grpc.ClientStream
}

type CursorService_StreamingCommitCursorServer 

type CursorService_StreamingCommitCursorServer interface {
	Send(*StreamingCommitCursorResponse) error
	Recv() (*StreamingCommitCursorRequest, error)
	grpc.ServerStream
}

type DeleteReservationRequest 

type DeleteReservationRequest struct {

	// Required. The name of the reservation to delete.
	// Structured like:
	// projects/{project_number}/locations/{location}/reservations/{reservation_id}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for DeleteReservation.

func (*DeleteReservationRequest) Descriptor deprecated 

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

Deprecated: Use DeleteReservationRequest.ProtoReflect.Descriptor instead.

func (*DeleteReservationRequest) GetName 

func (x *DeleteReservationRequest) GetName() string

func (*DeleteReservationRequest) ProtoMessage 

func (*DeleteReservationRequest) ProtoMessage()

func (*DeleteReservationRequest) ProtoReflect 

func (x *DeleteReservationRequest) ProtoReflect() protoreflect.Message

func (*DeleteReservationRequest) Reset 

func (x *DeleteReservationRequest) Reset()

func (*DeleteReservationRequest) String 

func (x *DeleteReservationRequest) String() string

type DeleteSubscriptionRequest 

type DeleteSubscriptionRequest struct {

	// Required. The name of the subscription to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for DeleteSubscription.

func (*DeleteSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*DeleteSubscriptionRequest) GetName 

func (x *DeleteSubscriptionRequest) GetName() string

func (*DeleteSubscriptionRequest) ProtoMessage 

func (*DeleteSubscriptionRequest) ProtoMessage()

func (*DeleteSubscriptionRequest) ProtoReflect 

func (x *DeleteSubscriptionRequest) ProtoReflect() protoreflect.Message

func (*DeleteSubscriptionRequest) Reset 

func (x *DeleteSubscriptionRequest) Reset()

func (*DeleteSubscriptionRequest) String 

func (x *DeleteSubscriptionRequest) String() string

type DeleteTopicRequest 

type DeleteTopicRequest struct {

	// Required. The name of the topic to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for DeleteTopic.

func (*DeleteTopicRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTopicRequest.ProtoReflect.Descriptor instead.

func (*DeleteTopicRequest) GetName 

func (x *DeleteTopicRequest) GetName() string

func (*DeleteTopicRequest) ProtoMessage 

func (*DeleteTopicRequest) ProtoMessage()

func (*DeleteTopicRequest) ProtoReflect 

func (x *DeleteTopicRequest) ProtoReflect() protoreflect.Message

func (*DeleteTopicRequest) Reset 

func (x *DeleteTopicRequest) Reset()

func (*DeleteTopicRequest) String 

func (x *DeleteTopicRequest) String() string

type FlowControlRequest 

type FlowControlRequest struct {

	// The number of message tokens to grant. Must be greater than or equal to 0.
	AllowedMessages int64 `protobuf:"varint,1,opt,name=allowed_messages,json=allowedMessages,proto3" json:"allowed_messages,omitempty"`
	// The number of byte tokens to grant. Must be greater than or equal to 0.
	AllowedBytes int64 `protobuf:"varint,2,opt,name=allowed_bytes,json=allowedBytes,proto3" json:"allowed_bytes,omitempty"`
	// contains filtered or unexported fields
}

Request to grant tokens to the server, requesting delivery of messages when they become available.

func (*FlowControlRequest) Descriptor deprecated 

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

Deprecated: Use FlowControlRequest.ProtoReflect.Descriptor instead.

func (*FlowControlRequest) GetAllowedBytes 

func (x *FlowControlRequest) GetAllowedBytes() int64

func (*FlowControlRequest) GetAllowedMessages 

func (x *FlowControlRequest) GetAllowedMessages() int64

func (*FlowControlRequest) ProtoMessage 

func (*FlowControlRequest) ProtoMessage()

func (*FlowControlRequest) ProtoReflect 

func (x *FlowControlRequest) ProtoReflect() protoreflect.Message

func (*FlowControlRequest) Reset 

func (x *FlowControlRequest) Reset()

func (*FlowControlRequest) String 

func (x *FlowControlRequest) String() string

type GetReservationRequest 

type GetReservationRequest struct {

	// Required. The name of the reservation whose configuration to return.
	// Structured like:
	// projects/{project_number}/locations/{location}/reservations/{reservation_id}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for GetReservation.

func (*GetReservationRequest) Descriptor deprecated 

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

Deprecated: Use GetReservationRequest.ProtoReflect.Descriptor instead.

func (*GetReservationRequest) GetName 

func (x *GetReservationRequest) GetName() string

func (*GetReservationRequest) ProtoMessage 

func (*GetReservationRequest) ProtoMessage()

func (*GetReservationRequest) ProtoReflect 

func (x *GetReservationRequest) ProtoReflect() protoreflect.Message

func (*GetReservationRequest) Reset 

func (x *GetReservationRequest) Reset()

func (*GetReservationRequest) String 

func (x *GetReservationRequest) String() string

type GetSubscriptionRequest 

type GetSubscriptionRequest struct {

	// Required. The name of the subscription whose configuration to return.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for GetSubscription.

func (*GetSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use GetSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*GetSubscriptionRequest) GetName 

func (x *GetSubscriptionRequest) GetName() string

func (*GetSubscriptionRequest) ProtoMessage 

func (*GetSubscriptionRequest) ProtoMessage()

func (*GetSubscriptionRequest) ProtoReflect 

func (x *GetSubscriptionRequest) ProtoReflect() protoreflect.Message

func (*GetSubscriptionRequest) Reset 

func (x *GetSubscriptionRequest) Reset()

func (*GetSubscriptionRequest) String 

func (x *GetSubscriptionRequest) String() string

type GetTopicPartitionsRequest 

type GetTopicPartitionsRequest struct {

	// Required. The topic whose partition information to return.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for GetTopicPartitions.

func (*GetTopicPartitionsRequest) Descriptor deprecated 

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

Deprecated: Use GetTopicPartitionsRequest.ProtoReflect.Descriptor instead.

func (*GetTopicPartitionsRequest) GetName 

func (x *GetTopicPartitionsRequest) GetName() string

func (*GetTopicPartitionsRequest) ProtoMessage 

func (*GetTopicPartitionsRequest) ProtoMessage()

func (*GetTopicPartitionsRequest) ProtoReflect 

func (x *GetTopicPartitionsRequest) ProtoReflect() protoreflect.Message

func (*GetTopicPartitionsRequest) Reset 

func (x *GetTopicPartitionsRequest) Reset()

func (*GetTopicPartitionsRequest) String 

func (x *GetTopicPartitionsRequest) String() string

type GetTopicRequest 

type GetTopicRequest struct {

	// Required. The name of the topic whose configuration to return.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for GetTopic.

func (*GetTopicRequest) Descriptor deprecated 

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

Deprecated: Use GetTopicRequest.ProtoReflect.Descriptor instead.

func (*GetTopicRequest) GetName 

func (x *GetTopicRequest) GetName() string

func (*GetTopicRequest) ProtoMessage 

func (*GetTopicRequest) ProtoMessage()

func (*GetTopicRequest) ProtoReflect 

func (x *GetTopicRequest) ProtoReflect() protoreflect.Message

func (*GetTopicRequest) Reset 

func (x *GetTopicRequest) Reset()

func (*GetTopicRequest) String 

func (x *GetTopicRequest) String() string

type InitialCommitCursorRequest 

type InitialCommitCursorRequest struct {

	// The subscription for which to manage committed cursors.
	Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// The partition for which to manage committed cursors. Partitions are zero
	// indexed, so `partition` must be in the range [0, topic.num_partitions).
	Partition int64 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

The first streaming request that must be sent on a newly-opened stream. The client must wait for the response before sending subsequent requests on the stream.

func (*InitialCommitCursorRequest) Descriptor deprecated 

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

Deprecated: Use InitialCommitCursorRequest.ProtoReflect.Descriptor instead.

func (*InitialCommitCursorRequest) GetPartition 

func (x *InitialCommitCursorRequest) GetPartition() int64

func (*InitialCommitCursorRequest) GetSubscription 

func (x *InitialCommitCursorRequest) GetSubscription() string

func (*InitialCommitCursorRequest) ProtoMessage 

func (*InitialCommitCursorRequest) ProtoMessage()

func (*InitialCommitCursorRequest) ProtoReflect 

func (x *InitialCommitCursorRequest) ProtoReflect() protoreflect.Message

func (*InitialCommitCursorRequest) Reset 

func (x *InitialCommitCursorRequest) Reset()

func (*InitialCommitCursorRequest) String 

func (x *InitialCommitCursorRequest) String() string

type InitialCommitCursorResponse 

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

Response to an InitialCommitCursorRequest.

func (*InitialCommitCursorResponse) Descriptor deprecated 

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

Deprecated: Use InitialCommitCursorResponse.ProtoReflect.Descriptor instead.

func (*InitialCommitCursorResponse) ProtoMessage 

func (*InitialCommitCursorResponse) ProtoMessage()

func (*InitialCommitCursorResponse) ProtoReflect 

func (x *InitialCommitCursorResponse) ProtoReflect() protoreflect.Message

func (*InitialCommitCursorResponse) Reset 

func (x *InitialCommitCursorResponse) Reset()

func (*InitialCommitCursorResponse) String 

func (x *InitialCommitCursorResponse) String() string

type InitialPartitionAssignmentRequest 

type InitialPartitionAssignmentRequest struct {

	// The subscription name. Structured like:
	// projects/<project number>/locations/<zone name>/subscriptions/<subscription
	// id>
	Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// An opaque, unique client identifier. This field must be exactly 16 bytes
	// long and is interpreted as an unsigned 128 bit integer. Other size values
	// will be rejected and the stream will be failed with a non-retryable error.
	//
	// This field is large enough to fit a uuid from standard uuid algorithms like
	// uuid1 or uuid4, which should be used to generate this number. The same
	// identifier should be reused following disconnections with retryable stream
	// errors.
	ClientId []byte `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

The first request that must be sent on a newly-opened stream. The client must wait for the response before sending subsequent requests on the stream.

func (*InitialPartitionAssignmentRequest) Descriptor deprecated 

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

Deprecated: Use InitialPartitionAssignmentRequest.ProtoReflect.Descriptor instead.

func (*InitialPartitionAssignmentRequest) GetClientId 

func (x *InitialPartitionAssignmentRequest) GetClientId() []byte

func (*InitialPartitionAssignmentRequest) GetSubscription 

func (x *InitialPartitionAssignmentRequest) GetSubscription() string

func (*InitialPartitionAssignmentRequest) ProtoMessage 

func (*InitialPartitionAssignmentRequest) ProtoMessage()

func (*InitialPartitionAssignmentRequest) ProtoReflect 

func (x *InitialPartitionAssignmentRequest) ProtoReflect() protoreflect.Message

func (*InitialPartitionAssignmentRequest) Reset 

func (x *InitialPartitionAssignmentRequest) Reset()

func (*InitialPartitionAssignmentRequest) String 

func (x *InitialPartitionAssignmentRequest) String() string

type InitialPublishRequest 

type InitialPublishRequest struct {

	// The topic to which messages will be written.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// The partition within the topic to which messages will be written.
	// Partitions are zero indexed, so `partition` must be in the range [0,
	// topic.num_partitions).
	Partition int64 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

The first request that must be sent on a newly-opened stream.

func (*InitialPublishRequest) Descriptor deprecated 

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

Deprecated: Use InitialPublishRequest.ProtoReflect.Descriptor instead.

func (*InitialPublishRequest) GetPartition 

func (x *InitialPublishRequest) GetPartition() int64

func (*InitialPublishRequest) GetTopic 

func (x *InitialPublishRequest) GetTopic() string

func (*InitialPublishRequest) ProtoMessage 

func (*InitialPublishRequest) ProtoMessage()

func (*InitialPublishRequest) ProtoReflect 

func (x *InitialPublishRequest) ProtoReflect() protoreflect.Message

func (*InitialPublishRequest) Reset 

func (x *InitialPublishRequest) Reset()

func (*InitialPublishRequest) String 

func (x *InitialPublishRequest) String() string

type InitialPublishResponse 

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

Response to an InitialPublishRequest.

func (*InitialPublishResponse) Descriptor deprecated 

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

Deprecated: Use InitialPublishResponse.ProtoReflect.Descriptor instead.

func (*InitialPublishResponse) ProtoMessage 

func (*InitialPublishResponse) ProtoMessage()

func (*InitialPublishResponse) ProtoReflect 

func (x *InitialPublishResponse) ProtoReflect() protoreflect.Message

func (*InitialPublishResponse) Reset 

func (x *InitialPublishResponse) Reset()

func (*InitialPublishResponse) String 

func (x *InitialPublishResponse) String() string

type InitialSubscribeRequest 

type InitialSubscribeRequest struct {

	// The subscription from which to receive messages.
	Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// The partition from which to receive messages. Partitions are zero indexed,
	// so `partition` must be in the range [0, topic.num_partitions).
	Partition int64 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// Optional. Initial target location within the message backlog. If not set, messages
	// will be delivered from the commit cursor for the given subscription and
	// partition.
	InitialLocation *SeekRequest `protobuf:"bytes,4,opt,name=initial_location,json=initialLocation,proto3" json:"initial_location,omitempty"`
	// contains filtered or unexported fields
}

The first request that must be sent on a newly-opened stream. The client must wait for the response before sending subsequent requests on the stream.

func (*InitialSubscribeRequest) Descriptor deprecated 

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

Deprecated: Use InitialSubscribeRequest.ProtoReflect.Descriptor instead.

func (*InitialSubscribeRequest) GetInitialLocation 

func (x *InitialSubscribeRequest) GetInitialLocation() *SeekRequest

func (*InitialSubscribeRequest) GetPartition 

func (x *InitialSubscribeRequest) GetPartition() int64

func (*InitialSubscribeRequest) GetSubscription 

func (x *InitialSubscribeRequest) GetSubscription() string

func (*InitialSubscribeRequest) ProtoMessage 

func (*InitialSubscribeRequest) ProtoMessage()

func (*InitialSubscribeRequest) ProtoReflect 

func (x *InitialSubscribeRequest) ProtoReflect() protoreflect.Message

func (*InitialSubscribeRequest) Reset 

func (x *InitialSubscribeRequest) Reset()

func (*InitialSubscribeRequest) String 

func (x *InitialSubscribeRequest) String() string

type InitialSubscribeResponse 

type InitialSubscribeResponse struct {

	// The cursor from which the subscriber will start receiving messages once
	// flow control tokens become available.
	Cursor *Cursor `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

Response to an InitialSubscribeRequest.

func (*InitialSubscribeResponse) Descriptor deprecated 

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

Deprecated: Use InitialSubscribeResponse.ProtoReflect.Descriptor instead.

func (*InitialSubscribeResponse) GetCursor 

func (x *InitialSubscribeResponse) GetCursor() *Cursor

func (*InitialSubscribeResponse) ProtoMessage 

func (*InitialSubscribeResponse) ProtoMessage()

func (*InitialSubscribeResponse) ProtoReflect 

func (x *InitialSubscribeResponse) ProtoReflect() protoreflect.Message

func (*InitialSubscribeResponse) Reset 

func (x *InitialSubscribeResponse) Reset()

func (*InitialSubscribeResponse) String 

func (x *InitialSubscribeResponse) String() string

type ListPartitionCursorsRequest 

type ListPartitionCursorsRequest struct {

	// Required. The subscription for which to retrieve cursors.
	// Structured like
	// `projects/{project_number}/locations/{location}/subscriptions/{subscription_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of cursors to return. The service may return fewer than
	// this value.
	// If unset or zero, all cursors for the parent will be returned.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `ListPartitionCursors` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListPartitionCursors`
	// must match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request for ListPartitionCursors.

func (*ListPartitionCursorsRequest) Descriptor deprecated 

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

Deprecated: Use ListPartitionCursorsRequest.ProtoReflect.Descriptor instead.

func (*ListPartitionCursorsRequest) GetPageSize 

func (x *ListPartitionCursorsRequest) GetPageSize() int32

func (*ListPartitionCursorsRequest) GetPageToken 

func (x *ListPartitionCursorsRequest) GetPageToken() string

func (*ListPartitionCursorsRequest) GetParent 

func (x *ListPartitionCursorsRequest) GetParent() string

func (*ListPartitionCursorsRequest) ProtoMessage 

func (*ListPartitionCursorsRequest) ProtoMessage()

func (*ListPartitionCursorsRequest) ProtoReflect 

func (x *ListPartitionCursorsRequest) ProtoReflect() protoreflect.Message

func (*ListPartitionCursorsRequest) Reset 

func (x *ListPartitionCursorsRequest) Reset()

func (*ListPartitionCursorsRequest) String 

func (x *ListPartitionCursorsRequest) String() string

type ListPartitionCursorsResponse 

type ListPartitionCursorsResponse struct {

	// The partition cursors from this request.
	PartitionCursors []*PartitionCursor `protobuf:"bytes,1,rep,name=partition_cursors,json=partitionCursors,proto3" json:"partition_cursors,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response for ListPartitionCursors

func (*ListPartitionCursorsResponse) Descriptor deprecated 

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

Deprecated: Use ListPartitionCursorsResponse.ProtoReflect.Descriptor instead.

func (*ListPartitionCursorsResponse) GetNextPageToken 

func (x *ListPartitionCursorsResponse) GetNextPageToken() string

func (*ListPartitionCursorsResponse) GetPartitionCursors 

func (x *ListPartitionCursorsResponse) GetPartitionCursors() []*PartitionCursor

func (*ListPartitionCursorsResponse) ProtoMessage 

func (*ListPartitionCursorsResponse) ProtoMessage()

func (*ListPartitionCursorsResponse) ProtoReflect 

func (x *ListPartitionCursorsResponse) ProtoReflect() protoreflect.Message

func (*ListPartitionCursorsResponse) Reset 

func (x *ListPartitionCursorsResponse) Reset()

func (*ListPartitionCursorsResponse) String 

func (x *ListPartitionCursorsResponse) String() string

type ListReservationTopicsRequest 

type ListReservationTopicsRequest struct {

	// Required. The name of the reservation whose topics to list.
	// Structured like:
	// projects/{project_number}/locations/{location}/reservations/{reservation_id}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The maximum number of topics to return. The service may return fewer
	// than this value.
	// If unset or zero, all topics for the given reservation will be returned.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `ListReservationTopics` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListReservationTopics`
	// must match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request for ListReservationTopics.

func (*ListReservationTopicsRequest) Descriptor deprecated 

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

Deprecated: Use ListReservationTopicsRequest.ProtoReflect.Descriptor instead.

func (*ListReservationTopicsRequest) GetName 

func (x *ListReservationTopicsRequest) GetName() string

func (*ListReservationTopicsRequest) GetPageSize 

func (x *ListReservationTopicsRequest) GetPageSize() int32

func (*ListReservationTopicsRequest) GetPageToken 

func (x *ListReservationTopicsRequest) GetPageToken() string

func (*ListReservationTopicsRequest) ProtoMessage 

func (*ListReservationTopicsRequest) ProtoMessage()

func (*ListReservationTopicsRequest) ProtoReflect 

func (x *ListReservationTopicsRequest) ProtoReflect() protoreflect.Message

func (*ListReservationTopicsRequest) Reset 

func (x *ListReservationTopicsRequest) Reset()

func (*ListReservationTopicsRequest) String 

func (x *ListReservationTopicsRequest) String() string

type ListReservationTopicsResponse 

type ListReservationTopicsResponse struct {

	// The names of topics attached to the reservation. The order of the
	// topics is unspecified.
	Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// A token that can be sent as `page_token` to retrieve the next page of
	// results. If this field is omitted, there are no more results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response for ListReservationTopics.

func (*ListReservationTopicsResponse) Descriptor deprecated 

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

Deprecated: Use ListReservationTopicsResponse.ProtoReflect.Descriptor instead.

func (*ListReservationTopicsResponse) GetNextPageToken 

func (x *ListReservationTopicsResponse) GetNextPageToken() string

func (*ListReservationTopicsResponse) GetTopics 

func (x *ListReservationTopicsResponse) GetTopics() []string

func (*ListReservationTopicsResponse) ProtoMessage 

func (*ListReservationTopicsResponse) ProtoMessage()

func (*ListReservationTopicsResponse) ProtoReflect 

func (x *ListReservationTopicsResponse) ProtoReflect() protoreflect.Message

func (*ListReservationTopicsResponse) Reset 

func (x *ListReservationTopicsResponse) Reset()

func (*ListReservationTopicsResponse) String 

func (x *ListReservationTopicsResponse) String() string

type ListReservationsRequest 

type ListReservationsRequest struct {

	// Required. The parent whose reservations are to be listed.
	// Structured like `projects/{project_number}/locations/{location}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of reservations to return. The service may return fewer
	// than this value. If unset or zero, all reservations for the parent will be
	// returned.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `ListReservations` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListReservations` must
	// match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request for ListReservations.

func (*ListReservationsRequest) Descriptor deprecated 

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

Deprecated: Use ListReservationsRequest.ProtoReflect.Descriptor instead.

func (*ListReservationsRequest) GetPageSize 

func (x *ListReservationsRequest) GetPageSize() int32

func (*ListReservationsRequest) GetPageToken 

func (x *ListReservationsRequest) GetPageToken() string

func (*ListReservationsRequest) GetParent 

func (x *ListReservationsRequest) GetParent() string

func (*ListReservationsRequest) ProtoMessage 

func (*ListReservationsRequest) ProtoMessage()

func (*ListReservationsRequest) ProtoReflect 

func (x *ListReservationsRequest) ProtoReflect() protoreflect.Message

func (*ListReservationsRequest) Reset 

func (x *ListReservationsRequest) Reset()

func (*ListReservationsRequest) String 

func (x *ListReservationsRequest) String() string

type ListReservationsResponse 

type ListReservationsResponse struct {

	// The list of reservation in the requested parent. The order of the
	// reservations is unspecified.
	Reservations []*Reservation `protobuf:"bytes,1,rep,name=reservations,proto3" json:"reservations,omitempty"`
	// A token that can be sent as `page_token` to retrieve the next page of
	// results. If this field is omitted, there are no more results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response for ListReservations.

func (*ListReservationsResponse) Descriptor deprecated 

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

Deprecated: Use ListReservationsResponse.ProtoReflect.Descriptor instead.

func (*ListReservationsResponse) GetNextPageToken 

func (x *ListReservationsResponse) GetNextPageToken() string

func (*ListReservationsResponse) GetReservations 

func (x *ListReservationsResponse) GetReservations() []*Reservation

func (*ListReservationsResponse) ProtoMessage 

func (*ListReservationsResponse) ProtoMessage()

func (*ListReservationsResponse) ProtoReflect 

func (x *ListReservationsResponse) ProtoReflect() protoreflect.Message

func (*ListReservationsResponse) Reset 

func (x *ListReservationsResponse) Reset()

func (*ListReservationsResponse) String 

func (x *ListReservationsResponse) String() string

type ListSubscriptionsRequest 

type ListSubscriptionsRequest struct {

	// Required. The parent whose subscriptions are to be listed.
	// Structured like `projects/{project_number}/locations/{location}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of subscriptions to return. The service may return fewer
	// than this value.
	// If unset or zero, all subscriptions for the parent will be returned.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `ListSubscriptions` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListSubscriptions` must
	// match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request for ListSubscriptions.

func (*ListSubscriptionsRequest) Descriptor deprecated 

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

Deprecated: Use ListSubscriptionsRequest.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsRequest) GetPageSize 

func (x *ListSubscriptionsRequest) GetPageSize() int32

func (*ListSubscriptionsRequest) GetPageToken 

func (x *ListSubscriptionsRequest) GetPageToken() string

func (*ListSubscriptionsRequest) GetParent 

func (x *ListSubscriptionsRequest) GetParent() string

func (*ListSubscriptionsRequest) ProtoMessage 

func (*ListSubscriptionsRequest) ProtoMessage()

func (*ListSubscriptionsRequest) ProtoReflect 

func (x *ListSubscriptionsRequest) ProtoReflect() protoreflect.Message

func (*ListSubscriptionsRequest) Reset 

func (x *ListSubscriptionsRequest) Reset()

func (*ListSubscriptionsRequest) String 

func (x *ListSubscriptionsRequest) String() string

type ListSubscriptionsResponse 

type ListSubscriptionsResponse struct {

	// The list of subscriptions in the requested parent. The order of the
	// subscriptions is unspecified.
	Subscriptions []*Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// A token that can be sent as `page_token` to retrieve the next page of
	// results. If this field is omitted, there are no more results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response for ListSubscriptions.

func (*ListSubscriptionsResponse) Descriptor deprecated 

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

Deprecated: Use ListSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsResponse) GetNextPageToken 

func (x *ListSubscriptionsResponse) GetNextPageToken() string

func (*ListSubscriptionsResponse) GetSubscriptions 

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

func (*ListSubscriptionsResponse) ProtoMessage 

func (*ListSubscriptionsResponse) ProtoMessage()

func (*ListSubscriptionsResponse) ProtoReflect 

func (x *ListSubscriptionsResponse) ProtoReflect() protoreflect.Message

func (*ListSubscriptionsResponse) Reset 

func (x *ListSubscriptionsResponse) Reset()

func (*ListSubscriptionsResponse) String 

func (x *ListSubscriptionsResponse) String() string

type ListTopicSubscriptionsRequest 

type ListTopicSubscriptionsRequest struct {

	// Required. The name of the topic whose subscriptions to list.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The maximum number of subscriptions to return. The service may return fewer
	// than this value.
	// If unset or zero, all subscriptions for the given topic will be returned.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `ListTopicSubscriptions` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListTopicSubscriptions`
	// must match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request for ListTopicSubscriptions.

func (*ListTopicSubscriptionsRequest) Descriptor deprecated 

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

Deprecated: Use ListTopicSubscriptionsRequest.ProtoReflect.Descriptor instead.

func (*ListTopicSubscriptionsRequest) GetName 

func (x *ListTopicSubscriptionsRequest) GetName() string

func (*ListTopicSubscriptionsRequest) GetPageSize 

func (x *ListTopicSubscriptionsRequest) GetPageSize() int32

func (*ListTopicSubscriptionsRequest) GetPageToken 

func (x *ListTopicSubscriptionsRequest) GetPageToken() string

func (*ListTopicSubscriptionsRequest) ProtoMessage 

func (*ListTopicSubscriptionsRequest) ProtoMessage()

func (*ListTopicSubscriptionsRequest) ProtoReflect 

func (x *ListTopicSubscriptionsRequest) ProtoReflect() protoreflect.Message

func (*ListTopicSubscriptionsRequest) Reset 

func (x *ListTopicSubscriptionsRequest) Reset()

func (*ListTopicSubscriptionsRequest) String 

func (x *ListTopicSubscriptionsRequest) String() string

type ListTopicSubscriptionsResponse 

type ListTopicSubscriptionsResponse struct {

	// The names of subscriptions attached to the topic. The order of the
	// subscriptions is unspecified.
	Subscriptions []string `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// A token that can be sent as `page_token` to retrieve the next page of
	// results. If this field is omitted, there are no more results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response for ListTopicSubscriptions.

func (*ListTopicSubscriptionsResponse) Descriptor deprecated 

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

Deprecated: Use ListTopicSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicSubscriptionsResponse) GetNextPageToken 

func (x *ListTopicSubscriptionsResponse) GetNextPageToken() string

func (*ListTopicSubscriptionsResponse) GetSubscriptions 

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

func (*ListTopicSubscriptionsResponse) ProtoMessage 

func (*ListTopicSubscriptionsResponse) ProtoMessage()

func (*ListTopicSubscriptionsResponse) ProtoReflect 

func (x *ListTopicSubscriptionsResponse) ProtoReflect() protoreflect.Message

func (*ListTopicSubscriptionsResponse) Reset 

func (x *ListTopicSubscriptionsResponse) Reset()

func (*ListTopicSubscriptionsResponse) String 

func (x *ListTopicSubscriptionsResponse) String() string

type ListTopicsRequest 

type ListTopicsRequest struct {

	// Required. The parent whose topics are to be listed.
	// Structured like `projects/{project_number}/locations/{location}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of topics to return. The service may return fewer than
	// this value.
	// If unset or zero, all topics for the parent will be returned.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `ListTopics` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListTopics` must match
	// the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request for ListTopics.

func (*ListTopicsRequest) Descriptor deprecated 

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

Deprecated: Use ListTopicsRequest.ProtoReflect.Descriptor instead.

func (*ListTopicsRequest) GetPageSize 

func (x *ListTopicsRequest) GetPageSize() int32

func (*ListTopicsRequest) GetPageToken 

func (x *ListTopicsRequest) GetPageToken() string

func (*ListTopicsRequest) GetParent 

func (x *ListTopicsRequest) GetParent() string

func (*ListTopicsRequest) ProtoMessage 

func (*ListTopicsRequest) ProtoMessage()

func (*ListTopicsRequest) ProtoReflect 

func (x *ListTopicsRequest) ProtoReflect() protoreflect.Message

func (*ListTopicsRequest) Reset 

func (x *ListTopicsRequest) Reset()

func (*ListTopicsRequest) String 

func (x *ListTopicsRequest) String() string

type ListTopicsResponse 

type ListTopicsResponse struct {

	// The list of topic in the requested parent. The order of the topics is
	// unspecified.
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// A token that can be sent as `page_token` to retrieve the next page of
	// results. If this field is omitted, there are no more results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response for ListTopics.

func (*ListTopicsResponse) Descriptor deprecated 

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

Deprecated: Use ListTopicsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicsResponse) GetNextPageToken 

func (x *ListTopicsResponse) GetNextPageToken() string

func (*ListTopicsResponse) GetTopics 

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

func (*ListTopicsResponse) ProtoMessage 

func (*ListTopicsResponse) ProtoMessage()

func (*ListTopicsResponse) ProtoReflect 

func (x *ListTopicsResponse) ProtoReflect() protoreflect.Message

func (*ListTopicsResponse) Reset 

func (x *ListTopicsResponse) Reset()

func (*ListTopicsResponse) String 

func (x *ListTopicsResponse) String() string

type MessagePublishRequest 

type MessagePublishRequest struct {

	// The messages to publish.
	Messages []*PubSubMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

Request to publish messages to the topic.

func (*MessagePublishRequest) Descriptor deprecated 

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

Deprecated: Use MessagePublishRequest.ProtoReflect.Descriptor instead.

func (*MessagePublishRequest) GetMessages 

func (x *MessagePublishRequest) GetMessages() []*PubSubMessage

func (*MessagePublishRequest) ProtoMessage 

func (*MessagePublishRequest) ProtoMessage()

func (*MessagePublishRequest) ProtoReflect 

func (x *MessagePublishRequest) ProtoReflect() protoreflect.Message

func (*MessagePublishRequest) Reset 

func (x *MessagePublishRequest) Reset()

func (*MessagePublishRequest) String 

func (x *MessagePublishRequest) String() string

type MessagePublishResponse 

type MessagePublishResponse struct {

	// The cursor of the first published message in the batch. The cursors for any
	// remaining messages in the batch are guaranteed to be sequential.
	StartCursor *Cursor `protobuf:"bytes,1,opt,name=start_cursor,json=startCursor,proto3" json:"start_cursor,omitempty"`
	// contains filtered or unexported fields
}

Response to a MessagePublishRequest.

func (*MessagePublishResponse) Descriptor deprecated 

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

Deprecated: Use MessagePublishResponse.ProtoReflect.Descriptor instead.

func (*MessagePublishResponse) GetStartCursor 

func (x *MessagePublishResponse) GetStartCursor() *Cursor

func (*MessagePublishResponse) ProtoMessage 

func (*MessagePublishResponse) ProtoMessage()

func (*MessagePublishResponse) ProtoReflect 

func (x *MessagePublishResponse) ProtoReflect() protoreflect.Message

func (*MessagePublishResponse) Reset 

func (x *MessagePublishResponse) Reset()

func (*MessagePublishResponse) String 

func (x *MessagePublishResponse) String() string

type MessageResponse 

type MessageResponse struct {

	// Messages from the topic partition.
	Messages []*SequencedMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

Response containing a list of messages. Upon delivering a MessageResponse to the client, the server:

  • Updates the stream's delivery cursor to one greater than the cursor of the last message in the list.
  • Subtracts the total number of bytes and messages from the tokens available to the server.

func (*MessageResponse) Descriptor deprecated 

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

Deprecated: Use MessageResponse.ProtoReflect.Descriptor instead.

func (*MessageResponse) GetMessages 

func (x *MessageResponse) GetMessages() []*SequencedMessage

func (*MessageResponse) ProtoMessage 

func (*MessageResponse) ProtoMessage()

func (*MessageResponse) ProtoReflect 

func (x *MessageResponse) ProtoReflect() protoreflect.Message

func (*MessageResponse) Reset 

func (x *MessageResponse) Reset()

func (*MessageResponse) String 

func (x *MessageResponse) String() string

type PartitionAssignment 

type PartitionAssignment struct {

	// The list of partition numbers this subscriber is assigned to.
	Partitions []int64 `protobuf:"varint,1,rep,packed,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

PartitionAssignments should not race with acknowledgements. There should be exactly one unacknowledged PartitionAssignment at a time. If not, the client must break the stream.

func (*PartitionAssignment) Descriptor deprecated 

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

Deprecated: Use PartitionAssignment.ProtoReflect.Descriptor instead.

func (*PartitionAssignment) GetPartitions 

func (x *PartitionAssignment) GetPartitions() []int64

func (*PartitionAssignment) ProtoMessage 

func (*PartitionAssignment) ProtoMessage()

func (*PartitionAssignment) ProtoReflect 

func (x *PartitionAssignment) ProtoReflect() protoreflect.Message

func (*PartitionAssignment) Reset 

func (x *PartitionAssignment) Reset()

func (*PartitionAssignment) String 

func (x *PartitionAssignment) String() string

type PartitionAssignmentAck 

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

Acknowledge receipt and handling of the previous assignment. If not sent within a short period after receiving the assignment, partitions may remain unassigned for a period of time until the client is known to be inactive, after which time the server will break the stream.

func (*PartitionAssignmentAck) Descriptor deprecated 

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

Deprecated: Use PartitionAssignmentAck.ProtoReflect.Descriptor instead.

func (*PartitionAssignmentAck) ProtoMessage 

func (*PartitionAssignmentAck) ProtoMessage()

func (*PartitionAssignmentAck) ProtoReflect 

func (x *PartitionAssignmentAck) ProtoReflect() protoreflect.Message

func (*PartitionAssignmentAck) Reset 

func (x *PartitionAssignmentAck) Reset()

func (*PartitionAssignmentAck) String 

func (x *PartitionAssignmentAck) String() string

type PartitionAssignmentRequest 

type PartitionAssignmentRequest struct {

	// The type of request this is.
	//
	// Types that are assignable to Request:
	//	*PartitionAssignmentRequest_Initial
	//	*PartitionAssignmentRequest_Ack
	Request isPartitionAssignmentRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

A request on the PartitionAssignment stream.

func (*PartitionAssignmentRequest) Descriptor deprecated 

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

Deprecated: Use PartitionAssignmentRequest.ProtoReflect.Descriptor instead.

func (*PartitionAssignmentRequest) GetAck 

func (x *PartitionAssignmentRequest) GetAck() *PartitionAssignmentAck

func (*PartitionAssignmentRequest) GetInitial 

func (x *PartitionAssignmentRequest) GetInitial() *InitialPartitionAssignmentRequest

func (*PartitionAssignmentRequest) GetRequest 

func (m *PartitionAssignmentRequest) GetRequest() isPartitionAssignmentRequest_Request

func (*PartitionAssignmentRequest) ProtoMessage 

func (*PartitionAssignmentRequest) ProtoMessage()

func (*PartitionAssignmentRequest) ProtoReflect 

func (x *PartitionAssignmentRequest) ProtoReflect() protoreflect.Message

func (*PartitionAssignmentRequest) Reset 

func (x *PartitionAssignmentRequest) Reset()

func (*PartitionAssignmentRequest) String 

func (x *PartitionAssignmentRequest) String() string

type PartitionAssignmentRequest_Ack 

type PartitionAssignmentRequest_Ack struct {
	// Acknowledgement of a partition assignment.
	Ack *PartitionAssignmentAck `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type PartitionAssignmentRequest_Initial 

type PartitionAssignmentRequest_Initial struct {
	// Initial request on the stream.
	Initial *InitialPartitionAssignmentRequest `protobuf:"bytes,1,opt,name=initial,proto3,oneof"`
}

type PartitionAssignmentServiceClient 

type PartitionAssignmentServiceClient interface {
	// Assign partitions for this client to handle for the specified subscription.
	//
	// The client must send an InitialPartitionAssignmentRequest first.
	// The server will then send at most one unacknowledged PartitionAssignment
	// outstanding on the stream at a time.
	// The client should send a PartitionAssignmentAck after updating the
	// partitions it is connected to to reflect the new assignment.
	AssignPartitions(ctx context.Context, opts ...grpc.CallOption) (PartitionAssignmentService_AssignPartitionsClient, error)
}

PartitionAssignmentServiceClient is the client API for PartitionAssignmentService service.

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

func NewPartitionAssignmentServiceClient 

func NewPartitionAssignmentServiceClient(cc grpc.ClientConnInterface) PartitionAssignmentServiceClient

type PartitionAssignmentServiceServer 

type PartitionAssignmentServiceServer interface {
	// Assign partitions for this client to handle for the specified subscription.
	//
	// The client must send an InitialPartitionAssignmentRequest first.
	// The server will then send at most one unacknowledged PartitionAssignment
	// outstanding on the stream at a time.
	// The client should send a PartitionAssignmentAck after updating the
	// partitions it is connected to to reflect the new assignment.
	AssignPartitions(PartitionAssignmentService_AssignPartitionsServer) error
}

PartitionAssignmentServiceServer is the server API for PartitionAssignmentService service.

type PartitionAssignmentService_AssignPartitionsClient 

type PartitionAssignmentService_AssignPartitionsClient interface {
	Send(*PartitionAssignmentRequest) error
	Recv() (*PartitionAssignment, error)
	grpc.ClientStream
}

type PartitionAssignmentService_AssignPartitionsServer 

type PartitionAssignmentService_AssignPartitionsServer interface {
	Send(*PartitionAssignment) error
	Recv() (*PartitionAssignmentRequest, error)
	grpc.ServerStream
}

type PartitionCursor 

type PartitionCursor struct {

	// The partition this is for.
	Partition int64 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"`
	// The value of the cursor.
	Cursor *Cursor `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

A pair of a Cursor and the partition it is for.

func (*PartitionCursor) Descriptor deprecated 

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

Deprecated: Use PartitionCursor.ProtoReflect.Descriptor instead.

func (*PartitionCursor) GetCursor 

func (x *PartitionCursor) GetCursor() *Cursor

func (*PartitionCursor) GetPartition 

func (x *PartitionCursor) GetPartition() int64

func (*PartitionCursor) ProtoMessage 

func (*PartitionCursor) ProtoMessage()

func (*PartitionCursor) ProtoReflect 

func (x *PartitionCursor) ProtoReflect() protoreflect.Message

func (*PartitionCursor) Reset 

func (x *PartitionCursor) Reset()

func (*PartitionCursor) String 

func (x *PartitionCursor) String() string

type PubSubMessage 

type PubSubMessage struct {

	// The key used for routing messages to partitions or for compaction (e.g.,
	// keep the last N messages per key). If the key is empty, the message is
	// routed to an arbitrary partition.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The payload of the message.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// Optional attributes that can be used for message metadata/headers.
	Attributes map[string]*AttributeValues `` /* 161-byte string literal not displayed */
	// An optional, user-specified event time.
	EventTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	// contains filtered or unexported fields
}

A message that is published by publishers and delivered to subscribers.

func (*PubSubMessage) Descriptor deprecated 

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

Deprecated: Use PubSubMessage.ProtoReflect.Descriptor instead.

func (*PubSubMessage) GetAttributes 

func (x *PubSubMessage) GetAttributes() map[string]*AttributeValues

func (*PubSubMessage) GetData 

func (x *PubSubMessage) GetData() []byte

func (*PubSubMessage) GetEventTime 

func (x *PubSubMessage) GetEventTime() *timestamppb.Timestamp

func (*PubSubMessage) GetKey 

func (x *PubSubMessage) GetKey() []byte

func (*PubSubMessage) ProtoMessage 

func (*PubSubMessage) ProtoMessage()

func (*PubSubMessage) ProtoReflect 

func (x *PubSubMessage) ProtoReflect() protoreflect.Message

func (*PubSubMessage) Reset 

func (x *PubSubMessage) Reset()

func (*PubSubMessage) String 

func (x *PubSubMessage) String() string

type PublishRequest 

type PublishRequest struct {

	// The type of request this is.
	//
	// Types that are assignable to RequestType:
	//	*PublishRequest_InitialRequest
	//	*PublishRequest_MessagePublishRequest
	RequestType isPublishRequest_RequestType `protobuf_oneof:"request_type"`
	// contains filtered or unexported fields
}

Request sent from the client to the server on a stream.

func (*PublishRequest) Descriptor deprecated 

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetInitialRequest 

func (x *PublishRequest) GetInitialRequest() *InitialPublishRequest

func (*PublishRequest) GetMessagePublishRequest 

func (x *PublishRequest) GetMessagePublishRequest() *MessagePublishRequest

func (*PublishRequest) GetRequestType 

func (m *PublishRequest) GetRequestType() isPublishRequest_RequestType

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect 

func (x *PublishRequest) ProtoReflect() protoreflect.Message

func (*PublishRequest) Reset 

func (x *PublishRequest) Reset()

func (*PublishRequest) String 

func (x *PublishRequest) String() string

type PublishRequest_InitialRequest 

type PublishRequest_InitialRequest struct {
	// Initial request on the stream.
	InitialRequest *InitialPublishRequest `protobuf:"bytes,1,opt,name=initial_request,json=initialRequest,proto3,oneof"`
}

type PublishRequest_MessagePublishRequest 

type PublishRequest_MessagePublishRequest struct {
	// Request to publish messages.
	MessagePublishRequest *MessagePublishRequest `protobuf:"bytes,2,opt,name=message_publish_request,json=messagePublishRequest,proto3,oneof"`
}

type PublishResponse 

type PublishResponse struct {

	// The type of response this is.
	//
	// Types that are assignable to ResponseType:
	//	*PublishResponse_InitialResponse
	//	*PublishResponse_MessageResponse
	ResponseType isPublishResponse_ResponseType `protobuf_oneof:"response_type"`
	// contains filtered or unexported fields
}

Response to a PublishRequest.

func (*PublishResponse) Descriptor deprecated 

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) GetInitialResponse 

func (x *PublishResponse) GetInitialResponse() *InitialPublishResponse

func (*PublishResponse) GetMessageResponse 

func (x *PublishResponse) GetMessageResponse() *MessagePublishResponse

func (*PublishResponse) GetResponseType 

func (m *PublishResponse) GetResponseType() isPublishResponse_ResponseType

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect 

func (x *PublishResponse) ProtoReflect() protoreflect.Message

func (*PublishResponse) Reset 

func (x *PublishResponse) Reset()

func (*PublishResponse) String 

func (x *PublishResponse) String() string

type PublishResponse_InitialResponse 

type PublishResponse_InitialResponse struct {
	// Initial response on the stream.
	InitialResponse *InitialPublishResponse `protobuf:"bytes,1,opt,name=initial_response,json=initialResponse,proto3,oneof"`
}

type PublishResponse_MessageResponse 

type PublishResponse_MessageResponse struct {
	// Response to publishing messages.
	MessageResponse *MessagePublishResponse `protobuf:"bytes,2,opt,name=message_response,json=messageResponse,proto3,oneof"`
}

type PublisherServiceClient 

type PublisherServiceClient interface {
	// Establishes a stream with the server for publishing messages. Once the
	// stream is initialized, the client publishes messages by sending publish
	// requests on the stream. The server responds with a PublishResponse for each
	// PublishRequest sent by the client, in the same order that the requests
	// were sent. Note that multiple PublishRequests can be in flight
	// simultaneously, but they will be processed by the server in the order that
	// they are sent by the client on a given stream.
	Publish(ctx context.Context, opts ...grpc.CallOption) (PublisherService_PublishClient, error)
}

PublisherServiceClient is the client API for PublisherService service.

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

func NewPublisherServiceClient 

func NewPublisherServiceClient(cc grpc.ClientConnInterface) PublisherServiceClient

type PublisherServiceServer 

type PublisherServiceServer interface {
	// Establishes a stream with the server for publishing messages. Once the
	// stream is initialized, the client publishes messages by sending publish
	// requests on the stream. The server responds with a PublishResponse for each
	// PublishRequest sent by the client, in the same order that the requests
	// were sent. Note that multiple PublishRequests can be in flight
	// simultaneously, but they will be processed by the server in the order that
	// they are sent by the client on a given stream.
	Publish(PublisherService_PublishServer) error
}

PublisherServiceServer is the server API for PublisherService service.

type PublisherService_PublishClient 

type PublisherService_PublishClient interface {
	Send(*PublishRequest) error
	Recv() (*PublishResponse, error)
	grpc.ClientStream
}

type PublisherService_PublishServer 

type PublisherService_PublishServer interface {
	Send(*PublishResponse) error
	Recv() (*PublishRequest, error)
	grpc.ServerStream
}

type Reservation 

type Reservation struct {

	// The name of the reservation.
	// Structured like:
	// projects/{project_number}/locations/{location}/reservations/{reservation_id}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The reserved throughput capacity. Every unit of throughput capacity is
	// equivalent to 1 MiB/s of published messages or 2 MiB/s of subscribed
	// messages.
	//
	// Any topics which are declared as using capacity from a Reservation will
	// consume resources from this reservation instead of being charged
	// individually.
	ThroughputCapacity int64 `protobuf:"varint,2,opt,name=throughput_capacity,json=throughputCapacity,proto3" json:"throughput_capacity,omitempty"`
	// contains filtered or unexported fields
}

Metadata about a reservation resource.

func (*Reservation) Descriptor deprecated 

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

Deprecated: Use Reservation.ProtoReflect.Descriptor instead.

func (*Reservation) GetName 

func (x *Reservation) GetName() string

func (*Reservation) GetThroughputCapacity 

func (x *Reservation) GetThroughputCapacity() int64

func (*Reservation) ProtoMessage 

func (*Reservation) ProtoMessage()

func (*Reservation) ProtoReflect 

func (x *Reservation) ProtoReflect() protoreflect.Message

func (*Reservation) Reset 

func (x *Reservation) Reset()

func (*Reservation) String 

func (x *Reservation) String() string

type SeekRequest 

type SeekRequest struct {

	// The target to seek to. Must be set.
	//
	// Types that are assignable to Target:
	//	*SeekRequest_NamedTarget_
	//	*SeekRequest_Cursor
	Target isSeekRequest_Target `protobuf_oneof:"target"`
	// contains filtered or unexported fields
}

Request to update the stream's delivery cursor based on the given target. Resets the server available tokens to 0. SeekRequests past head result in stream breakage.

SeekRequests may not be sent while another SeekRequest is outstanding (i.e., has not received a SeekResponse) on the same stream.

func (*SeekRequest) Descriptor deprecated 

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

Deprecated: Use SeekRequest.ProtoReflect.Descriptor instead.

func (*SeekRequest) GetCursor 

func (x *SeekRequest) GetCursor() *Cursor

func (*SeekRequest) GetNamedTarget 

func (x *SeekRequest) GetNamedTarget() SeekRequest_NamedTarget

func (*SeekRequest) GetTarget 

func (m *SeekRequest) GetTarget() isSeekRequest_Target

func (*SeekRequest) ProtoMessage 

func (*SeekRequest) ProtoMessage()

func (*SeekRequest) ProtoReflect 

func (x *SeekRequest) ProtoReflect() protoreflect.Message

func (*SeekRequest) Reset 

func (x *SeekRequest) Reset()

func (*SeekRequest) String 

func (x *SeekRequest) String() string

type SeekRequest_Cursor 

type SeekRequest_Cursor struct {
	// A target corresponding to the cursor, pointing to anywhere in the
	// topic partition.
	Cursor *Cursor `protobuf:"bytes,2,opt,name=cursor,proto3,oneof"`
}

type SeekRequest_NamedTarget 

type SeekRequest_NamedTarget int32

A special target in the partition that takes no other parameters. 

const (
	// Default value. This value is unused.
	SeekRequest_NAMED_TARGET_UNSPECIFIED SeekRequest_NamedTarget = 0
	// A target corresponding to the most recently published message in the
	// partition.
	SeekRequest_HEAD SeekRequest_NamedTarget = 1
	// A target corresponding to the committed cursor for the given subscription
	// and topic partition.
	SeekRequest_COMMITTED_CURSOR SeekRequest_NamedTarget = 2
)

func (SeekRequest_NamedTarget) Descriptor 

func (SeekRequest_NamedTarget) Descriptor() protoreflect.EnumDescriptor

func (SeekRequest_NamedTarget) Enum 

func (x SeekRequest_NamedTarget) Enum() *SeekRequest_NamedTarget

func (SeekRequest_NamedTarget) EnumDescriptor deprecated 

func (SeekRequest_NamedTarget) EnumDescriptor() ([]byte, []int)

Deprecated: Use SeekRequest_NamedTarget.Descriptor instead.

func (SeekRequest_NamedTarget) Number 

func (x SeekRequest_NamedTarget) Number() protoreflect.EnumNumber

func (SeekRequest_NamedTarget) String 

func (x SeekRequest_NamedTarget) String() string

func (SeekRequest_NamedTarget) Type 

func (SeekRequest_NamedTarget) Type() protoreflect.EnumType

type SeekRequest_NamedTarget_ 

type SeekRequest_NamedTarget_ struct {
	// A named target.
	NamedTarget SeekRequest_NamedTarget `` /* 127-byte string literal not displayed */
}

type SeekResponse 

type SeekResponse struct {

	// The new delivery cursor for the current stream.
	Cursor *Cursor `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

Response to a SeekRequest.

func (*SeekResponse) Descriptor deprecated 

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

Deprecated: Use SeekResponse.ProtoReflect.Descriptor instead.

func (*SeekResponse) GetCursor 

func (x *SeekResponse) GetCursor() *Cursor

func (*SeekResponse) ProtoMessage 

func (*SeekResponse) ProtoMessage()

func (*SeekResponse) ProtoReflect 

func (x *SeekResponse) ProtoReflect() protoreflect.Message

func (*SeekResponse) Reset 

func (x *SeekResponse) Reset()

func (*SeekResponse) String 

func (x *SeekResponse) String() string

type SequencedCommitCursorRequest 

type SequencedCommitCursorRequest struct {

	// The new value for the committed cursor.
	Cursor *Cursor `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

Streaming request to update the committed cursor. Subsequent SequencedCommitCursorRequests override outstanding ones.

func (*SequencedCommitCursorRequest) Descriptor deprecated 

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

Deprecated: Use SequencedCommitCursorRequest.ProtoReflect.Descriptor instead.

func (*SequencedCommitCursorRequest) GetCursor 

func (x *SequencedCommitCursorRequest) GetCursor() *Cursor

func (*SequencedCommitCursorRequest) ProtoMessage 

func (*SequencedCommitCursorRequest) ProtoMessage()

func (*SequencedCommitCursorRequest) ProtoReflect 

func (x *SequencedCommitCursorRequest) ProtoReflect() protoreflect.Message

func (*SequencedCommitCursorRequest) Reset 

func (x *SequencedCommitCursorRequest) Reset()

func (*SequencedCommitCursorRequest) String 

func (x *SequencedCommitCursorRequest) String() string

type SequencedCommitCursorResponse 

type SequencedCommitCursorResponse struct {

	// The number of outstanding SequencedCommitCursorRequests acknowledged by
	// this response. Note that SequencedCommitCursorRequests are acknowledged in
	// the order that they are received.
	AcknowledgedCommits int64 `protobuf:"varint,1,opt,name=acknowledged_commits,json=acknowledgedCommits,proto3" json:"acknowledged_commits,omitempty"`
	// contains filtered or unexported fields
}

Response to a SequencedCommitCursorRequest.

func (*SequencedCommitCursorResponse) Descriptor deprecated 

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

Deprecated: Use SequencedCommitCursorResponse.ProtoReflect.Descriptor instead.

func (*SequencedCommitCursorResponse) GetAcknowledgedCommits 

func (x *SequencedCommitCursorResponse) GetAcknowledgedCommits() int64

func (*SequencedCommitCursorResponse) ProtoMessage 

func (*SequencedCommitCursorResponse) ProtoMessage()

func (*SequencedCommitCursorResponse) ProtoReflect 

func (x *SequencedCommitCursorResponse) ProtoReflect() protoreflect.Message

func (*SequencedCommitCursorResponse) Reset 

func (x *SequencedCommitCursorResponse) Reset()

func (*SequencedCommitCursorResponse) String 

func (x *SequencedCommitCursorResponse) String() string

type SequencedMessage 

type SequencedMessage struct {

	// The position of a message within the partition where it is stored.
	Cursor *Cursor `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// The time when the message was received by the server when it was first
	// published.
	PublishTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=publish_time,json=publishTime,proto3" json:"publish_time,omitempty"`
	// The user message.
	Message *PubSubMessage `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// The size in bytes of this message for flow control and quota purposes.
	SizeBytes int64 `protobuf:"varint,4,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// contains filtered or unexported fields
}

A message that has been stored and sequenced by the Pub/Sub Lite system.

func (*SequencedMessage) Descriptor deprecated 

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

Deprecated: Use SequencedMessage.ProtoReflect.Descriptor instead.

func (*SequencedMessage) GetCursor 

func (x *SequencedMessage) GetCursor() *Cursor

func (*SequencedMessage) GetMessage 

func (x *SequencedMessage) GetMessage() *PubSubMessage

func (*SequencedMessage) GetPublishTime 

func (x *SequencedMessage) GetPublishTime() *timestamppb.Timestamp

func (*SequencedMessage) GetSizeBytes 

func (x *SequencedMessage) GetSizeBytes() int64

func (*SequencedMessage) ProtoMessage 

func (*SequencedMessage) ProtoMessage()

func (*SequencedMessage) ProtoReflect 

func (x *SequencedMessage) ProtoReflect() protoreflect.Message

func (*SequencedMessage) Reset 

func (x *SequencedMessage) Reset()

func (*SequencedMessage) String 

func (x *SequencedMessage) String() string

type StreamingCommitCursorRequest 

type StreamingCommitCursorRequest struct {

	// The type of request this is.
	//
	// Types that are assignable to Request:
	//	*StreamingCommitCursorRequest_Initial
	//	*StreamingCommitCursorRequest_Commit
	Request isStreamingCommitCursorRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

A request sent from the client to the server on a stream.

func (*StreamingCommitCursorRequest) Descriptor deprecated 

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

Deprecated: Use StreamingCommitCursorRequest.ProtoReflect.Descriptor instead.

func (*StreamingCommitCursorRequest) GetCommit 

func (x *StreamingCommitCursorRequest) GetCommit() *SequencedCommitCursorRequest

func (*StreamingCommitCursorRequest) GetInitial 

func (x *StreamingCommitCursorRequest) GetInitial() *InitialCommitCursorRequest

func (*StreamingCommitCursorRequest) GetRequest 

func (m *StreamingCommitCursorRequest) GetRequest() isStreamingCommitCursorRequest_Request

func (*StreamingCommitCursorRequest) ProtoMessage 

func (*StreamingCommitCursorRequest) ProtoMessage()

func (*StreamingCommitCursorRequest) ProtoReflect 

func (x *StreamingCommitCursorRequest) ProtoReflect() protoreflect.Message

func (*StreamingCommitCursorRequest) Reset 

func (x *StreamingCommitCursorRequest) Reset()

func (*StreamingCommitCursorRequest) String 

func (x *StreamingCommitCursorRequest) String() string

type StreamingCommitCursorRequest_Commit 

type StreamingCommitCursorRequest_Commit struct {
	// Request to commit a new cursor value.
	Commit *SequencedCommitCursorRequest `protobuf:"bytes,2,opt,name=commit,proto3,oneof"`
}

type StreamingCommitCursorRequest_Initial 

type StreamingCommitCursorRequest_Initial struct {
	// Initial request on the stream.
	Initial *InitialCommitCursorRequest `protobuf:"bytes,1,opt,name=initial,proto3,oneof"`
}

type StreamingCommitCursorResponse 

type StreamingCommitCursorResponse struct {

	// The type of request this is.
	//
	// Types that are assignable to Request:
	//	*StreamingCommitCursorResponse_Initial
	//	*StreamingCommitCursorResponse_Commit
	Request isStreamingCommitCursorResponse_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

Response to a StreamingCommitCursorRequest.

func (*StreamingCommitCursorResponse) Descriptor deprecated 

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

Deprecated: Use StreamingCommitCursorResponse.ProtoReflect.Descriptor instead.

func (*StreamingCommitCursorResponse) GetCommit 

func (x *StreamingCommitCursorResponse) GetCommit() *SequencedCommitCursorResponse

func (*StreamingCommitCursorResponse) GetInitial 

func (x *StreamingCommitCursorResponse) GetInitial() *InitialCommitCursorResponse

func (*StreamingCommitCursorResponse) GetRequest 

func (m *StreamingCommitCursorResponse) GetRequest() isStreamingCommitCursorResponse_Request

func (*StreamingCommitCursorResponse) ProtoMessage 

func (*StreamingCommitCursorResponse) ProtoMessage()

func (*StreamingCommitCursorResponse) ProtoReflect 

func (x *StreamingCommitCursorResponse) ProtoReflect() protoreflect.Message

func (*StreamingCommitCursorResponse) Reset 

func (x *StreamingCommitCursorResponse) Reset()

func (*StreamingCommitCursorResponse) String 

func (x *StreamingCommitCursorResponse) String() string

type StreamingCommitCursorResponse_Commit 

type StreamingCommitCursorResponse_Commit struct {
	// Response to committing a new cursor value.
	Commit *SequencedCommitCursorResponse `protobuf:"bytes,2,opt,name=commit,proto3,oneof"`
}

type StreamingCommitCursorResponse_Initial 

type StreamingCommitCursorResponse_Initial struct {
	// Initial response on the stream.
	Initial *InitialCommitCursorResponse `protobuf:"bytes,1,opt,name=initial,proto3,oneof"`
}

type SubscribeRequest 

type SubscribeRequest struct {

	// The type of request this is.
	//
	// Types that are assignable to Request:
	//	*SubscribeRequest_Initial
	//	*SubscribeRequest_Seek
	//	*SubscribeRequest_FlowControl
	Request isSubscribeRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

A request sent from the client to the server on a stream.

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetFlowControl 

func (x *SubscribeRequest) GetFlowControl() *FlowControlRequest

func (*SubscribeRequest) GetInitial 

func (x *SubscribeRequest) GetInitial() *InitialSubscribeRequest

func (*SubscribeRequest) GetRequest 

func (m *SubscribeRequest) GetRequest() isSubscribeRequest_Request

func (*SubscribeRequest) GetSeek 

func (x *SubscribeRequest) GetSeek() *SeekRequest

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeRequest_FlowControl 

type SubscribeRequest_FlowControl struct {
	// Request to grant tokens to the server,
	FlowControl *FlowControlRequest `protobuf:"bytes,3,opt,name=flow_control,json=flowControl,proto3,oneof"`
}

type SubscribeRequest_Initial 

type SubscribeRequest_Initial struct {
	// Initial request on the stream.
	Initial *InitialSubscribeRequest `protobuf:"bytes,1,opt,name=initial,proto3,oneof"`
}

type SubscribeRequest_Seek 

type SubscribeRequest_Seek struct {
	// Request to update the stream's delivery cursor.
	Seek *SeekRequest `protobuf:"bytes,2,opt,name=seek,proto3,oneof"`
}

type SubscribeResponse 

type SubscribeResponse struct {

	// The type of response this is.
	//
	// Types that are assignable to Response:
	//	*SubscribeResponse_Initial
	//	*SubscribeResponse_Seek
	//	*SubscribeResponse_Messages
	Response isSubscribeResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

Response to SubscribeRequest.

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetInitial 

func (x *SubscribeResponse) GetInitial() *InitialSubscribeResponse

func (*SubscribeResponse) GetMessages 

func (x *SubscribeResponse) GetMessages() *MessageResponse

func (*SubscribeResponse) GetResponse 

func (m *SubscribeResponse) GetResponse() isSubscribeResponse_Response

func (*SubscribeResponse) GetSeek 

func (x *SubscribeResponse) GetSeek() *SeekResponse

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

func (x *SubscribeResponse) ProtoReflect() protoreflect.Message

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *SubscribeResponse) String() string

type SubscribeResponse_Initial 

type SubscribeResponse_Initial struct {
	// Initial response on the stream.
	Initial *InitialSubscribeResponse `protobuf:"bytes,1,opt,name=initial,proto3,oneof"`
}

type SubscribeResponse_Messages 

type SubscribeResponse_Messages struct {
	// Response containing messages from the topic partition.
	Messages *MessageResponse `protobuf:"bytes,3,opt,name=messages,proto3,oneof"`
}

type SubscribeResponse_Seek 

type SubscribeResponse_Seek struct {
	// Response to a Seek operation.
	Seek *SeekResponse `protobuf:"bytes,2,opt,name=seek,proto3,oneof"`
}

type SubscriberServiceClient 

type SubscriberServiceClient interface {
	// Establishes a stream with the server for receiving messages.
	Subscribe(ctx context.Context, opts ...grpc.CallOption) (SubscriberService_SubscribeClient, error)
}

SubscriberServiceClient is the client API for SubscriberService service.

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

func NewSubscriberServiceClient 

func NewSubscriberServiceClient(cc grpc.ClientConnInterface) SubscriberServiceClient

type SubscriberServiceServer 

type SubscriberServiceServer interface {
	// Establishes a stream with the server for receiving messages.
	Subscribe(SubscriberService_SubscribeServer) error
}

SubscriberServiceServer is the server API for SubscriberService service.

type SubscriberService_SubscribeClient 

type SubscriberService_SubscribeClient interface {
	Send(*SubscribeRequest) error
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type SubscriberService_SubscribeServer 

type SubscriberService_SubscribeServer interface {
	Send(*SubscribeResponse) error
	Recv() (*SubscribeRequest, error)
	grpc.ServerStream
}

type Subscription 

type Subscription struct {

	// The name of the subscription.
	// Structured like:
	// projects/{project_number}/locations/{location}/subscriptions/{subscription_id}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The name of the topic this subscription is attached to.
	// Structured like:
	// projects/{project_number}/locations/{location}/topics/{topic_id}
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// The settings for this subscription's message delivery.
	DeliveryConfig *Subscription_DeliveryConfig `protobuf:"bytes,3,opt,name=delivery_config,json=deliveryConfig,proto3" json:"delivery_config,omitempty"`
	// contains filtered or unexported fields
}

Metadata about a subscription resource.

func (*Subscription) Descriptor deprecated 

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

Deprecated: Use Subscription.ProtoReflect.Descriptor instead.

func (*Subscription) GetDeliveryConfig 

func (x *Subscription) GetDeliveryConfig() *Subscription_DeliveryConfig

func (*Subscription) GetName 

func (x *Subscription) GetName() string

func (*Subscription) GetTopic 

func (x *Subscription) GetTopic() string

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) ProtoReflect 

func (x *Subscription) ProtoReflect() protoreflect.Message

func (*Subscription) Reset 

func (x *Subscription) Reset()

func (*Subscription) String 

func (x *Subscription) String() string

type Subscription_DeliveryConfig 

type Subscription_DeliveryConfig struct {

	// The DeliveryRequirement for this subscription.
	DeliveryRequirement Subscription_DeliveryConfig_DeliveryRequirement `` /* 199-byte string literal not displayed */
	// contains filtered or unexported fields
}

The settings for a subscription's message delivery.

func (*Subscription_DeliveryConfig) Descriptor deprecated 

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

Deprecated: Use Subscription_DeliveryConfig.ProtoReflect.Descriptor instead.

func (*Subscription_DeliveryConfig) GetDeliveryRequirement 

func (x *Subscription_DeliveryConfig) GetDeliveryRequirement() Subscription_DeliveryConfig_DeliveryRequirement

func (*Subscription_DeliveryConfig) ProtoMessage 

func (*Subscription_DeliveryConfig) ProtoMessage()

func (*Subscription_DeliveryConfig) ProtoReflect 

func (x *Subscription_DeliveryConfig) ProtoReflect() protoreflect.Message

func (*Subscription_DeliveryConfig) Reset 

func (x *Subscription_DeliveryConfig) Reset()

func (*Subscription_DeliveryConfig) String 

func (x *Subscription_DeliveryConfig) String() string

type Subscription_DeliveryConfig_DeliveryRequirement 

type Subscription_DeliveryConfig_DeliveryRequirement int32

When this subscription should send messages to subscribers relative to messages persistence in storage. For details, see [Creating Lite subscriptions](https://cloud.google.com/pubsub/lite/docs/subscriptions#creating_lite_subscriptions). 

const (
	// Default value. This value is unused.
	Subscription_DeliveryConfig_DELIVERY_REQUIREMENT_UNSPECIFIED Subscription_DeliveryConfig_DeliveryRequirement = 0
	// The server does not wait for a published message to be successfully
	// written to storage before delivering it to subscribers.
	Subscription_DeliveryConfig_DELIVER_IMMEDIATELY Subscription_DeliveryConfig_DeliveryRequirement = 1
	// The server will not deliver a published message to subscribers until
	// the message has been successfully written to storage. This will result
	// in higher end-to-end latency, but consistent delivery.
	Subscription_DeliveryConfig_DELIVER_AFTER_STORED Subscription_DeliveryConfig_DeliveryRequirement = 2
)

func (Subscription_DeliveryConfig_DeliveryRequirement) Descriptor 

func (Subscription_DeliveryConfig_DeliveryRequirement) Descriptor() protoreflect.EnumDescriptor

func (Subscription_DeliveryConfig_DeliveryRequirement) Enum 

func (x Subscription_DeliveryConfig_DeliveryRequirement) Enum() *Subscription_DeliveryConfig_DeliveryRequirement

func (Subscription_DeliveryConfig_DeliveryRequirement) EnumDescriptor deprecated 

func (Subscription_DeliveryConfig_DeliveryRequirement) EnumDescriptor() ([]byte, []int)

Deprecated: Use Subscription_DeliveryConfig_DeliveryRequirement.Descriptor instead.

func (Subscription_DeliveryConfig_DeliveryRequirement) Number 

func (x Subscription_DeliveryConfig_DeliveryRequirement) Number() protoreflect.EnumNumber

func (Subscription_DeliveryConfig_DeliveryRequirement) String 

func (x Subscription_DeliveryConfig_DeliveryRequirement) String() string

func (Subscription_DeliveryConfig_DeliveryRequirement) Type 

func (Subscription_DeliveryConfig_DeliveryRequirement) Type() protoreflect.EnumType

type TimeTarget 

type TimeTarget struct {

	// The type of message time to query.
	//
	// Types that are assignable to Time:
	//	*TimeTarget_PublishTime
	//	*TimeTarget_EventTime
	Time isTimeTarget_Time `protobuf_oneof:"time"`
	// contains filtered or unexported fields
}

A target publish or event time. Can be used for seeking to or retrieving the corresponding cursor.

func (*TimeTarget) Descriptor deprecated 

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

Deprecated: Use TimeTarget.ProtoReflect.Descriptor instead.

func (*TimeTarget) GetEventTime 

func (x *TimeTarget) GetEventTime() *timestamppb.Timestamp

func (*TimeTarget) GetPublishTime 

func (x *TimeTarget) GetPublishTime() *timestamppb.Timestamp

func (*TimeTarget) GetTime 

func (m *TimeTarget) GetTime() isTimeTarget_Time

func (*TimeTarget) ProtoMessage 

func (*TimeTarget) ProtoMessage()

func (*TimeTarget) ProtoReflect 

func (x *TimeTarget) ProtoReflect() protoreflect.Message

func (*TimeTarget) Reset 

func (x *TimeTarget) Reset()

func (*TimeTarget) String 

func (x *TimeTarget) String() string

type TimeTarget_EventTime 

type TimeTarget_EventTime struct {
	// Request the cursor of the first message with event time greater than or
	// equal to `event_time`. If messages are missing an event time, the publish
	// time is used as a fallback. As event times are user supplied, subsequent
	// messages may have event times less than `event_time` and should be
	// filtered by the client, if necessary.
	EventTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=event_time,json=eventTime,proto3,oneof"`
}

type TimeTarget_PublishTime 

type TimeTarget_PublishTime struct {
	// Request the cursor of the first message with publish time greater than or
	// equal to `publish_time`. All messages thereafter are guaranteed to have
	// publish times >= `publish_time`.
	PublishTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=publish_time,json=publishTime,proto3,oneof"`
}

type Topic 

type Topic struct {

	// The name of the topic.
	// Structured like:
	// projects/{project_number}/locations/{location}/topics/{topic_id}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The settings for this topic's partitions.
	PartitionConfig *Topic_PartitionConfig `protobuf:"bytes,2,opt,name=partition_config,json=partitionConfig,proto3" json:"partition_config,omitempty"`
	// The settings for this topic's message retention.
	RetentionConfig *Topic_RetentionConfig `protobuf:"bytes,3,opt,name=retention_config,json=retentionConfig,proto3" json:"retention_config,omitempty"`
	// The settings for this topic's Reservation usage.
	ReservationConfig *Topic_ReservationConfig `protobuf:"bytes,4,opt,name=reservation_config,json=reservationConfig,proto3" json:"reservation_config,omitempty"`
	// contains filtered or unexported fields
}

Metadata about a topic resource.

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetName 

func (x *Topic) GetName() string

func (*Topic) GetPartitionConfig 

func (x *Topic) GetPartitionConfig() *Topic_PartitionConfig

func (*Topic) GetReservationConfig 

func (x *Topic) GetReservationConfig() *Topic_ReservationConfig

func (*Topic) GetRetentionConfig 

func (x *Topic) GetRetentionConfig() *Topic_RetentionConfig

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect 

func (x *Topic) ProtoReflect() protoreflect.Message

func (*Topic) Reset 

func (x *Topic) Reset()

func (*Topic) String 

func (x *Topic) String() string

type TopicPartitions 

type TopicPartitions struct {

	// The number of partitions in the topic.
	PartitionCount int64 `protobuf:"varint,1,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	// contains filtered or unexported fields
}

Response for GetTopicPartitions.

func (*TopicPartitions) Descriptor deprecated 

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

Deprecated: Use TopicPartitions.ProtoReflect.Descriptor instead.

func (*TopicPartitions) GetPartitionCount 

func (x *TopicPartitions) GetPartitionCount() int64

func (*TopicPartitions) ProtoMessage 

func (*TopicPartitions) ProtoMessage()

func (*TopicPartitions) ProtoReflect 

func (x *TopicPartitions) ProtoReflect() protoreflect.Message

func (*TopicPartitions) Reset 

func (x *TopicPartitions) Reset()

func (*TopicPartitions) String 

func (x *TopicPartitions) String() string

type TopicStatsServiceClient 

type TopicStatsServiceClient interface {
	// Compute statistics about a range of messages in a given topic and
	// partition.
	ComputeMessageStats(ctx context.Context, in *ComputeMessageStatsRequest, opts ...grpc.CallOption) (*ComputeMessageStatsResponse, error)
	// Compute the head cursor for the partition.
	// The head cursor's offset is guaranteed to be less than or equal to all
	// messages which have not yet been acknowledged as published, and
	// greater than the offset of any message whose publish has already
	// been acknowledged. It is zero if there have never been messages in the
	// partition.
	ComputeHeadCursor(ctx context.Context, in *ComputeHeadCursorRequest, opts ...grpc.CallOption) (*ComputeHeadCursorResponse, error)
	// Compute the corresponding cursor for a publish or event time in a topic
	// partition.
	ComputeTimeCursor(ctx context.Context, in *ComputeTimeCursorRequest, opts ...grpc.CallOption) (*ComputeTimeCursorResponse, error)
}

TopicStatsServiceClient is the client API for TopicStatsService service.

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

func NewTopicStatsServiceClient 

func NewTopicStatsServiceClient(cc grpc.ClientConnInterface) TopicStatsServiceClient

type TopicStatsServiceServer 

type TopicStatsServiceServer interface {
	// Compute statistics about a range of messages in a given topic and
	// partition.
	ComputeMessageStats(context.Context, *ComputeMessageStatsRequest) (*ComputeMessageStatsResponse, error)
	// Compute the head cursor for the partition.
	// The head cursor's offset is guaranteed to be less than or equal to all
	// messages which have not yet been acknowledged as published, and
	// greater than the offset of any message whose publish has already
	// been acknowledged. It is zero if there have never been messages in the
	// partition.
	ComputeHeadCursor(context.Context, *ComputeHeadCursorRequest) (*ComputeHeadCursorResponse, error)
	// Compute the corresponding cursor for a publish or event time in a topic
	// partition.
	ComputeTimeCursor(context.Context, *ComputeTimeCursorRequest) (*ComputeTimeCursorResponse, error)
}

TopicStatsServiceServer is the server API for TopicStatsService service.

type Topic_PartitionConfig 

type Topic_PartitionConfig struct {

	// The number of partitions in the topic. Must be at least 1.
	//
	// Once a topic has been created the number of partitions can be increased
	// but not decreased. Message ordering is not guaranteed across a topic
	// resize. For more information see
	// https://cloud.google.com/pubsub/lite/docs/topics#scaling_capacity
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// The throughput dimension of this topic.
	//
	// Types that are assignable to Dimension:
	//	*Topic_PartitionConfig_Scale
	//	*Topic_PartitionConfig_Capacity_
	Dimension isTopic_PartitionConfig_Dimension `protobuf_oneof:"dimension"`
	// contains filtered or unexported fields
}

The settings for a topic's partitions.

func (*Topic_PartitionConfig) Descriptor deprecated 

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

Deprecated: Use Topic_PartitionConfig.ProtoReflect.Descriptor instead.

func (*Topic_PartitionConfig) GetCapacity 

func (x *Topic_PartitionConfig) GetCapacity() *Topic_PartitionConfig_Capacity

func (*Topic_PartitionConfig) GetCount 

func (x *Topic_PartitionConfig) GetCount() int64

func (*Topic_PartitionConfig) GetDimension 

func (m *Topic_PartitionConfig) GetDimension() isTopic_PartitionConfig_Dimension

func (*Topic_PartitionConfig) GetScale deprecated 

func (x *Topic_PartitionConfig) GetScale() int32

Deprecated: Do not use.

func (*Topic_PartitionConfig) ProtoMessage 

func (*Topic_PartitionConfig) ProtoMessage()

func (*Topic_PartitionConfig) ProtoReflect 

func (x *Topic_PartitionConfig) ProtoReflect() protoreflect.Message

func (*Topic_PartitionConfig) Reset 

func (x *Topic_PartitionConfig) Reset()

func (*Topic_PartitionConfig) String 

func (x *Topic_PartitionConfig) String() string

type Topic_PartitionConfig_Capacity 

type Topic_PartitionConfig_Capacity struct {

	// Publish throughput capacity per partition in MiB/s.
	// Must be >= 4 and <= 16.
	PublishMibPerSec int32 `protobuf:"varint,1,opt,name=publish_mib_per_sec,json=publishMibPerSec,proto3" json:"publish_mib_per_sec,omitempty"`
	// Subscribe throughput capacity per partition in MiB/s.
	// Must be >= 4 and <= 32.
	SubscribeMibPerSec int32 `protobuf:"varint,2,opt,name=subscribe_mib_per_sec,json=subscribeMibPerSec,proto3" json:"subscribe_mib_per_sec,omitempty"`
	// contains filtered or unexported fields
}

The throughput capacity configuration for each partition.

func (*Topic_PartitionConfig_Capacity) Descriptor deprecated 

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

Deprecated: Use Topic_PartitionConfig_Capacity.ProtoReflect.Descriptor instead.

func (*Topic_PartitionConfig_Capacity) GetPublishMibPerSec 

func (x *Topic_PartitionConfig_Capacity) GetPublishMibPerSec() int32

func (*Topic_PartitionConfig_Capacity) GetSubscribeMibPerSec 

func (x *Topic_PartitionConfig_Capacity) GetSubscribeMibPerSec() int32

func (*Topic_PartitionConfig_Capacity) ProtoMessage 

func (*Topic_PartitionConfig_Capacity) ProtoMessage()

func (*Topic_PartitionConfig_Capacity) ProtoReflect 

func (x *Topic_PartitionConfig_Capacity) ProtoReflect() protoreflect.Message

func (*Topic_PartitionConfig_Capacity) Reset 

func (x *Topic_PartitionConfig_Capacity) Reset()

func (*Topic_PartitionConfig_Capacity) String 

func (x *Topic_PartitionConfig_Capacity) String() string

type Topic_PartitionConfig_Capacity_ 

type Topic_PartitionConfig_Capacity_ struct {
	// The capacity configuration.
	Capacity *Topic_PartitionConfig_Capacity `protobuf:"bytes,3,opt,name=capacity,proto3,oneof"`
}

type Topic_PartitionConfig_Scale 

type Topic_PartitionConfig_Scale struct {
	// DEPRECATED: Use capacity instead which can express a superset of
	// configurations.
	//
	// Every partition in the topic is allocated throughput equivalent to
	// `scale` times the standard partition throughput (4 MiB/s). This is also
	// reflected in the cost of this topic; a topic with `scale` of 2 and
	// count of 10 is charged for 20 partitions. This value must be in the
	// range [1,4].
	//
	// Deprecated: Do not use.
	Scale int32 `protobuf:"varint,2,opt,name=scale,proto3,oneof"`
}

type Topic_ReservationConfig 

type Topic_ReservationConfig struct {

	// The Reservation to use for this topic's throughput capacity.
	// Structured like:
	// projects/{project_number}/locations/{location}/reservations/{reservation_id}
	ThroughputReservation string `protobuf:"bytes,1,opt,name=throughput_reservation,json=throughputReservation,proto3" json:"throughput_reservation,omitempty"`
	// contains filtered or unexported fields
}

The settings for this topic's Reservation usage.

func (*Topic_ReservationConfig) Descriptor deprecated 

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

Deprecated: Use Topic_ReservationConfig.ProtoReflect.Descriptor instead.

func (*Topic_ReservationConfig) GetThroughputReservation 

func (x *Topic_ReservationConfig) GetThroughputReservation() string

func (*Topic_ReservationConfig) ProtoMessage 

func (*Topic_ReservationConfig) ProtoMessage()

func (*Topic_ReservationConfig) ProtoReflect 

func (x *Topic_ReservationConfig) ProtoReflect() protoreflect.Message

func (*Topic_ReservationConfig) Reset 

func (x *Topic_ReservationConfig) Reset()

func (*Topic_ReservationConfig) String 

func (x *Topic_ReservationConfig) String() string

type Topic_RetentionConfig 

type Topic_RetentionConfig struct {

	// The provisioned storage, in bytes, per partition. If the number of bytes
	// stored in any of the topic's partitions grows beyond this value, older
	// messages will be dropped to make room for newer ones, regardless of the
	// value of `period`.
	PerPartitionBytes int64 `protobuf:"varint,1,opt,name=per_partition_bytes,json=perPartitionBytes,proto3" json:"per_partition_bytes,omitempty"`
	// How long a published message is retained. If unset, messages will be
	// retained as long as the bytes retained for each partition is below
	// `per_partition_bytes`.
	Period *durationpb.Duration `protobuf:"bytes,2,opt,name=period,proto3" json:"period,omitempty"`
	// contains filtered or unexported fields
}

The settings for a topic's message retention.

func (*Topic_RetentionConfig) Descriptor deprecated 

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

Deprecated: Use Topic_RetentionConfig.ProtoReflect.Descriptor instead.

func (*Topic_RetentionConfig) GetPerPartitionBytes 

func (x *Topic_RetentionConfig) GetPerPartitionBytes() int64

func (*Topic_RetentionConfig) GetPeriod 

func (x *Topic_RetentionConfig) GetPeriod() *durationpb.Duration

func (*Topic_RetentionConfig) ProtoMessage 

func (*Topic_RetentionConfig) ProtoMessage()

func (*Topic_RetentionConfig) ProtoReflect 

func (x *Topic_RetentionConfig) ProtoReflect() protoreflect.Message

func (*Topic_RetentionConfig) Reset 

func (x *Topic_RetentionConfig) Reset()

func (*Topic_RetentionConfig) String 

func (x *Topic_RetentionConfig) String() string

type UnimplementedAdminServiceServer 

type UnimplementedAdminServiceServer struct {
}

UnimplementedAdminServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdminServiceServer) CreateReservation 

func (*UnimplementedAdminServiceServer) CreateReservation(context.Context, *CreateReservationRequest) (*Reservation, error)

func (*UnimplementedAdminServiceServer) CreateSubscription 

func (*UnimplementedAdminServiceServer) CreateSubscription(context.Context, *CreateSubscriptionRequest) (*Subscription, error)

func (*UnimplementedAdminServiceServer) CreateTopic 

func (*UnimplementedAdminServiceServer) CreateTopic(context.Context, *CreateTopicRequest) (*Topic, error)

func (*UnimplementedAdminServiceServer) DeleteReservation 

func (*UnimplementedAdminServiceServer) DeleteReservation(context.Context, *DeleteReservationRequest) (*emptypb.Empty, error)

func (*UnimplementedAdminServiceServer) DeleteSubscription 

func (*UnimplementedAdminServiceServer) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*emptypb.Empty, error)

func (*UnimplementedAdminServiceServer) DeleteTopic 

func (*UnimplementedAdminServiceServer) DeleteTopic(context.Context, *DeleteTopicRequest) (*emptypb.Empty, error)

func (*UnimplementedAdminServiceServer) GetReservation 

func (*UnimplementedAdminServiceServer) GetReservation(context.Context, *GetReservationRequest) (*Reservation, error)

func (*UnimplementedAdminServiceServer) GetSubscription 

func (*UnimplementedAdminServiceServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error)

func (*UnimplementedAdminServiceServer) GetTopic 

func (*UnimplementedAdminServiceServer) GetTopic(context.Context, *GetTopicRequest) (*Topic, error)

func (*UnimplementedAdminServiceServer) GetTopicPartitions 

func (*UnimplementedAdminServiceServer) GetTopicPartitions(context.Context, *GetTopicPartitionsRequest) (*TopicPartitions, error)

func (*UnimplementedAdminServiceServer) ListReservationTopics 

func (*UnimplementedAdminServiceServer) ListReservationTopics(context.Context, *ListReservationTopicsRequest) (*ListReservationTopicsResponse, error)

func (*UnimplementedAdminServiceServer) ListReservations 

func (*UnimplementedAdminServiceServer) ListReservations(context.Context, *ListReservationsRequest) (*ListReservationsResponse, error)

func (*UnimplementedAdminServiceServer) ListSubscriptions 

func (*UnimplementedAdminServiceServer) ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)

func (*UnimplementedAdminServiceServer) ListTopicSubscriptions 

func (*UnimplementedAdminServiceServer) ListTopicSubscriptions(context.Context, *ListTopicSubscriptionsRequest) (*ListTopicSubscriptionsResponse, error)

func (*UnimplementedAdminServiceServer) ListTopics 

func (*UnimplementedAdminServiceServer) ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)

func (*UnimplementedAdminServiceServer) UpdateReservation 

func (*UnimplementedAdminServiceServer) UpdateReservation(context.Context, *UpdateReservationRequest) (*Reservation, error)

func (*UnimplementedAdminServiceServer) UpdateSubscription 

func (*UnimplementedAdminServiceServer) UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*Subscription, error)

func (*UnimplementedAdminServiceServer) UpdateTopic 

func (*UnimplementedAdminServiceServer) UpdateTopic(context.Context, *UpdateTopicRequest) (*Topic, error)

type UnimplementedCursorServiceServer 

type UnimplementedCursorServiceServer struct {
}

UnimplementedCursorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCursorServiceServer) CommitCursor 

func (*UnimplementedCursorServiceServer) CommitCursor(context.Context, *CommitCursorRequest) (*CommitCursorResponse, error)

func (*UnimplementedCursorServiceServer) ListPartitionCursors 

func (*UnimplementedCursorServiceServer) ListPartitionCursors(context.Context, *ListPartitionCursorsRequest) (*ListPartitionCursorsResponse, error)

func (*UnimplementedCursorServiceServer) StreamingCommitCursor 

func (*UnimplementedCursorServiceServer) StreamingCommitCursor(CursorService_StreamingCommitCursorServer) error

type UnimplementedPartitionAssignmentServiceServer 

type UnimplementedPartitionAssignmentServiceServer struct {
}

UnimplementedPartitionAssignmentServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPartitionAssignmentServiceServer) AssignPartitions 

func (*UnimplementedPartitionAssignmentServiceServer) AssignPartitions(PartitionAssignmentService_AssignPartitionsServer) error

type UnimplementedPublisherServiceServer 

type UnimplementedPublisherServiceServer struct {
}

UnimplementedPublisherServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPublisherServiceServer) Publish 

func (*UnimplementedPublisherServiceServer) Publish(PublisherService_PublishServer) error

type UnimplementedSubscriberServiceServer 

type UnimplementedSubscriberServiceServer struct {
}

UnimplementedSubscriberServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubscriberServiceServer) Subscribe 

func (*UnimplementedSubscriberServiceServer) Subscribe(SubscriberService_SubscribeServer) error

type UnimplementedTopicStatsServiceServer 

type UnimplementedTopicStatsServiceServer struct {
}

UnimplementedTopicStatsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTopicStatsServiceServer) ComputeHeadCursor 

func (*UnimplementedTopicStatsServiceServer) ComputeHeadCursor(context.Context, *ComputeHeadCursorRequest) (*ComputeHeadCursorResponse, error)

func (*UnimplementedTopicStatsServiceServer) ComputeMessageStats 

func (*UnimplementedTopicStatsServiceServer) ComputeMessageStats(context.Context, *ComputeMessageStatsRequest) (*ComputeMessageStatsResponse, error)

func (*UnimplementedTopicStatsServiceServer) ComputeTimeCursor 

func (*UnimplementedTopicStatsServiceServer) ComputeTimeCursor(context.Context, *ComputeTimeCursorRequest) (*ComputeTimeCursorResponse, error)

type UpdateReservationRequest 

type UpdateReservationRequest struct {

	// Required. The reservation to update. Its `name` field must be populated.
	Reservation *Reservation `protobuf:"bytes,1,opt,name=reservation,proto3" json:"reservation,omitempty"`
	// Required. A mask specifying the reservation fields to change.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

Request for UpdateReservation.

func (*UpdateReservationRequest) Descriptor deprecated 

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

Deprecated: Use UpdateReservationRequest.ProtoReflect.Descriptor instead.

func (*UpdateReservationRequest) GetReservation 

func (x *UpdateReservationRequest) GetReservation() *Reservation

func (*UpdateReservationRequest) GetUpdateMask 

func (x *UpdateReservationRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateReservationRequest) ProtoMessage 

func (*UpdateReservationRequest) ProtoMessage()

func (*UpdateReservationRequest) ProtoReflect 

func (x *UpdateReservationRequest) ProtoReflect() protoreflect.Message

func (*UpdateReservationRequest) Reset 

func (x *UpdateReservationRequest) Reset()

func (*UpdateReservationRequest) String 

func (x *UpdateReservationRequest) String() string

type UpdateSubscriptionRequest 

type UpdateSubscriptionRequest struct {

	// Required. The subscription to update. Its `name` field must be populated.
	// Topic field must not be populated.
	Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// Required. A mask specifying the subscription fields to change.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

Request for UpdateSubscription.

func (*UpdateSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use UpdateSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*UpdateSubscriptionRequest) GetSubscription 

func (x *UpdateSubscriptionRequest) GetSubscription() *Subscription

func (*UpdateSubscriptionRequest) GetUpdateMask 

func (x *UpdateSubscriptionRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateSubscriptionRequest) ProtoMessage 

func (*UpdateSubscriptionRequest) ProtoMessage()

func (*UpdateSubscriptionRequest) ProtoReflect 

func (x *UpdateSubscriptionRequest) ProtoReflect() protoreflect.Message

func (*UpdateSubscriptionRequest) Reset 

func (x *UpdateSubscriptionRequest) Reset()

func (*UpdateSubscriptionRequest) String 

func (x *UpdateSubscriptionRequest) String() string

type UpdateTopicRequest 

type UpdateTopicRequest struct {

	// Required. The topic to update. Its `name` field must be populated.
	Topic *Topic `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Required. A mask specifying the topic fields to change.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

Request for UpdateTopic.

func (*UpdateTopicRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTopicRequest.ProtoReflect.Descriptor instead.

func (*UpdateTopicRequest) GetTopic 

func (x *UpdateTopicRequest) GetTopic() *Topic

func (*UpdateTopicRequest) GetUpdateMask 

func (x *UpdateTopicRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateTopicRequest) ProtoMessage 

func (*UpdateTopicRequest) ProtoMessage()

func (*UpdateTopicRequest) ProtoReflect 

func (x *UpdateTopicRequest) ProtoReflect() protoreflect.Message

func (*UpdateTopicRequest) Reset 

func (x *UpdateTopicRequest) Reset()

func (*UpdateTopicRequest) String 

func (x *UpdateTopicRequest) String() string

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.