dynamodb

Documentation

Index

• type DynamoDBAPI
• type DynamoMetadataRepository
  • func NewMetadataStore(cfgApplication *config.Config) (*DynamoMetadataRepository, error)
  • func (s *DynamoMetadataRepository) DeleteMetadata(ctx context.Context, id string) error
  • func (s *DynamoMetadataRepository) GetMetadata(ctx context.Context, id string) (*model.Metadata, error)
  • func (s *DynamoMetadataRepository) SaveMetadata(ctx context.Context, metadata *model.Metadata) error
• type OperationStore
  • func NewOperationStore(cfgApplication *config.Config) (*OperationStore, error)
  • func (s *OperationStore) DeleteOperationResult(ctx context.Context, id, songID string) error
  • func (s *OperationStore) GetOperationResult(ctx context.Context, id, songID string) (*model.OperationResult, error)
  • func (s *OperationStore) SaveOperationsResult(ctx context.Context, result *model.OperationResult) error
  • func (s *OperationStore) UpdateOperationResult(ctx context.Context, operationID string, ...) error
  • func (s *OperationStore) UpdateOperationStatus(ctx context.Context, operationID string, songID string, status string) error

Types

type DynamoDBAPI

type DynamoDBAPI interface {
	PutItem(ctx context.Context, params *dynamodb.PutItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.PutItemOutput, error)
	GetItem(ctx context.Context, params *dynamodb.GetItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.GetItemOutput, error)
	DeleteItem(ctx context.Context, params *dynamodb.DeleteItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DeleteItemOutput, error)
	UpdateItem(ctx context.Context, params *dynamodb.UpdateItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateItemOutput, error)
}

DynamoDBAPI define los métodos necesarios para interactuar con DynamoDB.

type DynamoMetadataRepository

type DynamoMetadataRepository struct {
	Client DynamoDBAPI // Cliente para interactuar con DynamoDB.
	Config *config.Config
}

DynamoMetadataRepository Implementa la interface repository.MetadataRepository proporciona operaciones para almacenar, recuperar y eliminar metadatos en DynamoDB.

func NewMetadataStore

func NewMetadataStore(cfgApplication *config.Config) (*DynamoMetadataRepository, error)

NewMetadataStore crea una nueva instancia de MetadataStore con la configuración proporcionada.

func (*DynamoMetadataRepository) DeleteMetadata

func (s *DynamoMetadataRepository) DeleteMetadata(ctx context.Context, id string) error

DeleteMetadata elimina los metadatos de DynamoDB usando el ID proporcionado.

func (*DynamoMetadataRepository) GetMetadata

func (s *DynamoMetadataRepository) GetMetadata(ctx context.Context, id string) (*model.Metadata, error)

GetMetadata recupera los metadatos de DynamoDB usando el ID proporcionado.

func (*DynamoMetadataRepository) SaveMetadata

func (s *DynamoMetadataRepository) SaveMetadata(ctx context.Context, metadata *model.Metadata) error

SaveMetadata guarda los metadatos en DynamoDB. Genera un nuevo ID si no está presente y usa la fecha actual si DownloadDate está vacío.

type OperationStore

type OperationStore struct {
	Client DynamoDBAPI // Cliente para interactuar con DynamoDB.
	Cfg    *config.Config
}

OperationStore implementa la interface repository.OperationRepository maneja el almacenamiento, recuperación y eliminación de resultados de operación en DynamoDB.

func NewOperationStore

func NewOperationStore(cfgApplication *config.Config) (*OperationStore, error)

NewOperationStore crea una nueva instancia de OperationStore con la configuración proporcionada.

func (*OperationStore) DeleteOperationResult

func (s *OperationStore) DeleteOperationResult(ctx context.Context, id, songID string) error

DeleteOperationResult elimina el resultado de una operación de DynamoDB usando el ID y el SongID proporcionados.

func (*OperationStore) GetOperationResult

func (s *OperationStore) GetOperationResult(ctx context.Context, id, songID string) (*model.OperationResult, error)

GetOperationResult recupera el resultado de una operación desde DynamoDB usando el ID y el SongID proporcionados.

func (*OperationStore) SaveOperationsResult

func (s *OperationStore) SaveOperationsResult(ctx context.Context, result *model.OperationResult) error

SaveOperationsResult guarda el resultado de una operación en DynamoDB. Genera un nuevo ID si es necesario.

func (*OperationStore) UpdateOperationResult

func (s *OperationStore) UpdateOperationResult(ctx context.Context, operationID string, operationResult *model.OperationResult) error

func (*OperationStore) UpdateOperationStatus

func (s *OperationStore) UpdateOperationStatus(ctx context.Context, operationID string, songID string, status string) error