awsutils

type JobMarshaller[Job any, Message any] interface {
	Marshall(job Job) (SerializedJob[Message], error)
	Unmarshall(SerializedJob[Message]) (Job, error)
}

type SQSDecoder[Job any, Message any] struct {
	// contains filtered or unexported fields
}

type SQSExtendedQueue[Job any, Message any] struct {
	// contains filtered or unexported fields
}

type SerializedJob[Message any] struct {
	GroupID  *string
	Message  Message
	Extended io.Reader
}