lingress

README

lingress

Is an experemtary ingress controller.

WARNING: This project is still under heavy development. Everything could still change.

Contributing

lingress is an open source project by echocat. So if you want to make this project even better, you can contribute to this project on Github by fork us.

If you commit code to this project, you have to accept that this code will be released under the license of this project.

License

See the LICENSE file.

Documentation

Index

• type ConnectionInformation
  • func NewConnectionInformation() *ConnectionInformation
  • func (instance *ConnectionInformation) SetState(conn net.Conn, newState http.ConnState, keepFunc func(http.ConnState) bool) (previousState http.ConnState)
• type ConnectionStates
• type Lingress
  • func New(fps support.FileProviders) (*Lingress, error)
  • func (instance *Lingress) Init(stop support.Channel) error
  • func (instance *Lingress) RegisterFlag(fe support.FlagEnabled, appPrefix string) error
  • func (instance *Lingress) ServeHTTP(resp http.ResponseWriter, req *http.Request)

Types

type ConnectionInformation

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

func NewConnectionInformation

func NewConnectionInformation() *ConnectionInformation

func (*ConnectionInformation) SetState

func (instance *ConnectionInformation) SetState(
	conn net.Conn,
	newState http.ConnState,
	keepFunc func(http.ConnState) bool,
) (previousState http.ConnState)

type ConnectionStates

type ConnectionStates struct {
	New    uint64
	Active uint64
	Idle   uint64
}

type Lingress

type Lingress struct {
	RulesRepository rules.CombinedRepository
	Proxy           *proxy.Proxy
	Fallback        *fallback.Fallback
	Management      *management.Management

	HttpListenAddr    string
	HttpsListenAddr   string
	MaxHeaderBytes    uint
	ReadHeaderTimeout time.Duration
	WriteTimeout      time.Duration
	IdleTimeout       time.Duration

	AccessLogQueueSize uint16
	// contains filtered or unexported fields
}

func New

func New(fps support.FileProviders) (*Lingress, error)

func (*Lingress) Init

func (instance *Lingress) Init(stop support.Channel) error

func (*Lingress) RegisterFlag

func (instance *Lingress) RegisterFlag(fe support.FlagEnabled, appPrefix string) error

func (*Lingress) ServeHTTP

func (instance *Lingress) ServeHTTP(resp http.ResponseWriter, req *http.Request)