orchestrata_ultimate.cxp.proto.cxp_pb2

Reference › orchestrata_ultimate › cxp › proto › cxp_pb2

cxp_pb2 is the generated protocol buffer module for the CXP wire messages (packet, receipt, health, status, subscription, acknowledgement and the status enums). It is produced by the protobuf compiler and is not edited by hand. It imports nothing from the project. servicer, proto_codec and direct_cxp_adapter use its message classes, and the proto package re-exports them.

At a glance

Class diagram

No classes; see Functions.

Dependency diagram

API

No public API: the module defines no classes, functions or constants.

Source

Permalink: https://gitlab.com/MSamy/orchestrata-ultimate-architecture/-/blob/a4cbc2bdf/src/orchestrata_ultimate/cxp/proto/cxp_pb2.py

# Generated by the protocol buffer compiler.  DO NOT EDIT!
# NO CHECKED-IN PROTOBUF GENCODE
# source: cxp.proto
# Protobuf Python Version: 6.31.1
"""Generated protocol buffer code."""

from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import runtime_version as _runtime_version
from google.protobuf import symbol_database as _symbol_database
from google.protobuf.internal import builder as _builder

_runtime_version.ValidateProtobufRuntimeVersion(
    _runtime_version.Domain.PUBLIC, 6, 31, 1, "", "cxp.proto"
)
# @@protoc_insertion_point(imports)

_sym_db = _symbol_database.Default()


DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(
    b'\n\tcxp.proto\x12\x0forchestrata.cxp\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1cgoogle/protobuf/struct.proto"\xa2\x04\n\tCXPPacket\x12\x12\n\nmessage_id\x18\x01 \x01(\t\x12\x12\n\nfrom_agent\x18\x02 \x01(\t\x12\x10\n\x08to_agent\x18\x03 \x01(\t\x12\x11\n\tthread_id\x18\x04 \x01(\t\x12\x0f\n\x07subject\x18\x05 \x01(\t\x12(\n\x07payload\x18\x06 \x01(\x0b\x32\x17.google.protobuf.Struct\x12-\n\ttimestamp\x18\x07 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x10\n\x08priority\x18\x08 \x01(\x05\x12\x38\n\x0f\x64\x65livery_status\x18\t \x01(\x0e\x32\x1f.orchestrata.cxp.DeliveryStatus\x12\x30\n\x0bwork_status\x18\n \x01(\x0e\x32\x1b.orchestrata.cxp.WorkStatus\x12\x18\n\x10protocol_version\x18\x0b \x01(\t\x12\x30\n\x0bpacket_type\x18\x0c \x01(\x0e\x32\x1b.orchestrata.cxp.PacketType\x12\x12\n\nsession_id\x18\r \x01(\t\x12:\n\x08metadata\x18\x0e \x03(\x0b\x32(.orchestrata.cxp.CXPPacket.MetadataEntry\x12\x13\n\x0bttl_seconds\x18\x0f \x01(\x05\x1a/\n\rMetadataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01"\x96\x01\n\nCXPReceipt\x12\x12\n\nmessage_id\x18\x01 \x01(\t\x12\x0f\n\x07success\x18\x02 \x01(\x08\x12\x15\n\rerror_message\x18\x03 \x01(\t\x12/\n\x0breceived_at\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x1b\n\x13\x64\x65livery_latency_ms\x18\x05 \x01(\x05"$\n\x10\x43XPHealthRequest\x12\x10\n\x08\x61gent_id\x18\x01 \x01(\t"|\n\x11\x43XPHealthResponse\x12\x0f\n\x07healthy\x18\x01 \x01(\x08\x12\x0e\n\x06status\x18\x02 \x01(\t\x12\x16\n\x0euptime_seconds\x18\x03 \x01(\x03\x12\x14\n\x0cpackets_sent\x18\x04 \x01(\x05\x12\x18\n\x10packets_received\x18\x05 \x01(\x05"T\n\x11\x43XPReceiveRequest\x12\x10\n\x08\x61gent_id\x18\x01 \x01(\t\x12\x17\n\x0ftimeout_seconds\x18\x02 \x01(\x05\x12\x14\n\x0cmax_messages\x18\x03 \x01(\x05"J\n\x0f\x43XPSubscription\x12\x10\n\x08\x61gent_id\x18\x01 \x01(\t\x12\x10\n\x08subjects\x18\x02 \x03(\t\x12\x13\n\x0b\x66rom_agents\x18\x03 \x03(\t"Z\n\x06\x43XPAck\x12\x12\n\nmessage_id\x18\x01 \x01(\t\x12\x10\n\x08\x61gent_id\x18\x02 \x01(\t\x12*\n\x06status\x18\x03 \x01(\x0e\x32\x1a.orchestrata.cxp.AckStatus""\n\rStatusRequest\x12\x11\n\trequester\x18\x01 \x01(\t"p\n\nVolkStatus\x12\r\n\x05\x61lias\x18\x01 \x01(\t\x12\x0c\n\x04role\x18\x02 \x01(\t\x12\x0e\n\x06status\x18\x03 \x01(\t\x12\x0f\n\x07summary\x18\x04 \x01(\t\x12\x16\n\x0e\x63urrent_thread\x18\x05 \x01(\t\x12\x0c\n\x04\x62usy\x18\x06 \x01(\x08":\n\x0cStatusReport\x12*\n\x05volks\x18\x01 \x03(\x0b\x32\x1b.orchestrata.cxp.VolkStatus*\xaa\x01\n\x0e\x44\x65liveryStatus\x12\x1f\n\x1b\x44\x45LIVERY_STATUS_UNSPECIFIED\x10\x00\x12\x1a\n\x16\x44\x45LIVERY_STATUS_QUEUED\x10\x01\x12\x1d\n\x19\x44\x45LIVERY_STATUS_DELIVERED\x10\x02\x12 \n\x1c\x44\x45LIVERY_STATUS_ACKNOWLEDGED\x10\x03\x12\x1a\n\x16\x44\x45LIVERY_STATUS_FAILED\x10\x04*\x93\x01\n\nWorkStatus\x12\x1b\n\x17WORK_STATUS_UNSPECIFIED\x10\x00\x12\x17\n\x13WORK_STATUS_PENDING\x10\x01\x12\x1b\n\x17WORK_STATUS_IN_PROGRESS\x10\x02\x12\x18\n\x14WORK_STATUS_RESOLVED\x10\x03\x12\x18\n\x14WORK_STATUS_ARCHIVED\x10\x04*\xfd\x01\n\nPacketType\x12\x1b\n\x17PACKET_TYPE_UNSPECIFIED\x10\x00\x12\x17\n\x13PACKET_TYPE_MESSAGE\x10\x01\x12\x15\n\x11PACKET_TYPE_QUERY\x10\x02\x12\x17\n\x13PACKET_TYPE_COMMAND\x10\x03\x12\x18\n\x14PACKET_TYPE_RESPONSE\x10\x04\x12\x1f\n\x1bPACKET_TYPE_ACKNOWLEDGEMENT\x10\x05\x12\x15\n\x11PACKET_TYPE_ERROR\x10\x06\x12\x19\n\x15PACKET_TYPE_HEARTBEAT\x10\x07\x12\x1c\n\x18PACKET_TYPE_NOTIFICATION\x10\x08*m\n\tAckStatus\x12\x1a\n\x16\x41\x43K_STATUS_UNSPECIFIED\x10\x00\x12\x16\n\x12\x41\x43K_STATUS_SUCCESS\x10\x01\x12\x16\n\x12\x41\x43K_STATUS_FAILURE\x10\x02\x12\x14\n\x10\x41\x43K_STATUS_RETRY\x10\x03\x32\xc3\x02\n\tCXPServer\x12\x45\n\nSendPacket\x12\x1a.orchestrata.cxp.CXPPacket\x1a\x1b.orchestrata.cxp.CXPReceipt\x12M\n\x10SendPacketStream\x12\x1a.orchestrata.cxp.CXPPacket\x1a\x1b.orchestrata.cxp.CXPReceipt(\x01\x12T\n\x0bHealthCheck\x12!.orchestrata.cxp.CXPHealthRequest\x1a".orchestrata.cxp.CXPHealthResponse\x12J\n\tGetStatus\x12\x1e.orchestrata.cxp.StatusRequest\x1a\x1d.orchestrata.cxp.StatusReport2\xf2\x01\n\x0b\x43XPReceiver\x12Q\n\rReceivePacket\x12".orchestrata.cxp.CXPReceiveRequest\x1a\x1a.orchestrata.cxp.CXPPacket0\x01\x12K\n\tSubscribe\x12 .orchestrata.cxp.CXPSubscription\x1a\x1a.orchestrata.cxp.CXPPacket0\x01\x12\x43\n\x0b\x41\x63knowledge\x12\x17.orchestrata.cxp.CXPAck\x1a\x1b.orchestrata.cxp.CXPReceiptb\x06proto3'
)

_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, "cxp_pb2", _globals)
if not _descriptor._USE_C_DESCRIPTORS:
    DESCRIPTOR._loaded_options = None
    _globals["_CXPPACKET_METADATAENTRY"]._loaded_options = None
    _globals["_CXPPACKET_METADATAENTRY"]._serialized_options = b"8\001"
    _globals["_DELIVERYSTATUS"]._serialized_start = 1424
    _globals["_DELIVERYSTATUS"]._serialized_end = 1594
    _globals["_WORKSTATUS"]._serialized_start = 1597
    _globals["_WORKSTATUS"]._serialized_end = 1744
    _globals["_PACKETTYPE"]._serialized_start = 1747
    _globals["_PACKETTYPE"]._serialized_end = 2000
    _globals["_ACKSTATUS"]._serialized_start = 2002
    _globals["_ACKSTATUS"]._serialized_end = 2111
    _globals["_CXPPACKET"]._serialized_start = 94
    _globals["_CXPPACKET"]._serialized_end = 640
    _globals["_CXPPACKET_METADATAENTRY"]._serialized_start = 593
    _globals["_CXPPACKET_METADATAENTRY"]._serialized_end = 640
    _globals["_CXPRECEIPT"]._serialized_start = 643
    _globals["_CXPRECEIPT"]._serialized_end = 793
    _globals["_CXPHEALTHREQUEST"]._serialized_start = 795
    _globals["_CXPHEALTHREQUEST"]._serialized_end = 831
    _globals["_CXPHEALTHRESPONSE"]._serialized_start = 833
    _globals["_CXPHEALTHRESPONSE"]._serialized_end = 957
    _globals["_CXPRECEIVEREQUEST"]._serialized_start = 959
    _globals["_CXPRECEIVEREQUEST"]._serialized_end = 1043
    _globals["_CXPSUBSCRIPTION"]._serialized_start = 1045
    _globals["_CXPSUBSCRIPTION"]._serialized_end = 1119
    _globals["_CXPACK"]._serialized_start = 1121
    _globals["_CXPACK"]._serialized_end = 1211
    _globals["_STATUSREQUEST"]._serialized_start = 1213
    _globals["_STATUSREQUEST"]._serialized_end = 1247
    _globals["_VOLKSTATUS"]._serialized_start = 1249
    _globals["_VOLKSTATUS"]._serialized_end = 1361
    _globals["_STATUSREPORT"]._serialized_start = 1363
    _globals["_STATUSREPORT"]._serialized_end = 1421
    _globals["_CXPSERVER"]._serialized_start = 2114
    _globals["_CXPSERVER"]._serialized_end = 2437
    _globals["_CXPRECEIVER"]._serialized_start = 2440
    _globals["_CXPRECEIVER"]._serialized_end = 2682
# @@protoc_insertion_point(module_scope)