appres

Dec 15, 2021

Changes in this version

+ func NewAwsConfigForDDB() aws.Config

+ func NewAwsConfigForS3() aws.Config

+ func NewAwsConfigForSNS() aws.Config

+ func NewAwsConfigForSQS() aws.Config

Oct 23, 2021

Changes in this version

type Ddb

+ Del func(tableName string, key map[string]string) error

+ PutConditional func(tableName string, item interface{}, condition *string, ...) error

+ Query func(queryInput *dynamodb.QueryInput) ([]map[string]types.AttributeValue, error)

+ Scan func(tableName string, filter expression.ConditionBuilder) ([]map[string]types.AttributeValue, error)

type DynamoDb

+ func (ddb *DynamoDb) Del(tableName string, key map[string]string) error

+ func (ddb *DynamoDb) PutConditional(tableName string, item interface{}, condition *string, ...) error

+ func (ddb *DynamoDb) Query(queryInput *dynamodb.QueryInput) ([]map[string]types.AttributeValue, error)

+ func (ddb *DynamoDb) Scan(tableName string, filter expression.ConditionBuilder) ([]map[string]types.AttributeValue, error)

Sep 21, 2021

Changes in this version

+ type Publisher interface

+ Commit func() error

+ Name func() string

+ Publish func(payload string) error

+ func NewPublisher(urlString string) Publisher

+ type PublisherInMemory struct

+ List []string

+ func NewPublisherInMemory(url *url.URL) *PublisherInMemory

+ func (p *PublisherInMemory) Begin() error

+ func (p *PublisherInMemory) Commit() error

+ func (p *PublisherInMemory) Name() string

+ func (p *PublisherInMemory) Publish(Message string) error

+ func (p *PublisherInMemory) Rollback() error

+ type PublisherSns struct

+ func NewPublisherSns(url *url.URL) *PublisherSns

+ func (q *PublisherSns) Begin() error

+ func (q *PublisherSns) Commit() error

+ func (q *PublisherSns) Name() string

+ func (q *PublisherSns) Publish(Message string) error

+ func (q *PublisherSns) Rollback() error

Sep 6, 2021

Changes in this version

+ type DynamoDbItemNotFound struct

+ Key interface{}

+ TableName string

+ func (e *DynamoDbItemNotFound) Error() string

Sep 2, 2021

Changes in this version

+ func AwsSetQueueTimeout(svc *sqs.Client, envURL *url.URL, queueURL *string) error

+ func GetTimeoutFromURL(qURL *url.URL) (string, error)

+ func NewAwsConfig() aws.Config

+ func ResetMqInMemoryDynamoDb()

+ func ResetQueueInMemory()

+ type AppRes interface

+ Begin func() error

+ Commit func() error

+ Rollback func() error

+ type Bucket struct

+ func NewBucket(url *url.URL) *Bucket

+ func (b *Bucket) Begin() error

+ func (b *Bucket) Commit() error

+ func (b *Bucket) Del(name string) error

+ func (b *Bucket) Exists(name string) (bool, error)

+ func (b *Bucket) Get(name string) (interface{}, error)

+ func (b *Bucket) Put(name string, item interface{}) error

+ func (b *Bucket) Rollback() error

+ type Ddb interface

+ CreateTable func(input *dynamodb.CreateTableInput) error

+ Get func(tableName string, key map[string]string) (map[string]types.AttributeValue, error)

+ ListTables func() ([]string, error)

+ Put func(tableName string, item interface{}) error

+ type Dir struct

+ func NewDir(url *url.URL) *Dir

+ func (dir *Dir) Begin() error

+ func (dir *Dir) Commit() error

+ func (dir *Dir) Del(name string) error

+ func (dir *Dir) Exists(name string) (bool, error)

+ func (dir *Dir) Get(name string) (interface{}, error)

+ func (dir *Dir) Put(name string, item interface{}) error

+ func (dir *Dir) Rollback() error

+ type DynamoDb struct

+ func NewDynamoDb(url *url.URL) *DynamoDb

+ func (ddb *DynamoDb) Begin() error

+ func (ddb *DynamoDb) Commit() error

+ func (ddb *DynamoDb) CreateTable(input *dynamodb.CreateTableInput) error

+ func (ddb *DynamoDb) Get(tableName string, key map[string]string) (map[string]types.AttributeValue, error)

+ func (ddb *DynamoDb) ListTables() ([]string, error)

+ func (ddb *DynamoDb) Put(tableName string, item interface{}) error

+ func (ddb *DynamoDb) Rollback() error

+ type FS struct

+ func NewFS(url *url.URL) *FS

+ func (fs *FS) Begin() error

+ func (fs *FS) Commit() error

+ func (fs *FS) Del(path string, name string) error

+ func (fs *FS) Get(path string, name string) ([]byte, error)

+ func (fs *FS) Put(path string, name string, payload []byte) error

+ func (fs *FS) Rollback() error

+ type FileSystem interface

+ Del func(path string, name string) error

+ Get func(path string, name string) ([]byte, error)

+ Put func(path string, name string, payload []byte) error

+ type InMemKeyVal struct

+ func NewInMemKeyVal(url *url.URL) *InMemKeyVal

+ func (r *InMemKeyVal) Begin() error

+ func (r *InMemKeyVal) Commit() error

+ func (r *InMemKeyVal) Del(key string) error

+ func (r *InMemKeyVal) Exists(key string) (bool, error)

+ func (r *InMemKeyVal) Get(key string) (interface{}, error)

+ func (r *InMemKeyVal) Put(key string, item interface{}) error

+ func (r *InMemKeyVal) Rollback() error

+ type KeyVal interface

+ Del func(key string) error

+ Exists func(key string) (bool, error)

+ Get func(key string) (interface{}, error)

+ Put func(key string, item interface{}) error

+ type MqInMemoryDynamoDb struct

+ List []interface{}

+ TableNames []string

+ func NewMqInMemoryDynamoDb(url *url.URL) *MqInMemoryDynamoDb

+ func NewMqInMemoryDynamoDbFromString(urlString string) *MqInMemoryDynamoDb

+ func (ddb *MqInMemoryDynamoDb) Begin() error

+ func (ddb *MqInMemoryDynamoDb) Commit() error

+ func (ddb *MqInMemoryDynamoDb) CreateTable(input *dynamodb.CreateTableInput) error

+ func (ddb *MqInMemoryDynamoDb) Get(tableName string, key map[string]string) (map[string]types.AttributeValue, error)

+ func (ddb *MqInMemoryDynamoDb) ListTables() ([]string, error)

+ func (ddb *MqInMemoryDynamoDb) Put(tableName string, item interface{}) error

+ func (ddb *MqInMemoryDynamoDb) Rollback() error

+ type Queue interface

+ Commit func() error

+ Name func() string

+ Retrieve func() (*string, error)

+ Send func(payload string) error

+ func NewQueue(urlString string) Queue

+ type QueueBeanstalk struct

+ func NewQueueBeanstalk(url *url.URL) *QueueBeanstalk

+ func (q *QueueBeanstalk) Begin() error

+ func (q *QueueBeanstalk) Commit() error

+ func (q *QueueBeanstalk) Name() string

+ func (q *QueueBeanstalk) Retrieve() (*string, error)

+ func (q *QueueBeanstalk) Rollback() error

+ func (q *QueueBeanstalk) Send(payload string) error

+ type QueueInMemory struct

+ List []string

+ func NewQueueInMemory(url *url.URL) *QueueInMemory

+ func NewQueueInMemoryFromString(urlString string) *QueueInMemory

+ func (mq *QueueInMemory) Begin() error

+ func (mq *QueueInMemory) Commit() error

+ func (mq *QueueInMemory) Init() error

+ func (mq *QueueInMemory) Move(fromS string, toS string)

+ func (mq *QueueInMemory) Name() string

+ func (mq *QueueInMemory) Retrieve() (*string, error)

+ func (mq *QueueInMemory) Rollback() error

+ func (mq *QueueInMemory) Send(payload string) error

+ type QueueSqs struct

+ func NewQueueSqs(url *url.URL) *QueueSqs

+ func (q *QueueSqs) Begin() error

+ func (q *QueueSqs) Commit() error

+ func (q *QueueSqs) CreateQueue()

+ func (q *QueueSqs) Name() string

+ func (q *QueueSqs) Retrieve() (*string, error)

+ func (q *QueueSqs) Rollback() error

+ func (q *QueueSqs) Send(Message string) error

+ type Redis struct

+ func NewRedis(url *url.URL) *Redis

+ func (r *Redis) Begin() error

+ func (r *Redis) Commit() error

+ func (r *Redis) Del(key string) error

+ func (r *Redis) Exists(name string) (bool, error)

+ func (r *Redis) Get(key string) (interface{}, error)

+ func (r *Redis) Put(key string, item interface{}) error

+ func (r *Redis) Rollback() error

+ type S3 struct

+ func NewS3(url *url.URL) *S3

+ func (s *S3) Begin() error

+ func (s *S3) Commit() error

+ func (s *S3) Del(path string, name string) error

+ func (s *S3) Get(path string, name string) ([]byte, error)

+ func (s *S3) Put(path string, name string, payload []byte) error

+ func (s *S3) Rollback() error