Packages

snakepit

0.3.2
0.13.0 0.12.0 0.11.1 0.11.0 0.10.1 0.10.0 0.9.1 0.9.0 0.8.9 0.8.8 0.8.7 0.8.6 0.8.5 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.7 0.7.6 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.11 0.6.10 0.6.9 0.6.8 0.6.7 0.6.6 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.1 0.5.0 0.4.3 0.4.2 0.4.1 0.4.0 0.3.3 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 0.1.2 0.1.1 0.1.0

High-performance pooler and session manager for external language integrations. Supports Python, Node.js, Ruby, and more with gRPC streaming, session management, and production-ready process cleanup.

HexDocs

Current section

Files

Jump to
Readme
53 Versions
4 Dependencies
Dependants
Files
Activity
snakepit priv python snakepit_bridge grpc snakepit_pb2.py
Raw

priv/python/snakepit_bridge/grpc/snakepit_pb2.py 

# -*- coding: utf-8 -*-

# Generated by the protocol buffer compiler.  DO NOT EDIT!

# NO CHECKED-IN PROTOBUF GENCODE

# source: snakepit.proto

# Protobuf Python Version: 6.31.0

"""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,

    0,

    '',

    'snakepit.proto'

)

# @@protoc_insertion_point(imports)



_sym_db = _symbol_database.Default()









DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0esnakepit.proto\x12\x08snakepit\"\xa8\x01\n\x0e\x45xecuteRequest\x12\x0f\n\x07\x63ommand\x18\x01 \x01(\t\x12\x30\n\x04\x61rgs\x18\x02 \x03(\x0b\x32\".snakepit.ExecuteRequest.ArgsEntry\x12\x12\n\ntimeout_ms\x18\x03 \x01(\x05\x12\x12\n\nrequest_id\x18\x04 \x01(\t\x1a+\n\tArgsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01\"\xbe\x01\n\x0f\x45xecuteResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x35\n\x06result\x18\x02 \x03(\x0b\x32%.snakepit.ExecuteResponse.ResultEntry\x12\r\n\x05\x65rror\x18\x03 \x01(\t\x12\x11\n\ttimestamp\x18\x04 \x01(\x03\x12\x12\n\nrequest_id\x18\x05 \x01(\t\x1a-\n\x0bResultEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01\"\xcf\x01\n\x0eStreamResponse\x12\x10\n\x08is_final\x18\x01 \x01(\x08\x12\x32\n\x05\x63hunk\x18\x02 \x03(\x0b\x32#.snakepit.StreamResponse.ChunkEntry\x12\r\n\x05\x65rror\x18\x03 \x01(\t\x12\x11\n\ttimestamp\x18\x04 \x01(\x03\x12\x12\n\nrequest_id\x18\x05 \x01(\t\x12\x13\n\x0b\x63hunk_index\x18\x06 \x01(\x05\x1a,\n\nChunkEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01\"\xbc\x01\n\x0eSessionRequest\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12\x0f\n\x07\x63ommand\x18\x02 \x01(\t\x12\x30\n\x04\x61rgs\x18\x03 \x03(\x0b\x32\".snakepit.SessionRequest.ArgsEntry\x12\x12\n\ntimeout_ms\x18\x04 \x01(\x05\x12\x12\n\nrequest_id\x18\x05 \x01(\t\x1a+\n\tArgsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01\"\"\n\rHealthRequest\x12\x11\n\tworker_id\x18\x01 \x01(\t\"\x86\x01\n\x0eHealthResponse\x12\x0f\n\x07healthy\x18\x01 \x01(\x08\x12\x11\n\tworker_id\x18\x02 \x01(\t\x12\x11\n\tuptime_ms\x18\x03 \x01(\x03\x12\x16\n\x0etotal_requests\x18\x04 \x01(\x03\x12\x14\n\x0ctotal_errors\x18\x05 \x01(\x03\x12\x0f\n\x07version\x18\x06 \x01(\t\"B\n\x0bInfoRequest\x12\x1c\n\x14include_capabilities\x18\x01 \x01(\x08\x12\x15\n\rinclude_stats\x18\x02 \x01(\x08\"\xdb\x02\n\x0cInfoResponse\x12\x13\n\x0bworker_type\x18\x01 \x01(\t\x12\x0f\n\x07version\x18\x02 \x01(\t\x12\x1a\n\x12supported_commands\x18\x03 \x03(\t\x12>\n\x0c\x63\x61pabilities\x18\x04 \x03(\x0b\x32(.snakepit.InfoResponse.CapabilitiesEntry\x12$\n\x05stats\x18\x05 \x01(\x0b\x32\x15.snakepit.WorkerStats\x12;\n\x0bsystem_info\x18\x06 \x03(\x0b\x32&.snakepit.InfoResponse.SystemInfoEntry\x1a\x33\n\x11\x43\x61pabilitiesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x1a\x31\n\x0fSystemInfoEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xa3\x01\n\x0bWorkerStats\x12\x18\n\x10requests_handled\x18\x01 \x01(\x03\x12\x17\n\x0frequests_failed\x18\x02 \x01(\x03\x12\x11\n\tuptime_ms\x18\x03 \x01(\x03\x12\x1a\n\x12memory_usage_bytes\x18\x04 \x01(\x03\x12\x19\n\x11\x63pu_usage_percent\x18\x05 \x01(\x01\x12\x17\n\x0f\x61\x63tive_sessions\x18\x06 \x01(\x03\x32\xa7\x03\n\x0eSnakepitBridge\x12>\n\x07\x45xecute\x12\x18.snakepit.ExecuteRequest\x1a\x19.snakepit.ExecuteResponse\x12\x45\n\rExecuteStream\x12\x18.snakepit.ExecuteRequest\x1a\x18.snakepit.StreamResponse0\x01\x12G\n\x10\x45xecuteInSession\x12\x18.snakepit.SessionRequest\x1a\x19.snakepit.ExecuteResponse\x12N\n\x16\x45xecuteInSessionStream\x12\x18.snakepit.SessionRequest\x1a\x18.snakepit.StreamResponse0\x01\x12;\n\x06Health\x12\x17.snakepit.HealthRequest\x1a\x18.snakepit.HealthResponse\x12\x38\n\x07GetInfo\x12\x15.snakepit.InfoRequest\x1a\x16.snakepit.InfoResponseb\x06proto3')



_globals = globals()

_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)

_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'snakepit_pb2', _globals)

if not _descriptor._USE_C_DESCRIPTORS:

  DESCRIPTOR._loaded_options = None

  _globals['_EXECUTEREQUEST_ARGSENTRY']._loaded_options = None

  _globals['_EXECUTEREQUEST_ARGSENTRY']._serialized_options = b'8\001'

  _globals['_EXECUTERESPONSE_RESULTENTRY']._loaded_options = None

  _globals['_EXECUTERESPONSE_RESULTENTRY']._serialized_options = b'8\001'

  _globals['_STREAMRESPONSE_CHUNKENTRY']._loaded_options = None

  _globals['_STREAMRESPONSE_CHUNKENTRY']._serialized_options = b'8\001'

  _globals['_SESSIONREQUEST_ARGSENTRY']._loaded_options = None

  _globals['_SESSIONREQUEST_ARGSENTRY']._serialized_options = b'8\001'

  _globals['_INFORESPONSE_CAPABILITIESENTRY']._loaded_options = None

  _globals['_INFORESPONSE_CAPABILITIESENTRY']._serialized_options = b'8\001'

  _globals['_INFORESPONSE_SYSTEMINFOENTRY']._loaded_options = None

  _globals['_INFORESPONSE_SYSTEMINFOENTRY']._serialized_options = b'8\001'

  _globals['_EXECUTEREQUEST']._serialized_start=29

  _globals['_EXECUTEREQUEST']._serialized_end=197

  _globals['_EXECUTEREQUEST_ARGSENTRY']._serialized_start=154

  _globals['_EXECUTEREQUEST_ARGSENTRY']._serialized_end=197

  _globals['_EXECUTERESPONSE']._serialized_start=200

  _globals['_EXECUTERESPONSE']._serialized_end=390

  _globals['_EXECUTERESPONSE_RESULTENTRY']._serialized_start=345

  _globals['_EXECUTERESPONSE_RESULTENTRY']._serialized_end=390

  _globals['_STREAMRESPONSE']._serialized_start=393

  _globals['_STREAMRESPONSE']._serialized_end=600

  _globals['_STREAMRESPONSE_CHUNKENTRY']._serialized_start=556

  _globals['_STREAMRESPONSE_CHUNKENTRY']._serialized_end=600

  _globals['_SESSIONREQUEST']._serialized_start=603

  _globals['_SESSIONREQUEST']._serialized_end=791

  _globals['_SESSIONREQUEST_ARGSENTRY']._serialized_start=154

  _globals['_SESSIONREQUEST_ARGSENTRY']._serialized_end=197

  _globals['_HEALTHREQUEST']._serialized_start=793

  _globals['_HEALTHREQUEST']._serialized_end=827

  _globals['_HEALTHRESPONSE']._serialized_start=830

  _globals['_HEALTHRESPONSE']._serialized_end=964

  _globals['_INFOREQUEST']._serialized_start=966

  _globals['_INFOREQUEST']._serialized_end=1032

  _globals['_INFORESPONSE']._serialized_start=1035

  _globals['_INFORESPONSE']._serialized_end=1382

  _globals['_INFORESPONSE_CAPABILITIESENTRY']._serialized_start=1280

  _globals['_INFORESPONSE_CAPABILITIESENTRY']._serialized_end=1331

  _globals['_INFORESPONSE_SYSTEMINFOENTRY']._serialized_start=1333

  _globals['_INFORESPONSE_SYSTEMINFOENTRY']._serialized_end=1382

  _globals['_WORKERSTATS']._serialized_start=1385

  _globals['_WORKERSTATS']._serialized_end=1548

  _globals['_SNAKEPITBRIDGE']._serialized_start=1551

  _globals['_SNAKEPITBRIDGE']._serialized_end=1974

# @@protoc_insertion_point(module_scope)