Documentation ¶
Overview ¶
Package run manages Read, Write and Signal goroutines.
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func Run ¶
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
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.