view release on metacpan or search on metacpan
lib/AnyEvent/Consul.pm view on Meta::CPAN
AnyEvent::Consul is a thin wrapper around L<Consul> to connect it to
L<AnyEvent::HTTP> for asynchronous operation.
It takes the same arguments and methods as L<Consul> itself, so see the
documentation for that module for details. The important difference is that you
must pass the C<cb> option to the endpoint methods to enable their asynchronous
mode.
There's also a C<on_error> argument. If you pass in a coderef for this
argument, it will be called with a single string arg whenever something goes
wrong internally (usually a HTTP failure). Use it to safely log or cleanup
view all matches for this distribution
view release on metacpan or search on metacpan
lib/AnyEvent/Discord/Client.pm view on Meta::CPAN
},
);
=item C<api(I<$method>, I<$path>, I<$data>, I<$cb>)>
Invokes the Discord API asynchronously and returns immediately. C<$method> is the HTTP method to use; C<$path> is the endpoint to call. If C<$data> is a reference, it is sent as JSON; otherwise, if it is defined, it is sent as a C<x-www-form-urlenc...
=item C<api_sync(I<$method>, I<$path>, I<$data>)>
Invokes the Discord API synchronously and returns the result of the call. C<$method> is the HTTP method to use; C<$path> is the endpoint to call. If C<$data> is a reference, it is sent as JSON; otherwise, if it is defined, it is sent as a C<x-www-f...
=item C<websocket_send(I<$op>, I<$d>)>
Sends a raw WebSocket payload as per the L<Discord Gateway|https://discordapp.com/developers/docs/topics/gateway> documentation.
view all matches for this distribution
view release on metacpan or search on metacpan
lib/AnyEvent/Discord.pm view on Meta::CPAN
my $msg = $payload->as_json;
$self->_trace('ws out: ' . $msg);
$self->_socket->send($msg);
}
# Look up the gateway endpoint using the Discord API
method _lookup_gateway() {
my $payload = $self->_discord_api('GET', 'gateway');
die 'Invalid gateway returned by API' unless ($payload and $payload->{url} and $payload->{url} =~ /^wss/);
# Add the requested version and encoding to the provided URL
view all matches for this distribution
view release on metacpan or search on metacpan
lib/AnyEvent/JSONRPC/HTTP/Client.pm view on Meta::CPAN
=over 4
=item url => 'Str'
URL to json-RPC endpoint to connect. (Required)
=item username => 'Str'
Username to use for authorization (Optional).
view all matches for this distribution
view release on metacpan or search on metacpan
lib/AnyEvent/Lingr.pm view on Meta::CPAN
has 'api_key' => (
is => 'ro',
);
has 'endpoint' => (
is => 'ro',
default => 'http://lingr.com/api/',
);
has 'session' => (
view all matches for this distribution
view release on metacpan or search on metacpan
=item binds - C<ip:port>
Nodes can only talk to each other by creating some kind of connection to
each other. To do this, nodes should listen on one or more local transport
endpoints - binds.
Currently, only standard C<ip:port> specifications can be used, which
specify TCP ports to listen on. So a bind is basically just a tcp socket
in listening mode that accepts connections from other nodes.
view all matches for this distribution
view release on metacpan or search on metacpan
inc/Test/HTTP/AnyEvent/Server.pm view on Meta::CPAN
Return URI of a newly created server (with a trailing C</>).
=head2 start_server($prepare_cb)
B<(internal)> Wrapper for the C<tcp_server> from L<AnyEvent::Socket>.
C<$prepare_cb> is used to get the IP address and port of the local socket endpoint and populate respective attributes.
=head1 FUNCTIONS
=head2 _cleanup
view all matches for this distribution
view release on metacpan or search on metacpan
lib/AnyEvent/ReverseHTTP.pm view on Meta::CPAN
use base qw(Exporter);
our @EXPORT = qw(reverse_http);
use Any::Moose;
has endpoint => (
is => 'rw', isa => 'Str',
required => 1, default => "http://www.reversehttp.net/reversehttp",
);
has label => (
view all matches for this distribution
view release on metacpan or search on metacpan
lib/AnyEvent/SlackBot.pm view on Meta::CPAN
type=>'typing',
};
$self->send($msg);
}
=item * $self->post_to_web($msg,$endpoint|undef,"FORM"|"JSON"|undef)
Posts the to the given REST Endpoint outside of the WebSocket.
msg:
Hash ref representing the requrest being sent
token: set to $self->token if not set
scope: set to: 'chat:write:bot' if not set
endpoint:
The Rest xxx endpint, the default is 'chat.postMessage'
type:
Sets how the data will be sent over
Supported options are:
view all matches for this distribution
view release on metacpan or search on metacpan
lib/AnyEvent/Twitter.pm view on Meta::CPAN
return bless { %args }, $class;
}
sub get {
my $cb = pop;
my ($self, $endpoint, $params) = @_;
my $type = $endpoint =~ /^http.+\.json$/ ? 'url' : 'api';
$self->request($type => $endpoint, method => 'GET', params => $params, $cb);
return $self;
}
sub post {
my ($self, $endpoint, $params, $cb) = @_;
my $type = $endpoint =~ /^http.+\.json$/ ? 'url' : 'api';
$self->request($type => $endpoint, method => 'POST', params => $params, $cb);
return $self;
}
sub request {
view all matches for this distribution
view release on metacpan or search on metacpan
lib/AnyEvent/XMPP/Writer.pm view on Meta::CPAN
}
=item B<send_init_stream ($language, $domain, $namespace)>
This method will generate a XMPP stream header. C<$domain> has to be the
domain of the server (or endpoint) we want to connect to.
C<$namespace> is the namespace URI or the tag (from L<AnyEvent::XMPP::Namespaces>)
for the stream namespace. (This is used by L<AnyEvent::XMPP::Component> to connect
as component to a server). C<$namespace> can also be undefined, in this case
the C<client> namespace will be used.
view all matches for this distribution
view release on metacpan or search on metacpan
lib/AnyEvent/ZeroMQ/Types.pm view on Meta::CPAN
$rest =~ /^(?:$interface|$ip);$ip$andport$/;
return 0;
}
return 0;
}, message { 'An endpoint must be in the form "<transport>://<address>"' };
subtype Endpoints, as ArrayRef[Endpoint], message {
'Each endpoint must be in the form "<transport>://<address>"';
};
sub fixup_endpoint() {
s{(^[/])/$}{$1}g;
}
coerce Endpoint, from Str, via { fixup_endpoint };
coerce Endpoints, from ArrayRef[Str], via {
my @array = @$_;
fixup_endpoint for @array;
$_ = [@array];
};
my %allowed_sockettype = map { ZeroMQ::Raw::Constants->$_ => $_ } @socket_constants;
subtype SocketType, as Int, where {
view all matches for this distribution
view release on metacpan or search on metacpan
lib/AnyEvent/Handle.pm view on Meta::CPAN
read and write queues, EOF status, TLS status and similar properties of
the handle will have been reset.
If, for some reason, the handle is not acceptable, calling C<$retry> will
continue with the next connection target (in case of multi-homed hosts or
SRV records there can be multiple connection endpoints). The C<$retry>
callback can be invoked after the connect callback returns, i.e. one can
start a handshake and then decide to retry with the next host if the
handshake fails.
In most cases, you should ignore the C<$retry> parameter.
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Apache/SdnFw/js/tinymce/jscripts/tiny_mce/tiny_mce_src.js view on Meta::CPAN
// Setup temp range and collapse it
checkRng = ieRange.duplicate();
checkRng.collapse(start);
// Create marker and insert it at the end of the endpoints parent
marker = dom.create('a');
parent = checkRng.parentElement();
// If parent doesn't have any children then set the container to that parent and the index to 0
if (!parent.hasChildNodes()) {
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Apache/Solr.pm view on Meta::CPAN
sub _core_admin($@)
{ my ($self, $action, $params) = @_;
$params->{core} ||= $self->core;
my $endpoint = $self->endpoint('cores', core => 'admin', params => $params);
my @params = %$params;
my $result = Apache::Solr::Result->new(params => [ %$params ], endpoint => $endpoint, core => $self);
$self->request($endpoint, $result);
$result;
}
sub coreStatus(%)
view all matches for this distribution
view release on metacpan or search on metacpan
conf/server.xml.PL view on Meta::CPAN
subcomponents such as Valves or Loggers at this level.
-->
<Service>
<!--
A Connector represents an endpoint by which requests are received and
response are returned. Each Connector passes requests on to the
associated Container for processing.
By default, a non-secure Connector is enabled. You may also enable a
secure Connector by uncommenting the second Connector
view all matches for this distribution
view release on metacpan or search on metacpan
)
( #$3
( #$4 v
[^>]* #params and
)
\s/> #endpoint
| #or
( #5 v
[^>]* #params and
)
> #closure plus...
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Apigee/Edge.pm view on Meta::CPAN
for (qw/org usr pwd/) {
$args{$_} || croak "Param $_ is required.";
}
$args{endpoint} ||= 'https://api.enterprise.apigee.com/v1';
$args{timeout} ||= 60; # for ua timeout
return bless \%args, $class;
}
view all matches for this distribution
view release on metacpan or search on metacpan
t/pleroma_user.json view on Meta::CPAN
{"@context":["https://www.w3.org/ns/activitystreams","https://queer.hacktivis.me/schemas/litepub-0.1.jsonld",{"@language":"und"}],"alsoKnownAs":[],"attachment":[],"capabilities":{"acceptsChatMessages":true},"discoverable":true,"endpoints":{"oauthAuth...
view all matches for this distribution
view release on metacpan or search on metacpan
lib/App/Chart.pm view on Meta::CPAN
return File::Spec->catfile (File::Basename::dirname($INC{'App/Chart.pm'}),
'Chart', @_);
}
# return true if range ($alo,$ahi) overlaps range ($blo,$bhi)
# each endpoint is taken as inclusive, so say (1,4) and (4,7) do overlap
#
sub overlap_inclusive_p {
my ($alo, $ahi, $blo, $bhi) = @_;
return ! ($ahi < $blo || $alo > $bhi);
}
view all matches for this distribution
view release on metacpan or search on metacpan
- crictl images
- crictl ps -a
- crictl exec -it ... ls
- crictl logs ...
- crictl pods
- crictl --runtime-endpoint (?)
- For DEBUGGING.
# Pods recap (CKAD)
Pod
- Smallest possible creatable object.
view all matches for this distribution
view release on metacpan or search on metacpan
v1.1.1 - 2024-11-18
* Update to new API endpoints on cveawg.mitre.org (same data schema)
v1.1.0 - 2024-05-14
* Add support for CVE Schema 5.1
v1.0.5 - 2023-10-14
view all matches for this distribution
view release on metacpan or search on metacpan
lib/App/DuckPAN/Web.pm view on Meta::CPAN
my ($wrap_jsonp_callback, $callback, $wrap_string_callback, $missing_envs, $headers) =
($rewrite->wrap_jsonp_callback, $rewrite->callback, $rewrite->wrap_string_callback, defined($rewrite->missing_envs), $rewrite->headers);
# Check if environment variables (most likely the API key) is missing.
# If it is missing, switch to the DDG endpoint.
my ($use_ddh, $request_uri);
if ($missing_envs) {
++$use_ddh;
$request_uri = $request->request_uri;
# Display the URL that we used.
print "\nAPI key not found. Using DuckDuckGo's endpoint:\n";
}
$to = "https://beta.duckduckgo.com$request_uri" if $use_ddh;
my $h = HTTP::Headers->new( %$headers );
view all matches for this distribution
view release on metacpan or search on metacpan
lib/App/Egaz/Command/formats.pm view on Meta::CPAN
my $desc .= <<MARKDOWN;
* [lav format](http://www.bx.psu.edu/miller_lab/dist/lav_format.html)
Here <start> and <stop> are origin 1 (i.e. the first base in the original
given sequence is called '1') and inclusive (both endpoints are included
in the interval).
* [psl format](https://genome.ucsc.edu/FAQ/FAQformat.html#format2)
Be aware that the coordinates for a negative strand in a PSL line are
view all matches for this distribution