Skip to content

Add baseline glutton #243

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Max Smythe (maxsmythe) wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Add baseline glutton #243

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
106 changes: 53 additions & 53 deletions benchmarking/locust/common/ateapi_pb2.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
# Generated by the protocol buffer compiler. DO NOT EDIT!
# NO CHECKED-IN PROTOBUF GENCODE
# source: ateapi.proto
# Protobuf Python Version: 6.31.1
# Protobuf Python Version: 6.33.5
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
Expand All @@ -26,8 +26,8 @@
_runtime_version.ValidateProtobufRuntimeVersion(
_runtime_version.Domain.PUBLIC,
6,
31,
1,
33,
5,
'',
'ateapi.proto'
)
Expand All @@ -38,7 +38,7 @@



DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0c\x61teapi.proto\x12\x06\x61teapi\"\x87\x03\n\x05\x41\x63tor\x12\x10\n\x08\x61\x63tor_id\x18\x01 \x01(\t\x12\x0f\n\x07version\x18\x02 \x01(\x03\x12 \n\x18\x61\x63tor_template_namespace\x18\x03 \x01(\t\x12\x1b\n\x13\x61\x63tor_template_name\x18\x04 \x01(\t\x12$\n\x06status\x18\x05 \x01(\x0e\x32\x14.ateapi.Actor.Status\x12\x1b\n\x13\x61teom_pod_namespace\x18\x06 \x01(\t\x12\x16\n\x0e\x61teom_pod_name\x18\x07 \x01(\t\x12\x14\n\x0c\x61teom_pod_ip\x18\x08 \x01(\t\x12\x15\n\rlast_snapshot\x18\t \x01(\t\x12\x1c\n\x14in_progress_snapshot\x18\n \x01(\t\"v\n\x06Status\x12\x16\n\x12STATUS_UNSPECIFIED\x10\x00\x12\x13\n\x0fSTATUS_RESUMING\x10\x01\x12\x12\n\x0eSTATUS_RUNNING\x10\x02\x12\x15\n\x11STATUS_SUSPENDING\x10\x03\x12\x14\n\x10STATUS_SUSPENDED\x10\x04\"#\n\x0fGetActorRequest\x12\x10\n\x08\x61\x63tor_id\x18\x01 \x01(\t\"0\n\x10GetActorResponse\x12\x1c\n\x05\x61\x63tor\x18\x01 \x01(\x0b\x32\r.ateapi.Actor\"e\n\x12\x43reateActorRequest\x12\x10\n\x08\x61\x63tor_id\x18\x01 \x01(\t\x12 \n\x18\x61\x63tor_template_namespace\x18\x02 \x01(\t\x12\x1b\n\x13\x61\x63tor_template_name\x18\x03 \x01(\t\"3\n\x13\x43reateActorResponse\x12\x1c\n\x05\x61\x63tor\x18\x01 \x01(\x0b\x32\r.ateapi.Actor\"\'\n\x13SuspendActorRequest\x12\x10\n\x08\x61\x63tor_id\x18\x01 \x01(\t\"4\n\x14SuspendActorResponse\x12\x1c\n\x05\x61\x63tor\x18\x01 \x01(\x0b\x32\r.ateapi.Actor\"4\n\x12ResumeActorRequest\x12\x10\n\x08\x61\x63tor_id\x18\x01 \x01(\t\x12\x0c\n\x04\x62oot\x18\x02 \x01(\x08\"3\n\x13ResumeActorResponse\x12\x1c\n\x05\x61\x63tor\x18\x01 \x01(\x0b\x32\r.ateapi.Actor\"&\n\x12\x44\x65leteActorRequest\x12\x10\n\x08\x61\x63tor_id\x18\x01 \x01(\t\"\x15\n\x13\x44\x65leteActorResponse\"\x14\n\x12ListWorkersRequest\"6\n\x13ListWorkersResponse\x12\x1f\n\x07workers\x18\x01 \x03(\x0b\x32\x0e.ateapi.Worker\"\x13\n\x11ListActorsRequest\"3\n\x12ListActorsResponse\x12\x1d\n\x06\x61\x63tors\x18\x01 \x03(\x0b\x32\r.ateapi.Actor\"\xab\x01\n\x06Worker\x12\x18\n\x10worker_namespace\x18\x01 \x01(\t\x12\x13\n\x0bworker_pool\x18\x02 \x01(\t\x12\x12\n\nworker_pod\x18\x03 \x01(\t\x12\x17\n\x0f\x61\x63tor_namespace\x18\x04 \x01(\t\x12\x16\n\x0e\x61\x63tor_template\x18\x05 \x01(\t\x12\x10\n\x08\x61\x63tor_id\x18\x06 \x01(\t\x12\n\n\x02ip\x18\x07 \x01(\t\x12\x0f\n\x07version\x18\x08 \x01(\x03\"\x13\n\x11\x44\x65\x62ugClearRequest\"\x14\n\x12\x44\x65\x62ugClearResponse\"W\n\x0eMintJWTRequest\x12\x10\n\x08\x61udience\x18\x01 \x03(\t\x12\x0e\n\x06\x61pp_id\x18\x02 \x01(\t\x12\x0f\n\x07user_id\x18\x03 \x01(\t\x12\x12\n\nsession_id\x18\x04 \x01(\t\"&\n\x0fMintJWTResponse\x12\x13\n\x0bsession_jwt\x18\x01 \x01(\t\"k\n\x0fMintCertRequest\x12\x0e\n\x06\x61pp_id\x18\x01 \x01(\t\x12\x0f\n\x07user_id\x18\x02 \x01(\t\x12\x12\n\nsession_id\x18\x03 \x01(\t\x12#\n\x1b\x63\x65rtificate_signing_request\x18\x04 \x01(\x0c\"0\n\x10MintCertResponse\x12\x1c\n\x14session_certificates\x18\x01 \x03(\x0c\x32\xcd\x04\n\x07\x43ontrol\x12?\n\x08GetActor\x12\x17.ateapi.GetActorRequest\x1a\x18.ateapi.GetActorResponse\"\x00\x12H\n\x0b\x43reateActor\x12\x1a.ateapi.CreateActorRequest\x1a\x1b.ateapi.CreateActorResponse\"\x00\x12K\n\x0cSuspendActor\x12\x1b.ateapi.SuspendActorRequest\x1a\x1c.ateapi.SuspendActorResponse\"\x00\x12H\n\x0bResumeActor\x12\x1a.ateapi.ResumeActorRequest\x1a\x1b.ateapi.ResumeActorResponse\"\x00\x12H\n\x0b\x44\x65leteActor\x12\x1a.ateapi.DeleteActorRequest\x1a\x1b.ateapi.DeleteActorResponse\"\x00\x12H\n\x0bListWorkers\x12\x1a.ateapi.ListWorkersRequest\x1a\x1b.ateapi.ListWorkersResponse\"\x00\x12\x45\n\nListActors\x12\x19.ateapi.ListActorsRequest\x1a\x1a.ateapi.ListActorsResponse\"\x00\x12\x45\n\nDebugClear\x12\x19.ateapi.DebugClearRequest\x1a\x1a.ateapi.DebugClearResponse\"\x00\x32\x8c\x01\n\x0fSessionIdentity\x12:\n\x07MintJWT\x12\x16.ateapi.MintJWTRequest\x1a\x17.ateapi.MintJWTResponse\x12=\n\x08MintCert\x12\x17.ateapi.MintCertRequest\x1a\x18.ateapi.MintCertResponseB9Z7github.com/agent-substrate/substrate/pkg/proto/ateapipbb\x06proto3')
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0c\x61teapi.proto\x12\x06\x61teapi\"\x9e\x03\n\x05\x41\x63tor\x12\x10\n\x08\x61\x63tor_id\x18\x01 \x01(\t\x12\x0f\n\x07version\x18\x02 \x01(\x03\x12 \n\x18\x61\x63tor_template_namespace\x18\x03 \x01(\t\x12\x1b\n\x13\x61\x63tor_template_name\x18\x04 \x01(\t\x12$\n\x06status\x18\x05 \x01(\x0e\x32\x14.ateapi.Actor.Status\x12\x1b\n\x13\x61teom_pod_namespace\x18\x06 \x01(\t\x12\x16\n\x0e\x61teom_pod_name\x18\x07 \x01(\t\x12\x14\n\x0c\x61teom_pod_ip\x18\x08 \x01(\t\x12\x15\n\rlast_snapshot\x18\t \x01(\t\x12\x1c\n\x14in_progress_snapshot\x18\n \x01(\t\x12\x15\n\rateom_pod_uid\x18\x0b \x01(\t\"v\n\x06Status\x12\x16\n\x12STATUS_UNSPECIFIED\x10\x00\x12\x13\n\x0fSTATUS_RESUMING\x10\x01\x12\x12\n\x0eSTATUS_RUNNING\x10\x02\x12\x15\n\x11STATUS_SUSPENDING\x10\x03\x12\x14\n\x10STATUS_SUSPENDED\x10\x04\"#\n\x0fGetActorRequest\x12\x10\n\x08\x61\x63tor_id\x18\x01 \x01(\t\"0\n\x10GetActorResponse\x12\x1c\n\x05\x61\x63tor\x18\x01 \x01(\x0b\x32\r.ateapi.Actor\"e\n\x12\x43reateActorRequest\x12\x10\n\x08\x61\x63tor_id\x18\x01 \x01(\t\x12 \n\x18\x61\x63tor_template_namespace\x18\x02 \x01(\t\x12\x1b\n\x13\x61\x63tor_template_name\x18\x03 \x01(\t\"3\n\x13\x43reateActorResponse\x12\x1c\n\x05\x61\x63tor\x18\x01 \x01(\x0b\x32\r.ateapi.Actor\"\'\n\x13SuspendActorRequest\x12\x10\n\x08\x61\x63tor_id\x18\x01 \x01(\t\"4\n\x14SuspendActorResponse\x12\x1c\n\x05\x61\x63tor\x18\x01 \x01(\x0b\x32\r.ateapi.Actor\"4\n\x12ResumeActorRequest\x12\x10\n\x08\x61\x63tor_id\x18\x01 \x01(\t\x12\x0c\n\x04\x62oot\x18\x02 \x01(\x08\"3\n\x13ResumeActorResponse\x12\x1c\n\x05\x61\x63tor\x18\x01 \x01(\x0b\x32\r.ateapi.Actor\"&\n\x12\x44\x65leteActorRequest\x12\x10\n\x08\x61\x63tor_id\x18\x01 \x01(\t\"\x15\n\x13\x44\x65leteActorResponse\"\x14\n\x12ListWorkersRequest\"6\n\x13ListWorkersResponse\x12\x1f\n\x07workers\x18\x01 \x03(\x0b\x32\x0e.ateapi.Worker\":\n\x11ListActorsRequest\x12\x11\n\tpage_size\x18\x01 \x01(\x05\x12\x12\n\npage_token\x18\x02 \x01(\t\"L\n\x12ListActorsResponse\x12\x1d\n\x06\x61\x63tors\x18\x01 \x03(\x0b\x32\r.ateapi.Actor\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t\"\xc3\x01\n\x06Worker\x12\x18\n\x10worker_namespace\x18\x01 \x01(\t\x12\x13\n\x0bworker_pool\x18\x02 \x01(\t\x12\x12\n\nworker_pod\x18\x03 \x01(\t\x12\x17\n\x0f\x61\x63tor_namespace\x18\x04 \x01(\t\x12\x16\n\x0e\x61\x63tor_template\x18\x05 \x01(\t\x12\x10\n\x08\x61\x63tor_id\x18\x06 \x01(\t\x12\n\n\x02ip\x18\x07 \x01(\t\x12\x0f\n\x07version\x18\x08 \x01(\x03\x12\x16\n\x0eworker_pod_uid\x18\t \x01(\t\"\x13\n\x11\x44\x65\x62ugClearRequest\"\x14\n\x12\x44\x65\x62ugClearResponse\"W\n\x0eMintJWTRequest\x12\x10\n\x08\x61udience\x18\x01 \x03(\t\x12\x0e\n\x06\x61pp_id\x18\x02 \x01(\t\x12\x0f\n\x07user_id\x18\x03 \x01(\t\x12\x12\n\nsession_id\x18\x04 \x01(\t\"&\n\x0fMintJWTResponse\x12\x13\n\x0bsession_jwt\x18\x01 \x01(\t\"k\n\x0fMintCertRequest\x12\x0e\n\x06\x61pp_id\x18\x01 \x01(\t\x12\x0f\n\x07user_id\x18\x02 \x01(\t\x12\x12\n\nsession_id\x18\x03 \x01(\t\x12#\n\x1b\x63\x65rtificate_signing_request\x18\x04 \x01(\x0c\"0\n\x10MintCertResponse\x12\x1c\n\x14session_certificates\x18\x01 \x03(\x0c\x32\xcd\x04\n\x07\x43ontrol\x12?\n\x08GetActor\x12\x17.ateapi.GetActorRequest\x1a\x18.ateapi.GetActorResponse\"\x00\x12H\n\x0b\x43reateActor\x12\x1a.ateapi.CreateActorRequest\x1a\x1b.ateapi.CreateActorResponse\"\x00\x12K\n\x0cSuspendActor\x12\x1b.ateapi.SuspendActorRequest\x1a\x1c.ateapi.SuspendActorResponse\"\x00\x12H\n\x0bResumeActor\x12\x1a.ateapi.ResumeActorRequest\x1a\x1b.ateapi.ResumeActorResponse\"\x00\x12H\n\x0b\x44\x65leteActor\x12\x1a.ateapi.DeleteActorRequest\x1a\x1b.ateapi.DeleteActorResponse\"\x00\x12H\n\x0bListWorkers\x12\x1a.ateapi.ListWorkersRequest\x1a\x1b.ateapi.ListWorkersResponse\"\x00\x12\x45\n\nListActors\x12\x19.ateapi.ListActorsRequest\x1a\x1a.ateapi.ListActorsResponse\"\x00\x12\x45\n\nDebugClear\x12\x19.ateapi.DebugClearRequest\x1a\x1a.ateapi.DebugClearResponse\"\x00\x32\x8c\x01\n\x0fSessionIdentity\x12:\n\x07MintJWT\x12\x16.ateapi.MintJWTRequest\x1a\x17.ateapi.MintJWTResponse\x12=\n\x08MintCert\x12\x17.ateapi.MintCertRequest\x1a\x18.ateapi.MintCertResponseB9Z7github.com/agent-substrate/substrate/pkg/proto/ateapipbb\x06proto3')

_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
Expand All @@ -47,53 +47,53 @@
_globals['DESCRIPTOR']._loaded_options = None
_globals['DESCRIPTOR']._serialized_options = b'Z7github.com/agent-substrate/substrate/pkg/proto/ateapipb'
_globals['_ACTOR']._serialized_start=25
_globals['_ACTOR']._serialized_end=416
_globals['_ACTOR_STATUS']._serialized_start=298
_globals['_ACTOR_STATUS']._serialized_end=416
_globals['_GETACTORREQUEST']._serialized_start=418
_globals['_GETACTORREQUEST']._serialized_end=453
_globals['_GETACTORRESPONSE']._serialized_start=455
_globals['_GETACTORRESPONSE']._serialized_end=503
_globals['_CREATEACTORREQUEST']._serialized_start=505
_globals['_CREATEACTORREQUEST']._serialized_end=606
_globals['_CREATEACTORRESPONSE']._serialized_start=608
_globals['_CREATEACTORRESPONSE']._serialized_end=659
_globals['_SUSPENDACTORREQUEST']._serialized_start=661
_globals['_SUSPENDACTORREQUEST']._serialized_end=700
_globals['_SUSPENDACTORRESPONSE']._serialized_start=702
_globals['_SUSPENDACTORRESPONSE']._serialized_end=754
_globals['_RESUMEACTORREQUEST']._serialized_start=756
_globals['_RESUMEACTORREQUEST']._serialized_end=808
_globals['_RESUMEACTORRESPONSE']._serialized_start=810
_globals['_RESUMEACTORRESPONSE']._serialized_end=861
_globals['_DELETEACTORREQUEST']._serialized_start=863
_globals['_DELETEACTORREQUEST']._serialized_end=901
_globals['_DELETEACTORRESPONSE']._serialized_start=903
_globals['_DELETEACTORRESPONSE']._serialized_end=924
_globals['_LISTWORKERSREQUEST']._serialized_start=926
_globals['_LISTWORKERSREQUEST']._serialized_end=946
_globals['_LISTWORKERSRESPONSE']._serialized_start=948
_globals['_LISTWORKERSRESPONSE']._serialized_end=1002
_globals['_LISTACTORSREQUEST']._serialized_start=1004
_globals['_LISTACTORSREQUEST']._serialized_end=1023
_globals['_LISTACTORSRESPONSE']._serialized_start=1025
_globals['_LISTACTORSRESPONSE']._serialized_end=1076
_globals['_WORKER']._serialized_start=1079
_globals['_WORKER']._serialized_end=1250
_globals['_DEBUGCLEARREQUEST']._serialized_start=1252
_globals['_DEBUGCLEARREQUEST']._serialized_end=1271
_globals['_DEBUGCLEARRESPONSE']._serialized_start=1273
_globals['_DEBUGCLEARRESPONSE']._serialized_end=1293
_globals['_MINTJWTREQUEST']._serialized_start=1295
_globals['_MINTJWTREQUEST']._serialized_end=1382
_globals['_MINTJWTRESPONSE']._serialized_start=1384
_globals['_MINTJWTRESPONSE']._serialized_end=1422
_globals['_MINTCERTREQUEST']._serialized_start=1424
_globals['_MINTCERTREQUEST']._serialized_end=1531
_globals['_MINTCERTRESPONSE']._serialized_start=1533
_globals['_MINTCERTRESPONSE']._serialized_end=1581
_globals['_CONTROL']._serialized_start=1584
_globals['_CONTROL']._serialized_end=2173
_globals['_SESSIONIDENTITY']._serialized_start=2176
_globals['_SESSIONIDENTITY']._serialized_end=2316
_globals['_ACTOR']._serialized_end=439
_globals['_ACTOR_STATUS']._serialized_start=321
_globals['_ACTOR_STATUS']._serialized_end=439
_globals['_GETACTORREQUEST']._serialized_start=441
_globals['_GETACTORREQUEST']._serialized_end=476
_globals['_GETACTORRESPONSE']._serialized_start=478
_globals['_GETACTORRESPONSE']._serialized_end=526
_globals['_CREATEACTORREQUEST']._serialized_start=528
_globals['_CREATEACTORREQUEST']._serialized_end=629
_globals['_CREATEACTORRESPONSE']._serialized_start=631
_globals['_CREATEACTORRESPONSE']._serialized_end=682
_globals['_SUSPENDACTORREQUEST']._serialized_start=684
_globals['_SUSPENDACTORREQUEST']._serialized_end=723
_globals['_SUSPENDACTORRESPONSE']._serialized_start=725
_globals['_SUSPENDACTORRESPONSE']._serialized_end=777
_globals['_RESUMEACTORREQUEST']._serialized_start=779
_globals['_RESUMEACTORREQUEST']._serialized_end=831
_globals['_RESUMEACTORRESPONSE']._serialized_start=833
_globals['_RESUMEACTORRESPONSE']._serialized_end=884
_globals['_DELETEACTORREQUEST']._serialized_start=886
_globals['_DELETEACTORREQUEST']._serialized_end=924
_globals['_DELETEACTORRESPONSE']._serialized_start=926
_globals['_DELETEACTORRESPONSE']._serialized_end=947
_globals['_LISTWORKERSREQUEST']._serialized_start=949
_globals['_LISTWORKERSREQUEST']._serialized_end=969
_globals['_LISTWORKERSRESPONSE']._serialized_start=971
_globals['_LISTWORKERSRESPONSE']._serialized_end=1025
_globals['_LISTACTORSREQUEST']._serialized_start=1027
_globals['_LISTACTORSREQUEST']._serialized_end=1085
_globals['_LISTACTORSRESPONSE']._serialized_start=1087
_globals['_LISTACTORSRESPONSE']._serialized_end=1163
_globals['_WORKER']._serialized_start=1166
_globals['_WORKER']._serialized_end=1361
_globals['_DEBUGCLEARREQUEST']._serialized_start=1363
_globals['_DEBUGCLEARREQUEST']._serialized_end=1382
_globals['_DEBUGCLEARRESPONSE']._serialized_start=1384
_globals['_DEBUGCLEARRESPONSE']._serialized_end=1404
_globals['_MINTJWTREQUEST']._serialized_start=1406
_globals['_MINTJWTREQUEST']._serialized_end=1493
_globals['_MINTJWTRESPONSE']._serialized_start=1495
_globals['_MINTJWTRESPONSE']._serialized_end=1533
_globals['_MINTCERTREQUEST']._serialized_start=1535
_globals['_MINTCERTREQUEST']._serialized_end=1642
_globals['_MINTCERTRESPONSE']._serialized_start=1644
_globals['_MINTCERTRESPONSE']._serialized_end=1692
_globals['_CONTROL']._serialized_start=1695
_globals['_CONTROL']._serialized_end=2284
_globals['_SESSIONIDENTITY']._serialized_start=2287
_globals['_SESSIONIDENTITY']._serialized_end=2427
# @@protoc_insertion_point(module_scope)
14 changes: 7 additions & 7 deletions benchmarking/locust/common/ateapi_pb2_grpc.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@

from . import ateapi_pb2 as ateapi__pb2

GRPC_GENERATED_VERSION = '1.80.0'
GRPC_GENERATED_VERSION = '1.81.1'
GRPC_VERSION = grpc.__version__
_version_not_supported = False

Expand All @@ -39,7 +39,7 @@
)


class ControlStub(object):
class ControlStub:
"""Control is the primary RPC interface for Agentic Substrate.
"""

Expand Down Expand Up @@ -91,7 +91,7 @@ def __init__(self, channel):
_registered_method=True)


class ControlServicer(object):
class ControlServicer:
"""Control is the primary RPC interface for Agentic Substrate.
"""

Expand Down Expand Up @@ -202,7 +202,7 @@ def add_ControlServicer_to_server(servicer, server):


# This class is part of an EXPERIMENTAL API.
class Control(object):
class Control:
"""Control is the primary RPC interface for Agentic Substrate.
"""

Expand Down Expand Up @@ -423,7 +423,7 @@ def DebugClear(request,
_registered_method=True)


class SessionIdentityStub(object):
class SessionIdentityStub:
"""SessionIdentity allows substrate workloads to exchange their
infrastructure-level credentials (k8s service account token, etc.) for a
substrate session-level credential. A given substrate session might migrate
Expand Down Expand Up @@ -460,7 +460,7 @@ def __init__(self, channel):
_registered_method=True)


class SessionIdentityServicer(object):
class SessionIdentityServicer:
"""SessionIdentity allows substrate workloads to exchange their
infrastructure-level credentials (k8s service account token, etc.) for a
substrate session-level credential. A given substrate session might migrate
Expand Down Expand Up @@ -518,7 +518,7 @@ def add_SessionIdentityServicer_to_server(servicer, server):


# This class is part of an EXPERIMENTAL API.
class SessionIdentity(object):
class SessionIdentity:
"""SessionIdentity allows substrate workloads to exchange their
infrastructure-level credentials (k8s service account token, etc.) for a
substrate session-level credential. A given substrate session might migrate
Expand Down
Loading
Loading