server

Documentation

Index

• func ConfigTLS(caCrt, srvCrt, srvKey string) (*tls.Config, error)
• type Server
  • func New(config *options.FluentOptions) (*Server, error)
  • func NewTLS(config *options.FluentOptions, 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 {
	// contains filtered or unexported fields
}

Server listening fluentd protocol

func New

func New(config *options.FluentOptions) (*Server, error)

New server, with an handler

func NewTLS

func NewTLS(config *options.FluentOptions, cfg *tls.Config) (*Server, error)

New TLS server, with an handler

func (*Server) ListenAndServe

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

ListenAndServe an address