port

Documentation

Index

• type MessageQueue
• type MetadataRepository
• type OperationRepository
• type SQSClientInterface
• type Storage

Types

type MessageQueue

type MessageQueue interface {
	SendMessage(ctx context.Context, message model.Message) error
	ReceiveMessage(ctx context.Context) ([]model.Message, error)
	DeleteMessage(ctx context.Context, receiptHandle string) error
}

MessageQueue es la interfaz que debe implementar cualquier servicio de mensajeria

type MetadataRepository

type MetadataRepository interface {
	SaveMetadata(ctx context.Context, metadata *model.Metadata) error
	GetMetadata(ctx context.Context, id string) (*model.Metadata, error)
	DeleteMetadata(ctx context.Context, id string) error
}

MetadataRepository define las operaciones para manejar metadatos.

type OperationRepository

type OperationRepository interface {
	SaveOperationsResult(ctx context.Context, result *model.OperationResult) error
	GetOperationResult(ctx context.Context, id, songID string) (*model.OperationResult, error)
	DeleteOperationResult(ctx context.Context, id, songID string) error
	UpdateOperationStatus(ctx context.Context, operationID string, songID string, status string) error
	UpdateOperationResult(ctx context.Context, operationID string, operationResult *model.OperationResult) error
}

OperationRepository define las operaciones para manejar resultados de operación.

type SQSClientInterface

type SQSClientInterface interface {
	SendMessage(ctx context.Context, params *sqs.SendMessageInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)
	ReceiveMessage(ctx context.Context, params *sqs.ReceiveMessageInput, optFns ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)
	DeleteMessage(ctx context.Context, params *sqs.DeleteMessageInput, optFns ...func(*sqs.Options)) (*sqs.DeleteMessageOutput, error)
}

type Storage

type Storage interface {
	// UploadFile sube un archivo al servicio de almacenamiento con la clave especificada.
	UploadFile(ctx context.Context, key string, body io.Reader) error

	// GetFileMetadata obtiene los metadatos del archivo con la clave especificada.
	GetFileMetadata(ctx context.Context, key string) (*model.FileData, error)
}

Storage define la interfaz para interactuar con un servicio de almacenamiento. Permite subir archivos y obtener metadatos de archivos.