streamingcoord

Documentation

Index

• Constants
• func NewCataLog(metaKV kv.MetaKv) metastore.StreamingCoordCataLog

Constants

const (
	MetaPrefix          = "streamingcoord-meta/"
	PChannelMetaPrefix  = MetaPrefix + "pchannel/"
	BroadcastTaskPrefix = MetaPrefix + "broadcast-task/"
)

Functions

func NewCataLog

func NewCataLog(metaKV kv.MetaKv) metastore.StreamingCoordCataLog

NewCataLog creates a new catalog instance streamingcoord-meta ├── broadcast │   ├── task-1 │   └── task-2 └── pchannel

├── pchannel-1
└── pchannel-2