view release on metacpan or search on metacpan
examples/roundtrip.pl view on Meta::CPAN
@$_
)
})
->completed;
$log->infof('Copy data in');
# Normally you'd have a proper source that's streaming from some other system,
# this construct looks a bit unwieldy on its own but the ->from method
# would also accept the arrayref-of-rows directly.
await $db->query('copy roundtrip_one(name) from stdin')
->from([ map [ $_ ], qw(first second third) ])
->completed;
view release on metacpan or search on metacpan
*July 2005 to July 2008 - Perl Internal Applications Engineer*
* Developed and maintained internal applications for server automations, the internal ticket system and employee client management.
* Leveraged technologies such as Perl, MySQL, Apache mod_perl, Template Toolkit and Bash Shell to enhance operational efficiency.
* Specialized in code optimization, resulting in improved application performance and reduced processing time.
* Contributed to a collaborative environment at Napster, a pioneering music streaming service in the greater San Diego area.
----
### 4Retired.com
*July 2003 to June 2004 - Chief Information Officer*
* Oversaw the complete IT infrastructure, including server build, maintenance and software developement.
* Designed and implemented a cusdtomized web portal featuring free email accounts and affiliate distribution.
* Enhanced operational efficiency by streaming server management on RedHat Linux, leading to improved uptime and performance.
----
### eBuilt
view release on metacpan or search on metacpan
lib/Devel/Agent.pm view on Meta::CPAN
default=>0,
);
=item * on_frame_end=>CodeRef
This code ref is called when a frame is closed. This should act as the default data streaming hook callback. All tracing operations are halted durriong this callback.
Example:
sub {
my ($self,$last)=@_;
view release on metacpan or search on metacpan
0.01 2012-09-29 Tim Bunce
* Created new Devel::Memory extension using a modified version of
Devel::Size's perl memory data crawler, extended to support
callbacks, a 'data path name' concept, data streaming,
data processing and visualization.
* The Devel::Memory core was based on 0.77. The generic changes
will be fed back to Devel::Size so it will remain the
canonical source of knowledge of how to crawl perl internals.
view release on metacpan or search on metacpan
lib/Devel/hdb/App/Assets.pm view on Meta::CPAN
$fh->binmode();
} else {
$type = 'text/plain';
}
if ($env->{'psgi.streaming'}) {
return [ 200, ['Content-Type' => $type], $fh];
} else {
local $/;
my $buffer = <$fh>;
return [ 200, ['Content-Type' => $type], [$buffer]];
view release on metacpan or search on metacpan
integration/blank-env/run-integration.pl view on Meta::CPAN
stderr => defined $stderr ? $stderr : '',
};
}
# _capture_stream_prefix($label, $command, %opts)
# Runs one streaming shell command and records when expected stdout chunks first appear.
# Input: human label, shell command string, expected_chunks array ref, and optional timeout seconds.
# Output: hash reference with stdout, stderr, and matched event timing data.
sub _capture_stream_prefix {
my ( $label, $command, %opts ) = @_;
my $expected = $opts{expected_chunks} || [];
view release on metacpan or search on metacpan
lib/Device/SaleaeLogic.pm view on Meta::CPAN
sub is_usb2 {
return saleaeinterface_is_usb2($_[0]->{obj}, $_[1]);
}
sub is_streaming {
return saleaeinterface_is_streaming($_[0]->{obj}, $_[1]);
}
sub get_channel_count {
return saleaeinterface_get_channel_count($_[0]->{obj}, $_[1]);
}
lib/Device/SaleaeLogic.pm view on Meta::CPAN
This method can be invoked from any callback provided to the C<new()> function
or from outside the callbacks as long as you have a copy of the
Device::SaleaeLogic object created by C<new()> and a copy of the C<$id> as well.
=item C<is_streaming($id)>
This method informs the user whether the device with ID C<$id> is streaming data
or not. This is useful to know before calling methods like C<read_start()>,
C<write_start()> and C<stop()>. It returns 1 if streaming is going on and 0
otherwise.
The way to invoke this method is as below:
if ($self->is_streaming($id)) {
# ... do something ...
# ... look at the section for read_start() for an example ...
}
This method can be invoked from any callback provided to the C<new()> function
lib/Device/SaleaeLogic.pm view on Meta::CPAN
=item C<read_start($id)>
This method starts the data sampling from the Logic or Logic16 device given by
the ID C<$id>. This should be called only once and to check for whether to call
it or not the user should use C<is_streaming($id)> before that.
The way to invoke this method is as below:
unless ($self->is_streaming($id)) {
$self->read_start($id);
}
This method should B<not> be invoked from any callback provided to the C<new()>
function. It has to be invoked from outside of the callbacks as shown in
F<share/example.pl> in the distribution.
=item C<stop($id)>
This method stops the data streaming that is currently happening for the Logic
or Logic16 device given by the device ID C<$id>. This should be called after
checking with C<is_streaming($id)>.
The way to invoke this method is as below:
if ($self->is_streaming($id)) {
$self->stop($id);
}
This method can be invoked from any callback provided to the C<new()> function
or from outside the callbacks as long as you have a copy of the
view release on metacpan or search on metacpan
lib/Device/WebIO/Dancer.pm view on Meta::CPAN
my $mime_type = $type1 . '/' . $type2;
my $in_fh = $webio->vid_stream( $name, $channel, $mime_type );
return send_file( '/etc/hosts',
streaming => 1,
system_path => 1,
content_type => $mime_type,
callbacks => {
around_content => sub {
my ($writer, $chunk) = @_;
view release on metacpan or search on metacpan
- SPI interface
0.007 2014-11-30
- Video streaming
0.006 2014-11-22
- Use GStreamer to get image rather than calling raspistill
- Add quality parameter to examples/picture.pl
view release on metacpan or search on metacpan
lib/Device/WebIO.pm view on Meta::CPAN
=head3 vid_stream
vid_stream( $name, $channel, $type );
Returns a filehandle for streaming the video channel. C<$type> is one of the
MIME types returned by C<vid_allowed_content_types()>.
=head2 Video Callback
These can be used if the device does the C<VideoOutputCallback> role.
lib/Device/WebIO.pm view on Meta::CPAN
=head3 img_stream
img_stream( $name, $channel, $type );
Returns a filehandle for streaming the video channel. C<$type> is one of the
MIME types return by C<img_allowed_content_types()>.
=head2 I2C
=head3 i2c_read
view release on metacpan or search on metacpan
$outsideTempHumIndex,
$outsideTempHumIndexMaximum,
$avgWindChill,
$windChillMinimum);
B<&getSensorImage> enables a continuous streaming of "live" weather
data from the Davis Wx Station. I've found this stream to be very
easy to get out of sync, so this funcion reads a single block, stops
the streaming, and flushes the serial receive buffer. The data
returned by this function are the current values and not average
values within a sample period, like &getArcImg returns. The array
returned is as follows:
@array = ($insideTemp,
}
return 1;
}
##
## `getSensorImage' enables a continuous streaming of 18 byte chunks of
## weather data from the Davis Wx Station. I've found this stream to be
## very easy to get out of sync, so this funcion read a single 18 byte chunk,
## stops the streaming, and flushes the serial Rx buffer
##
sub getSensorImage {
##### LOOP ######
# Monitor, Wizard, and Perception Sensor Image:
# start of block 1 byte
view release on metacpan or search on metacpan
highwayhash/c/highwayhash.h view on Meta::CPAN
HighwayHashState state;
uint8_t packet[32];
int num;
} HighwayHashCat;
/* Allocates new state for a new streaming hash computation */
void HighwayHashCatStart(const uint64_t key[4], HighwayHashCat* state);
void HighwayHashCatAppend(const uint8_t* bytes, size_t num,
HighwayHashCat* state);
view release on metacpan or search on metacpan
ext/xxHash/xxhash.h view on Meta::CPAN
XXH_PUBLIC_API XXH64_state_t* XXH64_createState(void);
XXH_PUBLIC_API XXH_errorcode XXH64_freeState(XXH64_state_t* statePtr);
/* hash streaming */
XXH_PUBLIC_API XXH_errorcode XXH32_reset (XXH32_state_t* statePtr, unsigned int seed);
XXH_PUBLIC_API XXH_errorcode XXH32_update (XXH32_state_t* statePtr, const void* input, size_t length);
XXH_PUBLIC_API XXH32_hash_t XXH32_digest (const XXH32_state_t* statePtr);
view release on metacpan or search on metacpan
lib/Directory/Scanner.pm view on Meta::CPAN
->ignore(sub { $_->basename =~ /^\./ })
->recurse;
=head1 DESCRIPTION
This module provides a streaming interface for traversing directories.
Unlike most modules that provide similar capabilities, this will not
pre-fetch the list of files or directories, but instead will only focus
on one thing at a time. This is useful if you have a large directory tree
and need to do a lot of resource intensive work on each file.
view release on metacpan or search on metacpan
dist_zilla_docker_api_plugin_plan.md view on Meta::CPAN
$client->remote_tag_exists($image_ref); # optional registry helper
```
### `...::Progress`
Docker build/push endpoints return streaming progress records. The plugin should parse these and forward:
```text
stream/status/progress -> log_debug or log
errorDetail/error -> log_fatal
aux.ID -> captured image ID
dist_zilla_docker_api_plugin_plan.md view on Meta::CPAN
sub build_image {
my ($self, %arg) = @_;
# Adapter maps normalized plugin args to API::Docker method calls.
# It must consume the full streaming response and return a Result object.
}
sub push_image {
my ($self, %arg) = @_;
view release on metacpan or search on metacpan
0.045 2017-05-30 00:04:46Z
- fix MSWin32 test failures where path separators do not come out as
expected
0.044 2017-03-29 00:14:00Z
- once again streaming command output as each line is produced, rather than
buffering until the process ends (this behaviour was changed in 0.040)
0.043 2016-02-15 04:20:20Z
- new [Run::BeforeArchive] plugin
view release on metacpan or search on metacpan
share/specs/v1.25.yaml view on Meta::CPAN
description: |
Replay previous logs from the container.
This is useful for attaching to a container that has started and you want to output everything since the container started.
If `stream` is also enabled, once all the previous output has been returned, it will seamlessly transition into streaming current output.
type: "boolean"
default: false
- name: "stream"
in: "query"
description: "Stream attached streams from the the time the request was made onwards"
share/specs/v1.25.yaml view on Meta::CPAN
in: "query"
description: "Show events created since this timestamp then stream new events."
type: "string"
- name: "until"
in: "query"
description: "Show events created until this timestamp then stop streaming."
type: "string"
- name: "filters"
in: "query"
description: |
A JSON encoded value of filters (a `map[string][]string`) to process on the event list. Available filters:
view release on metacpan or search on metacpan
t/dracula.DOS.txt view on Meta::CPAN
whether she dies conscious or in her sleep. Wake that poor boy, and
let him come and see the last. He trusts us, and we have promised
him."
I went to the dining room and waked him. He was dazed for a moment,
but when he saw the sunlight streaming in through the edges of the
shutters he thought he was late, and expressed his fear. I assured
him that Lucy was still asleep, but told him as gently as I could that
both Van Helsing and I feared that the end was near. He covered his
face with his hands, and slid down on his knees by the sofa, where he
remained, perhaps a minute, with his head buried, praying, whilst his
t/dracula.DOS.txt view on Meta::CPAN
understand that sunrise and sunset are to her times of peculiar
freedom. When her old self can be manifest without any controlling
force subduing or restraining her, or inciting her to action. This
mood or condition begins some half hour or more before actual sunrise
or sunset, and lasts till either the sun is high, or whilst the clouds
are still aglow with the rays streaming above the horizon. At first
there is a sort of negative condition, as if some tie were loosened,
and then the absolute freedom quickly follows. When, however, the
freedom ceases the change back or relapse comes quickly, preceded
only by a spell of warning silence.
view release on metacpan or search on metacpan
lib/ETL/Yertl.pm view on Meta::CPAN
pipeline. If the size of the data is known, it can even provide
a progress bar and an ETA.
=item L<netcat (nc)|http://netcat.sourceforge.net>
Netcat allows simple streaming over a network. Using Netcat you can
start a Yertl pipeline on one machine and finish it on another machine.
For example, you could generate metrics on each client machine, and then
write them to a central machine to insert into a database on that
machine.
view release on metacpan or search on metacpan
eg/cancel_streaming.pl view on Meta::CPAN
#!/usr/bin/env perl
# Cancel a streaming select mid-flight from inside the on_data callback,
# once a condition is met. The connection stays alive for follow-up queries.
use strict;
use warnings;
use EV;
use EV::ClickHouse;
view release on metacpan or search on metacpan
eg/resumable_watch.pl view on Meta::CPAN
#!/usr/bin/env perl
#
# resumable_watch.pl - A watcher that survives process restarts without
# missing events. Persists the last seen revision to a file; on startup,
# reads it back, lists any keys changed during downtime via a one-shot
# get(prefix=>1, revision=>) and then resumes streaming from the next
# revision.
#
# Handles the compaction edge case: if the server has compacted past our
# saved revision, the watch arrives in the *error* callback (per the POD
# documentation of watch's error semantics). We then re-list at HEAD and
view release on metacpan or search on metacpan
lib/EV/MariaDB.pm view on Meta::CPAN
my ($rows, $err) = @_;
# callbacks fire in order
});
}
# streaming row-by-row (no full-result buffering)
$m->query_stream("select * from big_table", sub {
my ($row, $err) = @_;
if ($err) { warn $err; return }
if (!defined $row) { print "done\n"; return } # EOF
# process $row (arrayref)
lib/EV/MariaDB.pm view on Meta::CPAN
=item * Async transaction control (commit, rollback, autocommit)
=item * Connection utility operations (ping, reset, reset_connection,
change_user, select_db, set_charset)
=item * BLOB/TEXT streaming via C<send_long_data>
=item * Async graceful close via C<close_async>
=item * Multi-result set support for multi-statement queries
lib/EV/MariaDB.pm view on Meta::CPAN
=item utf8 => 1
When enabled, result strings from columns with a UTF-8 charset are
automatically flagged with Perl's internal UTF-8 flag (C<SvUTF8_on>).
Applies to text queries, prepared statements, and streaming results.
Without this option, all result values are returned as raw byte
strings (matching DBD::mysql's default).
Column names in C<$fields> are UTF-8-flagged when the connection
charset is C<utf8> or C<utf8mb4>, regardless of this option.
lib/EV/MariaDB.pm view on Meta::CPAN
=item * on error with C<(undef, $error_message)>
=back
Unlike C<query>, rows are not buffered -- suitable for very large
result sets. No other queries can be queued while streaming is active.
=head2 close_async
$m->close_async(sub { my ($ok, $err) = @_ });
lib/EV/MariaDB.pm view on Meta::CPAN
flag set so C<length>, regex, and other character operations behave
correctly.
=head2 Reading
With C<< utf8 => 1 >>, text query, prepared-statement, and streaming
results are UTF-8-flagged per column based on the column's charset.
Binary and non-UTF-8 columns are returned as raw bytes. Column names
in C<$fields> are UTF-8-flagged whenever the connection charset is
C<utf8> or C<utf8mb4>, regardless of this option.
view release on metacpan or search on metacpan
eg/copy_out.pl view on Meta::CPAN
use warnings;
use EV;
use EV::Pg;
# Demonstrates the multi-phase COPY OUT callback protocol:
# 1. callback fires with ("COPY_OUT") -- streaming has begun
# 2. caller drains rows by looping get_copy_data until it returns -1
# 3. callback fires AGAIN with ($cmd_tuples) on completion
my $conninfo = shift || $ENV{TEST_PG_CONNINFO} || 'dbname=postgres';
view release on metacpan or search on metacpan
eg/backpressure.pl view on Meta::CPAN
my $port = $ctx->listen(
port => 0,
on_connect => sub {
my ($c) = @_;
print "Server: client connected, streaming $TARGET_MSGS chunks of ${\ ($CHUNK_SIZE/1024)}KB\n";
$c->stash->{sent} = 0;
$t0 = time;
try_send($c);
},
on_drain => sub {
view release on metacpan or search on metacpan
lib/EEDB/Edge.pm view on Meta::CPAN
}
###############################################################################################
#
# streaming API section
#
###############################################################################################
=head2 stream_all
view release on metacpan or search on metacpan
lib/Elive/Util.pm view on Meta::CPAN
sub _tainted {
return grep { Scalar::Util::tainted($_) } @_;
}
#
# Hex encoding/decoding. Use for data streaming. E.g. upload & download
# of preload data.
#
sub _hex_decode {
my $data = shift;
view release on metacpan or search on metacpan
lib/Email/LocalDelivery/Mbox.pm view on Meta::CPAN
my $fh = $class->_open_fh($file) or next;
print $fh "\n" if tell($fh) > 0;
print $fh $class->_from_line($email);
print $fh $class->_escape_from_body($email);
# This will make streaming a bit more annoying. -- rjbs, 2007-05-25
print $fh "\n" unless $email->as_string =~ /\n$/;
$class->_close_fh($fh) || next;
push @rv, $file;
}
view release on metacpan or search on metacpan
lib/Email/Sender/Transport/SMTPS.pm view on Meta::CPAN
message => $message,
failures => \@failures,
);
}
# restore Pobox's support for streaming, code-based messages, and arrays here
# -- rjbs, 2008-12-04
$smtp->data or $FAULT->("error at DATA start");
my $msg_string = $email->as_string;
view release on metacpan or search on metacpan
lib/Email/Sender/Transport/Mbox.pm view on Meta::CPAN
or Carp::confess("couldn't write to $filename: $!");
$fh->print($self->_escape_from_body($email))
or Carp::confess("couldn't write to $filename: $!");
# This will make streaming a bit more annoying. -- rjbs, 2007-05-25
$fh->print("\n")
or Carp::confess("couldn't write to $filename: $!")
unless $email->as_string =~ /\n$/;
$self->_close_fh($fh)
view release on metacpan or search on metacpan
allow header_class arg to new(), to match Email::Simple's new (HDP)
0.050 2007-02-06
excellent features added by HDP:
test for reading from unseekable filehandles
add getline() for streaming from an email
add stream_to() for convenient streaming to a fh (or anything else)
0.011 2006-06-13
added this changelog