egress

type DialFunc ¶

type DialFunc func(addr string) (net.Conn, error)

DialFunc represents a method for creating a connection, either TCP or TLS.

type HTTPSWriter ¶

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

func (*HTTPSWriter) Close() error

func (w *HTTPSWriter) Write(env *loggregator_v2.Envelope) error

type LogClient ¶

type LogClient interface {
	EmitLog(message string, opts ...loggregator.EmitLogOption)
}

type NetworkConfig ¶

type NetworkConfig struct {
	Keepalive      time.Duration
	DialTimeout    time.Duration
	WriteTimeout   time.Duration
	SkipCertVerify bool
}

NetworkTimeoutConfig stores various timeout values.

type RetryDuration ¶

type RetryDuration func(attempt int) time.Duration

RetryDuration calculates a duration based on the number of write attempts.

type RetryWriter ¶

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

RetryWriter wraps a WriteCloser and will retry writes if the first fails.

func (r *RetryWriter) Close() error

func (r *RetryWriter) Write(e *loggregator_v2.Envelope) error

type TCPWriter ¶

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

TCPWriter represents a syslog writer that connects over unencrypted TCP. This writer is not meant to be used from multiple goroutines. The same goroutine that calls `.Write()` should be the one that calls `.Close()`.

func (w *TCPWriter) Close() error

func (w *TCPWriter) Write(env *loggregator_v2.Envelope) error

type TLSWriter ¶

type TLSWriter struct {
	TCPWriter
}

TLSWriter represents a syslog writer that connects over unencrypted TCP.

type URLBinding ¶

type URLBinding struct {
	Context  context.Context
	Hostname string
	URL      *url.URL
}

application is identified by AppID and Hostname. The syslog URL is identified by URL.

func (u *URLBinding) Scheme() string

type WriteCloser ¶

type WriteCloser interface {
	Writer
	io.Closer
}

WriteCloser is the interface for all syslog writers.

func NewHTTPSWriter(
	binding *URLBinding,
	netConf NetworkConfig,
) WriteCloser

func NewTCPWriter(
	binding *URLBinding,
	netConf NetworkConfig,
) WriteCloser

func NewTLSWriter(
	binding *URLBinding,
	netConf NetworkConfig,
) WriteCloser

func NewWriter(sourceHost string, url *url.URL, netConf NetworkConfig, log *log.Logger) WriteCloser

type Writer ¶

type Writer interface {
	Write(*loggregator_v2.Envelope) error
}

Write is the interface for all diode writers.

type WriterConstructor ¶

type WriterConstructor func(
	binding *URLBinding,
	netConf NetworkConfig,
) WriteCloser

func RetryWrapper(
	wc WriterConstructor,
	r RetryDuration,
	maxRetries int,
	logClient LogClient,
	sourceIndex string,
) WriterConstructor