Function SendReq

pkg/ingest/testkafka/client.go:65–67

(ctx context.Context, t testing.TB, client *kgo.Client, encode encodingFn, tenantID string)

}

func SendReq(ctx context.Context, t testing.TB, client *kgo.Client, encode encodingFn, tenantID string) []*kgo.Record {
	return SendReqWithOpts(ctx, t, client, encode, ReqOpts{Partition: 0, Time: time.Now(), TenantID: tenantID})
}

// nolint: revive,unparam
func SendTracesFor(t *testing.T, ctx context.Context, client *kgo.Client, dur, interval time.Duration, encode encodingFn) []*kgo.Record {