gateway

package

v1.16.0 Latest Latest Go to latest Published: Feb 14, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubeedge/edgemesh

Links

Open Source Insights

Documentation ¶

Index ¶

func GetAllIPs() ([]net.IP, error)
func GetIPsByName(name string) ([]net.IP, error)
func GetIPsNeedListen(c *v1alpha1.EdgeGatewayConfig) ([]net.IP, error)
func IsClosedError(err error) bool
func Register(c *v1alpha1.EdgeGatewayConfig, cli *clients.Clients) error
type EdgeGateway
type HTTP
- func (p *HTTP) Process()
type Protocol
type Server
- func NewServer(ip net.IP, port int, opts *ServerOptions) (*Server, error)
- func (srv *Server) Stop()
type ServerOptions
type TCP
- func (p *TCP) Process()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetAllIPs ¶

func GetAllIPs() ([]net.IP, error)

GetAllIPs get all IPs

func GetIPsByName ¶

func GetIPsByName(name string) ([]net.IP, error)

GetIPsByName get IPs by name

func GetIPsNeedListen ¶

func GetIPsNeedListen(c *v1alpha1.EdgeGatewayConfig) ([]net.IP, error)

GetIPsNeedListen get Ips need listen

func IsClosedError ¶ added in v1.13.0

func IsClosedError(err error) bool

func Register ¶

func Register(c *v1alpha1.EdgeGatewayConfig, cli *clients.Clients) error

Register edgegateway to beehive modules

Types ¶

type EdgeGateway ¶

type EdgeGateway struct {
	Config *v1alpha1.EdgeGatewayConfig
	// contains filtered or unexported fields
}

EdgeGateway is an edge ingress gateway

func (*EdgeGateway) Enable ¶

func (gw *EdgeGateway) Enable() bool

Enable indicates whether enable this module

func (*EdgeGateway) Group ¶

func (gw *EdgeGateway) Group() string

Group of edgegateway

func (*EdgeGateway) Name ¶

func (gw *EdgeGateway) Name() string

Name of edgegateway

func (*EdgeGateway) OnGatewayAdd ¶

func (gw *EdgeGateway) OnGatewayAdd(gateway *istiv1alpha3.Gateway)

OnGatewayAdd add a gateway server

func (*EdgeGateway) OnGatewayDelete ¶

func (gw *EdgeGateway) OnGatewayDelete(gateway *istiv1alpha3.Gateway)

OnGatewayDelete delete a gateway server

func (*EdgeGateway) OnGatewayUpdate ¶

func (gw *EdgeGateway) OnGatewayUpdate(_, gateway *istiv1alpha3.Gateway)

OnGatewayUpdate update a gateway server

func (*EdgeGateway) Run ¶

func (gw *EdgeGateway) Run() error

func (*EdgeGateway) Shutdown ¶ added in v1.13.1

func (gw *EdgeGateway) Shutdown()

Shutdown edgegateway

func (*EdgeGateway) Start ¶

func (gw *EdgeGateway) Start()

Start edgegateway

type HTTP ¶

type HTTP struct {
	Conn           net.Conn
	VirtualService *istioapi.VirtualService
	SvcName        string
	SvcNamespace   string
	SvcPort        int
}

HTTP http

func (*HTTP) Process ¶

func (p *HTTP) Process()

Process process

type Protocol ¶

type Protocol interface {
	Process()
}

Protocol protocol

type Server ¶

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

Server is gateway server

func NewServer ¶

func NewServer(ip net.IP, port int, opts *ServerOptions) (*Server, error)

NewServer new server and run

func (*Server) Stop ¶

func (srv *Server) Stop()

Stop stop

type ServerOptions ¶

type ServerOptions struct {
	// ingress
	Exposed        bool
	GwName         string
	Namespace      string
	Hosts          []string
	Protocol       string
	CredentialName string
	MinVersion     uint16
	MaxVersion     uint16
	CipherSuites   []uint16
}

ServerOptions options

type TCP ¶

type TCP struct {
	Conn         net.Conn
	SvcName      string
	SvcNamespace string
	SvcPort      int
	UpgradeReq   *http.Request
}

func (*TCP) Process ¶

func (p *TCP) Process()

Process process

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cache

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