pubsublite

Dec 12, 2022

Changes in this version

type CreateSubscriptionOption

+ func AtTargetLocation(target SeekTarget) CreateSubscriptionOption

+ type ExportConfig struct

+ CurrentState ExportState

+ DeadLetterTopic string

+ DesiredState ExportState

+ Destination ExportDestinationConfig

+ type ExportConfigToUpdate struct

+ DeadLetterTopic optional.String

+ DesiredState ExportState

+ Destination ExportDestinationConfig

+ type ExportDestinationConfig interface

+ type ExportState int

+ const ExportActive

+ const ExportPaused

+ const ExportPermissionDenied

+ const ExportResourceNotFound

+ const UnspecifiedExportState

+ type PubSubDestinationConfig struct

+ Topic string

type SubscriptionConfig

+ ExportConfig *ExportConfig

type SubscriptionConfigToUpdate

+ ExportConfig *ExportConfigToUpdate

Oct 1, 2021

Changes in this version

type AdminClient

+ func (ac *AdminClient) CreateReservation(ctx context.Context, config ReservationConfig) (*ReservationConfig, error)

+ func (ac *AdminClient) DeleteReservation(ctx context.Context, reservation string) error

+ func (ac *AdminClient) Reservation(ctx context.Context, reservation string) (*ReservationConfig, error)

+ func (ac *AdminClient) ReservationTopics(ctx context.Context, reservation string) *TopicPathIterator

+ func (ac *AdminClient) Reservations(ctx context.Context, parent string) *ReservationIterator

+ func (ac *AdminClient) UpdateReservation(ctx context.Context, config ReservationConfigToUpdate) (*ReservationConfig, error)

+ type ReservationConfig struct

+ Name string

+ ThroughputCapacity int

+ type ReservationConfigToUpdate struct

+ Name string

+ ThroughputCapacity int

+ type ReservationIterator struct

+ func (r *ReservationIterator) Next() (*ReservationConfig, error)

type TopicConfig

+ ThroughputReservation string

type TopicConfigToUpdate

+ ThroughputReservation optional.String

+ type TopicPathIterator struct

+ func (sp *TopicPathIterator) Next() (string, error)

Aug 9, 2021

Changes in this version

type AdminClient

+ func (ac *AdminClient) SeekSubscription(ctx context.Context, subscription string, target SeekTarget, ...) (*SeekSubscriptionOperation, error)

+ type EventTime time.Time

+ type OperationMetadata struct

+ CreateTime time.Time

+ EndTime time.Time

+ Target string

+ Verb string

+ type PublishTime time.Time

+ type SeekSubscriptionOperation struct

+ func (s *SeekSubscriptionOperation) Done() bool

+ func (s *SeekSubscriptionOperation) Metadata() (*OperationMetadata, error)

+ func (s *SeekSubscriptionOperation) Name() string

+ func (s *SeekSubscriptionOperation) Wait(ctx context.Context) (*SeekSubscriptionResult, error)

+ type SeekSubscriptionOption interface

+ type SeekSubscriptionResult struct

+ type SeekTarget interface

Mar 26, 2021

Changes in this version

+ type BacklogLocation int

+ const Beginning

+ const End

+ type CreateSubscriptionOption interface

+ Apply func(*createSubscriptionSettings)

+ func StartingOffset(location BacklogLocation) CreateSubscriptionOption

Feb 18, 2021

Changes in this version

type TopicConfigToUpdate

+ PartitionCount int

Jan 28, 2021

Changes in this version

type AdminClient

+ func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error)

Oct 29, 2020

Changes in this version

+ const DeliverAfterStored

+ const DeliverImmediately

+ const InfiniteRetention

+ const MaxPublishMessageBytes

+ const MaxPublishRequestBytes

+ const MaxPublishRequestCount

+ const UnspecifiedDeliveryRequirement

+ var DefaultPublishSettings = PublishSettings

+ var ErrOverflow = errors.New("pubsublite: client-side publish buffers have overflowed")

+ func ZoneToRegion(zone string) (string, error)

+ type AdminClient struct

+ func NewAdminClient(ctx context.Context, region string, opts ...option.ClientOption) (*AdminClient, error)

+ func (ac *AdminClient) Close() error

+ func (ac *AdminClient) CreateSubscription(ctx context.Context, config SubscriptionConfig) (*SubscriptionConfig, error)

+ func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error)

+ func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription SubscriptionPath) error

+ func (ac *AdminClient) DeleteTopic(ctx context.Context, topic TopicPath) error

+ func (ac *AdminClient) Subscription(ctx context.Context, subscription SubscriptionPath) (*SubscriptionConfig, error)

+ func (ac *AdminClient) Subscriptions(ctx context.Context, location LocationPath) *SubscriptionIterator

+ func (ac *AdminClient) Topic(ctx context.Context, topic TopicPath) (*TopicConfig, error)

+ func (ac *AdminClient) TopicPartitions(ctx context.Context, topic TopicPath) (int, error)

+ func (ac *AdminClient) TopicSubscriptions(ctx context.Context, topic TopicPath) (*SubscriptionPathIterator, error)

+ func (ac *AdminClient) Topics(ctx context.Context, location LocationPath) *TopicIterator

+ func (ac *AdminClient) UpdateSubscription(ctx context.Context, config SubscriptionConfigToUpdate) (*SubscriptionConfig, error)

+ func (ac *AdminClient) UpdateTopic(ctx context.Context, config TopicConfigToUpdate) (*TopicConfig, error)

+ type AttributeValues [][]byte

+ type DeliveryRequirement int32

+ type LocationPath struct

+ Project string

+ Zone string

+ func (l LocationPath) String() string

+ type Message struct

+ Attributes map[string]AttributeValues

+ Data []byte

+ EventTime time.Time

+ OrderingKey []byte

+ type PublishSettings struct

+ BufferedByteLimit int

+ ByteThreshold int

+ CountThreshold int

+ DelayThreshold time.Duration

+ Timeout time.Duration

+ type SubscriptionConfig struct

+ DeliveryRequirement DeliveryRequirement

+ Name SubscriptionPath

+ Topic TopicPath

+ type SubscriptionConfigToUpdate struct

+ DeliveryRequirement DeliveryRequirement

+ Name SubscriptionPath

+ type SubscriptionIterator struct

+ func (s *SubscriptionIterator) Next() (*SubscriptionConfig, error)

+ type SubscriptionPath struct

+ Project string

+ SubscriptionID string

+ Zone string

+ func (s SubscriptionPath) String() string

+ type SubscriptionPathIterator struct

+ func (sp *SubscriptionPathIterator) Next() (SubscriptionPath, error)

+ type TopicConfig struct

+ Name TopicPath

+ PartitionCount int

+ PerPartitionBytes int64

+ PublishCapacityMiBPerSec int

+ RetentionDuration time.Duration

+ SubscribeCapacityMiBPerSec int

+ type TopicConfigToUpdate struct

+ Name TopicPath

+ PerPartitionBytes int64

+ PublishCapacityMiBPerSec int

+ RetentionDuration optional.Duration

+ SubscribeCapacityMiBPerSec int

+ type TopicIterator struct

+ func (t *TopicIterator) Next() (*TopicConfig, error)

+ type TopicPath struct

+ Project string

+ TopicID string

+ Zone string

+ func (t TopicPath) String() string