integration

Documentation

Index

• type FakeSqs
  • func (f *FakeSqs) SendMessage(ctx context.Context, params *sqs.SendMessageInput, ...) (*sqs.SendMessageOutput, error)
• type Universe
  • func NewUniverse(ctx context.Context, t *testing.T) *Universe
  • func (uu *Universe) RunSteps(t *testing.T)

Types

type FakeSqs

type FakeSqs struct {
	Msgs []sqs.SendMessageInput
}

func (*FakeSqs) SendMessage

func (f *FakeSqs) SendMessage(ctx context.Context, params *sqs.SendMessageInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)

type Universe

type Universe struct {
	DeadMessageQuery   dante_spb.DeadMessageQueryServiceClient
	DeadMessageWorker  messaging_tpb.DeadMessageTopicClient
	DeadMessageCommand dante_spb.DeadMessageCommandServiceClient
	FakeSqs            FakeSqs

	*flowtest.Stepper[*testing.T]
}

func NewUniverse

func NewUniverse(ctx context.Context, t *testing.T) *Universe

func (*Universe) RunSteps

func (uu *Universe) RunSteps(t *testing.T)