Versions in this module Expand all Collapse all v1 v1.0.0 Feb 18, 2024 Changes in this version + var DefaultCtxKey any = "myKey" + func AssertError(t *testing.T, err error, expectErr bool) + func GenerateAnyArgsSlice(n int) []driver.Value + func InitPostgresContainer(ctx context.Context) (*postgres.PostgresContainer, error) + func MockLockedOutboxLock(mock sqlmock.Sqlmock, dispatcherId uuid.UUID) *sqlmock.Rows + func MockOutboxRows(mock sqlmock.Sqlmock) *sqlmock.Rows + func MockSubscriptionRowsAllActive(mock sqlmock.Sqlmock) *sqlmock.Rows + func MockSubscriptionRowsWithOneExpired(mock sqlmock.Sqlmock) *sqlmock.Rows + func MockUnlockedOutboxLock(mock sqlmock.Sqlmock, dispatcherId uuid.UUID) *sqlmock.Rows + type MockedKafkaEvent struct + func (*MockedKafkaEvent) String() string + type MockedKafkaProducer struct + MockedReportToSend kafka.Event + RetVal error + Snitch chan *kafka.Message + func (p *MockedKafkaProducer) Produce(msg *kafka.Message, internal chan kafka.Event) error + type MockedTallyCounter struct + Ctr int64 + Output chan int64 + func (c *MockedTallyCounter) Inc(delta int64)
Go to main page