Options
All
  • Public
  • Public/Protected
  • All
Menu

Class DynamoStore<T, K>

DynamoStore handles the DynamoDB

Parameters: accessKeyId: '' // try WEBDA_AWS_KEY env variable if not found secretAccessKey: '' // try WEBDA_AWS_SECRET env variable if not found table: '' region: ''

Type parameters

Hierarchy

  • Store<T, K>
    • DynamoStore

Implements

Constructors

constructor

Properties

_cascade
_client
_createException
_creationDateField
_exposeUrl
_initException
_initTime
_lastUpdateField
_model
_name
_reverseMap
_uuidField
_webda
logger
parameters
defaultMaxListeners

Methods

__clean
_cleanObject
_delete
_deleteItemFromCollection
_find
_get
_getWriteCondition
_handleCreatedMap
_handleDeletedMap
_handleMapFromPartial
_handleMapProperty
_handleUpdatedMap
_handleUpdatedMapMapper
_handleUpdatedMapTransferIn
_handleUpdatedMapTransferOut
_incrementAttribute
_patch
_removeAttribute
_save
_scan
_serializeDate
_update
_upsertItemToCollection
addListener
addReverseMap
addRoute
canTriggerConfiguration
cascadeDelete
computeParameters
createIndex
delete
deleteItemFromCollection
emit
emitSync
eventNames
exists
find
generateUid
get
getARNPolicy
getAll
getCloudFormation
getConfiguration
getMapper
getMaxListeners
getModel
getName
getParameters
getService
getUrl
getUuidField
getWebda
handleIndex
handleMap
httpAction
httpCreate
httpGet
httpGlobalAction
httpRoute
httpUpdate
incrementAttribute
init
initMap
initModel
initRoutes
isMapped
listenerCount
listeners
loadParameters
log
off
on
onAsync
once
patch
prependListener
prependOnceListener
rawListeners
reinit
removeAllListeners
removeAttribute
removeListener
removeMapper
resolve
save
setMaxListeners
toPublicJSON
toString
update
upsertItemToCollection
copyTable
getModda
listenerCount

Constructors

  • new DynamoStore(webda: Core, name: string, params?: any): DynamoStore

Properties

_cascade: any[]
_client: any
_createException: string
_creationDateField: string
_exposeUrl: string
_initException: any
_initTime: number
_lastUpdateField: string
_model: CoreModelDefinition
_name: string

Service name

_reverseMap: any[]
_uuidField: string
_webda: Core

Webda Core object

logger: Logger

Logger with class context

parameters: K

Hold the parameters for your service

It will be bring from the webda.config.json

defaultMaxListeners: number

Methods

  • __clean(): Promise<void>
  • _cleanObject(object: any): any
  • _delete(uid: any, writeCondition?: any): Promise<any>
  • _deleteItemFromCollection(uid: any, prop: any, index: any, itemWriteCondition: any, itemWriteConditionField: any, updateDate: Date): Promise<void>
  • _find(request: any): Promise<any>
  • _get(uid: any): Promise<any>
  • _getWriteCondition(writeCondition: any): string
  • _handleCreatedMap(object: any, map: any, mapped: any, store: any): any
  • _handleDeletedMap(object: any, map: any, mapped: any, store: any): any
  • _handleMapFromPartial(uid: string, updateDate: Date, prop?: string): Promise<void>
  • _handleMapProperty(store: any, object: any, property: any, updates: any): Promise<any>
  • _handleUpdatedMap(object: any, map: any, mapped: any, store: any, updates: any): Promise<any>
  • _handleUpdatedMapMapper(object: any, map: any, mapped: any, store: any, updates: any): any
  • _handleUpdatedMapTransferIn(object: any, map: any, store: any, updates: any): any
  • _handleUpdatedMapTransferOut(object: any, map: any, mapped: any, store: any, updates: any): any
  • _incrementAttribute(uid: any, prop: any, value: any, updateDate: Date): any
  • _patch(object: any, uid: any, writeCondition?: any): Promise<any>
  • _removeAttribute(uuid: string, attribute: string): Promise<void>
  • _save(object: any, uid?: any): Promise<any>
  • _scan(items: any, paging?: any): Promise<unknown>
  • _serializeDate(date: any): string
  • _update(object: any, uid: string, writeCondition?: any): Promise<any>
  • _upsertItemToCollection(uid: any, prop: any, item: any, index: any, itemWriteCondition: any, itemWriteConditionField: any, updateDate: Date): Promise<void>
  • addListener(event: string | symbol, listener: function): this
  • addReverseMap(prop: any, cascade: any, store: any): void
  • addRoute(url: string, methods: HttpMethodType[], executer: Function, openapi?: object, allowPath?: boolean): void
  • canTriggerConfiguration(id: string, callback: function): boolean
  • cascadeDelete(obj: any, uuid: string): Promise<any>
  • computeParameters(): void
  • createIndex(): Promise<void>
  • delete(uid: any, sync?: boolean): Promise<void>
  • deleteItemFromCollection(uid: any, prop: any, index: any, itemWriteCondition: any, itemWriteConditionField: any): Promise<void>
  • emit(event: string | symbol, ...args: any[]): boolean
  • emitSync(event: any, data: any): Promise<any[]>
  • eventNames(): Array<string | symbol>
  • exists(uid: any): Promise<boolean>
  • find(request?: any, offset?: number, limit?: number): Promise<any>
  • generateUid(): any
  • get(uid: string, ctx?: Context): Promise<T>
  • getARNPolicy(accountId: any): object
  • getAll(uids: any): Promise<any>
  • getConfiguration(id: string): Promise<Map<string, any>>
  • getMapper(map: any, uuid: any): number
  • getMaxListeners(): number
  • getName(): string
  • getParameters(): K
  • getService<T>(service: string): T
  • getUrl(): string
  • getUuidField(): string
  • getWebda(): Core
  • handleIndex(object: CoreModel, updates: object | string): Promise<void>
  • handleMap(object: any, map: any, updates: any): Promise<any[]>
  • httpAction(ctx: Context): Promise<void>
  • httpCreate(ctx: Context): Promise<void>
  • httpGet(ctx: Context): Promise<void>
  • httpGlobalAction(ctx: Context): Promise<void>
  • httpRoute(ctx: Context): Promise<void>
  • httpUpdate(ctx: Context): Promise<void>
  • incrementAttribute(uid: any, prop: any, value: any): Promise<void | any[]>
  • init(): Promise<void>
  • initMap(map: any): void
  • initModel(object: any): T
  • initRoutes(): void
  • isMapped(property: string): boolean
  • listenerCount(type: string | symbol): number
  • listeners(event: string | symbol): Function[]
  • loadParameters(params: any): any
  • off(event: string | symbol, listener: function): this
  • on(event: string | symbol, listener: function): this
  • onAsync(event: any, callback: any, queue?: string): void
  • once(event: string | symbol, listener: function): this
  • patch(object: any, reverseMap?: boolean): Promise<any>
  • prependListener(event: string | symbol, listener: function): this
  • prependOnceListener(event: string | symbol, listener: function): this
  • rawListeners(event: string | symbol): Function[]
  • reinit(config: any): Promise<void>
  • removeAllListeners(event?: string | symbol): this
  • removeAttribute(uuid: string, attribute: string): Promise<void>
  • removeListener(event: string | symbol, listener: function): this
  • removeMapper(map: any, uuid: any): boolean
  • resolve(): void
  • save(object: any, ctx?: Context): Promise<any>
  • setMaxListeners(n: number): this
  • toPublicJSON(object: any): string
  • toString(): string
  • update(object: any, reverseMap?: boolean, partial?: boolean): Promise<any>
  • upsertItemToCollection(uid: any, prop: any, item: any, index?: any, itemWriteCondition?: any, itemWriteConditionField?: any): Promise<void>
  • copyTable(output: WorkerOutput, source: any, target: any): Promise<void>
  • getModda(): ModdaDefinition
  • listenerCount(emitter: EventEmitter, event: string | symbol): number

Generated using TypeDoc