stock

Documentation

Index

• func CertificateAuthorityNode(config *Tls) node.Node
• func CertificateNode(config *Tls) node.Node
• func TlsNode(config *Tls) node.Node
• func WebServerNode(service *HttpServer) node.Node
• type HttpServer
  • func NewHttpServer(handler http.Handler) *HttpServer
  • func (service *HttpServer) ApplyOptions(options HttpServerOptions)
  • func (service *HttpServer) GetHttpClient() *http.Client
  • func (service *HttpServer) Options() HttpServerOptions
  • func (service *HttpServer) Stop()
• type HttpServerOptions
• type StreamSourceWebHandler
  • func (service StreamSourceWebHandler) ServeHTTP(wtr http.ResponseWriter, req *http.Request)
• type Tls
• type WebMetrics

Functions

func CertificateAuthorityNode

func CertificateAuthorityNode(config *Tls) node.Node

func CertificateNode

func CertificateNode(config *Tls) node.Node

func TlsNode

func TlsNode(config *Tls) node.Node

func WebServerNode

func WebServerNode(service *HttpServer) node.Node

Types

type HttpServer

type HttpServer struct {
	Server *http.Server

	Metrics WebMetrics
	// contains filtered or unexported fields
}

func NewHttpServer

func NewHttpServer(handler http.Handler) *HttpServer

func (*HttpServer) ApplyOptions

func (service *HttpServer) ApplyOptions(options HttpServerOptions)

func (*HttpServer) GetHttpClient

func (service *HttpServer) GetHttpClient() *http.Client

func (*HttpServer) Options

func (service *HttpServer) Options() HttpServerOptions

func (*HttpServer) Stop

func (service *HttpServer) Stop()

type HttpServerOptions

type HttpServerOptions struct {
	Addr                     string
	Port                     string
	ReadTimeout              int
	WriteTimeout             int
	Tls                      *Tls
	Iface                    string
	CallbackAddress          string
	NotifyKeepaliveTimeoutMs int
}

type StreamSourceWebHandler

type StreamSourceWebHandler struct {
	Source source.Opener
}

func (StreamSourceWebHandler) ServeHTTP

func (service StreamSourceWebHandler) ServeHTTP(wtr http.ResponseWriter, req *http.Request)

type Tls

type Tls struct {
	Config     tls.Config
	CertFile   string
	KeyFile    string
	CaCertFile string
}

type WebMetrics

type WebMetrics struct {
	New      int64
	Active   int64
	Idle     int64
	Hijacked int64
	Closed   int64
}