resource

package
v3.0.0-...-6fc1f16 Latest Latest
Warning

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

 Go to latest Published: Feb 25, 2025 License: Apache-2.0 Imports: 23 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 {
	ResourceService resourceServiceInterface
}

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 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 Resource 

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

func NewResource 

func NewResource(agentConfig *config.Config) *Resource

func (*Resource) Close 

func (*Resource) Close(ctx context.Context) error

func (*Resource) Info 

func (*Resource) Info() *bus.Info

func (*Resource) Init 

func (r *Resource) Init(ctx context.Context, messagePipe bus.MessagePipeInterface) error

func (*Resource) Process 

func (r *Resource) Process(ctx context.Context, msg *bus.Message)

cyclomatic complexity 11 max is 10 nolint: revive, cyclop

func (*Resource) Subscriptions 

func (*Resource) Subscriptions() []string

type ResourceService 

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

func NewResourceService 

func NewResourceService(ctx context.Context, agentConfig *config.Config) *ResourceService

func (*ResourceService) AddInstances 

func (r *ResourceService) AddInstances(instanceList []*mpi.Instance) *mpi.Resource

func (*ResourceService) AddOperator 

func (r *ResourceService) AddOperator(instanceList []*mpi.Instance)

func (*ResourceService) ApplyConfig 

func (r *ResourceService) ApplyConfig(ctx context.Context, instanceID string) error

func (*ResourceService) DeleteInstances 

func (r *ResourceService) DeleteInstances(ctx context.Context, instanceList []*mpi.Instance) *mpi.Resource

func (*ResourceService) GetHTTPUpstreamServers 

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

func (*ResourceService) GetStreamUpstreams 

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

func (*ResourceService) GetUpstreams 

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

func (*ResourceService) Instance 

func (r *ResourceService) Instance(instanceID string) *mpi.Instance

func (*ResourceService) RemoveOperator 

func (r *ResourceService) RemoveOperator(instanceList []*mpi.Instance)

func (*ResourceService) UpdateHTTPUpstreamServers 

func (r *ResourceService) 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 nolint: revive

func (*ResourceService) UpdateInstances 

func (r *ResourceService) UpdateInstances(ctx context.Context, instanceList []*mpi.Instance) *mpi.Resource

func (*ResourceService) UpdateStreamServers 

func (r *ResourceService) 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 nolint: revive

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.
JackTT - Gopher 🇻🇳