Options
All
  • Public
  • Public/Protected
  • All
Menu

Class TreeCacheImpl

Hierarchy

  • TreeCacheImpl

Implements

Index

Constructors

constructor

Properties

Private _treeState

_treeState: TreeState.LATENT | TreeState.STARTED | TreeState.CLOSED = TreeState.LATENT

cacheData

cacheData: boolean

client

Private createParentNodes

createParentNodes: boolean

Private errorListeners

errorListeners: UnhandledErrorListener[] = []

isInitialized

isInitialized: boolean = false

Private listeners

listeners: TreeCacheListener[] = []

Private logger

logger: Logger

maxDepth

maxDepth: number

outstandingOps

outstandingOps: number

Private root

root: TreeNode

selector

Methods

addErrorListener

addListener

close

  • close(): void

Private connectionStateListener

  • connectionStateListener(_: CuratorFramework, newState: ConnectionState.CONNECTED | ConnectionState.SUSPENDED | ConnectionState.RECONNECTED | ConnectionState.LOST | ConnectionState.READ_ONLY): void
  • Parameters

    • _: CuratorFramework
    • newState: ConnectionState.CONNECTED | ConnectionState.SUSPENDED | ConnectionState.RECONNECTED | ConnectionState.LOST | ConnectionState.READ_ONLY

    Returns void

Private find

  • find(findPath: string): TreeNode | null

getCurrentChildren

  • getCurrentChildren(fullPath: string): Map<string, ChildData> | null

getCurrentData

  • getCurrentData(fullPath: string): ChildData | null

handleException

  • handleException(e: Error): void

Private handleStateChange

  • handleStateChange(newState: ConnectionState.CONNECTED | ConnectionState.SUSPENDED | ConnectionState.RECONNECTED | ConnectionState.LOST | ConnectionState.READ_ONLY): void
  • Parameters

    • newState: ConnectionState.CONNECTED | ConnectionState.SUSPENDED | ConnectionState.RECONNECTED | ConnectionState.LOST | ConnectionState.READ_ONLY

    Returns void

Private publishEvent

publishEventType

  • publishEventType(type: TreeCacheEventType.NODE_ADDED | TreeCacheEventType.NODE_UPDATED | TreeCacheEventType.NODE_REMOVED | TreeCacheEventType.CONNECTION_SUSPENDED | TreeCacheEventType.CONNECTION_RECONNECTED | TreeCacheEventType.CONNECTION_LOST | TreeCacheEventType.INITIALIZED): void
  • Parameters

    • type: TreeCacheEventType.NODE_ADDED | TreeCacheEventType.NODE_UPDATED | TreeCacheEventType.NODE_REMOVED | TreeCacheEventType.CONNECTION_SUSPENDED | TreeCacheEventType.CONNECTION_RECONNECTED | TreeCacheEventType.CONNECTION_LOST | TreeCacheEventType.INITIALIZED

    Returns void

publishEventTypeWithData

  • publishEventTypeWithData(type: TreeCacheEventType.NODE_ADDED | TreeCacheEventType.NODE_UPDATED | TreeCacheEventType.NODE_REMOVED | TreeCacheEventType.CONNECTION_SUSPENDED | TreeCacheEventType.CONNECTION_RECONNECTED | TreeCacheEventType.CONNECTION_LOST | TreeCacheEventType.INITIALIZED, data: ChildData | null): void
  • Parameters

    • type: TreeCacheEventType.NODE_ADDED | TreeCacheEventType.NODE_UPDATED | TreeCacheEventType.NODE_REMOVED | TreeCacheEventType.CONNECTION_SUSPENDED | TreeCacheEventType.CONNECTION_RECONNECTED | TreeCacheEventType.CONNECTION_LOST | TreeCacheEventType.INITIALIZED
    • data: ChildData | null

    Returns void

removeErrorListener

removeListener

start

treeState

  • treeState(): TreeState.LATENT | TreeState.STARTED | TreeState.CLOSED

Generated using TypeDoc