run

Documentation

Overview

Package run manages Read, Write and Signal goroutines.

Index

• func Run(cfg config.Config)

Examples

• Run (FileToRedis)
• Run (FileToRedisTTL)
• Run (RedisToFile)
• Run (RedisToFileTTL)
• Run (RedisToRedis)
• Run (RedisToRedisSilent)
• Run (RedisToRedisTTL)

Functions

func Run

func Run(cfg config.Config)

Run orchestrate the Reader, Writer and Signal handler.

Example (FileToRedis)

setup()
defer teardown()

cfgFileDump := config.Config{
	Source: config.Resource{
		URI:     "redis://localhost:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     os.TempDir() + "/dump.rump",
		IsRedis: false,
	},
}
run.Run(cfgFileDump)

cfg := config.Config{
	Source: config.Resource{
		URI:     os.TempDir() + "/dump.rump",
		IsRedis: false,
	},
	Target: config.Resource{
		URI:     "redis://localhost:6379/10",
		IsRedis: true,
	},
}
run.Run(cfg)

Output:

rw
signal: exit
done
rw
signal: exit
done

Example (FileToRedisTTL)

setup()
defer teardown()

cfgFileDump := config.Config{
	Source: config.Resource{
		URI:     "redis://localhost:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     os.TempDir() + "/dump.rump",
		IsRedis: false,
	},
}
run.Run(cfgFileDump)

cfg := config.Config{
	Source: config.Resource{
		URI:     os.TempDir() + "/dump.rump",
		IsRedis: false,
	},
	Target: config.Resource{
		URI:     "redis://localhost:6379/10",
		IsRedis: true,
	},
	TTL: true,
}
run.Run(cfg)

Output:

rw
signal: exit
done
rw
signal: exit
done

Example (RedisToFile)

setup()
defer teardown()

cfg := config.Config{
	Source: config.Resource{
		URI:     "redis://localhost:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     os.TempDir() + "/dump.rump",
		IsRedis: false,
	},
}

run.Run(cfg)

Output:

rw
signal: exit
done

Example (RedisToFileTTL)

setup()
defer teardown()

cfg := config.Config{
	Source: config.Resource{
		URI:     "redis://localhost:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     os.TempDir() + "/dump.rump",
		IsRedis: false,
	},
	TTL: true,
}

run.Run(cfg)

Output:

rw
signal: exit
done

Example (RedisToRedis)

setup()
defer teardown()

cfg := config.Config{
	Source: config.Resource{
		URI:     "redis://localhost:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     "redis://localhost:6379/10",
		IsRedis: true,
	},
	Silent: false,
}

run.Run(cfg)

Output:

rw
signal: exit
done

Example (RedisToRedisSilent)

setup()
defer teardown()

cfg := config.Config{
	Source: config.Resource{
		URI:     "redis://localhost:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     "redis://localhost:6379/10",
		IsRedis: true,
	},
	Silent: true,
}

run.Run(cfg)

Output:

signal: exit
done

Example (RedisToRedisTTL)

setup()
defer teardown()

cfg := config.Config{
	Source: config.Resource{
		URI:     "redis://localhost:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     "redis://localhost:6379/10",
		IsRedis: true,
	},
	Silent: false,
	TTL:    true,
}

run.Run(cfg)

Output:

rw
signal: exit
done