fxgcppubsub

package module

Go to main page

Versions in this module

v1

v1.6.0

Mar 5, 2025

Changes in this version

+ func NewFxGcpPubSubDefaultClientFactory(p FxGcpPubSubDefaultClientFactoryParam) *client.DefaultClientFactory

type FxGcpPubSubClientParam

+ Factory client.ClientFactory

+ type FxGcpPubSubDefaultClientFactoryParam struct

+ Config *config.Config

+ Logger *log.Logger

v1.5.0

Jan 21, 2025

v1.4.1

Jul 10, 2024

v1.4.0

Jul 10, 2024

v1.3.1

Jul 9, 2024

v1.3.0

Jul 8, 2024

v1.2.0

Jul 8, 2024

Changes in this version

+ func AsPubSubTestServerReactor(constructor any) fx.Option

+ func AsPubSubTestServerReactors(constructors ...any) fx.Option

+ func NewFxGcpPubSubSchemaClient(p FxGcpPubSubSchemaClientParam) (*pubsub.SchemaClient, error)

+ func NewFxGcpPubSubTestServer(p FxGcpPubSubTestServerParam) *pstest.Server

+ func PrepareSchema(params PrepareSchemaParams) fx.Option

+ func PrepareTopic(params PrepareTopicParams) fx.Option

+ func PrepareTopicAndSubscription(params PrepareTopicAndSubscriptionParams) fx.Option

+ func PrepareTopicAndSubscriptionWithSchema(params PrepareTopicAndSubscriptionWithSchemaParams) fx.Option

+ func PrepareTopicWithSchema(params PrepareTopicWithSchemaParams) fx.Option

+ type DefaultPublisher struct

+ func NewDefaultPublisher(factory topic.TopicFactory, registry topic.TopicRegistry) *DefaultPublisher

+ func NewFxGcpPubSubPublisher(p FxGcpPubSubPublisherParam) *DefaultPublisher

+ func (p *DefaultPublisher) Publish(ctx context.Context, topicID string, data any, options ...topic.PublishOption) (*pubsub.PublishResult, error)

+ func (p *DefaultPublisher) Stop()

+ type DefaultSubscriber struct

+ func NewDefaultSubscriber(factory subscription.SubscriptionFactory, ...) *DefaultSubscriber

+ func NewFxGcpPubSubSubscriber(p FxGcpPubSubSubscriberParam) *DefaultSubscriber

+ func (s *DefaultSubscriber) Subscribe(ctx context.Context, subscriptionID string, f subscription.SubscribeFunc, ...) error

type FxGcpPubSubClientParam

+ Context context.Context

+ Server *pstest.Server

+ type FxGcpPubSubPublisherParam struct

+ Config *config.Config

+ Factory topic.TopicFactory

+ LifeCycle fx.Lifecycle

+ Registry topic.TopicRegistry

+ type FxGcpPubSubSchemaClientParam struct

+ Config *config.Config

+ Context context.Context

+ LifeCycle fx.Lifecycle

+ Server *pstest.Server

+ type FxGcpPubSubSubscriberParam struct

+ Factory subscription.SubscriptionFactory

+ Registry subscription.SubscriptionRegistry

+ type FxGcpPubSubTestServerParam struct

+ Reactors []Reactor

+ type PrepareSchemaParams struct

+ SchemaConfig pubsub.SchemaConfig

+ SchemaID string

+ type PrepareTopicAndSubscriptionParams struct

+ SubscriptionConfig pubsub.SubscriptionConfig

+ SubscriptionID string

+ TopicConfig pubsub.TopicConfig

+ TopicID string

+ type PrepareTopicAndSubscriptionWithSchemaParams struct

+ SchemaConfig pubsub.SchemaConfig

+ SchemaEncoding pubsub.SchemaEncoding

+ SchemaID string

+ SubscriptionConfig pubsub.SubscriptionConfig

+ SubscriptionID string

+ TopicConfig pubsub.TopicConfig

+ TopicID string

+ type PrepareTopicParams struct

+ TopicConfig pubsub.TopicConfig

+ TopicID string

+ type PrepareTopicWithSchemaParams struct

+ SchemaConfig pubsub.SchemaConfig

+ SchemaEncoding pubsub.SchemaEncoding

+ SchemaID string

+ TopicConfig pubsub.TopicConfig

+ TopicID string

+ type Publisher interface

+ Publish func(ctx context.Context, topicID string, data any, options ...topic.PublishOption) (*pubsub.PublishResult, error)

+ Stop func()

+ type Reactor interface

+ FuncNames func() []string

+ type Subscriber interface

+ Subscribe func(ctx context.Context, subscriptionID string, f subscription.SubscribeFunc, ...) error

v1.1.0

Mar 15, 2024

v1.0.0

Mar 5, 2024

Changes in this version

+ const ModuleName

+ var FxGcpPubSubModule = fx.Module(ModuleName, fx.Provide(NewFxGcpPubSubClient))

+ func NewFxGcpPubSubClient(p FxGcpPubSubClientParam) (*pubsub.Client, error)

+ type FxGcpPubSubClientParam struct

+ Config *config.Config

+ LifeCycle fx.Lifecycle

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL