nginx

package
v3.10.2 Latest Latest
Warning

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

 Go to latest Published: May 26, 2026 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type APIAction 

type APIAction struct {
	NginxService nginxServiceInterface
}

func (*APIAction) HandleGetHTTPUpstreamsServersRequest 

func (a *APIAction) HandleGetHTTPUpstreamsServersRequest(
	ctx context.Context,
	action *mpi.NGINXPlusAction,
	instance *mpi.Instance,
) *mpi.DataPlaneResponse

func (*APIAction) HandleGetStreamUpstreamsRequest 

func (a *APIAction) HandleGetStreamUpstreamsRequest(ctx context.Context,
	instance *mpi.Instance,
) *mpi.DataPlaneResponse

func (*APIAction) HandleGetUpstreamsRequest 

func (a *APIAction) HandleGetUpstreamsRequest(ctx context.Context, instance *mpi.Instance) *mpi.DataPlaneResponse

func (*APIAction) HandleUpdateHTTPUpstreamsRequest 

func (a *APIAction) HandleUpdateHTTPUpstreamsRequest(
	ctx context.Context,
	action *mpi.NGINXPlusAction,
	instance *mpi.Instance,
) *mpi.DataPlaneResponse

func (*APIAction) HandleUpdateStreamServersRequest 

func (a *APIAction) HandleUpdateStreamServersRequest(
	ctx context.Context,
	action *mpi.NGINXPlusAction,
	instance *mpi.Instance,
) *mpi.DataPlaneResponse

type NginxInstanceOperator 

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

func NewInstanceOperator 

func NewInstanceOperator(agentConfig *config.Config) *NginxInstanceOperator

func (*NginxInstanceOperator) Reload 

func (i *NginxInstanceOperator) Reload(ctx context.Context, instance *mpi.Instance) error

func (*NginxInstanceOperator) Validate 

func (i *NginxInstanceOperator) Validate(ctx context.Context, instance *mpi.Instance) error

type NginxInstanceProcessOperator 

type NginxInstanceProcessOperator struct{}

func NewNginxInstanceProcessOperator 

func NewNginxInstanceProcessOperator() *NginxInstanceProcessOperator

func (*NginxInstanceProcessOperator) FindNginxProcesses 

func (p *NginxInstanceProcessOperator) FindNginxProcesses(ctx context.Context) ([]*nginxprocess.Process, error)

func (*NginxInstanceProcessOperator) FindParentProcessID 

func (p *NginxInstanceProcessOperator) FindParentProcessID(ctx context.Context, instanceID string,
	nginxProcesses []*nginxprocess.Process, executer exec.ExecInterface,
) (int32, error)

func (*NginxInstanceProcessOperator) NginxWorkerProcesses 

func (p *NginxInstanceProcessOperator) NginxWorkerProcesses(ctx context.Context,
	masterProcessPid int32,
) []*nginxprocess.Process

type NginxLogTailerOperator 

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

func NewLogTailerOperator 

func NewLogTailerOperator(agentConfig *config.Config) *NginxLogTailerOperator

func (*NginxLogTailerOperator) Tail 

func (l *NginxLogTailerOperator) Tail(ctx context.Context, errorLog string, errorChannel chan error)

type NginxPlugin 

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

func NewNginx 

func NewNginx(agentConfig *config.Config, grpcConnection grpc.GrpcConnectionInterface,
	serverType model.ServerType, manifestLock *sync.RWMutex,
) *NginxPlugin

func (*NginxPlugin) Close 

func (n *NginxPlugin) Close(ctx context.Context) error

func (*NginxPlugin) Info 

func (n *NginxPlugin) Info() *bus.Info

func (*NginxPlugin) Init 

func (n *NginxPlugin) Init(ctx context.Context, messagePipe bus.MessagePipeInterface) error

func (*NginxPlugin) Process 

func (n *NginxPlugin) Process(ctx context.Context, msg *bus.Message)

func (*NginxPlugin) Reconfigure 

func (n *NginxPlugin) Reconfigure(ctx context.Context, agentConfig *config.Config) error

func (*NginxPlugin) Subscriptions 

func (n *NginxPlugin) Subscriptions() []string

type NginxService 

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

func NewNginxService 

func NewNginxService(ctx context.Context, agentConfig *config.Config) *NginxService

func (*NginxService) ApplyConfig 

func (n *NginxService) ApplyConfig(ctx context.Context, instanceID string) (*model.NginxConfigContext, error)

func (*NginxService) GetHTTPUpstreamServers 

func (n *NginxService) GetHTTPUpstreamServers(ctx context.Context, instance *mpi.Instance,
	upstream string,
) ([]client.UpstreamServer, error)

func (*NginxService) GetStreamUpstreams 

func (n *NginxService) GetStreamUpstreams(ctx context.Context, instance *mpi.Instance,
) (*client.StreamUpstreams, error)

func (*NginxService) GetUpstreams 

func (n *NginxService) GetUpstreams(ctx context.Context, instance *mpi.Instance,
) (*client.Upstreams, error)

func (*NginxService) Instance 

func (n *NginxService) Instance(instanceID string) *mpi.Instance

func (*NginxService) UpdateHTTPUpstreamServers 

func (n *NginxService) UpdateHTTPUpstreamServers(ctx context.Context, instance *mpi.Instance, upstream string,
	upstreams []*structpb.Struct,
) (added, updated, deleted []client.UpstreamServer, err error)

max number of returns from function is 3

func (*NginxService) UpdateResource 

func (n *NginxService) UpdateResource(ctx context.Context, resource *mpi.Resource) *mpi.Resource

func (*NginxService) UpdateStreamServers 

func (n *NginxService) UpdateStreamServers(ctx context.Context, instance *mpi.Instance, upstream string,
	upstreams []*structpb.Struct,
) (added, updated, deleted []client.StreamUpstreamServer, err error)

max number of returns from function is 3

Source Files

View all Source files

Directories

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.