gateway

Documentation

Index

• func NewGateway(config Config) *ceGateway
• type Auth
• type Config
  • func InitConfig(filename string) (*Config, error)
  • func (c Config) GetCloudEventReceiverPort() int
  • func (c Config) GetProxyConfig() proxy.Config
• type EventData

Functions

func NewGateway

func NewGateway(config Config) *ceGateway

Types

type Auth

type Auth struct {
	Disable bool `yaml:"disable"`
}

type Config

type Config struct {
	Port                 int                  `yaml:"port"`
	SinkPort             int                  `yaml:"sink_port"`
	Observability        observability.Config `yaml:"observability"`
	ControllerAddr       []string             `yaml:"controllers"`
	GRPCReflectionEnable bool                 `yaml:"grpc_reflection_enable"`
	Auth                 Auth                 `yaml:"auth"`
}

func InitConfig

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

func (Config) GetCloudEventReceiverPort

func (c Config) GetCloudEventReceiverPort() int

func (Config) GetProxyConfig

func (c Config) GetProxyConfig() proxy.Config

type EventData

type EventData struct {
	EventID string   `json:"event_id"`
	BusID   vanus.ID `json:"eventbus_id"`
}