infra

type DBExecutor interface {
	Execute(ctx context.Context, query string, args ...any) (int64, error)
}

type DBExecutorQuerier interface {
	DBExecutor
	DBQuerier
}

type DBQuerier interface {
	Query(ctx context.Context, dst any, query string, args ...any) error
	QueryRow(ctx context.Context, dst any, query string, args ...any) error
}

type HTTPTracedTransportOptionFn func(cfg *httpTracedTransportConfig)

type NopPublisher struct {
}

type NopReceiver struct {
}

type PgxPoolExecutorQuerier struct {
	// contains filtered or unexported fields
}

type PubsubMessage struct {
	ID     string
	AckFn  func()
	NackFn func()
	Data   []byte
}

type PubsubMessagePublisher interface {
	Publish(ctx context.Context, msg *pubsub.Message) error
}

type PubsubMessageReceiver interface {
	Receive(ctx context.Context, f func(context.Context, *PubsubMessage)) error
}

type PubsubPublisher struct {
	// contains filtered or unexported fields
}

type PubsubReceiver struct {
	// contains filtered or unexported fields
}

type SQLExecutorQuerier struct {
	// contains filtered or unexported fields
}