gateway

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
  • func (gw *EdgeGateway) Enable() bool
  • func (gw *EdgeGateway) Group() string
  • func (gw *EdgeGateway) Name() string
  • func (gw *EdgeGateway) OnGatewayAdd(gateway *istiv1alpha3.Gateway)
  • func (gw *EdgeGateway) OnGatewayDelete(gateway *istiv1alpha3.Gateway)
  • func (gw *EdgeGateway) OnGatewayUpdate(_, gateway *istiv1alpha3.Gateway)
  • func (gw *EdgeGateway) Run() error
  • func (gw *EdgeGateway) Shutdown()
  • func (gw *EdgeGateway) Start()
• 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()

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

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

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