Function FuzzExchange

contrib/fuzz/exchange_fuzz_test.go:30–57

(f *testing.F)

)

func FuzzExchange(f *testing.F) {
	f.Fuzz(func(t *testing.T, data []byte) {
		f := fuzz.NewConsumer(data)
		namespace, err := f.GetString()
		if err != nil {
			return
		}
		event := &eventstypes.ContainerCreate{}
		err = f.GenerateStruct(event)
		if err != nil {
			return
		}
		input, err := f.GetString()
		if err != nil {
			return
		}

		env := &events.Envelope{}
		err = f.GenerateStruct(env)
		if err != nil {
			return
		}
		ctx := namespaces.WithNamespace(context.Background(), namespace)
		exch := exchange.NewExchange()
		exch.Publish(ctx, input, event)
		exch.Forward(ctx, env)
	})
}