e2e_wasm_session

package
v0.51.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 7, 2026 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const ConfigID = ControllerID

ConfigID is the config identifier.

View Source 
const ControllerID = "e2e/wasm/session"

ControllerID is the controller identifier.

View Source 
const SRPCEstablishLinkResourceServiceServiceID = "e2e.wasm.session.EstablishLinkResourceService"
View Source 
const SRPCPeerInfoResourceServiceServiceID = "e2e.wasm.session.PeerInfoResourceService"
View Source 
const SRPCSignalRelayServiceServiceID = "e2e.wasm.session.SignalRelayService"

Variables

View Source 
var (
	EstablishLinkState_name = map[int32]string{
		0: "EstablishLinkState_UNKNOWN",
		1: "EstablishLinkState_PENDING",
		2: "EstablishLinkState_CONNECTED",
		3: "EstablishLinkState_FAILED",
	}
	EstablishLinkState_value = map[string]int32{
		"EstablishLinkState_UNKNOWN":   0,
		"EstablishLinkState_PENDING":   1,
		"EstablishLinkState_CONNECTED": 2,
		"EstablishLinkState_FAILED":    3,
	}
)

Enum value maps for EstablishLinkState.

View Source 
var Version = semver.MustParse("0.0.1")

Version is the component version.

Functions

func InjectSessionHarnessConfig 

func InjectSessionHarnessConfig(projectConfig *bldr_project.ProjectConfig) error

InjectSessionHarnessConfig adds the session harness controller to all Go compiler manifests in the project config so the session harness is available in plugin processes without modifying the production project config.

func NewFactory 

func NewFactory(b bus.Bus) controller.Factory

NewFactory constructs the component factory.

func NewSRPCEstablishLinkResourceServiceHandler 

func NewSRPCEstablishLinkResourceServiceHandler(impl SRPCEstablishLinkResourceServiceServer, serviceID string) srpc.Handler

NewSRPCEstablishLinkResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: e2e.wasm.session.EstablishLinkResourceService

func NewSRPCPeerInfoResourceServiceHandler 

func NewSRPCPeerInfoResourceServiceHandler(impl SRPCPeerInfoResourceServiceServer, serviceID string) srpc.Handler

NewSRPCPeerInfoResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: e2e.wasm.session.PeerInfoResourceService

func NewSRPCSignalRelayServiceHandler 

func NewSRPCSignalRelayServiceHandler(impl SRPCSignalRelayServiceServer, serviceID string) srpc.Handler

NewSRPCSignalRelayServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: e2e.wasm.session.SignalRelayService

func SRPCRegisterEstablishLinkResourceService 

func SRPCRegisterEstablishLinkResourceService(mux srpc.Mux, impl SRPCEstablishLinkResourceServiceServer) error

SRPCRegisterEstablishLinkResourceService registers the implementation with the mux. Uses the default serviceID: e2e.wasm.session.EstablishLinkResourceService

func SRPCRegisterPeerInfoResourceService 

func SRPCRegisterPeerInfoResourceService(mux srpc.Mux, impl SRPCPeerInfoResourceServiceServer) error

SRPCRegisterPeerInfoResourceService registers the implementation with the mux. Uses the default serviceID: e2e.wasm.session.PeerInfoResourceService

func SRPCRegisterSignalRelayService 

func SRPCRegisterSignalRelayService(mux srpc.Mux, impl SRPCSignalRelayServiceServer) error

SRPCRegisterSignalRelayService registers the implementation with the mux. Uses the default serviceID: e2e.wasm.session.SignalRelayService

Types

type Config 

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

Config configures the session harness controller.

func (*Config) CloneMessageVT 

func (m *Config) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*Config) CloneVT 

func (m *Config) CloneVT() *Config

func (*Config) EqualMessageVT 

func (this *Config) EqualMessageVT(thatMsg any) bool

func (*Config) EqualVT 

func (this *Config) EqualVT(that *Config) bool

func (*Config) EqualsConfig 

func (c *Config) EqualsConfig(other config.Config) bool

EqualsConfig checks if the config is equal to another.

func (*Config) GetConfigID 

func (c *Config) GetConfigID() string

GetConfigID returns the unique string for this configuration type.

func (*Config) MarshalJSON 

func (x *Config) MarshalJSON() ([]byte, error)

MarshalJSON marshals the Config to JSON.

func (*Config) MarshalProtoJSON 

func (x *Config) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the Config message to JSON.

func (*Config) MarshalProtoText 

func (x *Config) MarshalProtoText() string

func (*Config) MarshalToSizedBufferVT 

func (m *Config) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Config) MarshalToVT 

func (m *Config) MarshalToVT(dAtA []byte) (int, error)

func (*Config) MarshalVT 

func (m *Config) MarshalVT() (dAtA []byte, err error)

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) SizeVT 

func (m *Config) SizeVT() (n int)

func (*Config) String 

func (x *Config) String() string

func (*Config) UnmarshalJSON 

func (x *Config) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the Config from JSON.

func (*Config) UnmarshalProtoJSON 

func (x *Config) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the Config message from JSON.

func (*Config) UnmarshalVT 

func (m *Config) UnmarshalVT(dAtA []byte) error

func (*Config) Validate 

func (c *Config) Validate() error

Validate validates the configuration.

type Controller 

type Controller struct {
	*bus.BusController[*Config]
	// contains filtered or unexported fields
}

Controller is the session harness controller running inside the WASM plugin. It exposes RPC services for test orchestration: peer info, link establishment, and signaling relay.

func (*Controller) Execute 

func (c *Controller) Execute(ctx context.Context) error

Execute executes the controller.

func (*Controller) GetPeerInfo 

func (c *Controller) GetPeerInfo(
	ctx context.Context,
	req *GetPeerInfoRequest,
) (*GetPeerInfoResponse, error)

GetPeerInfo returns the local bifrost peer ID.

func (*Controller) HandleDirective 

func (c *Controller) HandleDirective(
	ctx context.Context,
	di directive.Instance,
) ([]directive.Resolver, error)

HandleDirective asks if the handler can resolve the directive.

func (*Controller) InvokeMethod 

func (c *Controller) InvokeMethod(serviceID, methodID string, strm srpc.Stream) (bool, error)

InvokeMethod invokes the method matching the service and method IDs.

func (*Controller) SignalRelay 

func (c *Controller) SignalRelay(strm SRPCSignalRelayService_SignalRelayStream) error

SignalRelay handles a bidirectional signaling relay stream. The first message must be a SignalRelayInit identifying the remote peer. Subsequent messages carry opaque signaling bytes forwarded between the Go test process and the browser WASM SignalPeer resolver.

func (*Controller) WatchState 

func (c *Controller) WatchState(
	req *WatchStateRequest,
	strm SRPCEstablishLinkResourceService_WatchStateStream,
) error

WatchState handles the EstablishLink streaming RPC. It emits an EstablishLinkWithPeer directive on the bus and streams state updates as the link progresses from PENDING to CONNECTED (or FAILED).

type EstablishLinkState 

type EstablishLinkState int32

EstablishLinkState represents the state of link establishment. 

const (
	// EstablishLinkState_UNKNOWN is the default state.
	EstablishLinkState_EstablishLinkState_UNKNOWN EstablishLinkState = 0
	// EstablishLinkState_PENDING indicates the link is being established.
	EstablishLinkState_EstablishLinkState_PENDING EstablishLinkState = 1
	// EstablishLinkState_CONNECTED indicates the bifrost link is up.
	EstablishLinkState_EstablishLinkState_CONNECTED EstablishLinkState = 2
	// EstablishLinkState_FAILED indicates link establishment failed.
	EstablishLinkState_EstablishLinkState_FAILED EstablishLinkState = 3
)

func (EstablishLinkState) Enum 

func (x EstablishLinkState) Enum() *EstablishLinkState

func (EstablishLinkState) MarshalJSON 

func (x EstablishLinkState) MarshalJSON() ([]byte, error)

MarshalJSON marshals the EstablishLinkState to JSON.

func (EstablishLinkState) MarshalProtoJSON 

func (x EstablishLinkState) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the EstablishLinkState to JSON.

func (EstablishLinkState) MarshalProtoText 

func (x EstablishLinkState) MarshalProtoText() string

func (EstablishLinkState) MarshalText 

func (x EstablishLinkState) MarshalText() ([]byte, error)

MarshalText marshals the EstablishLinkState to text.

func (EstablishLinkState) String 

func (x EstablishLinkState) String() string

func (*EstablishLinkState) UnmarshalJSON 

func (x *EstablishLinkState) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the EstablishLinkState from JSON.

func (*EstablishLinkState) UnmarshalProtoJSON 

func (x *EstablishLinkState) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the EstablishLinkState from JSON.

func (*EstablishLinkState) UnmarshalText 

func (x *EstablishLinkState) UnmarshalText(b []byte) error

UnmarshalText unmarshals the EstablishLinkState from text.

type GetPeerInfoRequest 

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

GetPeerInfoRequest is the request type for GetPeerInfo.

func (*GetPeerInfoRequest) CloneMessageVT 

func (m *GetPeerInfoRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetPeerInfoRequest) CloneVT 

func (m *GetPeerInfoRequest) CloneVT() *GetPeerInfoRequest

func (*GetPeerInfoRequest) EqualMessageVT 

func (this *GetPeerInfoRequest) EqualMessageVT(thatMsg any) bool

func (*GetPeerInfoRequest) EqualVT 

func (this *GetPeerInfoRequest) EqualVT(that *GetPeerInfoRequest) bool

func (*GetPeerInfoRequest) MarshalJSON 

func (x *GetPeerInfoRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetPeerInfoRequest to JSON.

func (*GetPeerInfoRequest) MarshalProtoJSON 

func (x *GetPeerInfoRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetPeerInfoRequest message to JSON.

func (*GetPeerInfoRequest) MarshalProtoText 

func (x *GetPeerInfoRequest) MarshalProtoText() string

func (*GetPeerInfoRequest) MarshalToSizedBufferVT 

func (m *GetPeerInfoRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetPeerInfoRequest) MarshalToVT 

func (m *GetPeerInfoRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetPeerInfoRequest) MarshalVT 

func (m *GetPeerInfoRequest) MarshalVT() (dAtA []byte, err error)

func (*GetPeerInfoRequest) ProtoMessage 

func (*GetPeerInfoRequest) ProtoMessage()

func (*GetPeerInfoRequest) Reset 

func (x *GetPeerInfoRequest) Reset()

func (*GetPeerInfoRequest) SizeVT 

func (m *GetPeerInfoRequest) SizeVT() (n int)

func (*GetPeerInfoRequest) String 

func (x *GetPeerInfoRequest) String() string

func (*GetPeerInfoRequest) UnmarshalJSON 

func (x *GetPeerInfoRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetPeerInfoRequest from JSON.

func (*GetPeerInfoRequest) UnmarshalProtoJSON 

func (x *GetPeerInfoRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetPeerInfoRequest message from JSON.

func (*GetPeerInfoRequest) UnmarshalVT 

func (m *GetPeerInfoRequest) UnmarshalVT(dAtA []byte) error

type GetPeerInfoResponse 

type GetPeerInfoResponse struct {

	// PeerId is the local bifrost peer ID (base58-encoded).
	PeerId string `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peerId,omitempty"`
	// contains filtered or unexported fields
}

GetPeerInfoResponse is the response type for GetPeerInfo.

func (*GetPeerInfoResponse) CloneMessageVT 

func (m *GetPeerInfoResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetPeerInfoResponse) CloneVT 

func (m *GetPeerInfoResponse) CloneVT() *GetPeerInfoResponse

func (*GetPeerInfoResponse) EqualMessageVT 

func (this *GetPeerInfoResponse) EqualMessageVT(thatMsg any) bool

func (*GetPeerInfoResponse) EqualVT 

func (this *GetPeerInfoResponse) EqualVT(that *GetPeerInfoResponse) bool

func (*GetPeerInfoResponse) GetPeerId 

func (x *GetPeerInfoResponse) GetPeerId() string

func (*GetPeerInfoResponse) MarshalJSON 

func (x *GetPeerInfoResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetPeerInfoResponse to JSON.

func (*GetPeerInfoResponse) MarshalProtoJSON 

func (x *GetPeerInfoResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetPeerInfoResponse message to JSON.

func (*GetPeerInfoResponse) MarshalProtoText 

func (x *GetPeerInfoResponse) MarshalProtoText() string

func (*GetPeerInfoResponse) MarshalToSizedBufferVT 

func (m *GetPeerInfoResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetPeerInfoResponse) MarshalToVT 

func (m *GetPeerInfoResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetPeerInfoResponse) MarshalVT 

func (m *GetPeerInfoResponse) MarshalVT() (dAtA []byte, err error)

func (*GetPeerInfoResponse) ProtoMessage 

func (*GetPeerInfoResponse) ProtoMessage()

func (*GetPeerInfoResponse) Reset 

func (x *GetPeerInfoResponse) Reset()

func (*GetPeerInfoResponse) SizeVT 

func (m *GetPeerInfoResponse) SizeVT() (n int)

func (*GetPeerInfoResponse) String 

func (x *GetPeerInfoResponse) String() string

func (*GetPeerInfoResponse) UnmarshalJSON 

func (x *GetPeerInfoResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetPeerInfoResponse from JSON.

func (*GetPeerInfoResponse) UnmarshalProtoJSON 

func (x *GetPeerInfoResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetPeerInfoResponse message from JSON.

func (*GetPeerInfoResponse) UnmarshalVT 

func (m *GetPeerInfoResponse) UnmarshalVT(dAtA []byte) error

type SRPCEstablishLinkResourceServiceClient 

type SRPCEstablishLinkResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	WatchState(ctx context.Context, in *WatchStateRequest) (SRPCEstablishLinkResourceService_WatchStateClient, error)
}

func NewSRPCEstablishLinkResourceServiceClient 

func NewSRPCEstablishLinkResourceServiceClient(cc srpc.Client) SRPCEstablishLinkResourceServiceClient

func NewSRPCEstablishLinkResourceServiceClientWithServiceID 

func NewSRPCEstablishLinkResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCEstablishLinkResourceServiceClient

type SRPCEstablishLinkResourceServiceHandler 

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

func (SRPCEstablishLinkResourceServiceHandler) GetMethodIDs 

func (SRPCEstablishLinkResourceServiceHandler) GetMethodIDs() []string

func (*SRPCEstablishLinkResourceServiceHandler) GetServiceID 

func (d *SRPCEstablishLinkResourceServiceHandler) GetServiceID() string

func (*SRPCEstablishLinkResourceServiceHandler) InvokeMethod 

func (d *SRPCEstablishLinkResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCEstablishLinkResourceServiceHandler) InvokeMethod_WatchState 

func (SRPCEstablishLinkResourceServiceHandler) InvokeMethod_WatchState(impl SRPCEstablishLinkResourceServiceServer, strm srpc.Stream) error

type SRPCEstablishLinkResourceServiceServer 

type SRPCEstablishLinkResourceServiceServer interface {
	WatchState(*WatchStateRequest, SRPCEstablishLinkResourceService_WatchStateStream) error
}

type SRPCEstablishLinkResourceService_WatchStateClient 

type SRPCEstablishLinkResourceService_WatchStateClient interface {
	srpc.Stream
	Recv() (*WatchStateResponse, error)
	RecvTo(*WatchStateResponse) error
}

type SRPCEstablishLinkResourceService_WatchStateStream 

type SRPCEstablishLinkResourceService_WatchStateStream interface {
	srpc.Stream
	Send(*WatchStateResponse) error
	SendAndClose(*WatchStateResponse) error
}

type SRPCPeerInfoResourceServiceClient 

type SRPCPeerInfoResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	GetPeerInfo(ctx context.Context, in *GetPeerInfoRequest) (*GetPeerInfoResponse, error)
}

func NewSRPCPeerInfoResourceServiceClient 

func NewSRPCPeerInfoResourceServiceClient(cc srpc.Client) SRPCPeerInfoResourceServiceClient

func NewSRPCPeerInfoResourceServiceClientWithServiceID 

func NewSRPCPeerInfoResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCPeerInfoResourceServiceClient

type SRPCPeerInfoResourceServiceHandler 

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

func (SRPCPeerInfoResourceServiceHandler) GetMethodIDs 

func (SRPCPeerInfoResourceServiceHandler) GetMethodIDs() []string

func (*SRPCPeerInfoResourceServiceHandler) GetServiceID 

func (d *SRPCPeerInfoResourceServiceHandler) GetServiceID() string

func (*SRPCPeerInfoResourceServiceHandler) InvokeMethod 

func (d *SRPCPeerInfoResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCPeerInfoResourceServiceHandler) InvokeMethod_GetPeerInfo 

func (SRPCPeerInfoResourceServiceHandler) InvokeMethod_GetPeerInfo(impl SRPCPeerInfoResourceServiceServer, strm srpc.Stream) error

type SRPCPeerInfoResourceServiceServer 

type SRPCPeerInfoResourceServiceServer interface {
	GetPeerInfo(context.Context, *GetPeerInfoRequest) (*GetPeerInfoResponse, error)
}

type SRPCPeerInfoResourceService_GetPeerInfoStream 

type SRPCPeerInfoResourceService_GetPeerInfoStream interface {
	srpc.Stream
}

type SRPCSignalRelayServiceClient 

type SRPCSignalRelayServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	SignalRelay(ctx context.Context) (SRPCSignalRelayService_SignalRelayClient, error)
}

func NewSRPCSignalRelayServiceClient 

func NewSRPCSignalRelayServiceClient(cc srpc.Client) SRPCSignalRelayServiceClient

func NewSRPCSignalRelayServiceClientWithServiceID 

func NewSRPCSignalRelayServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCSignalRelayServiceClient

type SRPCSignalRelayServiceHandler 

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

func (SRPCSignalRelayServiceHandler) GetMethodIDs 

func (SRPCSignalRelayServiceHandler) GetMethodIDs() []string

func (*SRPCSignalRelayServiceHandler) GetServiceID 

func (d *SRPCSignalRelayServiceHandler) GetServiceID() string

func (*SRPCSignalRelayServiceHandler) InvokeMethod 

func (d *SRPCSignalRelayServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCSignalRelayServiceHandler) InvokeMethod_SignalRelay 

func (SRPCSignalRelayServiceHandler) InvokeMethod_SignalRelay(impl SRPCSignalRelayServiceServer, strm srpc.Stream) error

type SRPCSignalRelayServiceServer 

type SRPCSignalRelayServiceServer interface {
	SignalRelay(SRPCSignalRelayService_SignalRelayStream) error
}

type SRPCSignalRelayService_SignalRelayClient 

type SRPCSignalRelayService_SignalRelayClient interface {
	srpc.Stream
	Send(*SignalRelayMessage) error
	Recv() (*SignalRelayMessage, error)
	RecvTo(*SignalRelayMessage) error
}

type SRPCSignalRelayService_SignalRelayStream 

type SRPCSignalRelayService_SignalRelayStream interface {
	srpc.Stream
	Send(*SignalRelayMessage) error
	SendAndClose(*SignalRelayMessage) error
	Recv() (*SignalRelayMessage, error)
	RecvTo(*SignalRelayMessage) error
}

type SignalRelayInit 

type SignalRelayInit struct {

	// RemotePeerId is the base58-encoded peer ID of the remote peer.
	RemotePeerId string `protobuf:"bytes,1,opt,name=remote_peer_id,json=remotePeerId,proto3" json:"remotePeerId,omitempty"`
	// contains filtered or unexported fields
}

SignalRelayInit identifies the remote peer for the relay session.

func (*SignalRelayInit) CloneMessageVT 

func (m *SignalRelayInit) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SignalRelayInit) CloneVT 

func (m *SignalRelayInit) CloneVT() *SignalRelayInit

func (*SignalRelayInit) EqualMessageVT 

func (this *SignalRelayInit) EqualMessageVT(thatMsg any) bool

func (*SignalRelayInit) EqualVT 

func (this *SignalRelayInit) EqualVT(that *SignalRelayInit) bool

func (*SignalRelayInit) GetRemotePeerId 

func (x *SignalRelayInit) GetRemotePeerId() string

func (*SignalRelayInit) MarshalJSON 

func (x *SignalRelayInit) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SignalRelayInit to JSON.

func (*SignalRelayInit) MarshalProtoJSON 

func (x *SignalRelayInit) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SignalRelayInit message to JSON.

func (*SignalRelayInit) MarshalProtoText 

func (x *SignalRelayInit) MarshalProtoText() string

func (*SignalRelayInit) MarshalToSizedBufferVT 

func (m *SignalRelayInit) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SignalRelayInit) MarshalToVT 

func (m *SignalRelayInit) MarshalToVT(dAtA []byte) (int, error)

func (*SignalRelayInit) MarshalVT 

func (m *SignalRelayInit) MarshalVT() (dAtA []byte, err error)

func (*SignalRelayInit) ProtoMessage 

func (*SignalRelayInit) ProtoMessage()

func (*SignalRelayInit) Reset 

func (x *SignalRelayInit) Reset()

func (*SignalRelayInit) SizeVT 

func (m *SignalRelayInit) SizeVT() (n int)

func (*SignalRelayInit) String 

func (x *SignalRelayInit) String() string

func (*SignalRelayInit) UnmarshalJSON 

func (x *SignalRelayInit) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SignalRelayInit from JSON.

func (*SignalRelayInit) UnmarshalProtoJSON 

func (x *SignalRelayInit) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SignalRelayInit message from JSON.

func (*SignalRelayInit) UnmarshalVT 

func (m *SignalRelayInit) UnmarshalVT(dAtA []byte) error

type SignalRelayMessage 

type SignalRelayMessage struct {

	// Types that are assignable to Body:
	//
	//	*SignalRelayMessage_Init
	//	*SignalRelayMessage_Data
	Body isSignalRelayMessage_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

SignalRelayMessage is a message in the SignalRelay bidirectional stream.

func (*SignalRelayMessage) CloneMessageVT 

func (m *SignalRelayMessage) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SignalRelayMessage) CloneVT 

func (m *SignalRelayMessage) CloneVT() *SignalRelayMessage

func (*SignalRelayMessage) EqualMessageVT 

func (this *SignalRelayMessage) EqualMessageVT(thatMsg any) bool

func (*SignalRelayMessage) EqualVT 

func (this *SignalRelayMessage) EqualVT(that *SignalRelayMessage) bool

func (*SignalRelayMessage) GetBody 

func (m *SignalRelayMessage) GetBody() isSignalRelayMessage_Body

func (*SignalRelayMessage) GetData 

func (x *SignalRelayMessage) GetData() []byte

func (*SignalRelayMessage) GetInit 

func (x *SignalRelayMessage) GetInit() *SignalRelayInit

func (*SignalRelayMessage) MarshalJSON 

func (x *SignalRelayMessage) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SignalRelayMessage to JSON.

func (*SignalRelayMessage) MarshalProtoJSON 

func (x *SignalRelayMessage) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SignalRelayMessage message to JSON.

func (*SignalRelayMessage) MarshalProtoText 

func (x *SignalRelayMessage) MarshalProtoText() string

func (*SignalRelayMessage) MarshalToSizedBufferVT 

func (m *SignalRelayMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SignalRelayMessage) MarshalToVT 

func (m *SignalRelayMessage) MarshalToVT(dAtA []byte) (int, error)

func (*SignalRelayMessage) MarshalVT 

func (m *SignalRelayMessage) MarshalVT() (dAtA []byte, err error)

func (*SignalRelayMessage) ProtoMessage 

func (*SignalRelayMessage) ProtoMessage()

func (*SignalRelayMessage) Reset 

func (x *SignalRelayMessage) Reset()

func (*SignalRelayMessage) SizeVT 

func (m *SignalRelayMessage) SizeVT() (n int)

func (*SignalRelayMessage) String 

func (x *SignalRelayMessage) String() string

func (*SignalRelayMessage) UnmarshalJSON 

func (x *SignalRelayMessage) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SignalRelayMessage from JSON.

func (*SignalRelayMessage) UnmarshalProtoJSON 

func (x *SignalRelayMessage) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SignalRelayMessage message from JSON.

func (*SignalRelayMessage) UnmarshalVT 

func (m *SignalRelayMessage) UnmarshalVT(dAtA []byte) error

type SignalRelayMessage_Data 

type SignalRelayMessage_Data struct {
	// Data carries opaque signaling bytes.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

func (*SignalRelayMessage_Data) CloneOneofVT 

func (m *SignalRelayMessage_Data) CloneOneofVT() isSignalRelayMessage_Body

func (*SignalRelayMessage_Data) CloneVT 

func (m *SignalRelayMessage_Data) CloneVT() *SignalRelayMessage_Data

func (*SignalRelayMessage_Data) EqualVT 

func (this *SignalRelayMessage_Data) EqualVT(thatIface isSignalRelayMessage_Body) bool

func (*SignalRelayMessage_Data) MarshalToSizedBufferVT 

func (m *SignalRelayMessage_Data) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SignalRelayMessage_Data) MarshalToVT 

func (m *SignalRelayMessage_Data) MarshalToVT(dAtA []byte) (int, error)

func (*SignalRelayMessage_Data) SizeVT 

func (m *SignalRelayMessage_Data) SizeVT() (n int)

type SignalRelayMessage_Init 

type SignalRelayMessage_Init struct {
	// Init identifies the remote peer for the relay session. Must be the
	// first message sent by the client.
	Init *SignalRelayInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

func (*SignalRelayMessage_Init) CloneOneofVT 

func (m *SignalRelayMessage_Init) CloneOneofVT() isSignalRelayMessage_Body

func (*SignalRelayMessage_Init) CloneVT 

func (m *SignalRelayMessage_Init) CloneVT() *SignalRelayMessage_Init

func (*SignalRelayMessage_Init) EqualVT 

func (this *SignalRelayMessage_Init) EqualVT(thatIface isSignalRelayMessage_Body) bool

func (*SignalRelayMessage_Init) MarshalToSizedBufferVT 

func (m *SignalRelayMessage_Init) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SignalRelayMessage_Init) MarshalToVT 

func (m *SignalRelayMessage_Init) MarshalToVT(dAtA []byte) (int, error)

func (*SignalRelayMessage_Init) SizeVT 

func (m *SignalRelayMessage_Init) SizeVT() (n int)

type WatchStateRequest 

type WatchStateRequest struct {

	// TargetPeerId is the base58-encoded peer ID to establish a link with.
	TargetPeerId string `protobuf:"bytes,1,opt,name=target_peer_id,json=targetPeerId,proto3" json:"targetPeerId,omitempty"`
	// contains filtered or unexported fields
}

WatchStateRequest is the request type for WatchState.

func (*WatchStateRequest) CloneMessageVT 

func (m *WatchStateRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WatchStateRequest) CloneVT 

func (m *WatchStateRequest) CloneVT() *WatchStateRequest

func (*WatchStateRequest) EqualMessageVT 

func (this *WatchStateRequest) EqualMessageVT(thatMsg any) bool

func (*WatchStateRequest) EqualVT 

func (this *WatchStateRequest) EqualVT(that *WatchStateRequest) bool

func (*WatchStateRequest) GetTargetPeerId 

func (x *WatchStateRequest) GetTargetPeerId() string

func (*WatchStateRequest) MarshalJSON 

func (x *WatchStateRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WatchStateRequest to JSON.

func (*WatchStateRequest) MarshalProtoJSON 

func (x *WatchStateRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WatchStateRequest message to JSON.

func (*WatchStateRequest) MarshalProtoText 

func (x *WatchStateRequest) MarshalProtoText() string

func (*WatchStateRequest) MarshalToSizedBufferVT 

func (m *WatchStateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WatchStateRequest) MarshalToVT 

func (m *WatchStateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*WatchStateRequest) MarshalVT 

func (m *WatchStateRequest) MarshalVT() (dAtA []byte, err error)

func (*WatchStateRequest) ProtoMessage 

func (*WatchStateRequest) ProtoMessage()

func (*WatchStateRequest) Reset 

func (x *WatchStateRequest) Reset()

func (*WatchStateRequest) SizeVT 

func (m *WatchStateRequest) SizeVT() (n int)

func (*WatchStateRequest) String 

func (x *WatchStateRequest) String() string

func (*WatchStateRequest) UnmarshalJSON 

func (x *WatchStateRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WatchStateRequest from JSON.

func (*WatchStateRequest) UnmarshalProtoJSON 

func (x *WatchStateRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WatchStateRequest message from JSON.

func (*WatchStateRequest) UnmarshalVT 

func (m *WatchStateRequest) UnmarshalVT(dAtA []byte) error

type WatchStateResponse 

type WatchStateResponse struct {

	// State is the current link establishment state.
	State EstablishLinkState `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

WatchStateResponse is the response type for WatchState.

func (*WatchStateResponse) CloneMessageVT 

func (m *WatchStateResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WatchStateResponse) CloneVT 

func (m *WatchStateResponse) CloneVT() *WatchStateResponse

func (*WatchStateResponse) EqualMessageVT 

func (this *WatchStateResponse) EqualMessageVT(thatMsg any) bool

func (*WatchStateResponse) EqualVT 

func (this *WatchStateResponse) EqualVT(that *WatchStateResponse) bool

func (*WatchStateResponse) GetState 

func (x *WatchStateResponse) GetState() EstablishLinkState

func (*WatchStateResponse) MarshalJSON 

func (x *WatchStateResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WatchStateResponse to JSON.

func (*WatchStateResponse) MarshalProtoJSON 

func (x *WatchStateResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WatchStateResponse message to JSON.

func (*WatchStateResponse) MarshalProtoText 

func (x *WatchStateResponse) MarshalProtoText() string

func (*WatchStateResponse) MarshalToSizedBufferVT 

func (m *WatchStateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WatchStateResponse) MarshalToVT 

func (m *WatchStateResponse) MarshalToVT(dAtA []byte) (int, error)

func (*WatchStateResponse) MarshalVT 

func (m *WatchStateResponse) MarshalVT() (dAtA []byte, err error)

func (*WatchStateResponse) ProtoMessage 

func (*WatchStateResponse) ProtoMessage()

func (*WatchStateResponse) Reset 

func (x *WatchStateResponse) Reset()

func (*WatchStateResponse) SizeVT 

func (m *WatchStateResponse) SizeVT() (n int)

func (*WatchStateResponse) String 

func (x *WatchStateResponse) String() string

func (*WatchStateResponse) UnmarshalJSON 

func (x *WatchStateResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WatchStateResponse from JSON.

func (*WatchStateResponse) UnmarshalProtoJSON 

func (x *WatchStateResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WatchStateResponse message from JSON.

func (*WatchStateResponse) UnmarshalVT 

func (m *WatchStateResponse) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.