Best K6 code snippet using local.Run
dir.go
Source:dir.go
1package vfstest2import (3 "context"4 "testing"5 "time"6 "github.com/stretchr/testify/assert"7 "github.com/stretchr/testify/require"8)9// TestDirLs checks out listing10func TestDirLs(t *testing.T) {11 run.skipIfNoFUSE(t)12 run.checkDir(t, "")13 run.mkdir(t, "a directory")14 run.createFile(t, "a file", "hello")15 run.checkDir(t, "a directory/|a file 5")16 run.rmdir(t, "a directory")17 run.rm(t, "a file")18 run.checkDir(t, "")19}20// TestDirCreateAndRemoveDir tests creating and removing a directory21func TestDirCreateAndRemoveDir(t *testing.T) {22 run.skipIfNoFUSE(t)23 run.mkdir(t, "dir")24 run.mkdir(t, "dir/subdir")25 run.checkDir(t, "dir/|dir/subdir/")26 // Check we can't delete a directory with stuff in27 err := run.os.Remove(run.path("dir"))28 assert.Error(t, err, "file exists")29 // Now delete subdir then dir - should produce no errors30 run.rmdir(t, "dir/subdir")31 run.checkDir(t, "dir/")32 run.rmdir(t, "dir")33 run.checkDir(t, "")34}35// TestDirCreateAndRemoveFile tests creating and removing a file36func TestDirCreateAndRemoveFile(t *testing.T) {37 run.skipIfNoFUSE(t)38 run.mkdir(t, "dir")39 run.createFile(t, "dir/file", "potato")40 run.checkDir(t, "dir/|dir/file 6")41 // Check we can't delete a directory with stuff in42 err := run.os.Remove(run.path("dir"))43 assert.Error(t, err, "file exists")44 // Now delete file45 run.rm(t, "dir/file")46 run.checkDir(t, "dir/")47 run.rmdir(t, "dir")48 run.checkDir(t, "")49}50// TestDirRenameFile tests renaming a file51func TestDirRenameFile(t *testing.T) {52 run.skipIfNoFUSE(t)53 run.mkdir(t, "dir")54 run.createFile(t, "file", "potato")55 run.checkDir(t, "dir/|file 6")56 err := run.os.Rename(run.path("file"), run.path("file2"))57 require.NoError(t, err)58 run.checkDir(t, "dir/|file2 6")59 data := run.readFile(t, "file2")60 assert.Equal(t, "potato", data)61 err = run.os.Rename(run.path("file2"), run.path("dir/file3"))62 require.NoError(t, err)63 run.checkDir(t, "dir/|dir/file3 6")64 data = run.readFile(t, "dir/file3")65 require.NoError(t, err)66 assert.Equal(t, "potato", data)67 run.rm(t, "dir/file3")68 run.rmdir(t, "dir")69 run.checkDir(t, "")70}71// TestDirRenameEmptyDir tests renaming and empty directory72func TestDirRenameEmptyDir(t *testing.T) {73 run.skipIfNoFUSE(t)74 run.mkdir(t, "dir")75 run.mkdir(t, "dir1")76 run.checkDir(t, "dir/|dir1/")77 err := run.os.Rename(run.path("dir1"), run.path("dir/dir2"))78 require.NoError(t, err)79 run.checkDir(t, "dir/|dir/dir2/")80 err = run.os.Rename(run.path("dir/dir2"), run.path("dir/dir3"))81 require.NoError(t, err)82 run.checkDir(t, "dir/|dir/dir3/")83 run.rmdir(t, "dir/dir3")84 run.rmdir(t, "dir")85 run.checkDir(t, "")86}87// TestDirRenameFullDir tests renaming a full directory88func TestDirRenameFullDir(t *testing.T) {89 run.skipIfNoFUSE(t)90 run.mkdir(t, "dir")91 run.mkdir(t, "dir1")92 run.createFile(t, "dir1/potato.txt", "maris piper")93 run.checkDir(t, "dir/|dir1/|dir1/potato.txt 11")94 err := run.os.Rename(run.path("dir1"), run.path("dir/dir2"))95 require.NoError(t, err)96 run.checkDir(t, "dir/|dir/dir2/|dir/dir2/potato.txt 11")97 err = run.os.Rename(run.path("dir/dir2"), run.path("dir/dir3"))98 require.NoError(t, err)99 run.checkDir(t, "dir/|dir/dir3/|dir/dir3/potato.txt 11")100 run.rm(t, "dir/dir3/potato.txt")101 run.rmdir(t, "dir/dir3")102 run.rmdir(t, "dir")103 run.checkDir(t, "")104}105// TestDirModTime tests mod times106func TestDirModTime(t *testing.T) {107 run.skipIfNoFUSE(t)108 run.mkdir(t, "dir")109 mtime := time.Date(2012, time.November, 18, 17, 32, 31, 0, time.UTC)110 err := run.os.Chtimes(run.path("dir"), mtime, mtime)111 require.NoError(t, err)112 info, err := run.os.Stat(run.path("dir"))113 require.NoError(t, err)114 // avoid errors because of timezone differences115 assert.Equal(t, info.ModTime().Unix(), mtime.Unix())116 run.rmdir(t, "dir")117}118// TestDirCacheFlush tests flushing the dir cache119func TestDirCacheFlush(t *testing.T) {120 run.skipIfNoFUSE(t)121 run.checkDir(t, "")122 run.mkdir(t, "dir")123 run.mkdir(t, "otherdir")124 run.createFile(t, "dir/file", "1")125 run.createFile(t, "otherdir/file", "1")126 dm := newDirMap("otherdir/|otherdir/file 1|dir/|dir/file 1")127 localDm := make(dirMap)128 run.readLocal(t, localDm, "")129 assert.Equal(t, dm, localDm, "expected vs fuse mount")130 err := run.fremote.Mkdir(context.Background(), "dir/subdir")131 require.NoError(t, err)132 // expect newly created "subdir" on remote to not show up133 run.forget("otherdir")134 run.readLocal(t, localDm, "")135 assert.Equal(t, dm, localDm, "expected vs fuse mount")136 run.forget("dir")137 dm = newDirMap("otherdir/|otherdir/file 1|dir/|dir/file 1|dir/subdir/")138 run.readLocal(t, localDm, "")139 assert.Equal(t, dm, localDm, "expected vs fuse mount")140 run.rm(t, "otherdir/file")141 run.rmdir(t, "otherdir")142 run.rm(t, "dir/file")143 run.rmdir(t, "dir/subdir")144 run.rmdir(t, "dir")145 run.checkDir(t, "")146}147// TestDirCacheFlushOnDirRename tests flushing the dir cache on rename148func TestDirCacheFlushOnDirRename(t *testing.T) {149 run.skipIfNoFUSE(t)150 run.mkdir(t, "dir")151 run.createFile(t, "dir/file", "1")152 dm := newDirMap("dir/|dir/file 1")153 localDm := make(dirMap)154 run.readLocal(t, localDm, "")155 assert.Equal(t, dm, localDm, "expected vs fuse mount")156 // expect remotely created directory to not show up157 err := run.fremote.Mkdir(context.Background(), "dir/subdir")158 require.NoError(t, err)159 run.readLocal(t, localDm, "")160 assert.Equal(t, dm, localDm, "expected vs fuse mount")161 err = run.os.Rename(run.path("dir"), run.path("rid"))162 require.NoError(t, err)163 dm = newDirMap("rid/|rid/subdir/|rid/file 1")164 localDm = make(dirMap)165 run.readLocal(t, localDm, "")166 assert.Equal(t, dm, localDm, "expected vs fuse mount")167 run.rm(t, "rid/file")168 run.rmdir(t, "rid/subdir")169 run.rmdir(t, "rid")170 run.checkDir(t, "")171}...
Var.go
Source:Var.go
...84}85func (o *Var) Read(r *context.Reader) {86 o.Index = r.GetU32()87}88func (o *Var) setRunner() {89 switch o.opcode {90 //@formatter:off91 case op.LOCAL_GET : o.setRunLocalGet()92 case op.LOCAL_SET : o.setRunLocalSet()93 case op.LOCAL_TEE : o.setRunLocalSet()94 case op.GLOBAL_GET: o.setRunGlobalGet()95 case op.GLOBAL_SET: o.setRunGlobalSet()96 //@formatter:on97 default:98 panic("Invalid var opcode")99 }100}101func (o *Var) setRunLocalGet() {102 sp := o.SP103 idx := o.Index104 switch o.dataType {105 //@formatter:off106 case value.I32: o.run = func(vm *Runner) { vm.Frame[sp].I32 = vm.Frame[idx].I32 }107 case value.I64: o.run = func(vm *Runner) { vm.Frame[sp].I64 = vm.Frame[idx].I64 }108 case value.F32: o.run = func(vm *Runner) { vm.Frame[sp].F32 = vm.Frame[idx].F32 }109 case value.F64: o.run = func(vm *Runner) { vm.Frame[sp].F64 = vm.Frame[idx].F64 }110 //@formatter:on111 default:112 panic("Invalid utils.Errordata type")113 }114}115func (o *Var) setRunLocalSet() {116 sp := o.SP117 idx := o.Index118 switch o.dataType {119 //@formatter:off120 case value.I32: o.run = func(vm *Runner) { vm.Frame[idx].I32 = vm.Frame[sp].I32 }121 case value.I64: o.run = func(vm *Runner) { vm.Frame[idx].I64 = vm.Frame[sp].I64 }122 case value.F32: o.run = func(vm *Runner) { vm.Frame[idx].F32 = vm.Frame[sp].F32 }123 case value.F64: o.run = func(vm *Runner) { vm.Frame[idx].F64 = vm.Frame[sp].F64 }124 //@formatter:on125 default:126 panic("Invalid utils.Errordata type")127 }128}129func (o *Var) setRunGlobalGet() {130 sp := o.SP131 idx := o.Index132 switch o.dataType {133 //@formatter:off134 case value.I32: o.run = func(vm *Runner) { vm.Frame[sp].I32 = vm.Module.GlobalVars[idx].I32 }135 case value.I64: o.run = func(vm *Runner) { vm.Frame[sp].I64 = vm.Module.GlobalVars[idx].I64 }136 case value.F32: o.run = func(vm *Runner) { vm.Frame[sp].F32 = vm.Module.GlobalVars[idx].F32 }137 case value.F64: o.run = func(vm *Runner) { vm.Frame[sp].F64 = vm.Module.GlobalVars[idx].F64 }138 //@formatter:on139 default:140 panic("Invalid utils.Errordata type")141 }142}143func (o *Var) setRunGlobalSet() {144 sp := o.SP145 idx := o.Index146 switch o.dataType {147 //@formatter:off148 case value.I32: o.run = func(vm *Runner) { vm.Module.GlobalVars[idx].I32 = vm.Frame[sp].I32 }149 case value.I64: o.run = func(vm *Runner) { vm.Module.GlobalVars[idx].I64 = vm.Frame[sp].I64 }150 case value.F32: o.run = func(vm *Runner) { vm.Module.GlobalVars[idx].F32 = vm.Frame[sp].F32 }151 case value.F64: o.run = func(vm *Runner) { vm.Module.GlobalVars[idx].F64 = vm.Frame[sp].F64 }152 //@formatter:on153 default:154 panic("Invalid utils.Errordata type")155 }156}157func (o *Var) String() string {158 return fmt.Sprintf("%s %d", o.Mnemonic(), o.Index)159}160func (o *Var) Write(w *context.Writer) {161 w.PutU32(o.Index)162}...
io_test.go
Source:io_test.go
...8 "github.com/stretchr/testify/assert"9 "github.com/stretchr/testify/require"10)11// Save before overriding12var _RunCMD = remotehost.RunCMD13// Overriding14func mockRunCMD(hostname, cmd string) (string, error) {15 return "remote value", nil16}17func TestFetchFile(t *testing.T) {18 testCases := []struct {19 name string20 remote bool21 expected string22 filename string23 }{24 {25 name: "Fetch from remote",26 remote: true,27 filename: "testdata/remote-file",28 expected: "remote value",29 },30 {31 name: "Fetch from local",32 remote: false,33 filename: "testdata/local-file",34 expected: "local value\n",35 },36 }37 for _, tc := range testCases {38 t.Run(tc.name, func(t *testing.T) {39 env.Config().Set("FetchFromRemote", tc.remote)40 if tc.remote {41 defer func() { remotehost.RunCMD = _RunCMD }()42 defer func() {43 if err := os.Remove(tc.filename); err != nil {44 t.Logf("Cannot remove file: %s", tc.filename)45 }46 }()47 remotehost.RunCMD = mockRunCMD48 }49 f, err := FetchFile(tc.filename)50 require.NoError(t, err)51 assert.Equal(t, f, []byte(tc.expected))52 })53 }54}55func TestFetchEnv(t *testing.T) {56 testCases := []struct {57 name string58 host string59 env string60 expected string61 remote bool62 }{63 {64 name: "Fetch remote ENV variable",65 host: "remote.test.com",66 env: "CPMA_TEST_ENV",67 expected: "remote value",68 remote: true,69 },70 {71 name: "Fetch local ENV variable",72 host: "",73 env: "CPMA_TEST_ENV",74 expected: "local value",75 remote: false,76 },77 }78 for _, tc := range testCases {79 t.Run(tc.name, func(t *testing.T) {80 if tc.remote {81 env.Config().Set("FetchFromRemote", true)82 } else {83 env.Config().Set("FetchFromRemote", false)84 os.Setenv("CPMA_TEST_ENV", "local value")85 }86 defer func() { remotehost.RunCMD = _RunCMD }()87 remotehost.RunCMD = mockRunCMD88 env, err := FetchEnv(tc.host, tc.env)89 require.NoError(t, err)90 assert.Equal(t, env, tc.expected)91 })92 }93}94func TestStringSource(t *testing.T) {95 testCases := []struct {96 name string97 filename string98 expected string99 }{100 {101 name: "Fetch String Source from value",102 filename: "testdata/local-file",103 expected: "local value",104 },105 }106 for _, tc := range testCases {107 t.Run(tc.name, func(t *testing.T) {108 env.Config().Set("FetchFromRemote", false)109 stringSource := legacyconfigv1.StringSource{}110 stringSource.File = "testdata/local-file"111 f, err := FetchStringSource(stringSource)112 require.NoError(t, err)113 assert.Equal(t, f, tc.expected)114 })115 }116}...
Run
Using AI Code Generation
1import (2func main() {3 fmt.Println("main function")4}5import (6func main() {7 fmt.Println("main function")8}9import (10func main() {11 fmt.Println("main function")12}13import (14func main() {15 fmt.Println("main function")16}17import (18func main() {19 fmt.Println("main function")20}21import (22func main() {23 fmt.Println("main function")24}25import (26func main() {27 fmt.Println("main function")28}29import (30func main() {31 fmt.Println("main function")32}33import (34func main() {35 fmt.Println("main function")36}37import (38func main() {39 fmt.Println("main function")40}
Run
Using AI Code Generation
1import "fmt"2type Local struct {3}4func (l Local) Run() {5fmt.Println("Local.Run()")6}7func main() {8l := Local{}9l.Run()10}11import "fmt"12type Local struct {13}14func (l Local) Run() {15fmt.Println("Local.Run()")16}17func main() {18l := Local{}19Local{}.Run()20}21import "fmt"22type Local struct {23}24func (l Local) Run() {25fmt.Println("Local.Run()")26}27func main() {28l := Local{}29l.Run()30l.Run()31}32import "fmt"33type Local struct {34}35func (l Local) Run() {36fmt.Println("Local.Run()")37}38func main() {39l := Local{}40l.Run()41l.Run()42l.Run()43}44import "fmt"45type Local struct {46}47func (l Local) Run() {48fmt.Println("Local.Run()")49}50func main() {51l := Local{}52l.Run()53l.Run()54l.Run()55l.Run()56}57import "fmt"58type Local struct {59}60func (l Local) Run() {61fmt.Println("Local.Run()")62}63func main() {64l := Local{}65l.Run()66l.Run()67l.Run()68l.Run()69l.Run()70}71import "fmt"72type Local struct {73}74func (l Local) Run() {75fmt.Println("Local.Run()")76}77func main() {78l := Local{}79l.Run()80l.Run()81l.Run()82l.Run()83l.Run()84l.Run()85}86import "fmt"87type Local struct {88}89func (l Local) Run() {90fmt.Println("Local.Run()")91}92func main() {93l := Local{}94l.Run()95l.Run()96l.Run()97l.Run()98l.Run()99l.Run()100l.Run()
Run
Using AI Code Generation
1import (2type local struct {3}4func (l local) Run() {5 fmt.Println("local Run")6}7func main() {8 l := local{a: 1}9 l.Run()10}11import (12type local struct {13}14func (l *local) Run() {15 fmt.Println("local Run")16}17func main() {18 l := local{a: 1}19 l.Run()20}21import (22type local struct {23}24func (l local) Run() {25 fmt.Println("local Run")26}27func main() {28 l := &local{a: 1}29 l.Run()30}31import (32type local struct {33}34func (l *local) Run() {35 fmt.Println("local Run")36}37func main() {38 l := &local{a: 1}39 l.Run()40}
Run
Using AI Code Generation
1import "fmt"2func main() {3 c = add(a, b)4 fmt.Printf("The sum is %d5 c = sub(a, b)6 fmt.Printf("The difference is %d7}8func add(x, y int) int {9}10func sub(x, y int) int {11}12type interface_name interface {13}14import "fmt"15type Adder interface {16 add(int, int) int17}18type Suber interface {19 sub(int, int) int20}21func main() {22 c = adder.add(a, b)23 fmt.Printf("The sum is %d24 c = suber.sub(a, b)25 fmt.Printf("The difference is %d26}27func add(x, y int) int {28}29func sub(x, y int) int {30}31type struct_name struct {32}33import "
Run
Using AI Code Generation
1import (2func main() {3 fmt.Println("Hello World!")4 fmt.Println("Sum of two numbers", z)5}6import (7func main() {8 fmt.Println("Hello World!")9 fmt.Println("Sum of two numbers", z)10}11import (12func main() {13 fmt.Println("Hello World!")14 fmt.Println("Sum of two numbers", z)15}16import (17func main() {18 fmt.Println("Hello World!")19 fmt.Println("Sum of two numbers", z)20}21import (22func main() {23 fmt.Println("Hello World!")24 fmt.Println("Sum of two numbers", z)25}26import (27func main() {28 fmt.Println("Hello World!")29 fmt.Println("Sum of two numbers", z)30}31import (32func main() {33 fmt.Println("Hello World!")34 fmt.Println("Sum of two numbers", z)35}
Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.
You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.
Get 100 minutes of automation test minutes FREE!!