protocol

type AbortRequest struct {
	DebugletId string `protobuf:"bytes,1,opt,name=debuglet_id,json=debugletId,proto3" json:"debuglet_id,omitempty"`
	Reason     string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type AbortResponse struct {
	// contains filtered or unexported fields
}

type BandwidthRequest struct {
	Limits []*DestinationLimit `protobuf:"bytes,1,rep,name=limits,proto3" json:"limits,omitempty"`
	// contains filtered or unexported fields
}

type BandwidthResponse struct {
	// contains filtered or unexported fields
}

type BindSessionRequest struct {
	ExecutorId string `protobuf:"bytes,1,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	// contains filtered or unexported fields
}

type BindSessionResponse struct {
	LeaseDurationMs int64 `protobuf:"varint,1,opt,name=lease_duration_ms,json=leaseDurationMs,proto3" json:"lease_duration_ms,omitempty"` // Original initial lease; repeats never rearm it.
	// contains filtered or unexported fields
}

type ControlBinding struct {
	DispatcherIncarnation string `protobuf:"bytes,1,opt,name=dispatcher_incarnation,json=dispatcherIncarnation,proto3" json:"dispatcher_incarnation,omitempty"`
	SessionId             string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

type DebugletAllocateRequest struct {
	DebugletId    string          `protobuf:"bytes,1,opt,name=debuglet_id,json=debugletId,proto3" json:"debuglet_id,omitempty"`
	ExecutorId    string          `protobuf:"bytes,2,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	TransactionId string          `protobuf:"bytes,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	Policy        *DebugletPolicy `protobuf:"bytes,4,opt,name=policy,proto3" json:"policy,omitempty"`
	// contains filtered or unexported fields
}

type DebugletAllocateResponse struct {
	AllocatedLimits []*DestinationLimit `protobuf:"bytes,1,rep,name=allocated_limits,json=allocatedLimits,proto3" json:"allocated_limits,omitempty"`
	// contains filtered or unexported fields
}

type DebugletExitRequest struct {
	DebugletId   string  `protobuf:"bytes,1,opt,name=debuglet_id,json=debugletId,proto3" json:"debuglet_id,omitempty"`
	ExitCode     int32   `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	ErrorMessage *string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

type DebugletExitResponse struct {
	// contains filtered or unexported fields
}

type DebugletIdent struct {
	DebugletId string `protobuf:"bytes,1,opt,name=debuglet_id,json=debugletId,proto3" json:"debuglet_id,omitempty"`
	ExecutorId string `protobuf:"bytes,2,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	// contains filtered or unexported fields
}

type DebugletOutput struct {
	Output    []byte                 `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type DebugletPolicy struct {
	FloorBw     int64    `protobuf:"varint,1,opt,name=floor_bw,json=floorBw,proto3" json:"floor_bw,omitempty"`             // min bits/s required
	CeilBw      int64    `protobuf:"varint,2,opt,name=ceil_bw,json=ceilBw,proto3" json:"ceil_bw,omitempty"`                // max bits/s it could use
	TimeoutMs   int64    `protobuf:"varint,3,opt,name=timeout_ms,json=timeoutMs,proto3" json:"timeout_ms,omitempty"`       // timeout in ms
	Addresses   []string `protobuf:"bytes,4,rep,name=addresses,proto3" json:"addresses,omitempty"`                         // e.g., SCION or network endpoints
	RequireIcmp bool     `protobuf:"varint,5,opt,name=require_icmp,json=requireIcmp,proto3" json:"require_icmp,omitempty"` // whether ICMP is required
	ListenUdp   bool     `protobuf:"varint,6,opt,name=listen_udp,json=listenUdp,proto3" json:"listen_udp,omitempty"`       // whether the debuglet should setup a UDP listening server
	ListenTcp   bool     `protobuf:"varint,7,opt,name=listen_tcp,json=listenTcp,proto3" json:"listen_tcp,omitempty"`       // whether the debuglet should setup a TCP listening server
	ListenScion bool     `protobuf:"varint,8,opt,name=listen_scion,json=listenScion,proto3" json:"listen_scion,omitempty"` // whether the debuglet should setup a SCION listening server
	// contains filtered or unexported fields
}

type DebugletStateRequest struct {
	DebugletId string   `protobuf:"bytes,1,opt,name=debuglet_id,json=debugletId,proto3" json:"debuglet_id,omitempty"`
	ExecutorId string   `protobuf:"bytes,2,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	State      RunState `protobuf:"varint,3,opt,name=state,proto3,enum=debuglet.protocol.RunState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

type DebugletStateResponse struct {
	// contains filtered or unexported fields
}

type DebugletStreamRequest struct {

	// Types that are valid to be assigned to Msg:
	//
	//	*DebugletStreamRequest_Ident
	//	*DebugletStreamRequest_Output
	Msg isDebugletStreamRequest_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

type DebugletStreamRequest_Ident struct {
	Ident *DebugletIdent `protobuf:"bytes,1,opt,name=ident,proto3,oneof"`
}

type DebugletStreamRequest_Output struct {
	Output *DebugletOutput `protobuf:"bytes,2,opt,name=output,proto3,oneof"`
}

type DebugletStreamResponse struct {
	// contains filtered or unexported fields
}

type DestinationLimit struct {
	Address   string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	BitsLimit int64  `protobuf:"varint,2,opt,name=bits_limit,json=bitsLimit,proto3" json:"bits_limit,omitempty"`
	// contains filtered or unexported fields
}

type DispatcherServiceClient interface {
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	Resources(ctx context.Context, in *ResourcesRequest, opts ...grpc.CallOption) (*ResourcesResponse, error)
	DebugletState(ctx context.Context, in *DebugletStateRequest, opts ...grpc.CallOption) (*DebugletStateResponse, error)
	// Request resource allocation before a debuglet starts. The dispatcher can then have the caller wait until the resources have been allocated.
	DebugletAllocate(ctx context.Context, in *DebugletAllocateRequest, opts ...grpc.CallOption) (*DebugletAllocateResponse, error)
	DebugletExit(ctx context.Context, in *DebugletExitRequest, opts ...grpc.CallOption) (*DebugletExitResponse, error)
	DebugletStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[DebugletStreamRequest, DebugletStreamResponse], error)
	BindSession(ctx context.Context, in *BindSessionRequest, opts ...grpc.CallOption) (*BindSessionResponse, error)
	RenewLease(ctx context.Context, in *RenewLeaseRequest, opts ...grpc.CallOption) (*RenewLeaseResponse, error)
}

type DispatcherServiceServer interface {
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	Resources(context.Context, *ResourcesRequest) (*ResourcesResponse, error)
	DebugletState(context.Context, *DebugletStateRequest) (*DebugletStateResponse, error)
	// Request resource allocation before a debuglet starts. The dispatcher can then have the caller wait until the resources have been allocated.
	DebugletAllocate(context.Context, *DebugletAllocateRequest) (*DebugletAllocateResponse, error)
	DebugletExit(context.Context, *DebugletExitRequest) (*DebugletExitResponse, error)
	DebugletStream(grpc.BidiStreamingServer[DebugletStreamRequest, DebugletStreamResponse]) error
	BindSession(context.Context, *BindSessionRequest) (*BindSessionResponse, error)
	RenewLease(context.Context, *RenewLeaseRequest) (*RenewLeaseResponse, error)
	// contains filtered or unexported methods
}

type DispatcherService_DebugletStreamClient = grpc.BidiStreamingClient[DebugletStreamRequest, DebugletStreamResponse]

type DispatcherService_DebugletStreamServer = grpc.BidiStreamingServer[DebugletStreamRequest, DebugletStreamResponse]

type ExecutorServiceClient interface {
	Hello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)
	Upload(ctx context.Context, in *UploadRequest, opts ...grpc.CallOption) (*UploadResponse, error)
	Abort(ctx context.Context, in *AbortRequest, opts ...grpc.CallOption) (*AbortResponse, error)
	Bandwidth(ctx context.Context, in *BandwidthRequest, opts ...grpc.CallOption) (*BandwidthResponse, error)
	ProbeSession(ctx context.Context, in *ProbeSessionRequest, opts ...grpc.CallOption) (*ProbeSessionResponse, error)
	// Optional. Reads one retained run without scheduling, starting, finalizing
	// or deleting it. An executor without inspection answers UNIMPLEMENTED,
	// which is never a missing-row answer.
	InspectRetainedRun(ctx context.Context, in *InspectRetainedRunRequest, opts ...grpc.CallOption) (*InspectRetainedRunResponse, error)
}

type ExecutorServiceServer interface {
	Hello(context.Context, *HelloRequest) (*HelloResponse, error)
	Upload(context.Context, *UploadRequest) (*UploadResponse, error)
	Abort(context.Context, *AbortRequest) (*AbortResponse, error)
	Bandwidth(context.Context, *BandwidthRequest) (*BandwidthResponse, error)
	ProbeSession(context.Context, *ProbeSessionRequest) (*ProbeSessionResponse, error)
	// Optional. Reads one retained run without scheduling, starting, finalizing
	// or deleting it. An executor without inspection answers UNIMPLEMENTED,
	// which is never a missing-row answer.
	InspectRetainedRun(context.Context, *InspectRetainedRunRequest) (*InspectRetainedRunResponse, error)
	// contains filtered or unexported methods
}

type HeartbeatRequest struct {
	ExecutorId    string `protobuf:"bytes,1,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	TimestampNs   int64  `protobuf:"varint,2,opt,name=timestamp_ns,json=timestampNs,proto3" json:"timestamp_ns,omitempty"`
	TeslaKeyEpoch int64  `protobuf:"varint,3,opt,name=tesla_key_epoch,json=teslaKeyEpoch,proto3" json:"tesla_key_epoch,omitempty"`
	TeslaKey      []byte `protobuf:"bytes,4,opt,name=tesla_key,json=teslaKey,proto3" json:"tesla_key,omitempty"`
	// contains filtered or unexported fields
}

type HeartbeatResponse struct {
	// contains filtered or unexported fields
}

type HelloRequest struct {
	ControlVersion        uint32 `protobuf:"varint,1,opt,name=control_version,json=controlVersion,proto3" json:"control_version,omitempty"`
	DispatcherIncarnation string `protobuf:"bytes,2,opt,name=dispatcher_incarnation,json=dispatcherIncarnation,proto3" json:"dispatcher_incarnation,omitempty"`
	SessionId             string `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	SessionToken          []byte `protobuf:"bytes,4,opt,name=session_token,json=sessionToken,proto3" json:"session_token,omitempty"`             // Private offer token; never persist or log.
	LeaseDurationMs       int64  `protobuf:"varint,5,opt,name=lease_duration_ms,json=leaseDurationMs,proto3" json:"lease_duration_ms,omitempty"` // Strict v3 control lease; receiver clocks only.
	// contains filtered or unexported fields
}

type HelloResponse struct {
	ExecutorId             string `protobuf:"bytes,1,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`             // Unique ID for this executor instance
	Version                string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`                                     // Optional: software version or capabilities
	SourceIp               string `protobuf:"bytes,3,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`                   // Source IP for packet attribution
	TeslaDelaySec          int64  `protobuf:"varint,4,opt,name=tesla_delay_sec,json=teslaDelaySec,proto3" json:"tesla_delay_sec,omitempty"` // TESLA epoch delay in seconds
	TeslaAnchorTimestampNs int64  ``                                                                                                        // Reference wall-clock time for epoch 0
	/* 132-byte string literal not displayed */
	TeslaAnchorKey        []byte  `protobuf:"bytes,6,opt,name=tesla_anchor_key,json=teslaAnchorKey,proto3" json:"tesla_anchor_key,omitempty"` // Public anchor k_0 = H^L(seed); used to verify disclosed keys
	IcmpEnabled           bool    `protobuf:"varint,7,opt,name=icmp_enabled,json=icmpEnabled,proto3" json:"icmp_enabled,omitempty"`           // Whether the executor can handle ICMP packets
	PricePerBwS           int64   `protobuf:"varint,8,opt,name=price_per_bw_s,json=pricePerBwS,proto3" json:"price_per_bw_s,omitempty"`       // Price per bit/s of bandwidth
	Currency              string  `protobuf:"bytes,9,opt,name=currency,proto3" json:"currency,omitempty"`
	PublicHost            *string `protobuf:"bytes,10,opt,name=public_host,json=publicHost,proto3,oneof" json:"public_host,omitempty"` // Optional: public host for the executor at which debuglet listeners can be contacted
	SuiWallet             *string `protobuf:"bytes,11,opt,name=sui_wallet,json=suiWallet,proto3,oneof" json:"sui_wallet,omitempty"`
	ControlVersion        uint32  `protobuf:"varint,12,opt,name=control_version,json=controlVersion,proto3" json:"control_version,omitempty"`                     // Selected control protocol version
	DispatcherIncarnation string  `protobuf:"bytes,13,opt,name=dispatcher_incarnation,json=dispatcherIncarnation,proto3" json:"dispatcher_incarnation,omitempty"` // Echoed dispatcher identity
	SessionId             string  `protobuf:"bytes,14,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`                                     // Echoed session identity
	LeaseDurationMs       int64   `protobuf:"varint,15,opt,name=lease_duration_ms,json=leaseDurationMs,proto3" json:"lease_duration_ms,omitempty"`                // Exact echo of the offered duration.
	// Single-use enrollment credential, presented only until this node's
	// certificate is bound to its executor ID. Never persist or log it.
	EnrollmentToken *string `protobuf:"bytes,16,opt,name=enrollment_token,json=enrollmentToken,proto3,oneof" json:"enrollment_token,omitempty"`
	// contains filtered or unexported fields
}

type InspectRetainedRunRequest struct {
	DebugletId     string          `protobuf:"bytes,1,opt,name=debuglet_id,json=debugletId,proto3" json:"debuglet_id,omitempty"`
	ControlBinding *ControlBinding `protobuf:"bytes,2,opt,name=control_binding,json=controlBinding,proto3" json:"control_binding,omitempty"` // The caller's own current session.
	// contains filtered or unexported fields
}

type InspectRetainedRunResponse struct {
	Status RetainedRunStatus `protobuf:"varint,1,opt,name=status,proto3,enum=debuglet.protocol.RetainedRunStatus" json:"status,omitempty"`
	Run    *RetainedRun      `protobuf:"bytes,2,opt,name=run,proto3,oneof" json:"run,omitempty"` // Present exactly when status is FOUND.
	// contains filtered or unexported fields
}

type ProbeSessionRequest struct {
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

type ProbeSessionResponse struct {
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

type RenewLeaseRequest struct {
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

type RenewLeaseResponse struct {
	Sequence        uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	LeaseDurationMs int64  `protobuf:"varint,2,opt,name=lease_duration_ms,json=leaseDurationMs,proto3" json:"lease_duration_ms,omitempty"`
	// contains filtered or unexported fields
}

type ResourcesRequest struct {
	ExecutorId        string `protobuf:"bytes,1,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	BandwidthCapacity int64  `protobuf:"varint,2,opt,name=bandwidth_capacity,json=bandwidthCapacity,proto3" json:"bandwidth_capacity,omitempty"` // Bandwidth capacity (bits/s) the executor can handle
	// contains filtered or unexported fields
}

type ResourcesResponse struct {
	// contains filtered or unexported fields
}

type RetainedRun struct {
	DebugletId      string                 `protobuf:"bytes,1,opt,name=debuglet_id,json=debugletId,proto3" json:"debuglet_id,omitempty"`
	OriginalBinding *ControlBinding        `protobuf:"bytes,2,opt,name=original_binding,json=originalBinding,proto3" json:"original_binding,omitempty"` // Empty fields for rows stored before run bindings existed.
	TransactionId   string                 `protobuf:"bytes,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	Started         bool                   `protobuf:"varint,4,opt,name=started,proto3" json:"started,omitempty"`
	StartedAt       *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3,oneof" json:"started_at,omitempty"`
	StartTime       *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

type RetainedRunStatus int32

type RunState int32

type UnimplementedDispatcherServiceServer struct{}

type UnimplementedExecutorServiceServer struct{}

type UnsafeDispatcherServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeExecutorServiceServer interface {
	// contains filtered or unexported methods
}

type UploadRequest struct {
	Id             string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	StartTime      *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`
	Wasm           []byte                 `protobuf:"bytes,3,opt,name=wasm,proto3" json:"wasm,omitempty"`
	Args           []string               `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	Policy         *DebugletPolicy        `protobuf:"bytes,5,opt,name=policy,proto3" json:"policy,omitempty"`
	TransactionId  string                 `protobuf:"bytes,6,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	ControlBinding *ControlBinding        `protobuf:"bytes,7,opt,name=control_binding,json=controlBinding,proto3" json:"control_binding,omitempty"`
	// contains filtered or unexported fields
}

type UploadResponse struct {
	// contains filtered or unexported fields
}