eventbus

Documentation

Index

• func GetMappingKey(namespace uint64, name string) string
• func NewController(cfg Config, mem member.Member) *controller
• type Config

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"`
}