utils

package

v3.1.0 Latest Latest Go to latest Published: Jul 3, 2025 License: Apache-2.0 Imports: 20 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 ¶

Constants
Variables
func ClearManagementPlaneResponses(t *testing.T)
func ManagementPlaneResponses(t *testing.T, numberOfExpectedResponses int) []*mpi.DataPlaneResponse
func PerformConfigApply(t *testing.T, nginxInstanceID string)
func PerformInvalidConfigApply(t *testing.T, nginxInstanceID string)
func SetupConnectionTest(tb testing.TB, expectNoErrorsInLogs, nginxless bool, agentConfig string) func(tb testing.TB)
func VerifyConnection(t *testing.T, instancesLength int) string
func VerifyUpdateDataPlaneHealth(t *testing.T)
func VerifyUpdateDataPlaneStatus(t *testing.T)
type ConnectionRequest
type Instance
type NginxUpdateDataPlaneHealthRequest
type UpdateDataPlaneStatusRequest

Constants ¶

View Source

const (
	RetryCount       = 8
	RetryWaitTime    = 5 * time.Second
	RetryMaxWaitTime = 6 * time.Second
)

Variables ¶

View Source

var (
	Container                        testcontainers.Container
	MockManagementPlaneGrpcContainer testcontainers.Container
	MockManagementPlaneGrpcAddress   string
)

View Source

var MockManagementPlaneAPIAddress string

Functions ¶

func ClearManagementPlaneResponses ¶

func ClearManagementPlaneResponses(t *testing.T)

func ManagementPlaneResponses ¶

func ManagementPlaneResponses(t *testing.T, numberOfExpectedResponses int) []*mpi.DataPlaneResponse

func PerformConfigApply ¶

func PerformConfigApply(t *testing.T, nginxInstanceID string)

func PerformInvalidConfigApply ¶

func PerformInvalidConfigApply(t *testing.T, nginxInstanceID string)

func SetupConnectionTest ¶

func SetupConnectionTest(tb testing.TB, expectNoErrorsInLogs, nginxless bool, agentConfig string) func(tb testing.TB)

func VerifyConnection ¶

func VerifyConnection(t *testing.T, instancesLength int) string

func VerifyUpdateDataPlaneHealth ¶

func VerifyUpdateDataPlaneHealth(t *testing.T)

func VerifyUpdateDataPlaneStatus ¶

func VerifyUpdateDataPlaneStatus(t *testing.T)

Types ¶

type ConnectionRequest ¶

type ConnectionRequest struct {
	ConnectionRequest *mpi.CreateConnectionRequest `json:"connectionRequest"`
}

type Instance ¶

type Instance struct {
	InstanceMeta    *mpi.InstanceMeta    `json:"instance_meta"`
	InstanceRuntime *mpi.InstanceRuntime `json:"instance_runtime"`
}

type NginxUpdateDataPlaneHealthRequest ¶

type NginxUpdateDataPlaneHealthRequest struct {
	MessageMeta *mpi.MessageMeta `json:"message_meta"`
	Instances   []Instance       `json:"instances"`
}

type UpdateDataPlaneStatusRequest ¶

type UpdateDataPlaneStatusRequest struct {
	UpdateDataPlaneStatusRequest NginxUpdateDataPlaneHealthRequest `json:"updateDataPlaneStatusRequest"`
}

Source Files ¶

View all Source files

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