fixtures

Sep 3, 2024

Changes in this version

type When

+ func (w *When) StreamControllerLogs() *When

+ func (w *When) StreamISBLogs() *When

+ func (w *When) StreamVertexPodLogs(vertexName, containerName string) *When

Aug 19, 2024

Changes in this version

+ func GenerateKafkaTopicName() string

+ func ListKafkaTopics()

+ func MonoVertexPodLogContains(ctx context.Context, kubeClient kubernetes.Interface, ...) (bool, error)

+ func PumpJetstream(streamName string, payload string, count int)

+ func WaitForMonoVertexPodRunning(kubeClient kubernetes.Interface, monoVertexClient flowpkg.MonoVertexInterface, ...) error

+ func WaitForMonoVertexRunning(ctx context.Context, monoVertexClient flowpkg.MonoVertexInterface, ...) error

type Expect

+ func (t *Expect) MonoVertexPodLogContains(regex string, opts ...PodLogCheckOption) *Expect

+ func (t *Expect) MonoVertexPodsRunning() *Expect

+ func (t *Expect) RedisSinkContains(hashKey string, targetStr string, opts ...SinkCheckOption) *Expect

+ func (t *Expect) RedisSinkNotContains(hashKey string, targetStr string, opts ...SinkCheckOption) *Expect

type Given

+ func (g *Given) MonoVertex(text string) *Given

+ func (g *Given) WithMonoVertex(mv *dfv1.MonoVertex) *Given

type When

+ func (w *When) CreateMonoVertexAndWait() *When

+ func (w *When) DeleteMonoVertexAndWait() *When

May 3, 2024

Changes in this version

type SinkCheckOption

+ func SinkCheckWithContainCount(c int) SinkCheckOption

+ func SinkCheckWithTimeout(t time.Duration) SinkCheckOption

type When

+ func (w *When) StreamVertexPodlogs(vertexName, containerName string) *When

+ func (w *When) TerminateAllPodLogs() *When

Dec 18, 2023

Changes in this version

type When

+ func (w *When) UXServerPodPortForward(localPort, remotePort int) *When

Oct 13, 2023

Changes in this version

type E2ESuite

+ func (s *E2ESuite) GetNumaflowServerPodName() string

Apr 3, 2023

Changes in this version

+ var CheckVertexScaled = func(t *testing.T, output string, err error)

+ func PumpRedisStream(stream string, n int, opts ...interface{})

+ func WaitForVertexPodScalingTo(kubeClient kubernetes.Interface, vertexClient flowpkg.VertexInterface, ...) error

type Expect

+ func (t *Expect) VertexSizeScaledTo(v string, size int) *Expect

Jan 13, 2023

Changes in this version

+ const SinkVertexStarted

+ func GetMsgCountContains(pipelineName, sinkName, targetStr string) int

+ func PumpNatsSubject(subject string, n int, opts ...interface{})

+ func RedisContains(ctx context.Context, pipelineName, sinkName, targetStr string, ...) bool

+ func RedisNotContains(ctx context.Context, pipelineName, sinkName, targetStr string, ...) bool

+ func SendMessageTo(podIp string, vertexName string, r HttpPostRequest)

+ type CheckFunc func() bool

type Expect

+ func (t *Expect) SinkContains(sinkName string, targetStr string, opts ...SinkCheckOption) *Expect

+ func (t *Expect) SinkNotContains(sinkName string, targetStr string) *Expect

+ type HttpPostRequest struct

+ Body []byte

+ Header map[string]string

+ func NewHttpPostRequest() HttpPostRequest

+ func (b HttpPostRequest) WithBody(body []byte) HttpPostRequest

+ func (b HttpPostRequest) WithHeader(k, v string) HttpPostRequest

+ type SinkCheckOption func(*redisCheckOptions)

+ func WithContainCount(c int) SinkCheckOption

+ func WithTimeout(t time.Duration) SinkCheckOption

type When

+ func (w *When) SendMessageTo(pipelineName string, vertexName string, req HttpPostRequest) *When

Dec 7, 2022

Changes in this version

+ const LogReduceUDFVertexStarted

+ var CheckPodKillSucceeded = func(t *testing.T, output string, err error)

Aug 6, 2022

Changes in this version

+ const LogDaemonStarted

+ func DaemonPodLogContains(ctx context.Context, kubeClient kubernetes.Interface, ...) (bool, error)

+ func WaitForDaemonPodsRunning(kubeClient kubernetes.Interface, namespace, pipelineName string, ...) error

type Expect

+ func (t *Expect) DaemonPodLogContains(pipelineName, regex string, opts ...PodLogCheckOption) *Expect

+ func (t *Expect) DaemonPodsRunning() *Expect

type When

+ func (w *When) DaemonPodPortForward(pipelineName string, localPort, remotePort int) *When

Jul 8, 2022

Changes in this version

+ const LogSinkVertexStarted

+ const LogSourceVertexStarted

+ const LogUDFVertexStarted

+ var OutputRegexp = func(rx string) func(t *testing.T, output string, err error)

+ func PodsLogNotContains(ctx context.Context, kubeClient kubernetes.Interface, namespace, regex string, ...) bool

+ func VertexPodLogNotContains(ctx context.Context, kubeClient kubernetes.Interface, ...) (bool, error)

type Expect

+ func (t *Expect) VertexPodLogNotContains(vertexName, regex string, opts ...PodLogCheckOption) *Expect

+ type PodLogCheckOption func(*podLogCheckOptions)

+ func PodLogCheckOptionWithContainer(c string) PodLogCheckOption

+ func PodLogCheckOptionWithCount(c int) PodLogCheckOption

+ func PodLogCheckOptionWithTimeout(t time.Duration) PodLogCheckOption

Jun 1, 2022

Changes in this version

+ const ISBSvcName

+ const Label

+ const LabelValue

+ const Namespace

+ func CreateKafkaTopic() string

+ func DeleteKafkaTopic(topic string) string

+ func Exec(name string, args ...string) (string, error)

+ func ExpectKafkaTopicCount(topic string, total int, timeout time.Duration)

+ func GetKafkaCount(topic string, count int) int

+ func HTTPExpect(t require.TestingT, baseURL string) *httpexpect.Expect

+ func InvokeE2EAPI(format string, args ...interface{}) string

+ func InvokeE2EAPIPOST(format string, body string, args ...interface{}) string

+ func PodPortForward(config *rest.Config, namespace, podName string, localPort, remotePort int, ...) error

+ func PodsLogContains(ctx context.Context, kubeClient kubernetes.Interface, namespace, regex string, ...) bool

+ func PumpKafkaTopic(topic string, n int, opts ...interface{})

+ func SendMessage(topic string, key string, message string)

+ func ValidateMessage(topic string, key string, position int)

+ func VertexPodLogContains(ctx context.Context, kubeClient kubernetes.Interface, ...) (bool, error)

+ func WaitForISBSvcReady(ctx context.Context, isbSvcClient flowpkg.InterStepBufferServiceInterface, ...) error

+ func WaitForISBSvcStatefulSetReady(ctx context.Context, kubeClient kubernetes.Interface, ...) error

+ func WaitForPipelineRunning(ctx context.Context, pipelineClient flowpkg.PipelineInterface, ...) error

+ func WaitForVertexPodRunning(kubeClient kubernetes.Interface, namespace, pipelineName, vertexName string, ...) error

+ type E2ESuite struct

+ func (s *E2ESuite) CheckError(err error)

+ func (s *E2ESuite) Given() *Given

+ func (s *E2ESuite) SetupSuite()

+ func (s *E2ESuite) StartPortForward(podName string, port int) (stopPortForward func())

+ func (s *E2ESuite) TearDownSuite()

+ type Expect struct

+ func (t *Expect) ISBSvcDeleted(timeout time.Duration) *Expect

+ func (t *Expect) VertexPodLogContains(vertexName, containerName, regex string) *Expect

+ func (t *Expect) VertexPodsRunning() *Expect

+ func (t *Expect) When() *When

+ type Given struct

+ func (g *Given) ISBSvc(text string) *Given

+ func (g *Given) Pipeline(text string) *Given

+ func (g *Given) When() *When

+ func (g *Given) WithPipeline(p *dfv1.Pipeline) *Given

+ type When struct

+ func (w *When) And(block func()) *When

+ func (w *When) CreateISBSvc() *When

+ func (w *When) CreatePipelineAndWait() *When

+ func (w *When) DeleteISBSvc() *When

+ func (w *When) DeletePipelineAndWait() *When

+ func (w *When) Exec(name string, args []string, block func(t *testing.T, output string, err error)) *When

+ func (w *When) Expect() *Expect

+ func (w *When) Given() *Given

+ func (w *When) TerminateAllPodPortForwards() *When

+ func (w *When) VertexPodPortForward(vertexName string, localPort, remotePort int) *When

+ func (w *When) Wait(timeout time.Duration) *When

+ func (w *When) WaitForISBSvcReady() *When