common_repositories

Documentation

Index

• type DynamodbBaseRepository
  • func NewDynamodbBaseRepository(client common_models.DynamodbClientAPI, tableName string) DynamodbBaseRepository
• type DynamodbTransactionManager
  • func NewDynamodbTransactionManager(client common_models.DynamodbClientAPI) DynamodbTransactionManager
• type RedisBaseRepository
  • func NewRedisBaseRepository(client *redis.Client, namespace string) RedisBaseRepository

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