controller

Documentation

Index

• type Config
  • func InitConfig(filename string) (*Config, error)
  • func (c *Config) GetClusterConfig() member.Config
  • func (c *Config) GetControllerAddrs() []string
  • func (c *Config) GetEventbusCtrlConfig() eventbus.Config
  • func (c *Config) GetSnowflakeConfig() root.Config
  • func (c *Config) GetTenantConfig() tenant.Config
  • func (c *Config) GetTriggerConfig() trigger.Config
• type MetadataConfig

Types

type Config

type Config struct {
	NodeID               uint16               `yaml:"node_id"`
	Name                 string               `yaml:"name"`
	IP                   string               `yaml:"ip"`
	Port                 int                  `yaml:"port"`
	GRPCReflectionEnable bool                 `yaml:"grpc_reflection_enable"`
	MetadataConfig       MetadataConfig       `yaml:"metadata"`
	Replicas             uint                 `yaml:"replicas"`
	SecretEncryptionSalt string               `yaml:"secret_encryption_salt"`
	SegmentCapacity      int64                `yaml:"segment_capacity"`
	Observability        observability.Config `yaml:"observability"`
	ClusterConfig        member.Config        `yaml:"cluster"`
	RootControllerAddr   []string             `yaml:"root_controllers"`
	NoCreateDefaultNs    bool                 `yaml:"no_create_default_namespace"`
}

func InitConfig

func InitConfig(filename string) (*Config, error)

func (*Config) GetClusterConfig

func (c *Config) GetClusterConfig() member.Config

func (*Config) GetControllerAddrs

func (c *Config) GetControllerAddrs() []string

func (*Config) GetEventbusCtrlConfig

func (c *Config) GetEventbusCtrlConfig() eventbus.Config

func (*Config) GetSnowflakeConfig

func (c *Config) GetSnowflakeConfig() root.Config

func (*Config) GetTenantConfig

func (c *Config) GetTenantConfig() tenant.Config

func (*Config) GetTriggerConfig

func (c *Config) GetTriggerConfig() trigger.Config

type MetadataConfig

type MetadataConfig struct {
	KeyPrefix string `yaml:"key_prefix"`
}