strongforce

Feb 1, 2025

Changes in this version

type Option

+ func WithDebeziumForwarder(options *forwarder.DebeziumOptions) Option

Sep 29, 2024

Changes in this version

type Client

+ func (sf *Client) TestHelper() *testhelper.TestHelper

Feb 26, 2024

Changes in this version

+ var ErrNoBus = errors.New("no bus configured")

+ var ErrNoDB = errors.New("no database configured")

+ type Client struct

+ func New(opts ...Option) (*Client, error)

+ func (sf *Client) Bus() bus.Bus

+ func (sf *Client) DB() db.DB

+ func (sf *Client) EventBuilder() *events.Builder

+ func (sf *Client) Init() error

+ type Option func(o *clientOptions)

+ func WithForwarder(options *forwarder.Options) Option

+ func WithLogger(logger *zap.Logger) Option

+ func WithMySQL(options *mysql.Options) Option

+ func WithNATS(options *nats.Options) Option

+ func WithPostgres(options *postgres.Options) Option

+ type Options struct

+ Bus bus.Bus

+ DB db.DB

+ Logger *zap.Logger