server

Documentation

Index

• func ConfigTLS(caCrt, srvCrt, srvKey string) (*tls.Config, error)
• type Server
  • func New(handler message.HandlerFunc) (*Server, error)
  • func NewTLS(handler message.HandlerFunc, cfg *tls.Config) (*Server, error)
  • func (s *Server) ListenAndServe(address string) error

Functions

func ConfigTLS

func ConfigTLS(caCrt, srvCrt, srvKey string) (*tls.Config, error)

Types

type Server

type Server struct {
	SharedKey string
	Hostname  string
	Logger    *log.Logger
	Users     func(string) []byte
	Debug     bool
	// contains filtered or unexported fields
}

Server listening fluentd protocol

func New

func New(handler message.HandlerFunc) (*Server, error)

New server, with an handler

func NewTLS

func NewTLS(handler message.HandlerFunc, cfg *tls.Config) (*Server, error)

New TLS server, with an handler

func (*Server) ListenAndServe

func (s *Server) ListenAndServe(address string) error

ListenAndServe an address