tcpjson

Mar 11, 2021

Changes in this version

+ func StartAsyncWriter(output io.Writer, registry metrics.Registry) io.WriteCloser

Mar 9, 2021

Changes in this version

+ const TCPWriterHealthCheckName

Mar 3, 2021

Changes in this version

+ const ErrFailedDial

+ const ErrFailedParsingURI

+ const ErrNoURIs

+ type ConnProvider interface

+ GetConn func() (net.Conn, error)

+ func NewTCPConnProvider(uris []string, tlsCfg *tls.Config) (ConnProvider, error)

+ type LogEnvelopeMetadata struct

+ Deployment string

+ Environment string

+ EnvironmentID string

+ Host string

+ NodeID string

+ Product string

+ ProductVersion string

+ Service string

+ ServiceID string

+ Stack string

+ StackID string

+ Type string

+ func GetEnvelopeMetadata() LogEnvelopeMetadata

+ type LogEnvelopeV1 struct

+ Payload json.RawMessage

+ type TCPWriter struct

+ func NewTCPWriter(metadata LogEnvelopeMetadata, provider ConnProvider) *TCPWriter

+ func (d *TCPWriter) Close() error

+ func (d *TCPWriter) HealthStatus(ctx context.Context) health.HealthStatus

+ func (d *TCPWriter) Write(p []byte) (n int, err error)