Documentation
¶
Index ¶
- func NewAMQPService() interfaces.AMQPServiceInterface
- func NewS3Service() (interfaces.S3ServiceInterface, error)
- type AMQPServiceWrapper
- type S3ServiceWrapper
- func (s *S3ServiceWrapper) BulkDeleteFiles(ctx context.Context, uploadedKeys []string)
- func (s *S3ServiceWrapper) BulkUploadFiles(ctx context.Context, payloads []*awss3.PutObjectInput) ([]string, error)
- func (s *S3ServiceWrapper) GenerateUploadPayload(ctx context.Context, data []byte, s3Path, filename string, ...) (*awss3.PutObjectInput, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAMQPService ¶
func NewAMQPService() interfaces.AMQPServiceInterface
NewAMQPService creates a new AMQP service wrapper
func NewS3Service ¶
func NewS3Service() (interfaces.S3ServiceInterface, error)
NewS3Service creates a new S3 service wrapper
Types ¶
type AMQPServiceWrapper ¶
type AMQPServiceWrapper struct{}
AMQPServiceWrapper wraps the existing AMQP functionality
func (*AMQPServiceWrapper) PublishMessage ¶
func (a *AMQPServiceWrapper) PublishMessage(exchangeName string, topic string, message map[string]interface{})
PublishMessage publishes a message to the AMQP broker
type S3ServiceWrapper ¶
type S3ServiceWrapper struct {
// contains filtered or unexported fields
}
S3ServiceWrapper wraps the existing S3 functionality
func (*S3ServiceWrapper) BulkDeleteFiles ¶
func (s *S3ServiceWrapper) BulkDeleteFiles(ctx context.Context, uploadedKeys []string)
BulkDeleteFiles deletes multiple files from S3
func (*S3ServiceWrapper) BulkUploadFiles ¶
func (s *S3ServiceWrapper) BulkUploadFiles(ctx context.Context, payloads []*awss3.PutObjectInput) ([]string, error)
BulkUploadFiles uploads multiple files given a list of payloads
func (*S3ServiceWrapper) GenerateUploadPayload ¶
func (s *S3ServiceWrapper) GenerateUploadPayload(ctx context.Context, data []byte, s3Path, filename string, metadata map[string]string) (*awss3.PutObjectInput, error)
GenerateUploadPayload generates a payload for uploading a file to S3
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.