?? GreyFile

?? GreyFile — Mystic File Browser

Current path: home/webdevt/prestashop17/modules/ps_metrics/vendor/segmentio/analytics-php/lib/Segment/

?? Go up: /home/webdevt/prestashop17/modules/ps_metrics/vendor/segmentio/analytics-php/lib

?? Editing: QueueConsumer.php

<?php
abstract class Segment_QueueConsumer extends Segment_Consumer {

protected $type = "QueueConsumer";

protected $queue;
  protected $max_queue_size = 1000;
  protected $batch_size = 100;

/**
   * Store our secret and options as part of this consumer
   * @param string $secret
   * @param array  $options
   */
  public function __construct($secret, $options = array()) {
    parent::__construct($secret, $options);

if (isset($options["max_queue_size"]))
      $this->max_queue_size = $options["max_queue_size"];

if (isset($options["batch_size"]))
      $this->batch_size = $options["batch_size"];

$this->queue = array();
  }

public function __destruct() {
    # Flush our queue on destruction
    $this->flush();
  }

/**
   * Tracks a user action
   *
   * @param  array  $message
   * @return boolean whether the track call succeeded
   */
  public function track(array $message) {
    return $this->enqueue($message);
  }

/**
   * Tags traits about the user.
   *
   * @param  array  $message
   * @return boolean whether the identify call succeeded
   */
  public function identify(array $message) {
    return $this->enqueue($message);
  }

/**
   * Tags traits about the group.
   *
   * @param  array  $message
   * @return boolean whether the group call succeeded
   */
  public function group(array $message) {
    return $this->enqueue($message);
  }

/**
   * Tracks a page view.
   *
   * @param  array  $message
   * @return boolean whether the page call succeeded
   */
  public function page(array $message) {
    return $this->enqueue($message);
  }

/**
   * Tracks a screen view.
   *
   * @param  array  $message
   * @return boolean whether the screen call succeeded
   */
  public function screen(array $message) {
    return $this->enqueue($message);
  }

/**
   * Aliases from one user id to another
   *
   * @param  array $message
   * @return boolean whether the alias call succeeded
   */
  public function alias(array $message) {
    return $this->enqueue($message);
  }

/**
   * Adds an item to our queue.
   * @param  mixed   $item
   * @return boolean whether the queue has room
   */
  protected function enqueue($item) {

$count = count($this->queue);

if ($count > $this->max_queue_size)
      return false;

$count = array_push($this->queue, $item);

if ($count > $this->batch_size)
      $this->flush();

return true;
  }

/**
   * Flushes our queue of messages by batching them to the server
   */
  public function flush() {

$count = count($this->queue);
    $success = true;

while($count > 0 && $success) {

$batch = array_splice($this->queue, 0, min($this->batch_size, $count));
      $success = $this->flushBatch($batch);

$count = count($this->queue);
    }

return $success;
  }

/**
   * Flushes a batch of messages.
   * @param  [type] $batch [description]
   * @return [type]        [description]
   */
  abstract function flushBatch($batch);
}

?? Consumer | ??? Delete
?? Client.php | ?? Edit | ??? Delete
?? Consumer.php | ?? Edit | ??? Delete
?? index.php | ?? Edit | ??? Delete
?? QueueConsumer.php | ?? Edit | ??? Delete