syslog

package
v0.1.0-alpha.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 19, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Host                string         `json:"host"`
	Port                int            `json:"port"`
	FlushLimit          int            `json:"flush_limit,omitempty"`
	DropLimit           int            `json:"drop_limit,omitempty"`
	Timeout             int            `json:"timeout,omitempty"`
	LogFormat           map[string]any `json:"log_format,omitempty"`
	LogFormatExtra      map[string]any `json:"log_format_extra,omitempty"`
	SockType            string         `json:"sock_type,omitempty"`
	PoolSize            int            `json:"pool_size,omitempty"`
	TLS                 bool           `json:"tls,omitempty"`
	SSLVerify           *bool          `json:"ssl_verify,omitempty"`
	IncludeReqBody      bool           `json:"include_req_body,omitempty"`
	IncludeReqBodyExpr  [][]any        `json:"include_req_body_expr,omitempty"`
	IncludeRespBody     bool           `json:"include_resp_body,omitempty"`
	IncludeRespBodyExpr [][]any        `json:"include_resp_body_expr,omitempty"`
	MaxReqBodyBytes     int            `json:"max_req_body_bytes,omitempty"`
	MaxRespBodyBytes    int            `json:"max_resp_body_bytes,omitempty"`

	BatchMaxSize      int `json:"batch_max_size,omitempty"`
	MaxRetryCount     int `json:"max_retry_count,omitempty"`
	RetryDelay        int `json:"retry_delay,omitempty"`
	BufferDuration    int `json:"buffer_duration,omitempty"`
	InactiveTimeout   int `json:"inactive_timeout,omitempty"`
	MaxPendingEntries int `json:"max_pending_entries,omitempty"`
	// contains filtered or unexported fields
}

func (*Config) UnmarshalJSON

func (c *Config) UnmarshalJSON(data []byte) error

type Plugin

type Plugin struct {
	base.BaseLoggerPlugin
	// contains filtered or unexported fields
}

func (*Plugin) Config

func (p *Plugin) Config() any

func (*Plugin) Handler

func (p *Plugin) Handler(next http.Handler) http.Handler

func (*Plugin) Init

func (p *Plugin) Init() error

func (*Plugin) PostInit

func (p *Plugin) PostInit() error

func (*Plugin) RunLogPhase

func (p *Plugin) RunLogPhase(snapshot base.LogSnapshot) error

func (*Plugin) Send

func (p *Plugin) Send(log map[string]any)

func (*Plugin) SendBatch

func (p *Plugin) SendBatch(ctx context.Context, entries []map[string]any, batchMaxSize int) (int, error)

func (*Plugin) Stop

func (p *Plugin) Stop()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL