AC-Yenta

 view release on metacpan or  search on metacpan

proto/auth.proto  view on Meta::CPAN

// Copyright (c) 2009 AdCopy
// Author: Jeff Weisberg
// Created: 2009-Sep-10 13:18 (EDT)
// Function: protocol authentication
//
// $Id$

message ACPAuth {
        required string         algorithm       = 1;
        // NYI
}

message ACPEncrypt {

        required string         algorithm       = 1;
        required fixed64        seqno           = 2;
        required string         nonce           = 3;
        required string         hmac            = 4;
        required int32          length          = 5;

        required bytes          ciphertext      = 50;
}

proto/heartbeat.proto  view on Meta::CPAN

// Copyright (c) 2008 AdCopy
// Author: Jeff Weisberg
// Created: 2008-Dec-15 19:23 (EST)
// Function: 
//
// $Id$

message ACPHeartBeat {
	required int32		status_code	= 1;
	optional string		status_message	= 2;
	optional fixed32	ipv4		= 3;
	optional int32		port		= 4;
	optional fixed64	timestamp	= 5;
	required string		subsystem	= 6;
	optional string		environment	= 7;
	optional int32		sort_metric	= 8;
        optional string         hostname        = 9;
        required string         server_id       = 10;
        required int32          process_id      = 11;
        optional int32          capacity_metric = 12;
}

proto/std_ipport.proto  view on Meta::CPAN

// Copyright (c) 2008 AdCopy
// Author: Jeff Weisberg
// Created: 2008-Dec-19 13:23 (EST)
// Function: 
//
// $Id$

message ACPIPPort {
	required fixed32	ipv4		= 1;
	optional int32		port		= 2;
        optional string         natdom          = 3;
}

proto/std_reply.proto  view on Meta::CPAN

// Copyright (c) 2008 AdCopy
// Author: Jeff Weisberg
// Created: 2008-Dec-15 19:19 (EST)
// Function: 
//
// $Id$

message ACPStdReply {
	required int32		status_code	= 1;
	optional string		status_message	= 2;
}

proto/yenta_check.proto  view on Meta::CPAN

// Copyright (c) 2009 AdCopy
// Author: Jeff Weisberg
// Created: 2009-Apr-01 10:57 (EDT)
// Function: 
//
// $Id$


message ACPYentaCheckValue {
        required string         map             = 1;
        required int64          version         = 2;
        optional int32          level           = 3;
        optional string         key             = 4;
        optional string         hash            = 5;
        optional int64          shard           = 6;
};

message ACPYentaCheckRequest {
        required string         map             = 1;
        required int32          level           = 2;
        required int64          version         = 3;
        optional int64          shard           = 4;
};

message ACPYentaCheckReply {
        repeated ACPYentaCheckValue check     = 1;
};

proto/yenta_getset.proto  view on Meta::CPAN

// Copyright (c) 2009 AdCopy
// Author: Jeff Weisberg
// Created: 2009-Apr-01 10:41 (EDT)
// Function: 
//
// $Id$

message ACPYentaMapDatum {
        required string         map             = 1;
        required string         key             = 2;
        optional int64          version         = 3;
        optional bytes          value           = 4;
        optional bytes          meta            = 5;
        optional bytes          file            = 6;
        optional int64          shard           = 7;
};

message ACPYentaGetSet {
        repeated ACPYentaMapDatum data          = 1;
};

message ACPYentaDistRequest {
        required int32          hop             = 1;
        required int64          expire          = 2;
        required string         sender          = 3;
        required ACPYentaMapDatum datum         = 4;
};

message ACPYentaDistReply {
	required int32		status_code	= 1;
	required string		status_message	= 2;
        required bool           haveit          = 3;
};

proto/yenta_status.proto  view on Meta::CPAN

// Copyright (c) 2009 AdCopy
// Author: Jeff Weisberg
// Created: 2009-Mar-27 16:05 (EDT)
// Function: yenta status exchanges
//
// $Id$

import "std_ipport.proto";

message ACPYentaStatus {
        required string         hostname        = 1;
        required string         datacenter      = 2;
	required string		subsystem	= 3;
        required string         environment     = 4;
        required string         via             = 5;
        repeated ACPIPPort      ip              = 6;
        required int32          status          = 7;
        required int64          timestamp       = 8;
        required int64          lastup          = 9;
        repeated string         map             = 10;
        optional bool           uptodate        = 11;
	optional int32		sort_metric	= 12;

        required string         server_id       = 13;   // typically IP:PORT
        required string         instance_id     = 14;   // for loop detection
        optional string         path            = 15;   // for debugging

        optional int32          capacity_metric = 16;   // bouncr slots
};

message ACPYentaStatusRequest {
        optional ACPYentaStatus  myself          = 1;
};

message ACPYentaStatusReply {