instance

package

v3.10.2 Latest Latest Go to latest Published: May 26, 2026 License: Apache-2.0 Imports: 25 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 ¶

type InstanceUpdates
type InstanceWatcherService
- func NewInstanceWatcherService(agentConfig *config.Config) *InstanceWatcherService
type NginxAppProtectInstanceWatcher
- func NewNginxAppProtectInstanceWatcher(agentConfig *config.Config) *NginxAppProtectInstanceWatcher
- func (w *NginxAppProtectInstanceWatcher) NginxAppProtectInstance() *mpi.Instance
- func (w *NginxAppProtectInstanceWatcher) Watch(ctx context.Context)
type NginxConfigContextMessage
type NginxProcessParser
- func NewNginxProcessParser() *NginxProcessParser
- func (npp *NginxProcessParser) Parse(ctx context.Context, processes []*nginxprocess.Process) map[string]*mpi.Instance
type ResourceUpdatesMessage

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type InstanceUpdates ¶

type InstanceUpdates struct {
	UpdatedInstances []*mpi.Instance
}

type InstanceWatcherService ¶

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

func NewInstanceWatcherService ¶

func NewInstanceWatcherService(agentConfig *config.Config) *InstanceWatcherService

func (*InstanceWatcherService) HandleNginxConfigContextUpdate ¶

func (iw *InstanceWatcherService) HandleNginxConfigContextUpdate(ctx context.Context, instanceID string,
	nginxConfigContext *model.NginxConfigContext,
)

func (*InstanceWatcherService) ReparseConfigs ¶

func (iw *InstanceWatcherService) ReparseConfigs(ctx context.Context)

func (*InstanceWatcherService) SetEnabled ¶

func (iw *InstanceWatcherService) SetEnabled(enabled bool)

func (*InstanceWatcherService) Watch ¶

func (iw *InstanceWatcherService) Watch(
	ctx context.Context,
	instancesChannel chan<- ResourceUpdatesMessage,
	nginxConfigContextChannel chan<- NginxConfigContextMessage,
)

type NginxAppProtectInstanceWatcher ¶ added in v3.1.0

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

func NewNginxAppProtectInstanceWatcher ¶ added in v3.1.0

func NewNginxAppProtectInstanceWatcher(agentConfig *config.Config) *NginxAppProtectInstanceWatcher

func (*NginxAppProtectInstanceWatcher) NginxAppProtectInstance ¶ added in v3.9.1

func (w *NginxAppProtectInstanceWatcher) NginxAppProtectInstance() *mpi.Instance

func (*NginxAppProtectInstanceWatcher) Watch ¶ added in v3.1.0

func (w *NginxAppProtectInstanceWatcher) Watch(ctx context.Context)

type NginxConfigContextMessage ¶

type NginxConfigContextMessage struct {
	CorrelationID      slog.Attr
	NginxConfigContext *model.NginxConfigContext
}

type NginxProcessParser ¶

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

func NewNginxProcessParser ¶

func NewNginxProcessParser() *NginxProcessParser

func (*NginxProcessParser) Parse ¶

func (npp *NginxProcessParser) Parse(ctx context.Context, processes []*nginxprocess.Process) map[string]*mpi.Instance

cognitive complexity of 16 because of the if statements in the for loop don't think can be avoided due to the need for continue

type ResourceUpdatesMessage ¶ added in v3.9.1

type ResourceUpdatesMessage struct {
	CorrelationID slog.Attr
	Resource      *mpi.Resource
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
instancefakes Code generated by counterfeiter.	Code generated by counterfeiter.

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