api

package
v0.9.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 10, 2024 License: AGPL-3.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsSwaggerEmbedded 

func IsSwaggerEmbedded() bool

Types

type API 

type API struct {
	v1.GatewayDAdminAPIServiceServer

	Options *Options

	Config         *config.Config
	PluginRegistry *plugin.Registry
	Pools          map[string]*pool.Pool
	Proxies        map[string]*network.Proxy
	Servers        map[string]*network.Server
}

func (*API) GetGlobalConfig 

func (a *API) GetGlobalConfig(_ context.Context, group *v1.Group) (*structpb.Struct, error)

GetGlobalConfig returns the global configuration of the GatewayD.

func (*API) GetPluginConfig 

func (a *API) GetPluginConfig(context.Context, *emptypb.Empty) (*structpb.Struct, error)

GetPluginConfig returns the plugin configuration of the GatewayD.

func (*API) GetPlugins 

func (a *API) GetPlugins(context.Context, *emptypb.Empty) (*v1.PluginConfigs, error)

GetPlugins returns the active plugin configuration of the GatewayD.

func (*API) GetPools 

func (a *API) GetPools(context.Context, *emptypb.Empty) (*structpb.Struct, error)

GetPools returns the pool configuration of the GatewayD.

func (*API) GetProxies 

func (a *API) GetProxies(context.Context, *emptypb.Empty) (*structpb.Struct, error)

GetProxies returns the proxy configuration of the GatewayD.

func (*API) GetServers 

func (a *API) GetServers(context.Context, *emptypb.Empty) (*structpb.Struct, error)

GetServers returns the server configuration of the GatewayD.

func (*API) Version 

func (a *API) Version(context.Context, *emptypb.Empty) (*v1.VersionResponse, error)

Version returns the version information of the GatewayD.

type GRPCServer added in v0.9.3 

type GRPCServer struct {
	API *API

	*HealthChecker
	// contains filtered or unexported fields
}

func NewGRPCServer added in v0.9.3 

func NewGRPCServer(server GRPCServer) *GRPCServer

NewGRPCServer creates a new gRPC server.

func (*GRPCServer) Shutdown added in v0.9.3 

func (s *GRPCServer) Shutdown(_ context.Context)

Shutdown shuts down the gRPC server.

func (*GRPCServer) Start added in v0.9.3 

func (s *GRPCServer) Start()

Start starts the gRPC server.

type HTTPServer added in v0.9.3 

type HTTPServer struct {
	// contains filtered or unexported fields
}

func NewHTTPServer added in v0.9.3 

func NewHTTPServer(options *Options) *HTTPServer

NewHTTPServer creates a new HTTP server.

func (*HTTPServer) Shutdown added in v0.9.3 

func (s *HTTPServer) Shutdown(ctx context.Context)

Shutdown shuts down the HTTP server.

func (*HTTPServer) Start added in v0.9.3 

func (s *HTTPServer) Start()

Start starts the HTTP server.

type HealthChecker added in v0.8.4 

type HealthChecker struct {
	grpc_health_v1.UnimplementedHealthServer

	Servers map[string]*network.Server
}

func (*HealthChecker) Check added in v0.8.4 

func (h *HealthChecker) Check(
	context.Context, *grpc_health_v1.HealthCheckRequest,
) (*grpc_health_v1.HealthCheckResponse, error)

func (*HealthChecker) Watch added in v0.8.4 

func (h *HealthChecker) Watch(
	*grpc_health_v1.HealthCheckRequest,
	grpc_health_v1.Health_WatchServer,
) error

type Healthz added in v0.8.4 

type Healthz struct {
	Status string `json:"status"`
}

type IAPIServer added in v0.9.3 

type IAPIServer interface {
	Start()
	Shutdown(ctx context.Context)
}

type Options 

type Options struct {
	Logger      zerolog.Logger
	GRPCNetwork string
	GRPCAddress string
	HTTPAddress string
	Servers     map[string]*network.Server
}

Source Files

View all Source files

Directories

Path Synopsis
Package v1 is a reverse proxy.
 Package v1 is a reverse proxy.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.