utils

Documentation

Index

• Constants
• Variables
• func CheckManifestFile(t *testing.T, container testcontainers.Container, ...)
• func ClearManagementPlaneResponses(t *testing.T, mockManagementPlaneAPIAddress string)
• func CreateContainerNetwork(ctx context.Context, tb testing.TB) *testcontainers.DockerNetwork
• func CurrentFileOverview(t *testing.T, nginxInstanceID, mockManagementPlaneAPIAddress string) *mpi.FileOverview
• func ManagementPlaneResponses(t *testing.T, numberOfExpectedResponses int, ...) []*mpi.DataPlaneResponse
• func PerformConfigApply(t *testing.T, nginxInstanceID, mockManagementPlaneAPIAddress string)
• func PerformInvalidConfigApply(t *testing.T, nginxInstanceID string)
• func SetupConnectionTest(tb testing.TB, expectNoErrorsInLogs, nginxless, auxiliaryServer bool, ...) func(tb testing.TB)
• func SetupMockManagementPlaneGrpc(ctx context.Context, tb testing.TB, ...)
• func VerifyConnection(t *testing.T, instancesLength int, mockManagementPlaneAPIAddress string) string
• func VerifyUpdateDataPlaneHealth(t *testing.T, mockManagementPlaneAPIAddress string)
• func VerifyUpdateDataPlaneStatus(t *testing.T, mockManagementPlaneAPIAddress string)
• func WriteConfigFileDataplane(t *testing.T, file1, file2, file3 string)
• func WriteConfigFileMock(t *testing.T, nginxInstanceID, file1, file2, file3 string)
• type ConnectionRequest
• type Instance
• type NginxUpdateDataPlaneHealthRequest
• type UpdateDataPlaneStatusRequest

Constants

const (
	RetryCount       = 10
	RetryWaitTime    = 5 * time.Second
	RetryMaxWaitTime = 1 * time.Minute
)

Variables

var (
	MockManagementPlaneAPIAddress          string
	AuxiliaryMockManagementPlaneAPIAddress string
)

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

Functions

func CheckManifestFile

func CheckManifestFile(t *testing.T, container testcontainers.Container,
	expectedContent map[string]*model.ManifestFile,
)

func ClearManagementPlaneResponses

func ClearManagementPlaneResponses(t *testing.T, mockManagementPlaneAPIAddress string)

func CreateContainerNetwork

func CreateContainerNetwork(ctx context.Context, tb testing.TB) *testcontainers.DockerNetwork

CreateContainerNetwork creates and configures a container network.

func CurrentFileOverview

func CurrentFileOverview(t *testing.T, nginxInstanceID, mockManagementPlaneAPIAddress string) *mpi.FileOverview

func ManagementPlaneResponses

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

func PerformConfigApply

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

func PerformInvalidConfigApply

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

func SetupConnectionTest

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

func SetupMockManagementPlaneGrpc

func SetupMockManagementPlaneGrpc(ctx context.Context, tb testing.TB, containerNetwork *testcontainers.DockerNetwork)

SetupMockManagementPlaneGrpc initializes the mock management plane gRPC container.

func VerifyConnection

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

func VerifyUpdateDataPlaneHealth

func VerifyUpdateDataPlaneHealth(t *testing.T, mockManagementPlaneAPIAddress string)

func VerifyUpdateDataPlaneStatus

func VerifyUpdateDataPlaneStatus(t *testing.T, mockManagementPlaneAPIAddress string)

func WriteConfigFileDataplane

func WriteConfigFileDataplane(t *testing.T, file1, file2, file3 string)

func WriteConfigFileMock

func WriteConfigFileMock(t *testing.T, nginxInstanceID, file1, file2, file3 string)

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"`
}