sqslink

Documentation

Index

• Constants
• type DeadLetterHandler
• type Endpoint
• type Handler
• type Invoker
• type Message
• type SNSMessageWrapper
• type SQSAPI
• type Worker
  • func NewWorker(sqs SQSAPI, queueURL string, deadLetters DeadLetterHandler) *Worker
  • func (ww *Worker) RegisterService(ctx context.Context, service protoreflect.ServiceDescriptor, invoker Invoker) error
  • func (ww *Worker) Run(ctx context.Context) error

Constants

const RawMessageName = "/o5.messaging.v1.topic.RawMessageTopic/Raw"

Types

type DeadLetterHandler

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

type Endpoint

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

type Handler

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

type Invoker

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

type Message

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

type SNSMessageWrapper

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

type SQSAPI

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

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

func NewWorker

func NewWorker(sqs SQSAPI, queueURL string, deadLetters DeadLetterHandler) *Worker

func (*Worker) RegisterService

func (ww *Worker) RegisterService(ctx context.Context, service protoreflect.ServiceDescriptor, invoker Invoker) error

func (*Worker) Run

func (ww *Worker) Run(ctx context.Context) error