Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

fixtures

package

Go to main page

Versions in this module

v0

v0.0.8

Nov 30, 2023

v0.0.7

Nov 28, 2023

v0.0.6

Nov 28, 2023

retracted

v0.0.5

Nov 27, 2023

Changes in this version

+ func WaitForPodToBeReady(ctx context.Context, kubeClient kubernetes.Interface, timeout time.Duration, ...) error

type When

+ func (w *When) WaitForPodReady(podName string) *When

v0.0.4

Nov 1, 2023

v0.0.3

Oct 31, 2023

v0.0.2

Oct 31, 2023

Changes in this version

+ func WaitForStatefulSetReady(ctx context.Context, kubeClient kubernetes.Interface, timeout time.Duration, ...) error

type When

+ func (w *When) WaitForStatefulSetReady(labelSelector string) *When

v0.0.1

Oct 30, 2023

Changes in this version

+ const ISBSvcName

+ const Label

+ const LabelValue

+ const LogDaemonStarted

+ const LogReduceUDFVertexStarted

+ const LogSourceVertexStarted

+ const LogUDFVertexStarted

+ const Namespace

+ const SinkVertexStarted

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

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

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

+ func CreateKafkaTopic() string

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

+ 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 GetMsgCountContains(pipelineName, sinkName, targetStr string) 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 PodsLogNotContains(ctx context.Context, kubeClient kubernetes.Interface, namespace, regex string, ...) bool

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

+ 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 SendMessage(topic string, key string, message string)

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

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

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

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

+ func WaitForDaemonPodsRunning(kubeClient kubernetes.Interface, namespace, pipelineName string, ...) 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, vertexClient flowpkg.VertexInterface, ...) error

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

+ type CheckFunc func() bool

+ type E2ESuite struct

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

+ func (s *E2ESuite) GetNumaflowServerPodName() string

+ 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) DaemonPodLogContains(pipelineName, regex string, opts ...PodLogCheckOption) *Expect

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

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

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

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

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

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

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

+ func (t *Expect) VertexSizeScaledTo(v string, size int) *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 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 PodLogCheckOption func(*podLogCheckOptions)

+ func PodLogCheckOptionWithContainer(c string) PodLogCheckOption

+ func PodLogCheckOptionWithCount(c int) PodLogCheckOption

+ func PodLogCheckOptionWithTimeout(t time.Duration) PodLogCheckOption

+ type SinkCheckOption func(*redisCheckOptions)

+ func WithContainCount(c int) SinkCheckOption

+ func WithTimeout(t time.Duration) SinkCheckOption

+ type When struct

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

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

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

+ func (w *When) DaemonPodPortForward(pipelineName string, localPort, remotePort int) *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) SendMessageTo(pipelineName string, vertexName string, req HttpPostRequest) *When

+ 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