resource

package
v0.0.0-...-34e0b2d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 9, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Init

func Init(opts ...optResourceInit)

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

func OptETCD

func OptETCD(etcd *clientv3.Client) optResourceInit

OptETCD provides the etcd client to the resource.

func OptStreamingCatalog

func OptStreamingCatalog(catalog metastore.StreamingCoordCataLog) optResourceInit

OptStreamingCatalog provides streaming catalog to the resource.

func Resource

func Resource() *resourceImpl

Resource access the underlying singleton of resources.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL