eventbus

Jan 8, 2024

Changes in this version

+ type Topic interface

Oct 12, 2023

Changes in this version

type LoggerOpt

+ func WithRedactPayloadFunc(f func(string, any) any) LoggerOpt

Sep 18, 2023

Changes in this version

+ type Logger struct

+ func NewLogger(opts ...LoggerOpt) *Logger

+ func (m Logger) Middleware(next internal.Handler) func(context.Context, *event.Event) error

+ type LoggerOpt func(*Logger)

+ func WithLogSensitiveData() LoggerOpt

+ func WithTopic(topic string) LoggerOpt

May 20, 2023

Changes in this version

type Client

+ func NewWithPubSubClientClient(cli *pubsub.Client, projectID, svcID, envID string) Client

May 16, 2023

Changes in this version

+ func TopicID() *embedTopics

+ func WithSubMaxOutstandingMessages(messages int) func(*pubsub.ReceiveSettings)

+ type Client interface

+ func DefaultClient(ctx context.Context) (Client, error)

+ func FromConfig(ctx context.Context, cfg Config) (Client, error)

+ func NewClient(ctx context.Context, projectID, svcID, envID, adcCredPath string) (Client, error)

+ type Config interface