genproto: google.golang.org/genproto/googleapis/cloud/pubsublite/v1 Index | Files

package pubsublite

import "google.golang.org/genproto/googleapis/cloud/pubsublite/v1"

Index

Package Files

admin.pb.go common.pb.go cursor.pb.go publisher.pb.go subscriber.pb.go topic_stats.pb.go

Variables

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.

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.

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

func RegisterAdminServiceServer Uses

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

func RegisterCursorServiceServer Uses

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

func RegisterPartitionAssignmentServiceServer Uses

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

func RegisterPublisherServiceServer Uses

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

func RegisterSubscriberServiceServer Uses

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

func RegisterTopicStatsServiceServer Uses

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

type AdminServiceClient Uses

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)
}

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 Uses

func NewAdminServiceClient(cc grpc.ClientConnInterface) AdminServiceClient

type AdminServiceServer Uses

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)
}

AdminServiceServer is the server API for AdminService service.

type AttributeValues Uses

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 Uses

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

Deprecated: Use AttributeValues.ProtoReflect.Descriptor instead.

func (*AttributeValues) GetValues Uses

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

func (*AttributeValues) ProtoMessage Uses

func (*AttributeValues) ProtoMessage()

func (*AttributeValues) ProtoReflect Uses

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

func (*AttributeValues) Reset Uses

func (x *AttributeValues) Reset()

func (*AttributeValues) String Uses

func (x *AttributeValues) String() string

type CommitCursorRequest Uses

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 Uses

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

Deprecated: Use CommitCursorRequest.ProtoReflect.Descriptor instead.

func (*CommitCursorRequest) GetCursor Uses

func (x *CommitCursorRequest) GetCursor() *Cursor

func (*CommitCursorRequest) GetPartition Uses

func (x *CommitCursorRequest) GetPartition() int64

func (*CommitCursorRequest) GetSubscription Uses

func (x *CommitCursorRequest) GetSubscription() string

func (*CommitCursorRequest) ProtoMessage Uses

func (*CommitCursorRequest) ProtoMessage()

func (*CommitCursorRequest) ProtoReflect Uses

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

func (*CommitCursorRequest) Reset Uses

func (x *CommitCursorRequest) Reset()

func (*CommitCursorRequest) String Uses

func (x *CommitCursorRequest) String() string

type CommitCursorResponse Uses

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

Response for CommitCursor.

func (*CommitCursorResponse) Descriptor Uses

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

Deprecated: Use CommitCursorResponse.ProtoReflect.Descriptor instead.

func (*CommitCursorResponse) ProtoMessage Uses

func (*CommitCursorResponse) ProtoMessage()

func (*CommitCursorResponse) ProtoReflect Uses

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

func (*CommitCursorResponse) Reset Uses

func (x *CommitCursorResponse) Reset()

func (*CommitCursorResponse) String Uses

func (x *CommitCursorResponse) String() string

type ComputeHeadCursorRequest Uses

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 Uses

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

Deprecated: Use ComputeHeadCursorRequest.ProtoReflect.Descriptor instead.

func (*ComputeHeadCursorRequest) GetPartition Uses

func (x *ComputeHeadCursorRequest) GetPartition() int64

func (*ComputeHeadCursorRequest) GetTopic Uses

func (x *ComputeHeadCursorRequest) GetTopic() string

func (*ComputeHeadCursorRequest) ProtoMessage Uses

func (*ComputeHeadCursorRequest) ProtoMessage()

func (*ComputeHeadCursorRequest) ProtoReflect Uses

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

func (*ComputeHeadCursorRequest) Reset Uses

func (x *ComputeHeadCursorRequest) Reset()

func (*ComputeHeadCursorRequest) String Uses

func (x *ComputeHeadCursorRequest) String() string

type ComputeHeadCursorResponse Uses

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 Uses

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

Deprecated: Use ComputeHeadCursorResponse.ProtoReflect.Descriptor instead.

func (*ComputeHeadCursorResponse) GetHeadCursor Uses

func (x *ComputeHeadCursorResponse) GetHeadCursor() *Cursor

func (*ComputeHeadCursorResponse) ProtoMessage Uses

func (*ComputeHeadCursorResponse) ProtoMessage()

func (*ComputeHeadCursorResponse) ProtoReflect Uses

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

func (*ComputeHeadCursorResponse) Reset Uses

func (x *ComputeHeadCursorResponse) Reset()

func (*ComputeHeadCursorResponse) String Uses

func (x *ComputeHeadCursorResponse) String() string

type ComputeMessageStatsRequest Uses

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 Uses

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

Deprecated: Use ComputeMessageStatsRequest.ProtoReflect.Descriptor instead.

func (*ComputeMessageStatsRequest) GetEndCursor Uses

func (x *ComputeMessageStatsRequest) GetEndCursor() *Cursor

func (*ComputeMessageStatsRequest) GetPartition Uses

func (x *ComputeMessageStatsRequest) GetPartition() int64

func (*ComputeMessageStatsRequest) GetStartCursor Uses

func (x *ComputeMessageStatsRequest) GetStartCursor() *Cursor

func (*ComputeMessageStatsRequest) GetTopic Uses

func (x *ComputeMessageStatsRequest) GetTopic() string

func (*ComputeMessageStatsRequest) ProtoMessage Uses

func (*ComputeMessageStatsRequest) ProtoMessage()

func (*ComputeMessageStatsRequest) ProtoReflect Uses

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

func (*ComputeMessageStatsRequest) Reset Uses

func (x *ComputeMessageStatsRequest) Reset()

func (*ComputeMessageStatsRequest) String Uses

func (x *ComputeMessageStatsRequest) String() string

type ComputeMessageStatsResponse Uses

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 Uses

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

Deprecated: Use ComputeMessageStatsResponse.ProtoReflect.Descriptor instead.

func (*ComputeMessageStatsResponse) GetMessageBytes Uses

func (x *ComputeMessageStatsResponse) GetMessageBytes() int64

func (*ComputeMessageStatsResponse) GetMessageCount Uses

func (x *ComputeMessageStatsResponse) GetMessageCount() int64

func (*ComputeMessageStatsResponse) GetMinimumEventTime Uses

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

func (*ComputeMessageStatsResponse) GetMinimumPublishTime Uses

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

func (*ComputeMessageStatsResponse) ProtoMessage Uses

func (*ComputeMessageStatsResponse) ProtoMessage()

func (*ComputeMessageStatsResponse) ProtoReflect Uses

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

func (*ComputeMessageStatsResponse) Reset Uses

func (x *ComputeMessageStatsResponse) Reset()

func (*ComputeMessageStatsResponse) String Uses

func (x *ComputeMessageStatsResponse) String() string

type CreateSubscriptionRequest Uses

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"`
    // contains filtered or unexported fields
}

Request for CreateSubscription.

func (*CreateSubscriptionRequest) Descriptor Uses

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

Deprecated: Use CreateSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*CreateSubscriptionRequest) GetParent Uses

func (x *CreateSubscriptionRequest) GetParent() string

func (*CreateSubscriptionRequest) GetSubscription Uses

func (x *CreateSubscriptionRequest) GetSubscription() *Subscription

func (*CreateSubscriptionRequest) GetSubscriptionId Uses

func (x *CreateSubscriptionRequest) GetSubscriptionId() string

func (*CreateSubscriptionRequest) ProtoMessage Uses

func (*CreateSubscriptionRequest) ProtoMessage()

func (*CreateSubscriptionRequest) ProtoReflect Uses

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

func (*CreateSubscriptionRequest) Reset Uses

func (x *CreateSubscriptionRequest) Reset()

func (*CreateSubscriptionRequest) String Uses

func (x *CreateSubscriptionRequest) String() string

type CreateTopicRequest Uses

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 Uses

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

Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest) GetParent Uses

func (x *CreateTopicRequest) GetParent() string

func (*CreateTopicRequest) GetTopic Uses

func (x *CreateTopicRequest) GetTopic() *Topic

func (*CreateTopicRequest) GetTopicId Uses

func (x *CreateTopicRequest) GetTopicId() string

func (*CreateTopicRequest) ProtoMessage Uses

func (*CreateTopicRequest) ProtoMessage()

func (*CreateTopicRequest) ProtoReflect Uses

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

func (*CreateTopicRequest) Reset Uses

func (x *CreateTopicRequest) Reset()

func (*CreateTopicRequest) String Uses

func (x *CreateTopicRequest) String() string

type Cursor Uses

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 Uses

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

Deprecated: Use Cursor.ProtoReflect.Descriptor instead.

func (*Cursor) GetOffset Uses

func (x *Cursor) GetOffset() int64

func (*Cursor) ProtoMessage Uses

func (*Cursor) ProtoMessage()

func (*Cursor) ProtoReflect Uses

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

func (*Cursor) Reset Uses

func (x *Cursor) Reset()

func (*Cursor) String Uses

func (x *Cursor) String() string

type CursorServiceClient Uses

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 Uses

func NewCursorServiceClient(cc grpc.ClientConnInterface) CursorServiceClient

type CursorServiceServer Uses

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 Uses

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

type CursorService_StreamingCommitCursorServer Uses

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

type DeleteSubscriptionRequest Uses

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 Uses

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

Deprecated: Use DeleteSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*DeleteSubscriptionRequest) GetName Uses

func (x *DeleteSubscriptionRequest) GetName() string

func (*DeleteSubscriptionRequest) ProtoMessage Uses

func (*DeleteSubscriptionRequest) ProtoMessage()

func (*DeleteSubscriptionRequest) ProtoReflect Uses

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

func (*DeleteSubscriptionRequest) Reset Uses

func (x *DeleteSubscriptionRequest) Reset()

func (*DeleteSubscriptionRequest) String Uses

func (x *DeleteSubscriptionRequest) String() string

type DeleteTopicRequest Uses

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 Uses

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

Deprecated: Use DeleteTopicRequest.ProtoReflect.Descriptor instead.

func (*DeleteTopicRequest) GetName Uses

func (x *DeleteTopicRequest) GetName() string

func (*DeleteTopicRequest) ProtoMessage Uses

func (*DeleteTopicRequest) ProtoMessage()

func (*DeleteTopicRequest) ProtoReflect Uses

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

func (*DeleteTopicRequest) Reset Uses

func (x *DeleteTopicRequest) Reset()

func (*DeleteTopicRequest) String Uses

func (x *DeleteTopicRequest) String() string

type FlowControlRequest Uses

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 Uses

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

Deprecated: Use FlowControlRequest.ProtoReflect.Descriptor instead.

func (*FlowControlRequest) GetAllowedBytes Uses

func (x *FlowControlRequest) GetAllowedBytes() int64

func (*FlowControlRequest) GetAllowedMessages Uses

func (x *FlowControlRequest) GetAllowedMessages() int64

func (*FlowControlRequest) ProtoMessage Uses

func (*FlowControlRequest) ProtoMessage()

func (*FlowControlRequest) ProtoReflect Uses

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

func (*FlowControlRequest) Reset Uses

func (x *FlowControlRequest) Reset()

func (*FlowControlRequest) String Uses

func (x *FlowControlRequest) String() string

type GetSubscriptionRequest Uses

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 Uses

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

Deprecated: Use GetSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*GetSubscriptionRequest) GetName Uses

func (x *GetSubscriptionRequest) GetName() string

func (*GetSubscriptionRequest) ProtoMessage Uses

func (*GetSubscriptionRequest) ProtoMessage()

func (*GetSubscriptionRequest) ProtoReflect Uses

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

func (*GetSubscriptionRequest) Reset Uses

func (x *GetSubscriptionRequest) Reset()

func (*GetSubscriptionRequest) String Uses

func (x *GetSubscriptionRequest) String() string

type GetTopicPartitionsRequest Uses

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 Uses

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

Deprecated: Use GetTopicPartitionsRequest.ProtoReflect.Descriptor instead.

func (*GetTopicPartitionsRequest) GetName Uses

func (x *GetTopicPartitionsRequest) GetName() string

func (*GetTopicPartitionsRequest) ProtoMessage Uses

func (*GetTopicPartitionsRequest) ProtoMessage()

func (*GetTopicPartitionsRequest) ProtoReflect Uses

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

func (*GetTopicPartitionsRequest) Reset Uses

func (x *GetTopicPartitionsRequest) Reset()

func (*GetTopicPartitionsRequest) String Uses

func (x *GetTopicPartitionsRequest) String() string

type GetTopicRequest Uses

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 Uses

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

Deprecated: Use GetTopicRequest.ProtoReflect.Descriptor instead.

func (*GetTopicRequest) GetName Uses

func (x *GetTopicRequest) GetName() string

func (*GetTopicRequest) ProtoMessage Uses

func (*GetTopicRequest) ProtoMessage()

func (*GetTopicRequest) ProtoReflect Uses

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

func (*GetTopicRequest) Reset Uses

func (x *GetTopicRequest) Reset()

func (*GetTopicRequest) String Uses

func (x *GetTopicRequest) String() string

type InitialCommitCursorRequest Uses

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 Uses

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

Deprecated: Use InitialCommitCursorRequest.ProtoReflect.Descriptor instead.

func (*InitialCommitCursorRequest) GetPartition Uses

func (x *InitialCommitCursorRequest) GetPartition() int64

func (*InitialCommitCursorRequest) GetSubscription Uses

func (x *InitialCommitCursorRequest) GetSubscription() string

func (*InitialCommitCursorRequest) ProtoMessage Uses

func (*InitialCommitCursorRequest) ProtoMessage()

func (*InitialCommitCursorRequest) ProtoReflect Uses

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

func (*InitialCommitCursorRequest) Reset Uses

func (x *InitialCommitCursorRequest) Reset()

func (*InitialCommitCursorRequest) String Uses

func (x *InitialCommitCursorRequest) String() string

type InitialCommitCursorResponse Uses

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

Response to an InitialCommitCursorRequest.

func (*InitialCommitCursorResponse) Descriptor Uses

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

Deprecated: Use InitialCommitCursorResponse.ProtoReflect.Descriptor instead.

func (*InitialCommitCursorResponse) ProtoMessage Uses

func (*InitialCommitCursorResponse) ProtoMessage()

func (*InitialCommitCursorResponse) ProtoReflect Uses

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

func (*InitialCommitCursorResponse) Reset Uses

func (x *InitialCommitCursorResponse) Reset()

func (*InitialCommitCursorResponse) String Uses

func (x *InitialCommitCursorResponse) String() string

type InitialPartitionAssignmentRequest Uses

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 Uses

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

Deprecated: Use InitialPartitionAssignmentRequest.ProtoReflect.Descriptor instead.

func (*InitialPartitionAssignmentRequest) GetClientId Uses

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

func (*InitialPartitionAssignmentRequest) GetSubscription Uses

func (x *InitialPartitionAssignmentRequest) GetSubscription() string

func (*InitialPartitionAssignmentRequest) ProtoMessage Uses

func (*InitialPartitionAssignmentRequest) ProtoMessage()

func (*InitialPartitionAssignmentRequest) ProtoReflect Uses

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

func (*InitialPartitionAssignmentRequest) Reset Uses

func (x *InitialPartitionAssignmentRequest) Reset()

func (*InitialPartitionAssignmentRequest) String Uses

func (x *InitialPartitionAssignmentRequest) String() string

type InitialPublishRequest Uses

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 Uses

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

Deprecated: Use InitialPublishRequest.ProtoReflect.Descriptor instead.

func (*InitialPublishRequest) GetPartition Uses

func (x *InitialPublishRequest) GetPartition() int64

func (*InitialPublishRequest) GetTopic Uses

func (x *InitialPublishRequest) GetTopic() string

func (*InitialPublishRequest) ProtoMessage Uses

func (*InitialPublishRequest) ProtoMessage()

func (*InitialPublishRequest) ProtoReflect Uses

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

func (*InitialPublishRequest) Reset Uses

func (x *InitialPublishRequest) Reset()

func (*InitialPublishRequest) String Uses

func (x *InitialPublishRequest) String() string

type InitialPublishResponse Uses

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

Response to an InitialPublishRequest.

func (*InitialPublishResponse) Descriptor Uses

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

Deprecated: Use InitialPublishResponse.ProtoReflect.Descriptor instead.

func (*InitialPublishResponse) ProtoMessage Uses

func (*InitialPublishResponse) ProtoMessage()

func (*InitialPublishResponse) ProtoReflect Uses

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

func (*InitialPublishResponse) Reset Uses

func (x *InitialPublishResponse) Reset()

func (*InitialPublishResponse) String Uses

func (x *InitialPublishResponse) String() string

type InitialSubscribeRequest Uses

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"`
    // 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 Uses

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

Deprecated: Use InitialSubscribeRequest.ProtoReflect.Descriptor instead.

func (*InitialSubscribeRequest) GetPartition Uses

func (x *InitialSubscribeRequest) GetPartition() int64

func (*InitialSubscribeRequest) GetSubscription Uses

func (x *InitialSubscribeRequest) GetSubscription() string

func (*InitialSubscribeRequest) ProtoMessage Uses

func (*InitialSubscribeRequest) ProtoMessage()

func (*InitialSubscribeRequest) ProtoReflect Uses

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

func (*InitialSubscribeRequest) Reset Uses

func (x *InitialSubscribeRequest) Reset()

func (*InitialSubscribeRequest) String Uses

func (x *InitialSubscribeRequest) String() string

type InitialSubscribeResponse Uses

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 Uses

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

Deprecated: Use InitialSubscribeResponse.ProtoReflect.Descriptor instead.

func (*InitialSubscribeResponse) GetCursor Uses

func (x *InitialSubscribeResponse) GetCursor() *Cursor

func (*InitialSubscribeResponse) ProtoMessage Uses

func (*InitialSubscribeResponse) ProtoMessage()

func (*InitialSubscribeResponse) ProtoReflect Uses

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

func (*InitialSubscribeResponse) Reset Uses

func (x *InitialSubscribeResponse) Reset()

func (*InitialSubscribeResponse) String Uses

func (x *InitialSubscribeResponse) String() string

type ListPartitionCursorsRequest Uses

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 Uses

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

Deprecated: Use ListPartitionCursorsRequest.ProtoReflect.Descriptor instead.

func (*ListPartitionCursorsRequest) GetPageSize Uses

func (x *ListPartitionCursorsRequest) GetPageSize() int32

func (*ListPartitionCursorsRequest) GetPageToken Uses

func (x *ListPartitionCursorsRequest) GetPageToken() string

func (*ListPartitionCursorsRequest) GetParent Uses

func (x *ListPartitionCursorsRequest) GetParent() string

func (*ListPartitionCursorsRequest) ProtoMessage Uses

func (*ListPartitionCursorsRequest) ProtoMessage()

func (*ListPartitionCursorsRequest) ProtoReflect Uses

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

func (*ListPartitionCursorsRequest) Reset Uses

func (x *ListPartitionCursorsRequest) Reset()

func (*ListPartitionCursorsRequest) String Uses

func (x *ListPartitionCursorsRequest) String() string

type ListPartitionCursorsResponse Uses

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 Uses

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

Deprecated: Use ListPartitionCursorsResponse.ProtoReflect.Descriptor instead.

func (*ListPartitionCursorsResponse) GetNextPageToken Uses

func (x *ListPartitionCursorsResponse) GetNextPageToken() string

func (*ListPartitionCursorsResponse) GetPartitionCursors Uses

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

func (*ListPartitionCursorsResponse) ProtoMessage Uses

func (*ListPartitionCursorsResponse) ProtoMessage()

func (*ListPartitionCursorsResponse) ProtoReflect Uses

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

func (*ListPartitionCursorsResponse) Reset Uses

func (x *ListPartitionCursorsResponse) Reset()

func (*ListPartitionCursorsResponse) String Uses

func (x *ListPartitionCursorsResponse) String() string

type ListSubscriptionsRequest Uses

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 Uses

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

Deprecated: Use ListSubscriptionsRequest.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsRequest) GetPageSize Uses

func (x *ListSubscriptionsRequest) GetPageSize() int32

func (*ListSubscriptionsRequest) GetPageToken Uses

func (x *ListSubscriptionsRequest) GetPageToken() string

func (*ListSubscriptionsRequest) GetParent Uses

func (x *ListSubscriptionsRequest) GetParent() string

func (*ListSubscriptionsRequest) ProtoMessage Uses

func (*ListSubscriptionsRequest) ProtoMessage()

func (*ListSubscriptionsRequest) ProtoReflect Uses

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

func (*ListSubscriptionsRequest) Reset Uses

func (x *ListSubscriptionsRequest) Reset()

func (*ListSubscriptionsRequest) String Uses

func (x *ListSubscriptionsRequest) String() string

type ListSubscriptionsResponse Uses

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 Uses

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

Deprecated: Use ListSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsResponse) GetNextPageToken Uses

func (x *ListSubscriptionsResponse) GetNextPageToken() string

func (*ListSubscriptionsResponse) GetSubscriptions Uses

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

func (*ListSubscriptionsResponse) ProtoMessage Uses

func (*ListSubscriptionsResponse) ProtoMessage()

func (*ListSubscriptionsResponse) ProtoReflect Uses

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

func (*ListSubscriptionsResponse) Reset Uses

func (x *ListSubscriptionsResponse) Reset()

func (*ListSubscriptionsResponse) String Uses

func (x *ListSubscriptionsResponse) String() string

type ListTopicSubscriptionsRequest Uses

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 Uses

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

Deprecated: Use ListTopicSubscriptionsRequest.ProtoReflect.Descriptor instead.

func (*ListTopicSubscriptionsRequest) GetName Uses

func (x *ListTopicSubscriptionsRequest) GetName() string

func (*ListTopicSubscriptionsRequest) GetPageSize Uses

func (x *ListTopicSubscriptionsRequest) GetPageSize() int32

func (*ListTopicSubscriptionsRequest) GetPageToken Uses

func (x *ListTopicSubscriptionsRequest) GetPageToken() string

func (*ListTopicSubscriptionsRequest) ProtoMessage Uses

func (*ListTopicSubscriptionsRequest) ProtoMessage()

func (*ListTopicSubscriptionsRequest) ProtoReflect Uses

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

func (*ListTopicSubscriptionsRequest) Reset Uses

func (x *ListTopicSubscriptionsRequest) Reset()

func (*ListTopicSubscriptionsRequest) String Uses

func (x *ListTopicSubscriptionsRequest) String() string

type ListTopicSubscriptionsResponse Uses

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 Uses

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

Deprecated: Use ListTopicSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicSubscriptionsResponse) GetNextPageToken Uses

func (x *ListTopicSubscriptionsResponse) GetNextPageToken() string

func (*ListTopicSubscriptionsResponse) GetSubscriptions Uses

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

func (*ListTopicSubscriptionsResponse) ProtoMessage Uses

func (*ListTopicSubscriptionsResponse) ProtoMessage()

func (*ListTopicSubscriptionsResponse) ProtoReflect Uses

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

func (*ListTopicSubscriptionsResponse) Reset Uses

func (x *ListTopicSubscriptionsResponse) Reset()

func (*ListTopicSubscriptionsResponse) String Uses

func (x *ListTopicSubscriptionsResponse) String() string

type ListTopicsRequest Uses

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 Uses

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

Deprecated: Use ListTopicsRequest.ProtoReflect.Descriptor instead.

func (*ListTopicsRequest) GetPageSize Uses

func (x *ListTopicsRequest) GetPageSize() int32

func (*ListTopicsRequest) GetPageToken Uses

func (x *ListTopicsRequest) GetPageToken() string

func (*ListTopicsRequest) GetParent Uses

func (x *ListTopicsRequest) GetParent() string

func (*ListTopicsRequest) ProtoMessage Uses

func (*ListTopicsRequest) ProtoMessage()

func (*ListTopicsRequest) ProtoReflect Uses

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

func (*ListTopicsRequest) Reset Uses

func (x *ListTopicsRequest) Reset()

func (*ListTopicsRequest) String Uses

func (x *ListTopicsRequest) String() string

type ListTopicsResponse Uses

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 Uses

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

Deprecated: Use ListTopicsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicsResponse) GetNextPageToken Uses

func (x *ListTopicsResponse) GetNextPageToken() string

func (*ListTopicsResponse) GetTopics Uses

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

func (*ListTopicsResponse) ProtoMessage Uses

func (*ListTopicsResponse) ProtoMessage()

func (*ListTopicsResponse) ProtoReflect Uses

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

func (*ListTopicsResponse) Reset Uses

func (x *ListTopicsResponse) Reset()

func (*ListTopicsResponse) String Uses

func (x *ListTopicsResponse) String() string

type MessagePublishRequest Uses

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 Uses

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

Deprecated: Use MessagePublishRequest.ProtoReflect.Descriptor instead.

func (*MessagePublishRequest) GetMessages Uses

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

func (*MessagePublishRequest) ProtoMessage Uses

func (*MessagePublishRequest) ProtoMessage()

func (*MessagePublishRequest) ProtoReflect Uses

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

func (*MessagePublishRequest) Reset Uses

func (x *MessagePublishRequest) Reset()

func (*MessagePublishRequest) String Uses

func (x *MessagePublishRequest) String() string

type MessagePublishResponse Uses

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 Uses

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

Deprecated: Use MessagePublishResponse.ProtoReflect.Descriptor instead.

func (*MessagePublishResponse) GetStartCursor Uses

func (x *MessagePublishResponse) GetStartCursor() *Cursor

func (*MessagePublishResponse) ProtoMessage Uses

func (*MessagePublishResponse) ProtoMessage()

func (*MessagePublishResponse) ProtoReflect Uses

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

func (*MessagePublishResponse) Reset Uses

func (x *MessagePublishResponse) Reset()

func (*MessagePublishResponse) String Uses

func (x *MessagePublishResponse) String() string

type MessageResponse Uses

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 Uses

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

Deprecated: Use MessageResponse.ProtoReflect.Descriptor instead.

func (*MessageResponse) GetMessages Uses

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

func (*MessageResponse) ProtoMessage Uses

func (*MessageResponse) ProtoMessage()

func (*MessageResponse) ProtoReflect Uses

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

func (*MessageResponse) Reset Uses

func (x *MessageResponse) Reset()

func (*MessageResponse) String Uses

func (x *MessageResponse) String() string

type PartitionAssignment Uses

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 Uses

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

Deprecated: Use PartitionAssignment.ProtoReflect.Descriptor instead.

func (*PartitionAssignment) GetPartitions Uses

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

func (*PartitionAssignment) ProtoMessage Uses

func (*PartitionAssignment) ProtoMessage()

func (*PartitionAssignment) ProtoReflect Uses

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

func (*PartitionAssignment) Reset Uses

func (x *PartitionAssignment) Reset()

func (*PartitionAssignment) String Uses

func (x *PartitionAssignment) String() string

type PartitionAssignmentAck Uses

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 Uses

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

Deprecated: Use PartitionAssignmentAck.ProtoReflect.Descriptor instead.

func (*PartitionAssignmentAck) ProtoMessage Uses

func (*PartitionAssignmentAck) ProtoMessage()

func (*PartitionAssignmentAck) ProtoReflect Uses

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

func (*PartitionAssignmentAck) Reset Uses

func (x *PartitionAssignmentAck) Reset()

func (*PartitionAssignmentAck) String Uses

func (x *PartitionAssignmentAck) String() string

type PartitionAssignmentRequest Uses

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 Uses

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

Deprecated: Use PartitionAssignmentRequest.ProtoReflect.Descriptor instead.

func (*PartitionAssignmentRequest) GetAck Uses

func (x *PartitionAssignmentRequest) GetAck() *PartitionAssignmentAck

func (*PartitionAssignmentRequest) GetInitial Uses

func (x *PartitionAssignmentRequest) GetInitial() *InitialPartitionAssignmentRequest

func (*PartitionAssignmentRequest) GetRequest Uses

func (m *PartitionAssignmentRequest) GetRequest() isPartitionAssignmentRequest_Request

func (*PartitionAssignmentRequest) ProtoMessage Uses

func (*PartitionAssignmentRequest) ProtoMessage()

func (*PartitionAssignmentRequest) ProtoReflect Uses

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

func (*PartitionAssignmentRequest) Reset Uses

func (x *PartitionAssignmentRequest) Reset()

func (*PartitionAssignmentRequest) String Uses

func (x *PartitionAssignmentRequest) String() string

type PartitionAssignmentRequest_Ack Uses

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

type PartitionAssignmentRequest_Initial Uses

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

type PartitionAssignmentServiceClient Uses

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 Uses

func NewPartitionAssignmentServiceClient(cc grpc.ClientConnInterface) PartitionAssignmentServiceClient

type PartitionAssignmentServiceServer Uses

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 Uses

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

type PartitionAssignmentService_AssignPartitionsServer Uses

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

type PartitionCursor Uses

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 Uses

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

Deprecated: Use PartitionCursor.ProtoReflect.Descriptor instead.

func (*PartitionCursor) GetCursor Uses

func (x *PartitionCursor) GetCursor() *Cursor

func (*PartitionCursor) GetPartition Uses

func (x *PartitionCursor) GetPartition() int64

func (*PartitionCursor) ProtoMessage Uses

func (*PartitionCursor) ProtoMessage()

func (*PartitionCursor) ProtoReflect Uses

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

func (*PartitionCursor) Reset Uses

func (x *PartitionCursor) Reset()

func (*PartitionCursor) String Uses

func (x *PartitionCursor) String() string

type PubSubMessage Uses

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 `protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // 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 Uses

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

Deprecated: Use PubSubMessage.ProtoReflect.Descriptor instead.

func (*PubSubMessage) GetAttributes Uses

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

func (*PubSubMessage) GetData Uses

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

func (*PubSubMessage) GetEventTime Uses

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

func (*PubSubMessage) GetKey Uses

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

func (*PubSubMessage) ProtoMessage Uses

func (*PubSubMessage) ProtoMessage()

func (*PubSubMessage) ProtoReflect Uses

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

func (*PubSubMessage) Reset Uses

func (x *PubSubMessage) Reset()

func (*PubSubMessage) String Uses

func (x *PubSubMessage) String() string

type PublishRequest Uses

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 Uses

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetInitialRequest Uses

func (x *PublishRequest) GetInitialRequest() *InitialPublishRequest

func (*PublishRequest) GetMessagePublishRequest Uses

func (x *PublishRequest) GetMessagePublishRequest() *MessagePublishRequest

func (*PublishRequest) GetRequestType Uses

func (m *PublishRequest) GetRequestType() isPublishRequest_RequestType

func (*PublishRequest) ProtoMessage Uses

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect Uses

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

func (*PublishRequest) Reset Uses

func (x *PublishRequest) Reset()

func (*PublishRequest) String Uses

func (x *PublishRequest) String() string

type PublishRequest_InitialRequest Uses

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 Uses

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

type PublishResponse Uses

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 Uses

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) GetInitialResponse Uses

func (x *PublishResponse) GetInitialResponse() *InitialPublishResponse

func (*PublishResponse) GetMessageResponse Uses

func (x *PublishResponse) GetMessageResponse() *MessagePublishResponse

func (*PublishResponse) GetResponseType Uses

func (m *PublishResponse) GetResponseType() isPublishResponse_ResponseType

func (*PublishResponse) ProtoMessage Uses

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect Uses

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

func (*PublishResponse) Reset Uses

func (x *PublishResponse) Reset()

func (*PublishResponse) String Uses

func (x *PublishResponse) String() string

type PublishResponse_InitialResponse Uses

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 Uses

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

type PublisherServiceClient Uses

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 Uses

func NewPublisherServiceClient(cc grpc.ClientConnInterface) PublisherServiceClient

type PublisherServiceServer Uses

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 Uses

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

type PublisherService_PublishServer Uses

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

type SeekRequest Uses

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 may not be sent while another SeekRequest is outstanding (i.e., has not received a SeekResponse) on the same stream. SeekRequests past head result in stream breakage.

func (*SeekRequest) Descriptor Uses

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

Deprecated: Use SeekRequest.ProtoReflect.Descriptor instead.

func (*SeekRequest) GetCursor Uses

func (x *SeekRequest) GetCursor() *Cursor

func (*SeekRequest) GetNamedTarget Uses

func (x *SeekRequest) GetNamedTarget() SeekRequest_NamedTarget

func (*SeekRequest) GetTarget Uses

func (m *SeekRequest) GetTarget() isSeekRequest_Target

func (*SeekRequest) ProtoMessage Uses

func (*SeekRequest) ProtoMessage()

func (*SeekRequest) ProtoReflect Uses

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

func (*SeekRequest) Reset Uses

func (x *SeekRequest) Reset()

func (*SeekRequest) String Uses

func (x *SeekRequest) String() string

type SeekRequest_Cursor Uses

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 Uses

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 Uses

func (SeekRequest_NamedTarget) Descriptor() protoreflect.EnumDescriptor

func (SeekRequest_NamedTarget) Enum Uses

func (x SeekRequest_NamedTarget) Enum() *SeekRequest_NamedTarget

func (SeekRequest_NamedTarget) EnumDescriptor Uses

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

Deprecated: Use SeekRequest_NamedTarget.Descriptor instead.

func (SeekRequest_NamedTarget) Number Uses

func (x SeekRequest_NamedTarget) Number() protoreflect.EnumNumber

func (SeekRequest_NamedTarget) String Uses

func (x SeekRequest_NamedTarget) String() string

func (SeekRequest_NamedTarget) Type Uses

func (SeekRequest_NamedTarget) Type() protoreflect.EnumType

type SeekRequest_NamedTarget_ Uses

type SeekRequest_NamedTarget_ struct {
    // A named target.
    NamedTarget SeekRequest_NamedTarget `protobuf:"varint,1,opt,name=named_target,json=namedTarget,proto3,enum=google.cloud.pubsublite.v1.SeekRequest_NamedTarget,oneof"`
}

type SeekResponse Uses

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 Uses

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

Deprecated: Use SeekResponse.ProtoReflect.Descriptor instead.

func (*SeekResponse) GetCursor Uses

func (x *SeekResponse) GetCursor() *Cursor

func (*SeekResponse) ProtoMessage Uses

func (*SeekResponse) ProtoMessage()

func (*SeekResponse) ProtoReflect Uses

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

func (*SeekResponse) Reset Uses

func (x *SeekResponse) Reset()

func (*SeekResponse) String Uses

func (x *SeekResponse) String() string

type SequencedCommitCursorRequest Uses

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 Uses

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

Deprecated: Use SequencedCommitCursorRequest.ProtoReflect.Descriptor instead.

func (*SequencedCommitCursorRequest) GetCursor Uses

func (x *SequencedCommitCursorRequest) GetCursor() *Cursor

func (*SequencedCommitCursorRequest) ProtoMessage Uses

func (*SequencedCommitCursorRequest) ProtoMessage()

func (*SequencedCommitCursorRequest) ProtoReflect Uses

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

func (*SequencedCommitCursorRequest) Reset Uses

func (x *SequencedCommitCursorRequest) Reset()

func (*SequencedCommitCursorRequest) String Uses

func (x *SequencedCommitCursorRequest) String() string

type SequencedCommitCursorResponse Uses

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 Uses

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

Deprecated: Use SequencedCommitCursorResponse.ProtoReflect.Descriptor instead.

func (*SequencedCommitCursorResponse) GetAcknowledgedCommits Uses

func (x *SequencedCommitCursorResponse) GetAcknowledgedCommits() int64

func (*SequencedCommitCursorResponse) ProtoMessage Uses

func (*SequencedCommitCursorResponse) ProtoMessage()

func (*SequencedCommitCursorResponse) ProtoReflect Uses

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

func (*SequencedCommitCursorResponse) Reset Uses

func (x *SequencedCommitCursorResponse) Reset()

func (*SequencedCommitCursorResponse) String Uses

func (x *SequencedCommitCursorResponse) String() string

type SequencedMessage Uses

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 Uses

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

Deprecated: Use SequencedMessage.ProtoReflect.Descriptor instead.

func (*SequencedMessage) GetCursor Uses

func (x *SequencedMessage) GetCursor() *Cursor

func (*SequencedMessage) GetMessage Uses

func (x *SequencedMessage) GetMessage() *PubSubMessage

func (*SequencedMessage) GetPublishTime Uses

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

func (*SequencedMessage) GetSizeBytes Uses

func (x *SequencedMessage) GetSizeBytes() int64

func (*SequencedMessage) ProtoMessage Uses

func (*SequencedMessage) ProtoMessage()

func (*SequencedMessage) ProtoReflect Uses

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

func (*SequencedMessage) Reset Uses

func (x *SequencedMessage) Reset()

func (*SequencedMessage) String Uses

func (x *SequencedMessage) String() string

type StreamingCommitCursorRequest Uses

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 Uses

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

Deprecated: Use StreamingCommitCursorRequest.ProtoReflect.Descriptor instead.

func (*StreamingCommitCursorRequest) GetCommit Uses

func (x *StreamingCommitCursorRequest) GetCommit() *SequencedCommitCursorRequest

func (*StreamingCommitCursorRequest) GetInitial Uses

func (x *StreamingCommitCursorRequest) GetInitial() *InitialCommitCursorRequest

func (*StreamingCommitCursorRequest) GetRequest Uses

func (m *StreamingCommitCursorRequest) GetRequest() isStreamingCommitCursorRequest_Request

func (*StreamingCommitCursorRequest) ProtoMessage Uses

func (*StreamingCommitCursorRequest) ProtoMessage()

func (*StreamingCommitCursorRequest) ProtoReflect Uses

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

func (*StreamingCommitCursorRequest) Reset Uses

func (x *StreamingCommitCursorRequest) Reset()

func (*StreamingCommitCursorRequest) String Uses

func (x *StreamingCommitCursorRequest) String() string

type StreamingCommitCursorRequest_Commit Uses

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

type StreamingCommitCursorRequest_Initial Uses

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

type StreamingCommitCursorResponse Uses

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 Uses

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

Deprecated: Use StreamingCommitCursorResponse.ProtoReflect.Descriptor instead.

func (*StreamingCommitCursorResponse) GetCommit Uses

func (x *StreamingCommitCursorResponse) GetCommit() *SequencedCommitCursorResponse

func (*StreamingCommitCursorResponse) GetInitial Uses

func (x *StreamingCommitCursorResponse) GetInitial() *InitialCommitCursorResponse

func (*StreamingCommitCursorResponse) GetRequest Uses

func (m *StreamingCommitCursorResponse) GetRequest() isStreamingCommitCursorResponse_Request

func (*StreamingCommitCursorResponse) ProtoMessage Uses

func (*StreamingCommitCursorResponse) ProtoMessage()

func (*StreamingCommitCursorResponse) ProtoReflect Uses

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

func (*StreamingCommitCursorResponse) Reset Uses

func (x *StreamingCommitCursorResponse) Reset()

func (*StreamingCommitCursorResponse) String Uses

func (x *StreamingCommitCursorResponse) String() string

type StreamingCommitCursorResponse_Commit Uses

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

type StreamingCommitCursorResponse_Initial Uses

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

type SubscribeRequest Uses

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 Uses

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetFlowControl Uses

func (x *SubscribeRequest) GetFlowControl() *FlowControlRequest

func (*SubscribeRequest) GetInitial Uses

func (x *SubscribeRequest) GetInitial() *InitialSubscribeRequest

func (*SubscribeRequest) GetRequest Uses

func (m *SubscribeRequest) GetRequest() isSubscribeRequest_Request

func (*SubscribeRequest) GetSeek Uses

func (x *SubscribeRequest) GetSeek() *SeekRequest

func (*SubscribeRequest) ProtoMessage Uses

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect Uses

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

func (*SubscribeRequest) Reset Uses

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String Uses

func (x *SubscribeRequest) String() string

type SubscribeRequest_FlowControl Uses

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 Uses

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

type SubscribeRequest_Seek Uses

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

type SubscribeResponse Uses

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 Uses

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetInitial Uses

func (x *SubscribeResponse) GetInitial() *InitialSubscribeResponse

func (*SubscribeResponse) GetMessages Uses

func (x *SubscribeResponse) GetMessages() *MessageResponse

func (*SubscribeResponse) GetResponse Uses

func (m *SubscribeResponse) GetResponse() isSubscribeResponse_Response

func (*SubscribeResponse) GetSeek Uses

func (x *SubscribeResponse) GetSeek() *SeekResponse

func (*SubscribeResponse) ProtoMessage Uses

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect Uses

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

func (*SubscribeResponse) Reset Uses

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String Uses

func (x *SubscribeResponse) String() string

type SubscribeResponse_Initial Uses

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

type SubscribeResponse_Messages Uses

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

type SubscribeResponse_Seek Uses

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

type SubscriberServiceClient Uses

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 Uses

func NewSubscriberServiceClient(cc grpc.ClientConnInterface) SubscriberServiceClient

type SubscriberServiceServer Uses

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 Uses

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

type SubscriberService_SubscribeServer Uses

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

type Subscription Uses

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 Uses

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

Deprecated: Use Subscription.ProtoReflect.Descriptor instead.

func (*Subscription) GetDeliveryConfig Uses

func (x *Subscription) GetDeliveryConfig() *Subscription_DeliveryConfig

func (*Subscription) GetName Uses

func (x *Subscription) GetName() string

func (*Subscription) GetTopic Uses

func (x *Subscription) GetTopic() string

func (*Subscription) ProtoMessage Uses

func (*Subscription) ProtoMessage()

func (*Subscription) ProtoReflect Uses

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

func (*Subscription) Reset Uses

func (x *Subscription) Reset()

func (*Subscription) String Uses

func (x *Subscription) String() string

type Subscription_DeliveryConfig Uses

type Subscription_DeliveryConfig struct {

    // The DeliveryRequirement for this subscription.
    DeliveryRequirement Subscription_DeliveryConfig_DeliveryRequirement `protobuf:"varint,3,opt,name=delivery_requirement,json=deliveryRequirement,proto3,enum=google.cloud.pubsublite.v1.Subscription_DeliveryConfig_DeliveryRequirement" json:"delivery_requirement,omitempty"`
    // contains filtered or unexported fields
}

The settings for a subscription's message delivery.

func (*Subscription_DeliveryConfig) Descriptor Uses

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

Deprecated: Use Subscription_DeliveryConfig.ProtoReflect.Descriptor instead.

func (*Subscription_DeliveryConfig) GetDeliveryRequirement Uses

func (x *Subscription_DeliveryConfig) GetDeliveryRequirement() Subscription_DeliveryConfig_DeliveryRequirement

func (*Subscription_DeliveryConfig) ProtoMessage Uses

func (*Subscription_DeliveryConfig) ProtoMessage()

func (*Subscription_DeliveryConfig) ProtoReflect Uses

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

func (*Subscription_DeliveryConfig) Reset Uses

func (x *Subscription_DeliveryConfig) Reset()

func (*Subscription_DeliveryConfig) String Uses

func (x *Subscription_DeliveryConfig) String() string

type Subscription_DeliveryConfig_DeliveryRequirement Uses

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 Uses

func (Subscription_DeliveryConfig_DeliveryRequirement) Descriptor() protoreflect.EnumDescriptor

func (Subscription_DeliveryConfig_DeliveryRequirement) Enum Uses

func (x Subscription_DeliveryConfig_DeliveryRequirement) Enum() *Subscription_DeliveryConfig_DeliveryRequirement

func (Subscription_DeliveryConfig_DeliveryRequirement) EnumDescriptor Uses

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

Deprecated: Use Subscription_DeliveryConfig_DeliveryRequirement.Descriptor instead.

func (Subscription_DeliveryConfig_DeliveryRequirement) Number Uses

func (x Subscription_DeliveryConfig_DeliveryRequirement) Number() protoreflect.EnumNumber

func (Subscription_DeliveryConfig_DeliveryRequirement) String Uses

func (x Subscription_DeliveryConfig_DeliveryRequirement) String() string

func (Subscription_DeliveryConfig_DeliveryRequirement) Type Uses

func (Subscription_DeliveryConfig_DeliveryRequirement) Type() protoreflect.EnumType

type Topic Uses

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"`
    // contains filtered or unexported fields
}

Metadata about a topic resource.

func (*Topic) Descriptor Uses

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetName Uses

func (x *Topic) GetName() string

func (*Topic) GetPartitionConfig Uses

func (x *Topic) GetPartitionConfig() *Topic_PartitionConfig

func (*Topic) GetRetentionConfig Uses

func (x *Topic) GetRetentionConfig() *Topic_RetentionConfig

func (*Topic) ProtoMessage Uses

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect Uses

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

func (*Topic) Reset Uses

func (x *Topic) Reset()

func (*Topic) String Uses

func (x *Topic) String() string

type TopicPartitions Uses

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 Uses

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

Deprecated: Use TopicPartitions.ProtoReflect.Descriptor instead.

func (*TopicPartitions) GetPartitionCount Uses

func (x *TopicPartitions) GetPartitionCount() int64

func (*TopicPartitions) ProtoMessage Uses

func (*TopicPartitions) ProtoMessage()

func (*TopicPartitions) ProtoReflect Uses

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

func (*TopicPartitions) Reset Uses

func (x *TopicPartitions) Reset()

func (*TopicPartitions) String Uses

func (x *TopicPartitions) String() string

type TopicStatsServiceClient Uses

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 before or equal to all
    // messages which have not yet been acknowledged to be published, and
    // greater than the offset of any message whose publish has already
    // been acknowledged. It is 0 if there have never been messages on the
    // partition.
    ComputeHeadCursor(ctx context.Context, in *ComputeHeadCursorRequest, opts ...grpc.CallOption) (*ComputeHeadCursorResponse, 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 Uses

func NewTopicStatsServiceClient(cc grpc.ClientConnInterface) TopicStatsServiceClient

type TopicStatsServiceServer Uses

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 before or equal to all
    // messages which have not yet been acknowledged to be published, and
    // greater than the offset of any message whose publish has already
    // been acknowledged. It is 0 if there have never been messages on the
    // partition.
    ComputeHeadCursor(context.Context, *ComputeHeadCursorRequest) (*ComputeHeadCursorResponse, error)
}

TopicStatsServiceServer is the server API for TopicStatsService service.

type Topic_PartitionConfig Uses

type Topic_PartitionConfig struct {

    // The number of partitions in the topic. Must be at least 1.
    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 Uses

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

Deprecated: Use Topic_PartitionConfig.ProtoReflect.Descriptor instead.

func (*Topic_PartitionConfig) GetCapacity Uses

func (x *Topic_PartitionConfig) GetCapacity() *Topic_PartitionConfig_Capacity

func (*Topic_PartitionConfig) GetCount Uses

func (x *Topic_PartitionConfig) GetCount() int64

func (*Topic_PartitionConfig) GetDimension Uses

func (m *Topic_PartitionConfig) GetDimension() isTopic_PartitionConfig_Dimension

func (*Topic_PartitionConfig) GetScale Uses

func (x *Topic_PartitionConfig) GetScale() int32

Deprecated: Do not use.

func (*Topic_PartitionConfig) ProtoMessage Uses

func (*Topic_PartitionConfig) ProtoMessage()

func (*Topic_PartitionConfig) ProtoReflect Uses

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

func (*Topic_PartitionConfig) Reset Uses

func (x *Topic_PartitionConfig) Reset()

func (*Topic_PartitionConfig) String Uses

func (x *Topic_PartitionConfig) String() string

type Topic_PartitionConfig_Capacity Uses

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 Uses

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

Deprecated: Use Topic_PartitionConfig_Capacity.ProtoReflect.Descriptor instead.

func (*Topic_PartitionConfig_Capacity) GetPublishMibPerSec Uses

func (x *Topic_PartitionConfig_Capacity) GetPublishMibPerSec() int32

func (*Topic_PartitionConfig_Capacity) GetSubscribeMibPerSec Uses

func (x *Topic_PartitionConfig_Capacity) GetSubscribeMibPerSec() int32

func (*Topic_PartitionConfig_Capacity) ProtoMessage Uses

func (*Topic_PartitionConfig_Capacity) ProtoMessage()

func (*Topic_PartitionConfig_Capacity) ProtoReflect Uses

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

func (*Topic_PartitionConfig_Capacity) Reset Uses

func (x *Topic_PartitionConfig_Capacity) Reset()

func (*Topic_PartitionConfig_Capacity) String Uses

func (x *Topic_PartitionConfig_Capacity) String() string

type Topic_PartitionConfig_Capacity_ Uses

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

type Topic_PartitionConfig_Scale Uses

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_RetentionConfig Uses

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 Uses

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

Deprecated: Use Topic_RetentionConfig.ProtoReflect.Descriptor instead.

func (*Topic_RetentionConfig) GetPerPartitionBytes Uses

func (x *Topic_RetentionConfig) GetPerPartitionBytes() int64

func (*Topic_RetentionConfig) GetPeriod Uses

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

func (*Topic_RetentionConfig) ProtoMessage Uses

func (*Topic_RetentionConfig) ProtoMessage()

func (*Topic_RetentionConfig) ProtoReflect Uses

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

func (*Topic_RetentionConfig) Reset Uses

func (x *Topic_RetentionConfig) Reset()

func (*Topic_RetentionConfig) String Uses

func (x *Topic_RetentionConfig) String() string

type UnimplementedAdminServiceServer Uses

type UnimplementedAdminServiceServer struct {
}

UnimplementedAdminServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdminServiceServer) CreateSubscription Uses

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

func (*UnimplementedAdminServiceServer) CreateTopic Uses

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

func (*UnimplementedAdminServiceServer) DeleteSubscription Uses

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

func (*UnimplementedAdminServiceServer) DeleteTopic Uses

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

func (*UnimplementedAdminServiceServer) GetSubscription Uses

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

func (*UnimplementedAdminServiceServer) GetTopic Uses

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

func (*UnimplementedAdminServiceServer) GetTopicPartitions Uses

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

func (*UnimplementedAdminServiceServer) ListSubscriptions Uses

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

func (*UnimplementedAdminServiceServer) ListTopicSubscriptions Uses

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

func (*UnimplementedAdminServiceServer) ListTopics Uses

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

func (*UnimplementedAdminServiceServer) UpdateSubscription Uses

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

func (*UnimplementedAdminServiceServer) UpdateTopic Uses

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

type UnimplementedCursorServiceServer Uses

type UnimplementedCursorServiceServer struct {
}

UnimplementedCursorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCursorServiceServer) CommitCursor Uses

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

func (*UnimplementedCursorServiceServer) ListPartitionCursors Uses

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

func (*UnimplementedCursorServiceServer) StreamingCommitCursor Uses

func (*UnimplementedCursorServiceServer) StreamingCommitCursor(CursorService_StreamingCommitCursorServer) error

type UnimplementedPartitionAssignmentServiceServer Uses

type UnimplementedPartitionAssignmentServiceServer struct {
}

UnimplementedPartitionAssignmentServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPartitionAssignmentServiceServer) AssignPartitions Uses

func (*UnimplementedPartitionAssignmentServiceServer) AssignPartitions(PartitionAssignmentService_AssignPartitionsServer) error

type UnimplementedPublisherServiceServer Uses

type UnimplementedPublisherServiceServer struct {
}

UnimplementedPublisherServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPublisherServiceServer) Publish Uses

func (*UnimplementedPublisherServiceServer) Publish(PublisherService_PublishServer) error

type UnimplementedSubscriberServiceServer Uses

type UnimplementedSubscriberServiceServer struct {
}

UnimplementedSubscriberServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubscriberServiceServer) Subscribe Uses

func (*UnimplementedSubscriberServiceServer) Subscribe(SubscriberService_SubscribeServer) error

type UnimplementedTopicStatsServiceServer Uses

type UnimplementedTopicStatsServiceServer struct {
}

UnimplementedTopicStatsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTopicStatsServiceServer) ComputeHeadCursor Uses

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

func (*UnimplementedTopicStatsServiceServer) ComputeMessageStats Uses

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

type UpdateSubscriptionRequest Uses

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 Uses

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

Deprecated: Use UpdateSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*UpdateSubscriptionRequest) GetSubscription Uses

func (x *UpdateSubscriptionRequest) GetSubscription() *Subscription

func (*UpdateSubscriptionRequest) GetUpdateMask Uses

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

func (*UpdateSubscriptionRequest) ProtoMessage Uses

func (*UpdateSubscriptionRequest) ProtoMessage()

func (*UpdateSubscriptionRequest) ProtoReflect Uses

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

func (*UpdateSubscriptionRequest) Reset Uses

func (x *UpdateSubscriptionRequest) Reset()

func (*UpdateSubscriptionRequest) String Uses

func (x *UpdateSubscriptionRequest) String() string

type UpdateTopicRequest Uses

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 Uses

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

Deprecated: Use UpdateTopicRequest.ProtoReflect.Descriptor instead.

func (*UpdateTopicRequest) GetTopic Uses

func (x *UpdateTopicRequest) GetTopic() *Topic

func (*UpdateTopicRequest) GetUpdateMask Uses

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

func (*UpdateTopicRequest) ProtoMessage Uses

func (*UpdateTopicRequest) ProtoMessage()

func (*UpdateTopicRequest) ProtoReflect Uses

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

func (*UpdateTopicRequest) Reset Uses

func (x *UpdateTopicRequest) Reset()

func (*UpdateTopicRequest) String Uses

func (x *UpdateTopicRequest) String() string

Package pubsublite imports 14 packages (graph) and is imported by 2 packages. Updated 2021-01-22. Refresh now. Tools for package owners.