eventbus

package
v0.9.0 Latest Latest
Warning

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

Go to latest
Published: Sep 7, 2023 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetMappingKey

func GetMappingKey(namespace uint64, name string) string

func NewController

func NewController(cfg Config, mem member.Member) *controller

Types

type Config

type Config struct {
	IP               string            `yaml:"ip"`
	Port             int               `yaml:"port"`
	KVStoreEndpoints []string          `yaml:"kv_store_endpoints"`
	KVKeyPrefix      string            `yaml:"kv_key_prefix"`
	Replicas         uint              `yaml:"replicas"`
	Topology         map[string]string `yaml:"topology"`
	SegmentCapacity  int64             `yaml:"segment_capacity"`
}

Directories

Path Synopsis
Package block is a generated GoMock package.
Package block is a generated GoMock package.
Package eventlog is a generated GoMock package.
Package eventlog is a generated GoMock package.
Package server is a generated GoMock package.
Package server is a generated GoMock package.
Package volume is a generated GoMock package.
Package volume is a generated GoMock package.

Jump to

Keyboard shortcuts

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