protocol

package

Go to main page

Versions in this module

v0

v0.3.1

Oct 19, 2026

v0.3.0

Oct 19, 2026

Changes in this version

+ const DisclosureSampleLifetime

+ const DispatcherService_ExperimentReady_FullMethodName

+ const DispatcherService_ReflectAddress_FullMethodName

+ const ExecutorService_VerifyTags_FullMethodName

+ const MaxDisclosureReceipts

+ const MaxOutputFrameBytes

+ const OutputFrameCharge

+ const OutputReasonExecutorInterrupted

+ const OutputReasonLimit

+ const OutputReasonProducerFailed

+ const OutputReasonSpoolLimit

+ const OutputReasonStorageLimit

+ const OutputRunCharge

+ const OutputVersion

+ var DebugletOutputStatus_name = map[int32]string

+ var DebugletOutputStatus_value = map[string]int32

+ func ValidOutputEnd(end *DebugletOutputEnd) bool

+ type AddressSelfCheck struct

+ Ipv4LocalPrivate *bool

+ ResolvesA bool

+ ResolvesAaaa bool

+ func (*AddressSelfCheck) Descriptor() ([]byte, []int)

+ func (*AddressSelfCheck) ProtoMessage()

+ func (x *AddressSelfCheck) GetIpv4LocalPrivate() bool

+ func (x *AddressSelfCheck) GetResolvesA() bool

+ func (x *AddressSelfCheck) GetResolvesAaaa() bool

+ func (x *AddressSelfCheck) ProtoReflect() protoreflect.Message

+ func (x *AddressSelfCheck) Reset()

+ func (x *AddressSelfCheck) String() string

+ type AttributionState struct

+ DisclosureHeldMs *int64

+ Epoch int64

+ InstalledEpoch *int64

+ LastRefreshAgeMs *int64

+ Reason string

+ RefreshError string

+ State string

+ func (*AttributionState) Descriptor() ([]byte, []int)

+ func (*AttributionState) ProtoMessage()

+ func (x *AttributionState) GetDisclosureHeldMs() int64

+ func (x *AttributionState) GetEpoch() int64

+ func (x *AttributionState) GetInstalledEpoch() int64

+ func (x *AttributionState) GetLastRefreshAgeMs() int64

+ func (x *AttributionState) GetReason() string

+ func (x *AttributionState) GetRefreshError() string

+ func (x *AttributionState) GetState() string

+ func (x *AttributionState) ProtoReflect() protoreflect.Message

+ func (x *AttributionState) Reset()

+ func (x *AttributionState) String() string

type BandwidthRequest

+ Revision uint64

+ func (x *BandwidthRequest) GetRevision() uint64

type BandwidthResponse

+ Revision uint64

+ func (x *BandwidthResponse) GetRevision() uint64

+ type ClockState struct

+ ErrorBoundNs int64

+ EstimatedErrorNs *int64

+ MaxErrorNs *int64

+ Readiness string

+ Reason string

+ State string

+ func (*ClockState) Descriptor() ([]byte, []int)

+ func (*ClockState) ProtoMessage()

+ func (x *ClockState) GetErrorBoundNs() int64

+ func (x *ClockState) GetEstimatedErrorNs() int64

+ func (x *ClockState) GetMaxErrorNs() int64

+ func (x *ClockState) GetReadiness() string

+ func (x *ClockState) GetReason() string

+ func (x *ClockState) GetState() string

+ func (x *ClockState) ProtoReflect() protoreflect.Message

+ func (x *ClockState) Reset()

+ func (x *ClockState) String() string

+ type ConnectivityReport struct

+ Ipv4 *EgressTest

+ Ipv6 *EgressTest

+ Listeners []*ListenerChallenge

+ ListenersEnabled bool

+ TcpReason string

+ UdpReason string

+ func (*ConnectivityReport) Descriptor() ([]byte, []int)

+ func (*ConnectivityReport) ProtoMessage()

+ func (x *ConnectivityReport) GetIpv4() *EgressTest

+ func (x *ConnectivityReport) GetIpv6() *EgressTest

+ func (x *ConnectivityReport) GetListeners() []*ListenerChallenge

+ func (x *ConnectivityReport) GetListenersEnabled() bool

+ func (x *ConnectivityReport) GetTcpReason() string

+ func (x *ConnectivityReport) GetUdpReason() string

+ func (x *ConnectivityReport) ProtoReflect() protoreflect.Message

+ func (x *ConnectivityReport) Reset()

+ func (x *ConnectivityReport) String() string

type DebugletIdent

+ OriginalBinding *ControlBinding

+ func (x *DebugletIdent) GetOriginalBinding() *ControlBinding

type DebugletOutput

+ Sequence int64

+ func (x *DebugletOutput) GetSequence() int64

+ type DebugletOutputEnd struct

+ LastSequence int64

+ Reason string

+ Status DebugletOutputStatus

+ func (*DebugletOutputEnd) Descriptor() ([]byte, []int)

+ func (*DebugletOutputEnd) ProtoMessage()

+ func (x *DebugletOutputEnd) GetLastSequence() int64

+ func (x *DebugletOutputEnd) GetReason() string

+ func (x *DebugletOutputEnd) GetStatus() DebugletOutputStatus

+ func (x *DebugletOutputEnd) ProtoReflect() protoreflect.Message

+ func (x *DebugletOutputEnd) Reset()

+ func (x *DebugletOutputEnd) String() string

+ type DebugletOutputStatus int32

+ const DebugletOutputStatus_DEBUGLET_OUTPUT_STATUS_COMPLETE

+ const DebugletOutputStatus_DEBUGLET_OUTPUT_STATUS_TRUNCATED

+ const DebugletOutputStatus_DEBUGLET_OUTPUT_STATUS_UNSPECIFIED

+ func (DebugletOutputStatus) Descriptor() protoreflect.EnumDescriptor

+ func (DebugletOutputStatus) EnumDescriptor() ([]byte, []int)

+ func (DebugletOutputStatus) Type() protoreflect.EnumType

+ func (x DebugletOutputStatus) Enum() *DebugletOutputStatus

+ func (x DebugletOutputStatus) Number() protoreflect.EnumNumber

+ func (x DebugletOutputStatus) String() string

type DebugletPolicy

+ EgressGrant *EgressGrant

+ func (x *DebugletPolicy) GetEgressGrant() *EgressGrant

type DebugletStateRequest

+ TcpListener *ListenerEndpoint

+ func (x *DebugletStateRequest) GetTcpListener() *ListenerEndpoint

type DebugletStreamRequest

+ func (x *DebugletStreamRequest) GetEnd() *DebugletOutputEnd

+ type DebugletStreamRequest_End struct

+ End *DebugletOutputEnd

type DebugletStreamResponse

+ CommittedSequence int64

+ End *DebugletOutputEnd

+ func (x *DebugletStreamResponse) GetCommittedSequence() int64

+ func (x *DebugletStreamResponse) GetEnd() *DebugletOutputEnd

type DestinationLimit

+ Denied bool

+ func (x *DestinationLimit) GetDenied() bool

+ type DisclosureDeliveryObservation struct

+ Anchor []byte

+ SampleAgeNs int64

+ ScheduledToAckNs int64

+ StoredThroughEpoch int64

+ func (*DisclosureDeliveryObservation) Descriptor() ([]byte, []int)

+ func (*DisclosureDeliveryObservation) ProtoMessage()

+ func (x *DisclosureDeliveryObservation) GetAnchor() []byte

+ func (x *DisclosureDeliveryObservation) GetSampleAgeNs() int64

+ func (x *DisclosureDeliveryObservation) GetScheduledToAckNs() int64

+ func (x *DisclosureDeliveryObservation) GetStoredThroughEpoch() int64

+ func (x *DisclosureDeliveryObservation) ProtoReflect() protoreflect.Message

+ func (x *DisclosureDeliveryObservation) Reset()

+ func (x *DisclosureDeliveryObservation) String() string

type DispatcherServiceClient

+ ExperimentReady func(ctx context.Context, in *ExperimentReadyRequest, opts ...grpc.CallOption) (*ExperimentReadyResponse, error)

+ ReflectAddress func(ctx context.Context, in *ReflectAddressRequest, opts ...grpc.CallOption) (*ReflectAddressResponse, error)

type DispatcherServiceServer

+ ExperimentReady func(context.Context, *ExperimentReadyRequest) (*ExperimentReadyResponse, error)

+ ReflectAddress func(context.Context, *ReflectAddressRequest) (*ReflectAddressResponse, error)

+ type EgressGrant struct

+ Addresses []string

+ AttemptBurst int64

+ Attempts int64

+ AttemptsPerSecond int64

+ BitsPerSecond int64

+ BurstBytes int64

+ Bytes int64

+ ExpiresUnix int64

+ NotBeforeUnix int64

+ Version uint32

+ func (*EgressGrant) Descriptor() ([]byte, []int)

+ func (*EgressGrant) ProtoMessage()

+ func (x *EgressGrant) GetAddresses() []string

+ func (x *EgressGrant) GetAttemptBurst() int64

+ func (x *EgressGrant) GetAttempts() int64

+ func (x *EgressGrant) GetAttemptsPerSecond() int64

+ func (x *EgressGrant) GetBitsPerSecond() int64

+ func (x *EgressGrant) GetBurstBytes() int64

+ func (x *EgressGrant) GetBytes() int64

+ func (x *EgressGrant) GetExpiresUnix() int64

+ func (x *EgressGrant) GetNotBeforeUnix() int64

+ func (x *EgressGrant) GetVersion() uint32

+ func (x *EgressGrant) ProtoReflect() protoreflect.Message

+ func (x *EgressGrant) Reset()

+ func (x *EgressGrant) String() string

+ type EgressTest struct

+ Nonce []byte

+ Reason string

+ State string

+ func (*EgressTest) Descriptor() ([]byte, []int)

+ func (*EgressTest) ProtoMessage()

+ func (x *EgressTest) GetNonce() []byte

+ func (x *EgressTest) GetReason() string

+ func (x *EgressTest) GetState() string

+ func (x *EgressTest) ProtoReflect() protoreflect.Message

+ func (x *EgressTest) Reset()

+ func (x *EgressTest) String() string

+ type ExecutorCapabilities struct

+ Attribution *AttributionState

+ EnforcementMode string

+ EnforcementReason string

+ Icmp *ProbeState

+ Protocols []string

+ SchemaVersion uint32

+ Tagging *TaggingMode

+ func (*ExecutorCapabilities) Descriptor() ([]byte, []int)

+ func (*ExecutorCapabilities) ProtoMessage()

+ func (x *ExecutorCapabilities) GetAttribution() *AttributionState

+ func (x *ExecutorCapabilities) GetEnforcementMode() string

+ func (x *ExecutorCapabilities) GetEnforcementReason() string

+ func (x *ExecutorCapabilities) GetIcmp() *ProbeState

+ func (x *ExecutorCapabilities) GetProtocols() []string

+ func (x *ExecutorCapabilities) GetSchemaVersion() uint32

+ func (x *ExecutorCapabilities) GetTagging() *TaggingMode

+ func (x *ExecutorCapabilities) ProtoReflect() protoreflect.Message

+ func (x *ExecutorCapabilities) Reset()

+ func (x *ExecutorCapabilities) String() string

type ExecutorServiceClient

+ VerifyTags func(ctx context.Context, in *VerifyTagsRequest, opts ...grpc.CallOption) (*VerifyTagsResponse, error)

type ExecutorServiceServer

+ VerifyTags func(context.Context, *VerifyTagsRequest) (*VerifyTagsResponse, error)

+ type ExperimentParticipant struct

+ ExecutorId string

+ Id string

+ Metadata []byte

+ ReadyAtNs int64

+ func (*ExperimentParticipant) Descriptor() ([]byte, []int)

+ func (*ExperimentParticipant) ProtoMessage()

+ func (x *ExperimentParticipant) GetExecutorId() string

+ func (x *ExperimentParticipant) GetId() string

+ func (x *ExperimentParticipant) GetMetadata() []byte

+ func (x *ExperimentParticipant) GetReadyAtNs() int64

+ func (x *ExperimentParticipant) ProtoReflect() protoreflect.Message

+ func (x *ExperimentParticipant) Reset()

+ func (x *ExperimentParticipant) String() string

+ type ExperimentReadyRequest struct

+ DebugletId string

+ ExecutorId string

+ Metadata []byte

+ func (*ExperimentReadyRequest) Descriptor() ([]byte, []int)

+ func (*ExperimentReadyRequest) ProtoMessage()

+ func (x *ExperimentReadyRequest) GetDebugletId() string

+ func (x *ExperimentReadyRequest) GetExecutorId() string

+ func (x *ExperimentReadyRequest) GetMetadata() []byte

+ func (x *ExperimentReadyRequest) ProtoReflect() protoreflect.Message

+ func (x *ExperimentReadyRequest) Reset()

+ func (x *ExperimentReadyRequest) String() string

+ type ExperimentReadyResponse struct

+ ExperimentId string

+ Participants []*ExperimentParticipant

+ StartTimeNs int64

+ func (*ExperimentReadyResponse) Descriptor() ([]byte, []int)

+ func (*ExperimentReadyResponse) ProtoMessage()

+ func (x *ExperimentReadyResponse) GetExperimentId() string

+ func (x *ExperimentReadyResponse) GetParticipants() []*ExperimentParticipant

+ func (x *ExperimentReadyResponse) GetStartTimeNs() int64

+ func (x *ExperimentReadyResponse) ProtoReflect() protoreflect.Message

+ func (x *ExperimentReadyResponse) Reset()

+ func (x *ExperimentReadyResponse) String() string

type HeartbeatRequest

+ Capabilities *ExecutorCapabilities

+ ExtraDisclosures []*TeslaDisclosure

+ TeslaKeyAnchor []byte

+ VantagePoint *VantagePointReport

+ func (x *HeartbeatRequest) GetCapabilities() *ExecutorCapabilities

+ func (x *HeartbeatRequest) GetExtraDisclosures() []*TeslaDisclosure

+ func (x *HeartbeatRequest) GetTeslaKeyAnchor() []byte

+ func (x *HeartbeatRequest) GetVantagePoint() *VantagePointReport

type HeartbeatResponse

+ DisclosureReceipts []*TeslaDisclosureReceipt

+ func (x *HeartbeatResponse) GetDisclosureReceipts() []*TeslaDisclosureReceipt

type HelloRequest

+ OutputVersion uint32

+ func (x *HelloRequest) GetOutputVersion() uint32

type HelloResponse

+ BandwidthVersion uint32

+ Capabilities *ExecutorCapabilities

+ EgressBudgetVersion uint32

+ OutputVersion uint32

+ TeslaChainLength int64

+ TeslaDisclosureDelayEpochs int64

+ TeslaScheduleProof []byte

+ VantagePoint *VantagePointReport

+ func (x *HelloResponse) GetBandwidthVersion() uint32

+ func (x *HelloResponse) GetCapabilities() *ExecutorCapabilities

+ func (x *HelloResponse) GetEgressBudgetVersion() uint32

+ func (x *HelloResponse) GetOutputVersion() uint32

+ func (x *HelloResponse) GetTeslaChainLength() int64

+ func (x *HelloResponse) GetTeslaDisclosureDelayEpochs() int64

+ func (x *HelloResponse) GetTeslaScheduleProof() []byte

+ func (x *HelloResponse) GetVantagePoint() *VantagePointReport

+ type HostPlatform struct

+ Arch string

+ BuildVersion string

+ Cpus uint32

+ KernelRelease string

+ MemoryBytes *uint64

+ Os string

+ func (*HostPlatform) Descriptor() ([]byte, []int)

+ func (*HostPlatform) ProtoMessage()

+ func (x *HostPlatform) GetArch() string

+ func (x *HostPlatform) GetBuildVersion() string

+ func (x *HostPlatform) GetCpus() uint32

+ func (x *HostPlatform) GetKernelRelease() string

+ func (x *HostPlatform) GetMemoryBytes() uint64

+ func (x *HostPlatform) GetOs() string

+ func (x *HostPlatform) ProtoReflect() protoreflect.Message

+ func (x *HostPlatform) Reset()

+ func (x *HostPlatform) String() string

+ type HostResourceValue struct

+ Unavailable string

+ Value *uint64

+ func (*HostResourceValue) Descriptor() ([]byte, []int)

+ func (*HostResourceValue) ProtoMessage()

+ func (x *HostResourceValue) GetUnavailable() string

+ func (x *HostResourceValue) GetValue() uint64

+ func (x *HostResourceValue) ProtoReflect() protoreflect.Message

+ func (x *HostResourceValue) Reset()

+ func (x *HostResourceValue) String() string

+ type HostResources struct

+ OpenFds *HostResourceValue

+ ProcessRssBytes *HostResourceValue

+ StateAvailableBytes *HostResourceValue

+ StateCapacityBytes *HostResourceValue

+ func (*HostResources) Descriptor() ([]byte, []int)

+ func (*HostResources) ProtoMessage()

+ func (x *HostResources) GetOpenFds() *HostResourceValue

+ func (x *HostResources) GetProcessRssBytes() *HostResourceValue

+ func (x *HostResources) GetStateAvailableBytes() *HostResourceValue

+ func (x *HostResources) GetStateCapacityBytes() *HostResourceValue

+ func (x *HostResources) ProtoReflect() protoreflect.Message

+ func (x *HostResources) Reset()

+ func (x *HostResources) String() string

+ type ListenerChallenge struct

+ Port uint32

+ Token []byte

+ Transport string

+ func (*ListenerChallenge) Descriptor() ([]byte, []int)

+ func (*ListenerChallenge) ProtoMessage()

+ func (x *ListenerChallenge) GetPort() uint32

+ func (x *ListenerChallenge) GetToken() []byte

+ func (x *ListenerChallenge) GetTransport() string

+ func (x *ListenerChallenge) ProtoReflect() protoreflect.Message

+ func (x *ListenerChallenge) Reset()

+ func (x *ListenerChallenge) String() string

+ type ListenerEndpoint struct

+ Address string

+ func (*ListenerEndpoint) Descriptor() ([]byte, []int)

+ func (*ListenerEndpoint) ProtoMessage()

+ func (x *ListenerEndpoint) GetAddress() string

+ func (x *ListenerEndpoint) ProtoReflect() protoreflect.Message

+ func (x *ListenerEndpoint) Reset()

+ func (x *ListenerEndpoint) String() string

+ type NetworkDenials struct

+ RefusedAdmissions uint64

+ RevokedSockets uint64

+ func (*NetworkDenials) Descriptor() ([]byte, []int)

+ func (*NetworkDenials) ProtoMessage()

+ func (x *NetworkDenials) GetRefusedAdmissions() uint64

+ func (x *NetworkDenials) GetRevokedSockets() uint64

+ func (x *NetworkDenials) ProtoReflect() protoreflect.Message

+ func (x *NetworkDenials) Reset()

+ func (x *NetworkDenials) String() string

+ type PacketDropObservations struct

+ EgressSkbBytes uint64

+ EgressVerdicts uint64

+ IngressSkbBytes uint64

+ IngressVerdicts uint64

+ func (*PacketDropObservations) Descriptor() ([]byte, []int)

+ func (*PacketDropObservations) ProtoMessage()

+ func (x *PacketDropObservations) GetEgressSkbBytes() uint64

+ func (x *PacketDropObservations) GetEgressVerdicts() uint64

+ func (x *PacketDropObservations) GetIngressSkbBytes() uint64

+ func (x *PacketDropObservations) GetIngressVerdicts() uint64

+ func (x *PacketDropObservations) ProtoReflect() protoreflect.Message

+ func (x *PacketDropObservations) Reset()

+ func (x *PacketDropObservations) String() string

+ type ProbeState struct

+ Reason string

+ State string

+ func (*ProbeState) Descriptor() ([]byte, []int)

+ func (*ProbeState) ProtoMessage()

+ func (x *ProbeState) GetReason() string

+ func (x *ProbeState) GetState() string

+ func (x *ProbeState) ProtoReflect() protoreflect.Message

+ func (x *ProbeState) Reset()

+ func (x *ProbeState) String() string

+ type ReflectAddressRequest struct

+ ExecutorId string

+ Nonce []byte

+ func (*ReflectAddressRequest) Descriptor() ([]byte, []int)

+ func (*ReflectAddressRequest) ProtoMessage()

+ func (x *ReflectAddressRequest) GetExecutorId() string

+ func (x *ReflectAddressRequest) GetNonce() []byte

+ func (x *ReflectAddressRequest) ProtoReflect() protoreflect.Message

+ func (x *ReflectAddressRequest) Reset()

+ func (x *ReflectAddressRequest) String() string

+ type ReflectAddressResponse struct

+ Address string

+ func (*ReflectAddressResponse) Descriptor() ([]byte, []int)

+ func (*ReflectAddressResponse) ProtoMessage()

+ func (x *ReflectAddressResponse) GetAddress() string

+ func (x *ReflectAddressResponse) ProtoReflect() protoreflect.Message

+ func (x *ReflectAddressResponse) Reset()

+ func (x *ReflectAddressResponse) String() string

+ type TaggingMode struct

+ Ipv4 string

+ Ipv6 string

+ Scion string

+ TagSpec string

+ func (*TaggingMode) Descriptor() ([]byte, []int)

+ func (*TaggingMode) ProtoMessage()

+ func (x *TaggingMode) GetIpv4() string

+ func (x *TaggingMode) GetIpv6() string

+ func (x *TaggingMode) GetScion() string

+ func (x *TaggingMode) GetTagSpec() string

+ func (x *TaggingMode) ProtoReflect() protoreflect.Message

+ func (x *TaggingMode) Reset()

+ func (x *TaggingMode) String() string

+ type TeslaDisclosure struct

+ Anchor []byte

+ Epoch int64

+ Key []byte

+ func (*TeslaDisclosure) Descriptor() ([]byte, []int)

+ func (*TeslaDisclosure) ProtoMessage()

+ func (x *TeslaDisclosure) GetAnchor() []byte

+ func (x *TeslaDisclosure) GetEpoch() int64

+ func (x *TeslaDisclosure) GetKey() []byte

+ func (x *TeslaDisclosure) ProtoReflect() protoreflect.Message

+ func (x *TeslaDisclosure) Reset()

+ func (x *TeslaDisclosure) String() string

+ type TeslaDisclosureReceipt struct

+ Anchor []byte

+ StoredThroughEpoch int64

+ func (*TeslaDisclosureReceipt) Descriptor() ([]byte, []int)

+ func (*TeslaDisclosureReceipt) ProtoMessage()

+ func (x *TeslaDisclosureReceipt) GetAnchor() []byte

+ func (x *TeslaDisclosureReceipt) GetStoredThroughEpoch() int64

+ func (x *TeslaDisclosureReceipt) ProtoReflect() protoreflect.Message

+ func (x *TeslaDisclosureReceipt) Reset()

+ func (x *TeslaDisclosureReceipt) String() string

type UnimplementedDispatcherServiceServer

+ func (UnimplementedDispatcherServiceServer) ExperimentReady(context.Context, *ExperimentReadyRequest) (*ExperimentReadyResponse, error)

+ func (UnimplementedDispatcherServiceServer) ReflectAddress(context.Context, *ReflectAddressRequest) (*ReflectAddressResponse, error)

type UnimplementedExecutorServiceServer

+ func (UnimplementedExecutorServiceServer) VerifyTags(context.Context, *VerifyTagsRequest) (*VerifyTagsResponse, error)

+ type VantagePointReport struct

+ AddressCheck *AddressSelfCheck

+ AddressOptOut bool

+ Clock *ClockState

+ Connectivity *ConnectivityReport

+ CounterAttachment string

+ DisclosureDelivery *DisclosureDeliveryObservation

+ HostTags []string

+ Listeners []string

+ LocationOptOut bool

+ NetworkDenials *NetworkDenials

+ PacketDrops *PacketDropObservations

+ Platform *HostPlatform

+ Resources *HostResources

+ SchemaVersion uint32

+ ScionHost string

+ ScionIsdAs string

+ ScionPathTarget string

+ ScionPaths *ProbeState

+ func (*VantagePointReport) Descriptor() ([]byte, []int)

+ func (*VantagePointReport) ProtoMessage()

+ func (x *VantagePointReport) GetAddressCheck() *AddressSelfCheck

+ func (x *VantagePointReport) GetAddressOptOut() bool

+ func (x *VantagePointReport) GetClock() *ClockState

+ func (x *VantagePointReport) GetConnectivity() *ConnectivityReport

+ func (x *VantagePointReport) GetCounterAttachment() string

+ func (x *VantagePointReport) GetDisclosureDelivery() *DisclosureDeliveryObservation

+ func (x *VantagePointReport) GetHostTags() []string

+ func (x *VantagePointReport) GetListeners() []string

+ func (x *VantagePointReport) GetLocationOptOut() bool

+ func (x *VantagePointReport) GetNetworkDenials() *NetworkDenials

+ func (x *VantagePointReport) GetPacketDrops() *PacketDropObservations

+ func (x *VantagePointReport) GetPlatform() *HostPlatform

+ func (x *VantagePointReport) GetResources() *HostResources

+ func (x *VantagePointReport) GetSchemaVersion() uint32

+ func (x *VantagePointReport) GetScionHost() string

+ func (x *VantagePointReport) GetScionIsdAs() string

+ func (x *VantagePointReport) GetScionPathTarget() string

+ func (x *VantagePointReport) GetScionPaths() *ProbeState

+ func (x *VantagePointReport) ProtoReflect() protoreflect.Message

+ func (x *VantagePointReport) Reset()

+ func (x *VantagePointReport) String() string

+ type VerifyTagsRequest struct

+ CandidateRunIds []string

+ ChainAnchor []byte

+ ControlBinding *ControlBinding

+ Epoch int64

+ Packets [][]byte

+ func (*VerifyTagsRequest) Descriptor() ([]byte, []int)

+ func (*VerifyTagsRequest) ProtoMessage()

+ func (x *VerifyTagsRequest) GetCandidateRunIds() []string

+ func (x *VerifyTagsRequest) GetChainAnchor() []byte

+ func (x *VerifyTagsRequest) GetControlBinding() *ControlBinding

+ func (x *VerifyTagsRequest) GetEpoch() int64

+ func (x *VerifyTagsRequest) GetPackets() [][]byte

+ func (x *VerifyTagsRequest) ProtoReflect() protoreflect.Message

+ func (x *VerifyTagsRequest) Reset()

+ func (x *VerifyTagsRequest) String() string

+ type VerifyTagsResponse struct

+ Reason string

+ RunId string

+ Verdict string

+ func (*VerifyTagsResponse) Descriptor() ([]byte, []int)

+ func (*VerifyTagsResponse) ProtoMessage()

+ func (x *VerifyTagsResponse) GetReason() string

+ func (x *VerifyTagsResponse) GetRunId() string

+ func (x *VerifyTagsResponse) GetVerdict() string

+ func (x *VerifyTagsResponse) ProtoReflect() protoreflect.Message

+ func (x *VerifyTagsResponse) Reset()

+ func (x *VerifyTagsResponse) String() string

v0.3.0-rc.1

Oct 6, 2026

v0.2.0

Sep 27, 2026

Changes in this version

+ const DispatcherService_BindSession_FullMethodName

+ const DispatcherService_DebugletAllocate_FullMethodName

+ const DispatcherService_DebugletExit_FullMethodName

+ const DispatcherService_DebugletState_FullMethodName

+ const DispatcherService_DebugletStream_FullMethodName

+ const DispatcherService_Heartbeat_FullMethodName

+ const DispatcherService_RenewLease_FullMethodName

+ const DispatcherService_Resources_FullMethodName

+ const ExecutorService_Abort_FullMethodName

+ const ExecutorService_Bandwidth_FullMethodName

+ const ExecutorService_Hello_FullMethodName

+ const ExecutorService_InspectRetainedRun_FullMethodName

+ const ExecutorService_ProbeSession_FullMethodName

+ const ExecutorService_Upload_FullMethodName

+ var DispatcherService_ServiceDesc = grpc.ServiceDesc

+ var ExecutorService_ServiceDesc = grpc.ServiceDesc

+ var File_protocol_protocol_proto protoreflect.FileDescriptor

+ var RetainedRunStatus_name = map[int32]string

+ var RetainedRunStatus_value = map[string]int32

+ var RunState_name = map[int32]string

+ var RunState_value = map[string]int32

+ func RegisterDispatcherServiceServer(s grpc.ServiceRegistrar, srv DispatcherServiceServer)

+ func RegisterExecutorServiceServer(s grpc.ServiceRegistrar, srv ExecutorServiceServer)

+ type AbortRequest struct

+ DebugletId string

+ Reason string

+ func (*AbortRequest) Descriptor() ([]byte, []int)

+ func (*AbortRequest) ProtoMessage()

+ func (x *AbortRequest) GetDebugletId() string

+ func (x *AbortRequest) GetReason() string

+ func (x *AbortRequest) ProtoReflect() protoreflect.Message

+ func (x *AbortRequest) Reset()

+ func (x *AbortRequest) String() string

+ type AbortResponse struct

+ func (*AbortResponse) Descriptor() ([]byte, []int)

+ func (*AbortResponse) ProtoMessage()

+ func (x *AbortResponse) ProtoReflect() protoreflect.Message

+ func (x *AbortResponse) Reset()

+ func (x *AbortResponse) String() string

+ type BandwidthRequest struct

+ Limits []*DestinationLimit

+ func (*BandwidthRequest) Descriptor() ([]byte, []int)

+ func (*BandwidthRequest) ProtoMessage()

+ func (x *BandwidthRequest) GetLimits() []*DestinationLimit

+ func (x *BandwidthRequest) ProtoReflect() protoreflect.Message

+ func (x *BandwidthRequest) Reset()

+ func (x *BandwidthRequest) String() string

+ type BandwidthResponse struct

+ func (*BandwidthResponse) Descriptor() ([]byte, []int)

+ func (*BandwidthResponse) ProtoMessage()

+ func (x *BandwidthResponse) ProtoReflect() protoreflect.Message

+ func (x *BandwidthResponse) Reset()

+ func (x *BandwidthResponse) String() string

+ type BindSessionRequest struct

+ ExecutorId string

+ func (*BindSessionRequest) Descriptor() ([]byte, []int)

+ func (*BindSessionRequest) ProtoMessage()

+ func (x *BindSessionRequest) GetExecutorId() string

+ func (x *BindSessionRequest) ProtoReflect() protoreflect.Message

+ func (x *BindSessionRequest) Reset()

+ func (x *BindSessionRequest) String() string

+ type BindSessionResponse struct

+ LeaseDurationMs int64

+ func (*BindSessionResponse) Descriptor() ([]byte, []int)

+ func (*BindSessionResponse) ProtoMessage()

+ func (x *BindSessionResponse) GetLeaseDurationMs() int64

+ func (x *BindSessionResponse) ProtoReflect() protoreflect.Message

+ func (x *BindSessionResponse) Reset()

+ func (x *BindSessionResponse) String() string

+ type ControlBinding struct

+ DispatcherIncarnation string

+ SessionId string

+ func (*ControlBinding) Descriptor() ([]byte, []int)

+ func (*ControlBinding) ProtoMessage()

+ func (x *ControlBinding) GetDispatcherIncarnation() string

+ func (x *ControlBinding) GetSessionId() string

+ func (x *ControlBinding) ProtoReflect() protoreflect.Message

+ func (x *ControlBinding) Reset()

+ func (x *ControlBinding) String() string

+ type DebugletAllocateRequest struct

+ DebugletId string

+ ExecutorId string

+ Policy *DebugletPolicy

+ TransactionId string

+ func (*DebugletAllocateRequest) Descriptor() ([]byte, []int)

+ func (*DebugletAllocateRequest) ProtoMessage()

+ func (x *DebugletAllocateRequest) GetDebugletId() string

+ func (x *DebugletAllocateRequest) GetExecutorId() string

+ func (x *DebugletAllocateRequest) GetPolicy() *DebugletPolicy

+ func (x *DebugletAllocateRequest) GetTransactionId() string

+ func (x *DebugletAllocateRequest) ProtoReflect() protoreflect.Message

+ func (x *DebugletAllocateRequest) Reset()

+ func (x *DebugletAllocateRequest) String() string

+ type DebugletAllocateResponse struct

+ AllocatedLimits []*DestinationLimit

+ func (*DebugletAllocateResponse) Descriptor() ([]byte, []int)

+ func (*DebugletAllocateResponse) ProtoMessage()

+ func (x *DebugletAllocateResponse) GetAllocatedLimits() []*DestinationLimit

+ func (x *DebugletAllocateResponse) ProtoReflect() protoreflect.Message

+ func (x *DebugletAllocateResponse) Reset()

+ func (x *DebugletAllocateResponse) String() string

+ type DebugletExitRequest struct

+ DebugletId string

+ ErrorMessage *string

+ ExitCode int32

+ func (*DebugletExitRequest) Descriptor() ([]byte, []int)

+ func (*DebugletExitRequest) ProtoMessage()

+ func (x *DebugletExitRequest) GetDebugletId() string

+ func (x *DebugletExitRequest) GetErrorMessage() string

+ func (x *DebugletExitRequest) GetExitCode() int32

+ func (x *DebugletExitRequest) ProtoReflect() protoreflect.Message

+ func (x *DebugletExitRequest) Reset()

+ func (x *DebugletExitRequest) String() string

+ type DebugletExitResponse struct

+ func (*DebugletExitResponse) Descriptor() ([]byte, []int)

+ func (*DebugletExitResponse) ProtoMessage()

+ func (x *DebugletExitResponse) ProtoReflect() protoreflect.Message

+ func (x *DebugletExitResponse) Reset()

+ func (x *DebugletExitResponse) String() string

+ type DebugletIdent struct

+ DebugletId string

+ ExecutorId string

+ func (*DebugletIdent) Descriptor() ([]byte, []int)

+ func (*DebugletIdent) ProtoMessage()

+ func (x *DebugletIdent) GetDebugletId() string

+ func (x *DebugletIdent) GetExecutorId() string

+ func (x *DebugletIdent) ProtoReflect() protoreflect.Message

+ func (x *DebugletIdent) Reset()

+ func (x *DebugletIdent) String() string

+ type DebugletOutput struct

+ Output []byte

+ Timestamp *timestamppb.Timestamp

+ func (*DebugletOutput) Descriptor() ([]byte, []int)

+ func (*DebugletOutput) ProtoMessage()

+ func (x *DebugletOutput) GetOutput() []byte

+ func (x *DebugletOutput) GetTimestamp() *timestamppb.Timestamp

+ func (x *DebugletOutput) ProtoReflect() protoreflect.Message

+ func (x *DebugletOutput) Reset()

+ func (x *DebugletOutput) String() string

+ type DebugletPolicy struct

+ Addresses []string

+ CeilBw int64

+ FloorBw int64

+ ListenScion bool

+ ListenTcp bool

+ ListenUdp bool

+ RequireIcmp bool

+ TimeoutMs int64

+ func (*DebugletPolicy) Descriptor() ([]byte, []int)

+ func (*DebugletPolicy) ProtoMessage()

+ func (x *DebugletPolicy) GetAddresses() []string

+ func (x *DebugletPolicy) GetCeilBw() int64

+ func (x *DebugletPolicy) GetFloorBw() int64

+ func (x *DebugletPolicy) GetListenScion() bool

+ func (x *DebugletPolicy) GetListenTcp() bool

+ func (x *DebugletPolicy) GetListenUdp() bool

+ func (x *DebugletPolicy) GetRequireIcmp() bool

+ func (x *DebugletPolicy) GetTimeoutMs() int64

+ func (x *DebugletPolicy) ProtoReflect() protoreflect.Message

+ func (x *DebugletPolicy) Reset()

+ func (x *DebugletPolicy) String() string

+ type DebugletStateRequest struct

+ DebugletId string

+ ExecutorId string

+ State RunState

+ func (*DebugletStateRequest) Descriptor() ([]byte, []int)

+ func (*DebugletStateRequest) ProtoMessage()

+ func (x *DebugletStateRequest) GetDebugletId() string

+ func (x *DebugletStateRequest) GetExecutorId() string

+ func (x *DebugletStateRequest) GetState() RunState

+ func (x *DebugletStateRequest) ProtoReflect() protoreflect.Message

+ func (x *DebugletStateRequest) Reset()

+ func (x *DebugletStateRequest) String() string

+ type DebugletStateResponse struct

+ func (*DebugletStateResponse) Descriptor() ([]byte, []int)

+ func (*DebugletStateResponse) ProtoMessage()

+ func (x *DebugletStateResponse) ProtoReflect() protoreflect.Message

+ func (x *DebugletStateResponse) Reset()

+ func (x *DebugletStateResponse) String() string

+ type DebugletStreamRequest struct

+ Msg isDebugletStreamRequest_Msg

+ func (*DebugletStreamRequest) Descriptor() ([]byte, []int)

+ func (*DebugletStreamRequest) ProtoMessage()

+ func (x *DebugletStreamRequest) GetIdent() *DebugletIdent

+ func (x *DebugletStreamRequest) GetMsg() isDebugletStreamRequest_Msg

+ func (x *DebugletStreamRequest) GetOutput() *DebugletOutput

+ func (x *DebugletStreamRequest) ProtoReflect() protoreflect.Message

+ func (x *DebugletStreamRequest) Reset()

+ func (x *DebugletStreamRequest) String() string

+ type DebugletStreamRequest_Ident struct

+ Ident *DebugletIdent

+ type DebugletStreamRequest_Output struct

+ Output *DebugletOutput

+ type DebugletStreamResponse struct

+ func (*DebugletStreamResponse) Descriptor() ([]byte, []int)

+ func (*DebugletStreamResponse) ProtoMessage()

+ func (x *DebugletStreamResponse) ProtoReflect() protoreflect.Message

+ func (x *DebugletStreamResponse) Reset()

+ func (x *DebugletStreamResponse) String() string

+ type DestinationLimit struct

+ Address string

+ BitsLimit int64

+ func (*DestinationLimit) Descriptor() ([]byte, []int)

+ func (*DestinationLimit) ProtoMessage()

+ func (x *DestinationLimit) GetAddress() string

+ func (x *DestinationLimit) GetBitsLimit() int64

+ func (x *DestinationLimit) ProtoReflect() protoreflect.Message

+ func (x *DestinationLimit) Reset()

+ func (x *DestinationLimit) String() string

+ type DispatcherServiceClient interface

+ BindSession func(ctx context.Context, in *BindSessionRequest, opts ...grpc.CallOption) (*BindSessionResponse, error)

+ DebugletAllocate func(ctx context.Context, in *DebugletAllocateRequest, opts ...grpc.CallOption) (*DebugletAllocateResponse, error)

+ DebugletExit func(ctx context.Context, in *DebugletExitRequest, opts ...grpc.CallOption) (*DebugletExitResponse, error)

+ DebugletState func(ctx context.Context, in *DebugletStateRequest, opts ...grpc.CallOption) (*DebugletStateResponse, error)

+ DebugletStream func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[DebugletStreamRequest, DebugletStreamResponse], error)

+ Heartbeat func(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)

+ RenewLease func(ctx context.Context, in *RenewLeaseRequest, opts ...grpc.CallOption) (*RenewLeaseResponse, error)

+ Resources func(ctx context.Context, in *ResourcesRequest, opts ...grpc.CallOption) (*ResourcesResponse, error)

+ func NewDispatcherServiceClient(cc grpc.ClientConnInterface) DispatcherServiceClient

+ type DispatcherServiceServer interface

+ BindSession func(context.Context, *BindSessionRequest) (*BindSessionResponse, error)

+ DebugletAllocate func(context.Context, *DebugletAllocateRequest) (*DebugletAllocateResponse, error)

+ DebugletExit func(context.Context, *DebugletExitRequest) (*DebugletExitResponse, error)

+ DebugletState func(context.Context, *DebugletStateRequest) (*DebugletStateResponse, error)

+ DebugletStream func(grpc.BidiStreamingServer[DebugletStreamRequest, DebugletStreamResponse]) error

+ Heartbeat func(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)

+ RenewLease func(context.Context, *RenewLeaseRequest) (*RenewLeaseResponse, error)

+ Resources func(context.Context, *ResourcesRequest) (*ResourcesResponse, error)

+ type DispatcherService_DebugletStreamClient = grpc.BidiStreamingClient[DebugletStreamRequest, DebugletStreamResponse]

+ type DispatcherService_DebugletStreamServer = grpc.BidiStreamingServer[DebugletStreamRequest, DebugletStreamResponse]

+ type ExecutorServiceClient interface

+ Abort func(ctx context.Context, in *AbortRequest, opts ...grpc.CallOption) (*AbortResponse, error)

+ Bandwidth func(ctx context.Context, in *BandwidthRequest, opts ...grpc.CallOption) (*BandwidthResponse, error)

+ Hello func(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)

+ InspectRetainedRun func(ctx context.Context, in *InspectRetainedRunRequest, opts ...grpc.CallOption) (*InspectRetainedRunResponse, error)

+ ProbeSession func(ctx context.Context, in *ProbeSessionRequest, opts ...grpc.CallOption) (*ProbeSessionResponse, error)

+ Upload func(ctx context.Context, in *UploadRequest, opts ...grpc.CallOption) (*UploadResponse, error)

+ func NewExecutorServiceClient(cc grpc.ClientConnInterface) ExecutorServiceClient

+ type ExecutorServiceServer interface

+ Abort func(context.Context, *AbortRequest) (*AbortResponse, error)

+ Bandwidth func(context.Context, *BandwidthRequest) (*BandwidthResponse, error)

+ Hello func(context.Context, *HelloRequest) (*HelloResponse, error)

+ InspectRetainedRun func(context.Context, *InspectRetainedRunRequest) (*InspectRetainedRunResponse, error)

+ ProbeSession func(context.Context, *ProbeSessionRequest) (*ProbeSessionResponse, error)

+ Upload func(context.Context, *UploadRequest) (*UploadResponse, error)

+ type HeartbeatRequest struct

+ ExecutorId string

+ TeslaKey []byte

+ TeslaKeyEpoch int64

+ TimestampNs int64

+ func (*HeartbeatRequest) Descriptor() ([]byte, []int)

+ func (*HeartbeatRequest) ProtoMessage()

+ func (x *HeartbeatRequest) GetExecutorId() string

+ func (x *HeartbeatRequest) GetTeslaKey() []byte

+ func (x *HeartbeatRequest) GetTeslaKeyEpoch() int64

+ func (x *HeartbeatRequest) GetTimestampNs() int64

+ func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message

+ func (x *HeartbeatRequest) Reset()

+ func (x *HeartbeatRequest) String() string

+ type HeartbeatResponse struct

+ func (*HeartbeatResponse) Descriptor() ([]byte, []int)

+ func (*HeartbeatResponse) ProtoMessage()

+ func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message

+ func (x *HeartbeatResponse) Reset()

+ func (x *HeartbeatResponse) String() string

+ type HelloRequest struct

+ ControlVersion uint32

+ DispatcherIncarnation string

+ LeaseDurationMs int64

+ SessionId string

+ SessionToken []byte

+ func (*HelloRequest) Descriptor() ([]byte, []int)

+ func (*HelloRequest) ProtoMessage()

+ func (x *HelloRequest) GetControlVersion() uint32

+ func (x *HelloRequest) GetDispatcherIncarnation() string

+ func (x *HelloRequest) GetLeaseDurationMs() int64

+ func (x *HelloRequest) GetSessionId() string

+ func (x *HelloRequest) GetSessionToken() []byte

+ func (x *HelloRequest) ProtoReflect() protoreflect.Message

+ func (x *HelloRequest) Reset()

+ func (x *HelloRequest) String() string

+ type HelloResponse struct

+ ControlVersion uint32

+ Currency string

+ DispatcherIncarnation string

+ EnrollmentToken *string

+ ExecutorId string

+ IcmpEnabled bool

+ LeaseDurationMs int64

+ PricePerBwS int64

+ PublicHost *string

+ SessionId string

+ SourceIp string

+ SuiWallet *string

+ TeslaAnchorKey []byte

+ TeslaAnchorTimestampNs int64

+ TeslaDelaySec int64

+ Version string

+ func (*HelloResponse) Descriptor() ([]byte, []int)

+ func (*HelloResponse) ProtoMessage()

+ func (x *HelloResponse) GetControlVersion() uint32

+ func (x *HelloResponse) GetCurrency() string

+ func (x *HelloResponse) GetDispatcherIncarnation() string

+ func (x *HelloResponse) GetEnrollmentToken() string

+ func (x *HelloResponse) GetExecutorId() string

+ func (x *HelloResponse) GetIcmpEnabled() bool

+ func (x *HelloResponse) GetLeaseDurationMs() int64

+ func (x *HelloResponse) GetPricePerBwS() int64

+ func (x *HelloResponse) GetPublicHost() string

+ func (x *HelloResponse) GetSessionId() string

+ func (x *HelloResponse) GetSourceIp() string

+ func (x *HelloResponse) GetSuiWallet() string

+ func (x *HelloResponse) GetTeslaAnchorKey() []byte

+ func (x *HelloResponse) GetTeslaAnchorTimestampNs() int64

+ func (x *HelloResponse) GetTeslaDelaySec() int64

+ func (x *HelloResponse) GetVersion() string

+ func (x *HelloResponse) ProtoReflect() protoreflect.Message

+ func (x *HelloResponse) Reset()

+ func (x *HelloResponse) String() string

+ type InspectRetainedRunRequest struct

+ ControlBinding *ControlBinding

+ DebugletId string

+ func (*InspectRetainedRunRequest) Descriptor() ([]byte, []int)

+ func (*InspectRetainedRunRequest) ProtoMessage()

+ func (x *InspectRetainedRunRequest) GetControlBinding() *ControlBinding

+ func (x *InspectRetainedRunRequest) GetDebugletId() string

+ func (x *InspectRetainedRunRequest) ProtoReflect() protoreflect.Message

+ func (x *InspectRetainedRunRequest) Reset()

+ func (x *InspectRetainedRunRequest) String() string

+ type InspectRetainedRunResponse struct

+ Run *RetainedRun

+ Status RetainedRunStatus

+ func (*InspectRetainedRunResponse) Descriptor() ([]byte, []int)

+ func (*InspectRetainedRunResponse) ProtoMessage()

+ func (x *InspectRetainedRunResponse) GetRun() *RetainedRun

+ func (x *InspectRetainedRunResponse) GetStatus() RetainedRunStatus

+ func (x *InspectRetainedRunResponse) ProtoReflect() protoreflect.Message

+ func (x *InspectRetainedRunResponse) Reset()

+ func (x *InspectRetainedRunResponse) String() string

+ type ProbeSessionRequest struct

+ Sequence uint64

+ func (*ProbeSessionRequest) Descriptor() ([]byte, []int)

+ func (*ProbeSessionRequest) ProtoMessage()

+ func (x *ProbeSessionRequest) GetSequence() uint64

+ func (x *ProbeSessionRequest) ProtoReflect() protoreflect.Message

+ func (x *ProbeSessionRequest) Reset()

+ func (x *ProbeSessionRequest) String() string

+ type ProbeSessionResponse struct

+ Sequence uint64

+ func (*ProbeSessionResponse) Descriptor() ([]byte, []int)

+ func (*ProbeSessionResponse) ProtoMessage()

+ func (x *ProbeSessionResponse) GetSequence() uint64

+ func (x *ProbeSessionResponse) ProtoReflect() protoreflect.Message

+ func (x *ProbeSessionResponse) Reset()

+ func (x *ProbeSessionResponse) String() string

+ type RenewLeaseRequest struct

+ Sequence uint64

+ func (*RenewLeaseRequest) Descriptor() ([]byte, []int)

+ func (*RenewLeaseRequest) ProtoMessage()

+ func (x *RenewLeaseRequest) GetSequence() uint64

+ func (x *RenewLeaseRequest) ProtoReflect() protoreflect.Message

+ func (x *RenewLeaseRequest) Reset()

+ func (x *RenewLeaseRequest) String() string

+ type RenewLeaseResponse struct

+ LeaseDurationMs int64

+ Sequence uint64

+ func (*RenewLeaseResponse) Descriptor() ([]byte, []int)

+ func (*RenewLeaseResponse) ProtoMessage()

+ func (x *RenewLeaseResponse) GetLeaseDurationMs() int64

+ func (x *RenewLeaseResponse) GetSequence() uint64

+ func (x *RenewLeaseResponse) ProtoReflect() protoreflect.Message

+ func (x *RenewLeaseResponse) Reset()

+ func (x *RenewLeaseResponse) String() string

+ type ResourcesRequest struct

+ BandwidthCapacity int64

+ ExecutorId string

+ func (*ResourcesRequest) Descriptor() ([]byte, []int)

+ func (*ResourcesRequest) ProtoMessage()

+ func (x *ResourcesRequest) GetBandwidthCapacity() int64

+ func (x *ResourcesRequest) GetExecutorId() string

+ func (x *ResourcesRequest) ProtoReflect() protoreflect.Message

+ func (x *ResourcesRequest) Reset()

+ func (x *ResourcesRequest) String() string

+ type ResourcesResponse struct

+ func (*ResourcesResponse) Descriptor() ([]byte, []int)

+ func (*ResourcesResponse) ProtoMessage()

+ func (x *ResourcesResponse) ProtoReflect() protoreflect.Message

+ func (x *ResourcesResponse) Reset()

+ func (x *ResourcesResponse) String() string

+ type RetainedRun struct

+ DebugletId string

+ OriginalBinding *ControlBinding

+ StartTime *timestamppb.Timestamp

+ Started bool

+ StartedAt *timestamppb.Timestamp

+ TransactionId string

+ func (*RetainedRun) Descriptor() ([]byte, []int)

+ func (*RetainedRun) ProtoMessage()

+ func (x *RetainedRun) GetDebugletId() string

+ func (x *RetainedRun) GetOriginalBinding() *ControlBinding

+ func (x *RetainedRun) GetStartTime() *timestamppb.Timestamp

+ func (x *RetainedRun) GetStarted() bool

+ func (x *RetainedRun) GetStartedAt() *timestamppb.Timestamp

+ func (x *RetainedRun) GetTransactionId() string

+ func (x *RetainedRun) ProtoReflect() protoreflect.Message

+ func (x *RetainedRun) Reset()

+ func (x *RetainedRun) String() string

+ type RetainedRunStatus int32

+ const RetainedRunStatus_RETAINED_RUN_STATUS_ABSENT

+ const RetainedRunStatus_RETAINED_RUN_STATUS_FILTERED

+ const RetainedRunStatus_RETAINED_RUN_STATUS_FOUND

+ const RetainedRunStatus_RETAINED_RUN_STATUS_UNSPECIFIED

+ func (RetainedRunStatus) Descriptor() protoreflect.EnumDescriptor

+ func (RetainedRunStatus) EnumDescriptor() ([]byte, []int)

+ func (RetainedRunStatus) Type() protoreflect.EnumType

+ func (x RetainedRunStatus) Enum() *RetainedRunStatus

+ func (x RetainedRunStatus) Number() protoreflect.EnumNumber

+ func (x RetainedRunStatus) String() string

+ type RunState int32

+ const RunState_RUN_STATE_INITIALIZING

+ const RunState_RUN_STATE_STARTED

+ const RunState_RUN_STATE_UNSPECIFIED

+ func (RunState) Descriptor() protoreflect.EnumDescriptor

+ func (RunState) EnumDescriptor() ([]byte, []int)

+ func (RunState) Type() protoreflect.EnumType

+ func (x RunState) Enum() *RunState

+ func (x RunState) Number() protoreflect.EnumNumber

+ func (x RunState) String() string

+ type UnimplementedDispatcherServiceServer struct

+ func (UnimplementedDispatcherServiceServer) BindSession(context.Context, *BindSessionRequest) (*BindSessionResponse, error)

+ func (UnimplementedDispatcherServiceServer) DebugletAllocate(context.Context, *DebugletAllocateRequest) (*DebugletAllocateResponse, error)

+ func (UnimplementedDispatcherServiceServer) DebugletExit(context.Context, *DebugletExitRequest) (*DebugletExitResponse, error)

+ func (UnimplementedDispatcherServiceServer) DebugletState(context.Context, *DebugletStateRequest) (*DebugletStateResponse, error)

+ func (UnimplementedDispatcherServiceServer) DebugletStream(grpc.BidiStreamingServer[DebugletStreamRequest, DebugletStreamResponse]) error

+ func (UnimplementedDispatcherServiceServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)

+ func (UnimplementedDispatcherServiceServer) RenewLease(context.Context, *RenewLeaseRequest) (*RenewLeaseResponse, error)

+ func (UnimplementedDispatcherServiceServer) Resources(context.Context, *ResourcesRequest) (*ResourcesResponse, error)

+ type UnimplementedExecutorServiceServer struct

+ func (UnimplementedExecutorServiceServer) Abort(context.Context, *AbortRequest) (*AbortResponse, error)

+ func (UnimplementedExecutorServiceServer) Bandwidth(context.Context, *BandwidthRequest) (*BandwidthResponse, error)

+ func (UnimplementedExecutorServiceServer) Hello(context.Context, *HelloRequest) (*HelloResponse, error)

+ func (UnimplementedExecutorServiceServer) InspectRetainedRun(context.Context, *InspectRetainedRunRequest) (*InspectRetainedRunResponse, error)

+ func (UnimplementedExecutorServiceServer) ProbeSession(context.Context, *ProbeSessionRequest) (*ProbeSessionResponse, error)

+ func (UnimplementedExecutorServiceServer) Upload(context.Context, *UploadRequest) (*UploadResponse, error)

+ type UnsafeDispatcherServiceServer interface

+ type UnsafeExecutorServiceServer interface

+ type UploadRequest struct

+ Args []string

+ ControlBinding *ControlBinding

+ Id string

+ Policy *DebugletPolicy

+ StartTime *timestamppb.Timestamp

+ TransactionId string

+ Wasm []byte

+ func (*UploadRequest) Descriptor() ([]byte, []int)

+ func (*UploadRequest) ProtoMessage()

+ func (x *UploadRequest) GetArgs() []string

+ func (x *UploadRequest) GetControlBinding() *ControlBinding

+ func (x *UploadRequest) GetId() string

+ func (x *UploadRequest) GetPolicy() *DebugletPolicy

+ func (x *UploadRequest) GetStartTime() *timestamppb.Timestamp

+ func (x *UploadRequest) GetTransactionId() string

+ func (x *UploadRequest) GetWasm() []byte

+ func (x *UploadRequest) ProtoReflect() protoreflect.Message

+ func (x *UploadRequest) Reset()

+ func (x *UploadRequest) String() string

+ type UploadResponse struct

+ func (*UploadResponse) Descriptor() ([]byte, []int)

+ func (*UploadResponse) ProtoMessage()

+ func (x *UploadResponse) ProtoReflect() protoreflect.Message

+ func (x *UploadResponse) Reset()

+ func (x *UploadResponse) String() string

v0.2.0-rc.3

Sep 26, 2026

v0.2.0-rc.2

Sep 26, 2026

v0.2.0-rc.1

Sep 25, 2026

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL