envoy

Documentation

Index

• type EnvoyAlsServer
  • func Create(address string) (*EnvoyAlsServer, error)
  • func (s *EnvoyAlsServer) Close() error
  • func (s *EnvoyAlsServer) Dial() error
  • func (s *EnvoyAlsServer) Errors() chan error
  • func (s *EnvoyAlsServer) Packets() chan syslog.Packet
  • func (s *EnvoyAlsServer) Pools() bool
  • func (s *EnvoyAlsServer) StreamAccessLogs(stream v2.AccessLogService_StreamAccessLogsServer) error

Types

type EnvoyAlsServer

type EnvoyAlsServer struct {
	// contains filtered or unexported fields
}

Envoy ALS Server structure.

func Create

func Create(address string) (*EnvoyAlsServer, error)

Create creates an envoy input handler.

func (*EnvoyAlsServer) Close

func (s *EnvoyAlsServer) Close() error

Close closes the envoy handler

func (*EnvoyAlsServer) Dial

func (s *EnvoyAlsServer) Dial() error

Dial connects the handler

func (*EnvoyAlsServer) Errors

func (s *EnvoyAlsServer) Errors() chan error

Errors returns a channel where errors from the input channel are recieved.

func (*EnvoyAlsServer) Packets

func (s *EnvoyAlsServer) Packets() chan syslog.Packet

Packets returns a channel where packets from the input are received

func (*EnvoyAlsServer) Pools

func (s *EnvoyAlsServer) Pools() bool

Pools returns whether the input pools connections

func (*EnvoyAlsServer) StreamAccessLogs

func (s *EnvoyAlsServer) StreamAccessLogs(stream v2.AccessLogService_StreamAccessLogsServer) error

StreamAccessLogs is part of the interface called by the GRPC library from envoy