Documentation
¶
Overview ¶
Package http implements the HTTP service for Flow.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Data ¶
type Data struct {
// Address that the HTTP service is configured to listen on.
HTTPListenAddr string
// Address that the HTTP service is configured to listen on for in-memory
// traffic when [DialFunc] is used to establish a connection.
MemoryListenAddr string
// DialFunc is a function which establishes in-memory network connection when
// address is MemoryListenAddr. If address is not MemoryListenAddr, DialFunc
// establishes an outbound network connection.
DialFunc func(ctx context.Context, network, address string) (net.Conn, error)
}
Data includes information associated with the HTTP service.
type Options ¶
type Options struct {
Logger log.Logger // Where to send logs.
Tracer trace.TracerProvider // Where to send traces.
Gatherer prometheus.Gatherer // Where to collect metrics from.
Clusterer *cluster.Clusterer
ReadyFunc func() bool
ReloadFunc func() error
HTTPListenAddr string // Address to listen for HTTP traffic on.
MemoryListenAddr string // Address to accept in-memory traffic on.
UIPrefix string // Path prefix to host the UI at.
EnablePProf bool // Whether pprof endpoints should be exposed.
}
Options are used to configure the HTTP service. Options are constant for the lifetime of the HTTP service.
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func (*Service) Data ¶
Data returns an instance of Data. Calls to Data are cachable by the caller.
Data must only be called after parsing command-line flags.
func (*Service) Definition ¶
func (s *Service) Definition() service.Definition
Definition returns the definition of the HTTP service.
Click to show internal directories.
Click to hide internal directories.