input

Documentation

Index

• type HttpInput
  • func NewHttpInput(options HttpInputOptions, processors *common.Processors) *HttpInput
  • func (h *HttpInput) SetupCors(w http.ResponseWriter, r *http.Request)
  • func (h *HttpInput) Start(wg *sync.WaitGroup)
• type HttpInputOptions
• type HttpOidc
  • func NewHttpOidc(options *HttpInputOptions) *HttpOidc
• type RequestsRate
• type ResponseLogger
  • func (r *ResponseLogger) Write(b []byte) (int, error)

Types

type HttpInput

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

func NewHttpInput

func NewHttpInput(options HttpInputOptions, processors *common.Processors) *HttpInput

func (*HttpInput) SetupCors

func (h *HttpInput) SetupCors(w http.ResponseWriter, r *http.Request)

func (*HttpInput) Start

func (h *HttpInput) Start(wg *sync.WaitGroup)

type HttpInputOptions

type HttpInputOptions struct {
	URL              string
	Listen           string
	Cors             bool
	Tls              bool
	Cert             string
	Key              string
	Chain            string
	ExternalHost     string
	OidcEnabled      bool
	OidcClientId     string
	OidcClientSecret string
	OidcConfigURL    string
	OidcLoginURL     string
	OidcLogoutURL    string
	OidcCallbackURL  string
	OidcDefaultURL   string
	OidcScopes       string
	RateSuffixURL    string
}

type HttpOidc

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

func NewHttpOidc

func NewHttpOidc(options *HttpInputOptions) *HttpOidc

type RequestsRate

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

type ResponseLogger

type ResponseLogger struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

func (*ResponseLogger) Write

func (r *ResponseLogger) Write(b []byte) (int, error)