j8a

type AboutResponse struct {
	J8a      string
	ServerID string
	Version  string
}

type Atmpt struct {
	URL        *URL
	Label      string
	Count      int
	StatusCode int

	CompleteHeader chan struct{}
	CompleteBody   chan struct{}
	Aborted        <-chan struct{}
	AbortedFlag    bool
	CancelFunc     func()
	// contains filtered or unexported fields
}

type Config struct {
	Policies   map[string]Policy
	Routes     Routes
	Resources  map[string][]ResourceMapping
	Connection Connection
}

type Connection struct {
	Downstream Downstream
	Upstream   Upstream
}

type Down struct {
	Req         *http.Request
	Resp        Resp
	Method      string
	Path        string
	URI         string
	UserAgent   string
	Body        []byte
	Aborted     <-chan struct{}
	AbortedFlag bool

	HttpVer string
	TlsVer  string
	// contains filtered or unexported fields
}

type Downstream struct {
	// ReadTimeoutSeconds is the maximum duration for reading the entire
	// request, including the body, the downstream user agent sends to us.
	ReadTimeoutSeconds int

	// WriteTimeoutSeconds is the maximum duration round trip time in seconds any
	// single request spends in the server, this includes the time to read the request,
	// processing upstream attempts and writing the response into downstream socket.
	RoundTripTimeoutSeconds int

	// IdleTimeoutSeconds is the maximum duration, a downstream idle socket connection is kept open
	// before the server hangs up on the downstream user agent.
	IdleTimeoutSeconds int

	// Serving Mode, can be "TLS"
	Mode string

	// Serving on this port
	Port int

	// TLS x509 certificate
	Cert string

	// TLS secret key
	Key string
}

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
	Get(uri string) (*http.Response, error)
}

type LabelWeight struct {
	Label  string
	Weight float64
}

type PDuration time.Duration

type Policy []LabelWeight

type Proxy struct {
	XRequestID    string
	XRequestDebug bool
	Up            Up
	Dwn           Down
}

type ResourceMapping struct {
	Name   string
	Labels []string
	URL    URL
}

type Resp struct {
	Writer        http.ResponseWriter
	StatusCode    int
	Message       string
	SendGzip      bool
	Body          *[]byte
	ContentLength int
}

type Route struct {
	Path     string
	Regex    *regexp.Regexp
	Resource string
	Policy   string
}

type Routes []Route

type Runtime struct {
	Config
}

type StatusCodeResponse struct {
	AboutResponse
	Code    int
	Message string
}

type TLSType string

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

type URL struct {
	Scheme string
	Host   string
	Port   uint16
}

type Up struct {
	Atmpt  *Atmpt
	Atmpts []Atmpt
	Count  int
}

type Upstream struct {

	// PoolSize is the maximum size of the client socket connection pool for idle connections
	PoolSize int

	// IdleTimeoutSeconds is the total wait period in seconds before we hang up on an idle upstream connection.
	IdleTimeoutSeconds int

	// SocketTimeoutSeconds is the wait period to establish socket connection with an upstream server.
	// This setting controls roundtrip time for simple TCP connections, combined with handshake time for TLS
	// if applicable.
	SocketTimeoutSeconds int

	// ReadTimeoutSeconds is the wait period to read the entire upstream response once connection was established
	// before an individual upstream request is aborted
	ReadTimeoutSeconds int

	// MaxAttempts is the maximum allowable number of request attempts to obtain a successful response for repeatable
	// HTTP requests.
	MaxAttempts int

	// TlsInsecureSkipVerify skips the host name validation and certificate chain verification of upstream connections
	// using TLS. Use this only for testing or if you know what you are doing. Defaults to false
	TlsInsecureSkipVerify bool
}