instance

Documentation

Index

• type InstanceUpdates
• type InstanceUpdatesMessage
• type InstanceWatcherService
  • func NewInstanceWatcherService(agentConfig *config.Config) *InstanceWatcherService
  • func (iw *InstanceWatcherService) HandleNginxConfigContextUpdate(ctx context.Context, instanceID string, ...)
  • func (iw *InstanceWatcherService) ReparseConfigs(ctx context.Context)
  • func (iw *InstanceWatcherService) SetEnabled(enabled bool)
  • func (iw *InstanceWatcherService) Watch(ctx context.Context, instancesChannel chan<- InstanceUpdatesMessage, ...)
• type NginxAppProtectInstanceWatcher
  • func NewNginxAppProtectInstanceWatcher(agentConfig *config.Config) *NginxAppProtectInstanceWatcher
  • func (w *NginxAppProtectInstanceWatcher) Watch(ctx context.Context, instancesChannel chan<- InstanceUpdatesMessage)
• type NginxConfigContextMessage
• type NginxProcessParser
  • func NewNginxProcessParser() *NginxProcessParser
  • func (npp *NginxProcessParser) Parse(ctx context.Context, processes []*nginxprocess.Process) map[string]*mpi.Instance

Types

type InstanceUpdates

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

type InstanceUpdatesMessage

type InstanceUpdatesMessage struct {
	CorrelationID   slog.Attr
	InstanceUpdates InstanceUpdates
}

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<- InstanceUpdatesMessage,
	nginxConfigContextChannel chan<- NginxConfigContextMessage,
)

type NginxAppProtectInstanceWatcher

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

func NewNginxAppProtectInstanceWatcher

func NewNginxAppProtectInstanceWatcher(agentConfig *config.Config) *NginxAppProtectInstanceWatcher

func (*NginxAppProtectInstanceWatcher) Watch

func (w *NginxAppProtectInstanceWatcher) Watch(ctx context.Context, instancesChannel chan<- InstanceUpdatesMessage)

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