util

package

v1.16.7 Latest Latest Go to latest Published: Feb 19, 2026 License: MIT Imports: 22 Imported by: 0

Details

This section is empty.

This section is empty.

func CopyDir(src string, dst string, fs afero.Fs) error

CopyDir copies a directory from src to dst using the provided filesystem. If no filesystem is provided, it uses the OS filesystem.

func DestroyDockerResources(ctx context.Context, enclave ...string) error

DestroyDockerResources removes all Docker resources associated with the given enclave

func NewDockerClient() (*client.Client, error)

NewDockerClient creates a new Docker client and checks if Docker is available

func SetReverseProxyConfig(ctx context.Context) error

SetReverseProxyConfig recreates the Traefik container with correct configuration for service routing

func TestRPCEndpoints(ctx context.Context, apiClient *client.Client) error

func WithRetry[T any](ctx context.Context, operation string, fn func() (T, error)) (T, error)

WithRetry executes a function with exponential backoff retry logic This is specifically designed for handling gRPC connection timeouts with Kurtosis

type RPCEndpoint struct {
	Name        string
	Port        int
	UUID        string
	EnclaveUUID string
}

type ServicePort struct {
	Name string
	Port int
}

type ServiceWithoutLabels struct {
	Name        string
	ServiceUUID string
	EnclaveUUID string
	Ports       []ServicePort
}

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

func (t *TraefikHostTransport) RoundTrip(req *http.Request) (*http.Response, error)