Versions in this module Expand all Collapse all v0 v0.24.0 May 27, 2024 v0.23.0 May 14, 2024 v0.22.0 Jan 23, 2024 v0.21.0 Jan 10, 2024 Changes in this version + func CSVToMap(reader io.Reader) (map[string]string, error) + func GetResourceVersion(c client.Client, o client.Object, name, namespace string, ...) string + func LoadRedisDataset(ctx context.Context, srv *redis.Server, file string) error + func MinioClient(ctx context.Context, cfg *rest.Config, podKey types.NamespacedName, ...) (*s3.Client, chan struct{}, error) + func MustParseRFC3339(in string) time.Time + func NewTestPortForwarder(cfg *rest.Config, key types.NamespacedName, localPort, podPort uint32, ...) (*portforward.PortForwarder, error) + func PortForward(cfg *rest.Config, key types.NamespacedName, podPort uint32) (uint32, chan struct{}, error) + func RecordToKeyValues(headers []string, record []string) map[string]string + func RedisClient(cfg *rest.Config, podKey types.NamespacedName) (*redis.Server, chan struct{}, error) + func SentinelClient(cfg *rest.Config, podKey types.NamespacedName) (*redis.Server, chan struct{}, error) + type ExpectedResource struct + LastVersion string + Missing bool + Name string + Namespace string + func (er *ExpectedResource) Assert(c client.Client, o client.Object, timeout, poll time.Duration) func() + type ExpectedWorkload struct + ContainerImage string + ContainerName string + ContainterArgs []string + ContainterCmd []string + EnvoyConfig bool + HPA bool + LastVersion string + Name string + Namespace string + PDB bool + PodMonitor bool + Replicas int32 + func (ew *ExpectedWorkload) Assert(c client.Client, dep *appsv1.Deployment, timeout, poll time.Duration) func()