controller

Documentation

Index

• type Config
  • func InitConfig(filename string) (*Config, error)
  • func (c *Config) GetEtcdConfig() embedetcd.Config
  • func (c *Config) GetEventbusCtrlConfig() eventbus.Config
  • func (c *Config) GetTriggerConfig() trigger.Config
• type MetadataConfig

Types

type Config

type Config struct {
	Name                 string            `yaml:"name"`
	IP                   string            `yaml:"ip"`
	Port                 int               `yaml:"port"`
	GRPCReflectionEnable bool              `yaml:"grpc_reflection_enable"`
	EtcdEndpoints        []string          `yaml:"etcd"`
	DataDir              string            `yaml:"data_dir"`
	MetadataConfig       MetadataConfig    `yaml:"metadata"`
	EtcdConfig           embedetcd.Config  `yaml:"embed_etcd"`
	Topology             map[string]string `yaml:"topology"`
	Replicas             uint              `yaml:"replicas"`
	GatewayEndpoint      string            `yaml:"gateway_endpoint"`
}

func InitConfig

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

func (*Config) GetEtcdConfig

func (c *Config) GetEtcdConfig() embedetcd.Config

func (*Config) GetEventbusCtrlConfig

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

func (*Config) GetTriggerConfig

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

type MetadataConfig

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