Class TypeormStakePoolProvider

Hierarchy

TypeormProvider
- TypeormStakePoolProvider

Implements

StakePoolProvider

Constructors

constructor

new TypeormStakePoolProvider(config: TypeOrmStakePoolProviderProps, deps: TypeormStakePoolProviderDependencies): TypeormStakePoolProvider
Parameters
- config: TypeOrmStakePoolProviderProps
- deps: TypeormStakePoolProviderDependencies
Returns TypeormStakePoolProvider
Overrides TypeormProvider.constructor
- Defined in packages/cardano-services/src/StakePool/TypeormStakePoolProvider/TypeormStakePoolProvider.ts:67

Properties

`Private` #cache

#cache: InMemoryCache

`Private` #connectionConfig$

#connectionConfig$: Observable<PgConnectionConfig>

`Private` #connectionTimeout

#connectionTimeout: Milliseconds

`Private` #entities

#entities: Function[]

`Private` #fuzzyOptions

#fuzzyOptions: FuzzyOptions

`Private` #lastRosEpochs

#lastRosEpochs: number

`Private` `Optional` #overrideFuzzyOptions

#overrideFuzzyOptions?: boolean

`Private` #paginationPageSizeLimit

#paginationPageSizeLimit: number

`Private` #subscription

#subscription: undefined | Subscription

`Protected` dataSource$

dataSource$: BehaviorSubject<null | DataSource> = ...

health

health: HealthCheckResponse = ...

healthCheckCache

healthCheckCache: InMemoryCache

logger

logger: Logger

name

name: string

state

state: RunnableModuleState

Methods

`Private` #reset

#reset(): void
Returns void
Inherited from TypeormProvider.#reset
- Defined in packages/cardano-services/src/util/TypeormService/TypeormService.ts:47

`Private` #subscribeToDataSource

#subscribeToDataSource(): Promise<unknown>
Returns Promise<unknown>
Inherited from TypeormProvider.#subscribeToDataSource
- Defined in packages/cardano-services/src/util/TypeormService/TypeormService.ts:30

`Private` getFuse

getFuse(dataSource: DataSource, fuzzyOptions?: {
    distance?: number;
    fieldNormWeight?: number;
    ignoreFieldNorm?: boolean;
    ignoreLocation?: boolean;
    location?: number;
    minMatchCharLength?: number;
    threshold?: number;
    useExtendedSearch?: boolean;
    weights?: { description?: number | undefined; homepage?: number | undefined; name?: number | undefined; poolId?: number | undefined; ticker?: number | undefined; };
}): Promise<Fuse<{
    description: string;
    homepage: string;
    name: string;
    pool_id: string;
    ticker: string;
}>>
Parameters
- dataSource: DataSource
- Optional fuzzyOptions: {
      distance?: number;
      fieldNormWeight?: number;
      ignoreFieldNorm?: boolean;
      ignoreLocation?: boolean;
      location?: number;
      minMatchCharLength?: number;
      threshold?: number;
      useExtendedSearch?: boolean;
      weights?: { description?: number | undefined; homepage?: number | undefined; name?: number | undefined; poolId?: number | undefined; ticker?: number | undefined; };
  }
  - Optional distance?: number
  - Optional fieldNormWeight?: number
  - Optional ignoreFieldNorm?: boolean
  - Optional ignoreLocation?: boolean
  - Optional location?: number
  - Optional minMatchCharLength?: number
  - Optional threshold?: number
  - Optional useExtendedSearch?: boolean
  - Optional weights?: { description?: number | undefined; homepage?: number | undefined; name?: number | undefined; poolId?: number | undefined; ticker?: number | undefined; }
Returns Promise<Fuse<{
    description: string;
    homepage: string;
    name: string;
    pool_id: string;
    ticker: string;
}>>
- Defined in packages/cardano-services/src/StakePool/TypeormStakePoolProvider/TypeormStakePoolProvider.ts:91

healthCheck

healthCheck(): Promise<HealthCheckResponse>
Returns Promise<HealthCheckResponse>
Implementation of StakePoolProvider.healthCheck

Inherited from TypeormProvider.healthCheck
- Defined in packages/cardano-services/src/util/TypeormProvider/TypeormProvider.ts:26

initialize

initialize(): Promise<void>
Returns Promise<void>
Inherited from TypeormProvider.initialize
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:15

initializeAfter

initializeAfter(): void
Returns void
Inherited from TypeormProvider.initializeAfter
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:19

initializeBefore

initializeBefore(): void
Returns void
Inherited from TypeormProvider.initializeBefore
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:18

initializeImpl

initializeImpl(): Promise<void>
Returns Promise<void>
Inherited from TypeormProvider.initializeImpl
- Defined in packages/cardano-services/src/util/TypeormService/TypeormService.ts:89

onError

onError(_: unknown): void
Parameters
- _: unknown
Returns void
Inherited from TypeormProvider.onError
- Defined in packages/cardano-services/src/util/TypeormService/TypeormService.ts:53

queryStakePools

queryStakePools(options: QueryStakePoolsArgs): Promise<Paginated<StakePool>>
Parameters
- options: QueryStakePoolsArgs
Returns Promise<Paginated<StakePool>>
Implementation of StakePoolProvider.queryStakePools
- Defined in packages/cardano-services/src/StakePool/TypeormStakePoolProvider/TypeormStakePoolProvider.ts:158

shutdown

shutdown(): Promise<void>
Returns Promise<void>
Inherited from TypeormProvider.shutdown
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:17

shutdownAfter

shutdownAfter(): void
Returns void
Inherited from TypeormProvider.shutdownAfter
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:23

shutdownBefore

shutdownBefore(): void
Returns void
Inherited from TypeormProvider.shutdownBefore
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:22

shutdownImpl

shutdownImpl(): Promise<void>
Returns Promise<void>
Inherited from TypeormProvider.shutdownImpl
- Defined in packages/cardano-services/src/util/TypeormService/TypeormService.ts:97

stakePoolStats

stakePoolStats(): Promise<StakePoolStats>
Returns Promise<StakePoolStats>
Implementation of StakePoolProvider.stakePoolStats
- Defined in packages/cardano-services/src/StakePool/TypeormStakePoolProvider/TypeormStakePoolProvider.ts:255

start

start(): Promise<void>
Returns Promise<void>
Inherited from TypeormProvider.start
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:16

startAfter

startAfter(): void
Returns void
Inherited from TypeormProvider.startAfter
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:21

startBefore

startBefore(): void
Returns void
Inherited from TypeormProvider.startBefore
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:20

startImpl

startImpl(): Promise<void>
Returns Promise<void>
Overrides TypeormProvider.startImpl
- Defined in packages/cardano-services/src/StakePool/TypeormStakePoolProvider/TypeormStakePoolProvider.ts:85

withDataSource

withDataSource<T>(callback: ((dataSource: DataSource) => Promise<T>)): Promise<T>
Type Parameters
- T
Parameters
- callback: ((dataSource: DataSource) => Promise<T>)
  - - (dataSource: DataSource): Promise<T>
    - Parameters
      
      dataSource: DataSource
      
      Returns Promise<T>
Returns Promise<T>
Inherited from TypeormProvider.withDataSource
- Defined in packages/cardano-services/src/util/TypeormService/TypeormService.ts:58

withQueryRunner

withQueryRunner<T>(callback: ((queryRunner: QueryRunner) => Promise<T>)): Promise<T>
Type Parameters
- T
Parameters
- callback: ((queryRunner: QueryRunner) => Promise<T>)
  - - (queryRunner: QueryRunner): Promise<T>
    - Parameters
      
      queryRunner: QueryRunner
      
      Returns Promise<T>
Returns Promise<T>
Inherited from TypeormProvider.withQueryRunner
- Defined in packages/cardano-services/src/util/TypeormService/TypeormService.ts:71

Class TypeormStakePoolProvider

Hierarchy

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

config: TypeOrmStakePoolProviderProps

deps: TypeormStakePoolProviderDependencies

Returns TypeormStakePoolProvider

Properties

Private #cache

Private #connectionConfig$

Private #connectionTimeout

Private #entities

Private #fuzzyOptions

Private #lastRosEpochs

Private Optional #overrideFuzzyOptions

Private #paginationPageSizeLimit

Private #subscription

Protected dataSource$

health

healthCheckCache

logger

name

state

Methods

Private #reset

Returns void

Private #subscribeToDataSource

Returns Promise<unknown>

Private getFuse

Parameters

dataSource: DataSource

Optional distance?: number

Optional fieldNormWeight?: number

Optional ignoreFieldNorm?: boolean

Optional ignoreLocation?: boolean

Optional location?: number

Optional minMatchCharLength?: number

Optional threshold?: number

Optional useExtendedSearch?: boolean

Optional weights?: { description?: number | undefined; homepage?: number | undefined; name?: number | undefined; poolId?: number | undefined; ticker?: number | undefined; }

Returns Promise<Fuse<{ description: string; homepage: string; name: string; pool_id: string; ticker: string; }>>

healthCheck

Returns Promise<HealthCheckResponse>

initialize

Returns Promise<void>

initializeAfter

Returns void

initializeBefore

Returns void

initializeImpl

Returns Promise<void>

onError

Parameters

_: unknown

Returns void

queryStakePools

Parameters

options: QueryStakePoolsArgs

Returns Promise<Paginated<StakePool>>

shutdown

Returns Promise<void>

shutdownAfter

Returns void

shutdownBefore

Returns void

shutdownImpl

Returns Promise<void>

stakePoolStats

Returns Promise<StakePoolStats>

start

Returns Promise<void>

startAfter

Returns void

startBefore

`Private` #cache

`Private` #connectionConfig$

`Private` #connectionTimeout

`Private` #entities

`Private` #fuzzyOptions

`Private` #lastRosEpochs

`Private` `Optional` #overrideFuzzyOptions

`Private` #paginationPageSizeLimit

`Private` #subscription

`Protected` dataSource$

`Private` #reset

`Private` #subscribeToDataSource

`Private` getFuse

`Optional` distance?: number

`Optional` fieldNormWeight?: number

`Optional` ignoreFieldNorm?: boolean

`Optional` ignoreLocation?: boolean

`Optional` location?: number

`Optional` minMatchCharLength?: number

`Optional` threshold?: number

`Optional` useExtendedSearch?: boolean

`Optional` weights?: { description?: number | undefined; homepage?: number | undefined; name?: number | undefined; poolId?: number | undefined; ticker?: number | undefined; }

Returns Promise<Fuse<{
description: string;
homepage: string;
name: string;
pool_id: string;
ticker: string;
}>>