run

Documentation

Overview

Package run manages Read, Write and Signal goroutines.

Index

• Variables
• func Run(cfg config.Config)

Examples

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

Variables

var CustomConnFunc = func(network, addr string) (radix.Conn, error) {
	tlsConf := &tls.Config{
		InsecureSkipVerify: true,
	}
	return radix.Dial(network, addr, radix.DialUseTLS(tlsConf))
}

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://redis:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     "/app/dump.rump",
		IsRedis: false,
	},
}
run.Run(cfgFileDump)

cfg := config.Config{
	Source: config.Resource{
		URI:     "/app/dump.rump",
		IsRedis: false,
	},
	Target: config.Resource{
		URI:     "redis://redis: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://redis:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     "/app/dump.rump",
		IsRedis: false,
	},
}
run.Run(cfgFileDump)

cfg := config.Config{
	Source: config.Resource{
		URI:     "/app/dump.rump",
		IsRedis: false,
	},
	Target: config.Resource{
		URI:     "redis://redis: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://redis:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     "/app/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://redis:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     "/app/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://redis:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     "redis://redis: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://redis:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     "redis://redis: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://redis:6379/9",
		IsRedis: true,
	},
	Target: config.Resource{
		URI:     "redis://redis:6379/10",
		IsRedis: true,
	},
	Silent: false,
	TTL:    true,
}

run.Run(cfg)

Output:

rw
signal: exit
done