Versions in this module Expand all Collapse all v0 v0.1.3 Dec 2, 2024 Changes in this version + type Dumper struct + func NewDumper(outDir string) *Dumper + func (x *Dumper) Publish(ctx context.Context, data []byte) (types.PubSubMessageID, error) + type Mock struct + MockPublish func(ctx context.Context, data []byte) (types.PubSubMessageID, error) + Results []*MockResult + func NewMock() *Mock + func (x *Mock) Publish(ctx context.Context, data []byte) (types.PubSubMessageID, error) + type MockResult struct + Data []byte + ID types.PubSubMessageID + type SubscriptionClient struct + func NewSubscriptionClient(ctx context.Context) (*SubscriptionClient, error) + func (x *SubscriptionClient) Acknowledge(ctx context.Context, subName string, ackID string) error + func (x *SubscriptionClient) Close() error + func (x *SubscriptionClient) ModifyAckDeadline(ctx context.Context, subName string, ackID string, deadline time.Duration) error + func (x *SubscriptionClient) Pull(ctx context.Context, subName string) ([]*pubsubpb.ReceivedMessage, error) + type TopicClient struct + func NewTopic(ctx context.Context, projectID types.GoogleProjectID, ...) (*TopicClient, error) + func (x *TopicClient) Close() + func (x *TopicClient) Publish(ctx context.Context, data []byte) (types.PubSubMessageID, error)
Go to main page