-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
test(docker) - encapsulate docker stuff
in package t::NeoCon
- Loading branch information
Showing
5 changed files
with
106 additions
and
122 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,69 @@ | ||
| package t::NeoCon; | ||
| use Log::Log4perl qw/:easy/; | ||
| use IPC::Run qw/run/; | ||
| use Carp qw/croak/; | ||
| use strict; | ||
|
|
||
| my ($in,$out,$err); | ||
| my $TAG = 'maj1/test-db-bento-meta'; | ||
| unless (eval 'require IO::Pty;1') { | ||
| croak __PACKAGE__." requires IO::Pty - please install it" | ||
| } | ||
| unless (run ['docker'],\$in,\$out,\$err) { | ||
| croak __PACKAGE__." requires docker - please install it" | ||
| } | ||
|
|
||
| # tag => <docker tag> | ||
| # name => <container name> | ||
| # ports => <hash of port mappings container => host> | ||
|
|
||
| sub new { | ||
| my $class = shift; | ||
| my %args = @_; | ||
| my $self = bless \%args, $class; | ||
| $self->{tag} //= $TAG; | ||
| $self->{name} //= "test$$"; | ||
| $self->{ports} //= {7687 => undef}; | ||
| return $self; | ||
| } | ||
| sub error { shift->{_error} } | ||
| sub port { shift->{ports}{shift()} } | ||
| sub ports { shift->{ports} } | ||
| sub start { | ||
| my $self = shift; | ||
| my @startcmd = split / /, "docker run -d -P --name $$self{name} $$self{tag}"; | ||
| INFO "Starting docker $$self{tag} as $$self{name}"; | ||
| unless (run \@startcmd, \$in, \$out, \$err) { | ||
| $self->{_error} = $err; | ||
| return; | ||
| } | ||
| sleep 10; | ||
| run [split / /, "docker container port $$self{name}"], \$in, \$out, \$err; | ||
| for my $port (keys %{$self->{ports}}) { | ||
| my ($p) = grep /${port}.tcp/, split /\n/,$out; | ||
| ($p) = $p =~ m/([0-9]+)$/; | ||
| $self->{ports}{$port} = $p; | ||
| } | ||
| return 1; | ||
| } | ||
|
|
||
| sub stop { | ||
| my $self = shift; | ||
| INFO "Stopping docker container $$self{name}"; | ||
| unless (run [split / /,"docker kill $$self{name}"], \$in,\$out,\$err) { | ||
| $self->{_error} = $err; | ||
| return; | ||
| } | ||
| return 1; | ||
| } | ||
|
|
||
| sub rm { | ||
| my $self = shift; | ||
| INFO "Removing docker container $$self{name}"; | ||
| unless ( run [split / /, "docker rm $$self{name}"],\$in,\$out,\$err ) { | ||
| $self->{_error} = $err; | ||
| return; | ||
| } | ||
| return 1; | ||
| } | ||
| 1; |