nginx

package

v3.3.2 Latest Latest Go to latest Published: Sep 24, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/nginx/agent

Links

Open Source Insights

Documentation ¶

Index ¶

func ConfPathFromCommand(command string) string
func Exe(ctx context.Context, executer exec.ExecInterface) string
func ParseNginxVersionCommandOutput(ctx context.Context, output *bytes.Buffer) *model.ProcessInfo
func ProcessInfo(ctx context.Context, proc *nginxprocess.Process, executer exec.ExecInterface) (*model.ProcessInfo, error)
type LTSVTailer
- func NewLTSVTailer(file string) (*LTSVTailer, error)
- func (t *LTSVTailer) Tail(ctx context.Context, data chan<- map[string]string)
type NginxAccessItem
- func NewNginxAccessItem(v map[string]string) (*NginxAccessItem, error)
type PatternTailer
- func NewPatternTailer(file string, patterns map[string]string) (*PatternTailer, error)
- func (t *PatternTailer) Tail(ctx context.Context, data chan<- map[string]string)
type Tailer
- func NewTailer(file string) (*Tailer, error)
- func (t *Tailer) Tail(ctx context.Context, data chan<- string)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ConfPathFromCommand ¶ added in v3.2.1

func ConfPathFromCommand(command string) string

func Exe ¶ added in v3.2.1

func Exe(ctx context.Context, executer exec.ExecInterface) string

func ParseNginxVersionCommandOutput ¶ added in v3.2.1

func ParseNginxVersionCommandOutput(ctx context.Context, output *bytes.Buffer) *model.ProcessInfo

func ProcessInfo ¶ added in v3.2.1

func ProcessInfo(ctx context.Context, proc *nginxprocess.Process,
	executer exec.ExecInterface,
) (*model.ProcessInfo, error)

Types ¶

type LTSVTailer ¶

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

LTSV (Labeled Tab-separated Values) Tailer

func NewLTSVTailer ¶

func NewLTSVTailer(file string) (*LTSVTailer, error)

func (*LTSVTailer) Tail ¶

func (t *LTSVTailer) Tail(ctx context.Context, data chan<- map[string]string)

type NginxAccessItem ¶

type NginxAccessItem struct {
	BodyBytesSent          string `mapstructure:"body_bytes_sent"`
	Status                 string `mapstructure:"status"`
	RemoteAddress          string `mapstructure:"remote_addr"`
	HTTPUserAgent          string `mapstructure:"http_user_agent"`
	Request                string `mapstructure:"request"`
	BytesSent              string `mapstructure:"bytes_sent"`
	RequestLength          string `mapstructure:"request_length"`
	RequestTime            string `mapstructure:"request_time"`
	GzipRatio              string `mapstructure:"gzip_ratio"`
	ServerProtocol         string `mapstructure:"server_protocol"`
	UpstreamConnectTime    string `mapstructure:"upstream_connect_time"`
	UpstreamHeaderTime     string `mapstructure:"upstream_header_time"`
	UpstreamResponseTime   string `mapstructure:"upstream_response_time"`
	UpstreamResponseLength string `mapstructure:"upstream_response_length"`
	UpstreamStatus         string `mapstructure:"upstream_status"`
	UpstreamCacheStatus    string `mapstructure:"upstream_cache_status"`
}

NginxAccessItem represents the decoded access log data

func NewNginxAccessItem ¶

func NewNginxAccessItem(v map[string]string) (*NginxAccessItem, error)

type PatternTailer ¶

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

func NewPatternTailer ¶

func NewPatternTailer(file string, patterns map[string]string) (*PatternTailer, error)

func (*PatternTailer) Tail ¶

func (t *PatternTailer) Tail(ctx context.Context, data chan<- map[string]string)

type Tailer ¶

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

func NewTailer ¶

func NewTailer(file string) (*Tailer, error)

func (*Tailer) Tail ¶

func (t *Tailer) Tail(ctx context.Context, data chan<- string)

Source Files ¶

View all Source files

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