sqslink

type DeadLetterHandler interface {
	DeadLetter(context.Context, *dante_tpb.DeadMessage) error
}

type Endpoint interface {
	RoundTrip(ctx context.Context, serviceName string, protoMessage []byte) error
}

type Handler interface {
	HandleMessage(context.Context, *Message) error
}

type Invoker interface {
	Invoke(context.Context, string, interface{}, interface{}, ...grpc.CallOption) error
}

type Message struct {
	Proto        proto.Message
	ServiceName  string
	SQSMessageID string
	MessageID    string
}

type SNSMessageWrapper struct {
	Type      string `json:"Type"`
	Message   []byte `json:"Message"`
	MessageID string `json:"MessageId"`
	TopicArn  string `json:"TopicArn"`
}

type SQSAPI interface {
	ReceiveMessage(ctx context.Context, input *sqs.ReceiveMessageInput, opts ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)
	DeleteMessage(ctx context.Context, input *sqs.DeleteMessageInput, opts ...func(*sqs.Options)) (*sqs.DeleteMessageOutput, error)
}

type Worker struct {
	SQSClient SQSAPI
	QueueURL  string
	// contains filtered or unexported fields
}