Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DynamodbBaseRepository ¶
type DynamodbBaseRepository interface {
FindBySimplePrimaryKey(ctx *common_models.LambdaContext, primaryKey common_models.DynamodbSimplePrimaryKey, isConsistentRead bool) (map[string]types.AttributeValue, common_errors.GenericApplicationError)
FindByComplexPrimaryKey(ctx *common_models.LambdaContext, primaryKey common_models.DynamodbComplexPrimaryKey, isConsistentRead bool) (map[string]types.AttributeValue, common_errors.GenericApplicationError)
SaveIfNotPresentWithSimplePrimaryKey(ctx *common_models.LambdaContext, primaryKey common_models.DynamodbSimplePrimaryKey, item interface{}) common_errors.GenericApplicationError
SaveIfNotPresentWithComplexPrimaryKey(ctx *common_models.LambdaContext, primaryKey common_models.DynamodbComplexPrimaryKey, item interface{}) common_errors.GenericApplicationError
Save(ctx *common_models.LambdaContext, item interface{}) common_errors.GenericApplicationError
}
func NewDynamodbBaseRepository ¶
func NewDynamodbBaseRepository(client common_models.DynamodbClientAPI, tableName string) DynamodbBaseRepository
type DynamodbTransactionManager ¶
type DynamodbTransactionManager interface {
StartReadTransaction(ctx *common_models.LambdaContext) common_errors.GenericApplicationError
ExecuteReadTransaction(ctx *common_models.LambdaContext) (map[string]types.AttributeValue, common_errors.GenericApplicationError)
StartWriteTransaction(ctx *common_models.LambdaContext) common_errors.GenericApplicationError
ExecuteWriteTransaction(ctx *common_models.LambdaContext) common_errors.GenericApplicationError
}
func NewDynamodbTransactionManager ¶
func NewDynamodbTransactionManager(client common_models.DynamodbClientAPI) DynamodbTransactionManager
type RedisBaseRepository ¶
type RedisBaseRepository interface {
Save(ctx *common_models.LambdaContext, redisEntity common_models.RedisEntity) common_errors.GenericApplicationError
FindKey(ctx *common_models.LambdaContext, key string, value interface{}) (bool, common_errors.GenericApplicationError)
GetTTL(ctx *common_models.LambdaContext, key string) (bool, time.Duration, common_errors.GenericApplicationError)
DeleteKey(ctx *common_models.LambdaContext, key string) common_errors.GenericApplicationError
}
func NewRedisBaseRepository ¶
func NewRedisBaseRepository(client *redis.Client, namespace string) RedisBaseRepository
Click to show internal directories.
Click to hide internal directories.