gateway

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: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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