reflowlet

Documentation

Index

• func IgnoreSigpipe()
• type Server
  • func (s *Server) AddFlags(flags *flag.FlagSet)
  • func (s *Server) ListenAndServe() error

Functions

func IgnoreSigpipe

func IgnoreSigpipe()

IgnoreSigpipe consumes (and ignores) SIGPIPE signals. As of Go 1.6, these are generated only for stdout and stderr.

This is useful where a reflowlet's standard output is closed while running, as can happen when journald restarts on systemd managed systems.

See the following for more information:

https://bugzilla.redhat.com/show_bug.cgi?id=1300076

Types

type Server

type Server struct {
	// The server's config.
	// TODO(marius): move most of what is now flags here into the config.
	Config config.Config

	// Addr is the address on which to listen.
	Addr string
	// Prefix is the prefix used for directory lookup; permits reflowlet
	// to run inside of Docker.
	Prefix string
	// Insecure listens on HTTP, not HTTPS.
	Insecure bool
	// Dir is the runtime data directory.
	Dir string
	// NDigest is the number of allowable concurrent digest operations.
	NDigest int
	// EC2Cluster tells whether this reflowlet is part of an EC2cluster.
	// When true, the reflowlet shuts down if it is idle after 10 minutes.
	EC2Cluster bool
	// HTTPDebug determines whether HTTP debug logging is turned on.
	HTTPDebug bool
	// contains filtered or unexported fields
}

A Server is a reflow server, exposing a local pool over an HTTP server.

func (*Server) AddFlags

func (s *Server) AddFlags(flags *flag.FlagSet)

AddFlags adds flags configuring various Reflowlet parameters to the provided FlagSet.

func (*Server) ListenAndServe

func (s *Server) ListenAndServe() error

ListenAndServe serves the Reflowlet server on the configured address.