test

Documentation

Index

• Variables
• 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
  • func (*MockedKafkaEvent) String() string
• type MockedKafkaProducer
  • func (p *MockedKafkaProducer) Produce(msg *kafka.Message, internal chan kafka.Event) error
• type MockedTallyCounter
  • func (c *MockedTallyCounter) Inc(delta int64)

Variables

var DefaultCtxKey any = "myKey"

Functions

func AssertError

func AssertError(t *testing.T, err error, expectErr bool)

func GenerateAnyArgsSlice

func GenerateAnyArgsSlice(n int) []driver.Value

func InitPostgresContainer

func InitPostgresContainer(ctx context.Context) (*postgres.PostgresContainer, error)

InitPostgresContainer initializes a local Postgres instance using Testcontainers.

func MockLockedOutboxLock

func MockLockedOutboxLock(mock sqlmock.Sqlmock, dispatcherId uuid.UUID) *sqlmock.Rows

func MockOutboxRows

func MockOutboxRows(mock sqlmock.Sqlmock) *sqlmock.Rows

func MockSubscriptionRowsAllActive

func MockSubscriptionRowsAllActive(mock sqlmock.Sqlmock) *sqlmock.Rows

func MockSubscriptionRowsWithOneExpired

func MockSubscriptionRowsWithOneExpired(mock sqlmock.Sqlmock) *sqlmock.Rows

func MockUnlockedOutboxLock

func MockUnlockedOutboxLock(mock sqlmock.Sqlmock, dispatcherId uuid.UUID) *sqlmock.Rows

Types

type MockedKafkaEvent

type MockedKafkaEvent struct{}

func (*MockedKafkaEvent) String

func (*MockedKafkaEvent) String() string

type MockedKafkaProducer

type MockedKafkaProducer struct {
	MockedReportToSend kafka.Event
	Snitch             chan *kafka.Message
	RetVal             error
}

func (*MockedKafkaProducer) Produce

func (p *MockedKafkaProducer) Produce(msg *kafka.Message, internal chan kafka.Event) error

type MockedTallyCounter

type MockedTallyCounter struct {
	Ctr    int64
	Output chan int64
}

func (*MockedTallyCounter) Inc

func (c *MockedTallyCounter) Inc(delta int64)