view release on metacpan or search on metacpan
lib/Kafka/Connection.pm view on Meta::CPAN
Optional, default value is 0 (false).
If set to false, when communicating with a broker, the client will
automatically try to find out the best version numbers to use for each of the
API endpoints.
If set to true, the client will always use
C<$Kafka::Protocol::DEFAULT_APIVERSION> as API version.
WARNING: API versions are supported starting from Kafka 0.10. Set this parameter to true
lib/Kafka/Connection.pm view on Meta::CPAN
# call the server and try to get the supported API versions
my $api_versions = [];
my $error;
try {
# The ApiVersions API endpoint is only supported on Kafka versions >
# 0.10.0.0 so this call may fail. We simply ignore this failure and
# carry on.
$api_versions = $self->_get_supported_api_versions( $server );
}
catch {
lib/Kafka/Connection.pm view on Meta::CPAN
foreach my $element (@$api_versions) {
# we want to choose which api version to use for each API call. We
# try to use the max version that the server supports, with
# fallback to the max version the protocol implements. If it's
# lower than the min version the kafka server supports, we set it
# to -1. If thie API endpoint is called, it'll die.
my $kafka_min_version = $element->{MinVersion};
my $kafka_max_version = $element->{MaxVersion};
my $api_key = $element->{ApiKey};
my $implemented_max_version = $IMPLEMENTED_APIVERSIONS->{$api_key} // -1;
my $version = $kafka_max_version;
view release on metacpan or search on metacpan
lib/Kanboard/API.pm view on Meta::CPAN
Kanboard::API is a Perl interface to the Kanboard API. It provides a simple way to interact with a Kanboard instance.
use Kanboard::API;
my $kanboard = Kanboard::API->new(username => 'yourusername|jsonrpc', password => 'apikey', endpoint => 'https://yourkanboardinstance.com');
...
=head1 ATTRIBUTES
=head2 username
lib/Kanboard/API.pm view on Meta::CPAN
=cut
has password => ( is => 'ro', required => 1 );
=head2 endpoint
The JSON RPC Endpoint of the Kanboard instance.
=cut
has endpoint => ( is => 'ro', required => 1 );
=head2 ua
The LWP::UserAgent object used to make requests.
lib/Kanboard/API.pm view on Meta::CPAN
method => $method,
params => $params // [],
};
my $body = encode_json($request_json);
my $request =
HTTP::Request->new( 'POST', $self->endpoint, $headers, $body );
my $response = $self->ua->request($request);
if ( $response->is_success ) {
my $content = $response->decoded_content;
view release on metacpan or search on metacpan
lib/Kayako/RestAPI.pm view on Meta::CPAN
'module' => 'tickets',
'title' => 'Flash drives department'
}
]
API endpoint is /Base/Department/
=head2 get_ticket_statuses_old
$kayako_api->get_ticket_statuses();
lib/Kayako/RestAPI.pm view on Meta::CPAN
'id' => '4',
'title' => 'New'
}
]
API endpoint is /Tickets/TicketStatus/
=head2 get_ticket_priorities_old
$kayako_api->get_ticket_priorities();
lib/Kayako/RestAPI.pm view on Meta::CPAN
'id' => '3',
'title' => 'Urgent'
},
]
API endpoint is /Tickets/TicketPriority/
=head2 get_ticket_types_old
$kayako_api->get_ticket_types();
lib/Kayako/RestAPI.pm view on Meta::CPAN
'id' => '5',
'title' => 'Feedback'
}
];
API endpoint is /Tickets/TicketType/
=head2 get_staff_old
$kayako_api->get_staff();
lib/Kayako/RestAPI.pm view on Meta::CPAN
'signature' => {},
'fullname' => { 'text' => 'Pavel Serikov' }
}
]
API endpoint is /Base/Staff/
=head1 AUTHOR
Pavel Serikov <pavelsr@cpan.org>
view release on metacpan or search on metacpan
lib/Kubernetes/REST.pm view on Meta::CPAN
# ============================================================================
sub _prepare_request {
my ($self, $method, $path, %opts) = @_;
my $url = $self->server->endpoint . $path;
my $content_type = $opts{content_type} // 'application/json';
my $body = $opts{body};
my $parameters = $opts{parameters};
my $extra_headers = $opts{headers} // {};
lib/Kubernetes/REST.pm view on Meta::CPAN
use Kubernetes::REST;
my $api = Kubernetes::REST->new(
server => {
endpoint => 'https://kubernetes.local:6443',
ssl_verify_server => 1,
ssl_ca_file => '/path/to/ca.crt',
},
credentials => { token => $token },
);
lib/Kubernetes/REST.pm view on Meta::CPAN
=head2 server
Required. L<Kubernetes::REST::Server> instance or hashref with server connection configuration.
server => { endpoint => 'https://kubernetes.local:6443' }
Automatically coerces hashrefs to L<Kubernetes::REST::Server> objects.
=head2 credentials
lib/Kubernetes/REST.pm view on Meta::CPAN
Set to C<0> to use L<IO::K8s> built-in resource map instead (faster startup, but may not match your cluster version).
=head2 cluster_version
Read-only. The Kubernetes cluster version string (e.g., C<v1.31.0>). Fetched automatically from the C</version> endpoint when first accessed.
=head2 resource_map
Hashref mapping short resource names to L<IO::K8s> class paths. By default loads dynamically from the cluster (if C<resource_map_from_cluster> is true) or uses L<IO::K8s> built-in map.
lib/Kubernetes/REST.pm view on Meta::CPAN
=head2 fetch_resource_map
my $map = $api->fetch_resource_map;
Fetch the resource map from the cluster's OpenAPI spec (C</openapi/v2> endpoint). Returns a hashref mapping short resource names (e.g., C<Pod>) to full L<IO::K8s> class paths.
Called automatically if C<resource_map_from_cluster> is enabled.
=head2 schema_for
lib/Kubernetes/REST.pm view on Meta::CPAN
=head2 server
Required. Connection details for the Kubernetes API server. Can be a hashref or
a L<Kubernetes::REST::Server> object.
server => { endpoint => 'https://kubernetes.local:6443' }
=head2 credentials
Required. Authentication credentials. Can be a hashref or a L<Kubernetes::REST::AuthToken>
object.
lib/Kubernetes/REST.pm view on Meta::CPAN
resource_map => { MyResource => 'Custom::V1::MyResource' }
=head2 cluster_version
Read-only. The Kubernetes cluster version string (e.g., "v1.31.0"). Fetched
automatically from the /version endpoint when first accessed.
=head1 METHODS
=head2 new_object($class, \%attrs) or new_object($class, %attrs)
lib/Kubernetes/REST.pm view on Meta::CPAN
Requires an IO backend implementing C<call_duplex>. The default sync backends
currently do not provide duplex transport.
=head2 fetch_resource_map()
Fetch the resource map from the cluster's OpenAPI spec (/openapi/v2 endpoint).
Returns a hashref mapping short resource names (e.g., "Pod") to full IO::K8s
class paths. This method is called automatically if C<resource_map_from_cluster>
is enabled.
=head1 BUILDING BLOCKS FOR ASYNC WRAPPERS
view release on metacpan or search on metacpan
eg/push-flex-message-showcases.pl view on Meta::CPAN
use LINE::Bot::API;
my $channel_secret = $ENV{CHANNEL_SECRET} or die "requiers env: CHANNEL_SECRET";
my $channel_access_token = $ENV{CHANNEL_ACCESS_TOKEN} or die "requires env: CHANNEL_ACCESS_TOKEN";
my $messaging_api_endpoint = $ENV{MESSAGING_API_ENDPOINT};
my($to_id) = @ARGV;
$to_id or die "requires \$ARGV[0]: a user ID";
my $bot = LINE::Bot::API->new(
channel_secret => $channel_secret,
channel_access_token => $channel_access_token,
$messaging_api_endpoint ? (
messaging_api_endpoint => $messaging_api_endpoint,
):(),
);
my $json = JSON->new->utf8;