resource

Documentation

Index

• func Init(opts ...optResourceInit)
• func OptBufferManager(wbMgr writebuffer.BufferManager) optResourceInit
• func OptChunkManager(chunkManager storage.ChunkManager) optResourceInit
• func OptDataCoordClient(dataCoordClient types.DataCoordClient) optResourceInit
• func OptETCD(etcd *clientv3.Client) optResourceInit
• func OptFlusher(flusher flusher.Flusher) optResourceInit
• func OptRootCoordClient(rootCoordClient types.RootCoordClient) optResourceInit
• func OptStreamingNodeCatalog(catalog metastore.StreamingNodeCataLog) optResourceInit
• func OptSyncManager(syncMgr syncmgr.SyncManager) optResourceInit
• func Resource() *resourceImpl

Functions

func Init

func Init(opts ...optResourceInit)

Init initializes the singleton of resources. Should be call when streaming node startup.

func OptBufferManager

func OptBufferManager(wbMgr writebuffer.BufferManager) optResourceInit

OptBufferManager provides the write buffer manager to the resource.

func OptChunkManager

func OptChunkManager(chunkManager storage.ChunkManager) optResourceInit

OptChunkManager provides the chunk manager to the resource.

func OptDataCoordClient

func OptDataCoordClient(dataCoordClient types.DataCoordClient) optResourceInit

OptDataCoordClient provides the data coordinator client to the resource.

func OptETCD

func OptETCD(etcd *clientv3.Client) optResourceInit

OptETCD provides the etcd client to the resource.

func OptFlusher

func OptFlusher(flusher flusher.Flusher) optResourceInit

OptFlusher provides the flusher to the resource.

func OptRootCoordClient

func OptRootCoordClient(rootCoordClient types.RootCoordClient) optResourceInit

OptRootCoordClient provides the root coordinator client to the resource.

func OptStreamingNodeCatalog

func OptStreamingNodeCatalog(catalog metastore.StreamingNodeCataLog) optResourceInit

OptStreamingNodeCatalog provides the streaming node catalog to the resource.

func OptSyncManager

func OptSyncManager(syncMgr syncmgr.SyncManager) optResourceInit

OptSyncManager provides the sync manager to the resource.

func Resource

func Resource() *resourceImpl

Resource access the underlying singleton of resources.