google

Sep 26, 2024

Changes in this version

+ func New(conf Config, logger pubsub.Logger, metrics Metrics) *googleClient

+ type Client interface

+ Close func() error

+ Subscriptions func(ctx context.Context) *pubsub.SubscriptionIterator

+ Topics func(ctx context.Context) *pubsub.TopicIterator

+ type Config struct

+ ProjectID string

+ SubscriptionName string

+ type Metrics interface

+ IncrementCounter func(ctx context.Context, name string, labels ...string)

+ type MockMetrics struct

+ func NewMockMetrics(ctrl *gomock.Controller) *MockMetrics

+ func (m *MockMetrics) EXPECT() *MockMetricsMockRecorder

+ func (m *MockMetrics) IncrementCounter(ctx context.Context, name string, labels ...string)

+ type MockMetricsMockRecorder struct

+ func (mr *MockMetricsMockRecorder) IncrementCounter(ctx, name any, labels ...any) *gomock.Call

+ type Reader interface

+ CreateTopic func(ctx context.Context, topicID string) (*pubsub.Topic, error)

+ Topic func(id string) *pubsub.Topic

+ type Writer interface

+ CreateSubscription func(ctx context.Context, id string, cfg pubsub.SubscriptionConfig) (*pubsub.Subscription, error)

+ Subscription func(id string) *pubsub.Subscription