Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CollectorWrappedInTransaction ¶
type CollectorWrappedInTransaction struct {
// contains filtered or unexported fields
}
func NewCollectorWrappedInTransaction ¶
func NewCollectorWrappedInTransaction(decorated store.Collector, connection Transactionable) *CollectorWrappedInTransaction
func (*CollectorWrappedInTransaction) Collect ¶
func (c *CollectorWrappedInTransaction) Collect(ctx context.Context, event *cloudevents.Event) error
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func NewConsumer ¶
func (*Consumer) ConsumeFor ¶
func (c *Consumer) ConsumeFor(channel chan cloudevents.Event)
type Execable ¶
type Execable interface {
ExecEx(ctx context.Context, sql string, options *pgx.QueryExOptions, arguments ...interface{}) (commandTag pgx.CommandTag, err error)
}
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
func NewPublisher ¶
type ReadableQueryResult ¶
type ReadableQueryResult interface {
Scan(dest ...interface{}) (err error)
}
type Storage ¶
type Storage struct {
// contains filtered or unexported fields
}
func NewStorage ¶
func (*Storage) MatchingStream ¶
Click to show internal directories.
Click to hide internal directories.