Documentation
¶
Index ¶
- Variables
- func DefaultConfigInit(config configv1.StreamControllerConfig)
- func GetDispatcherDeptName(b *v1.Broker) string
- func GetDispatcherManagerContainerPort() string
- func GetPublisherManagerContainerPort() string
- func GetPublisherName(b *v1.Broker) string
- func GetSelector(b *v1.Broker) string
- func GetStreamName(b *v1.Broker) string
- func StartPartitionAllocator(ctx context.Context, manager manager.Manager)
Constants ¶
This section is empty.
Variables ¶
View Source
var AllocateRequestCh = make(chan v12.Broker, 1)
View Source
var DispatcherManagerContainerPort = `8080`
View Source
var PublisherContainerPort = `8080`
Functions ¶
func DefaultConfigInit ¶
func DefaultConfigInit(config configv1.StreamControllerConfig)
func GetDispatcherDeptName ¶
func GetDispatcherManagerContainerPort ¶
func GetDispatcherManagerContainerPort() string
func GetPublisherManagerContainerPort ¶
func GetPublisherManagerContainerPort() string
func GetPublisherName ¶
func GetSelector ¶
func GetStreamName ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.