resource

Documentation

Index

• func Apply(opts ...optResourceInit)
• func Done()
• 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 Resource() *resourceImpl

Functions

func Apply

func Apply(opts ...optResourceInit)

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

func Done

func Done()

Done finish all initialization of resources.

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 Resource

func Resource() *resourceImpl

Resource access the underlying singleton of resources.