common

Documentation

Index

• Variables
• func AppendQueryParams(url string, query_params map[string]string) string
• func ConfigureDynamoDB(region string)
• func Contains(arr []string, str string) bool
• func GetCall(url string, query_params map[string]string, header http.Header, ...) ([]byte, error)
• func GetUTCTimeString() string
• func GetUUID() string
• func InterfaceToMap(request interface{}) map[string]interface{}
• func IsEmpty(str string) bool
• func Logger(inner http.Handler, name string) http.Handler
• func LowerFirst(s string) string
• func PrepareUpdateExpression(request interface{}, keysToExclude []string) map[string]interface{}
• func TransactWriteItems(transactItems []TransactItem) map[string]interface{}
• func ZapLogger() *zap.Logger
• type DBService
  • func (db DBService) BatchGetItem(keyDetails []map[string]string, items interface{}) error
  • func (db DBService) BatchWriteItemDelete(keyDetails []map[string]string, items interface{}) error
  • func (db DBService) GetItem(keyDetails map[string]string, item interface{}) error
  • func (db DBService) PutItem(transactItem TransactItem)
  • func (db DBService) QueryOnGSI(keyDetails map[string]string, items interface{}, keyEx string, ...) error
  • func (db DBService) QuerytItem(keyDetails map[string]string, items interface{}, keyEx string) error
  • func (db DBService) UpdateItem(keyDetails map[string]string, itemDetails map[string]string, ...)
• type MyDynamo
• type TransactItem

Variables

var ZapLoggerObj *zap.Logger

ZapLoggerObj Global LOgger Object

Functions

func AppendQueryParams

func AppendQueryParams(url string, query_params map[string]string) string

func ConfigureDynamoDB

func ConfigureDynamoDB(region string)

ConfigureDynamoDB : For creating dynamodb connection.

func Contains

func Contains(arr []string, str string) bool

func GetCall

func GetCall(url string, query_params map[string]string, header http.Header, timeout time.Duration) ([]byte, error)

func GetUTCTimeString

func GetUTCTimeString() string

func GetUUID

func GetUUID() string

func InterfaceToMap

func InterfaceToMap(request interface{}) map[string]interface{}

InterfaceToMap function converts an interface to map

func IsEmpty

func IsEmpty(str string) bool

func Logger

func Logger(inner http.Handler, name string) http.Handler

func LowerFirst

func LowerFirst(s string) string

func PrepareUpdateExpression

func PrepareUpdateExpression(request interface{}, keysToExclude []string) map[string]interface{}

func TransactWriteItems

func TransactWriteItems(transactItems []TransactItem) map[string]interface{}

TransactWriteItems write to dynamodb in a single transaction

func ZapLogger

func ZapLogger() *zap.Logger

ZapLogger logger init

Types

type DBService

type DBService struct {
	TableName string
}

DBService : For creating dynamodb connection.

func (DBService) BatchGetItem

func (db DBService) BatchGetItem(keyDetails []map[string]string, items interface{}) error

BatchGetItem gets data from dynamodb (with multiple PK returns multiple records)

func (DBService) BatchWriteItemDelete

func (db DBService) BatchWriteItemDelete(keyDetails []map[string]string, items interface{}) error

BatchWriteItemDelete delete data from dynamodb (with multiple PK delete in single go)

func (DBService) GetItem

func (db DBService) GetItem(keyDetails map[string]string, item interface{}) error

GetItem gets data from dynamodb

func (DBService) PutItem

func (db DBService) PutItem(transactItem TransactItem)

PutItem : Inserts an item into Dynamodb

func (DBService) QueryOnGSI

func (db DBService) QueryOnGSI(keyDetails map[string]string, items interface{}, keyEx string, indexName string) error

QueryOnGSI gets data from dynamodb by querying on GSI

func (DBService) QuerytItem

func (db DBService) QuerytItem(keyDetails map[string]string, items interface{}, keyEx string) error

QuerytItem gets data from dynamodb (only HK returns multiple records)

func (DBService) UpdateItem

func (db DBService) UpdateItem(keyDetails map[string]string,
	itemDetails map[string]string, UpdateExpression string)

UpdateItem : Updates an item in dynamodb

type MyDynamo

type MyDynamo struct {
	Db dynamodbiface.DynamoDBAPI
}

MyDynamo : For creating dynamodb connection.

var Dyna *MyDynamo

Dyna - exported

type TransactItem

type TransactItem struct {
	TransactType              string
	TableName                 string
	KeyDetails                map[string]interface{}
	ItemDetails               interface{}
	ExpressionAttributeValues map[string]interface{}
	UpdateExpression          string
}

TransactItem : For creating TransactItem.