Help us shape the future of Go! Take the 2026 Go Developer Survey

prototype_webworker_rpcstream_common

package
v0.57.21 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const SRPCPrototypeServiceServiceID = "prototype.webworker_rpcstream.common.PrototypeService"

Variables

This section is empty.

Functions

func NewSRPCPrototypeServiceHandler

func NewSRPCPrototypeServiceHandler(impl SRPCPrototypeServiceServer, serviceID string) srpc.Handler

NewSRPCPrototypeServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: prototype.webworker_rpcstream.common.PrototypeService

func SRPCRegisterPrototypeService

func SRPCRegisterPrototypeService(mux srpc.Mux, impl SRPCPrototypeServiceServer) error

SRPCRegisterPrototypeService registers the implementation with the mux. Uses the default serviceID: prototype.webworker_rpcstream.common.PrototypeService

Types

type PrototypeRequest

type PrototypeRequest struct {
	Body string `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

PrototypeRequest is the request message for the Prototype RPC.

func (*PrototypeRequest) CloneMessageVT

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

func (*PrototypeRequest) CloneVT

func (m *PrototypeRequest) CloneVT() *PrototypeRequest

func (*PrototypeRequest) EqualMessageVT

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

func (*PrototypeRequest) EqualVT

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

func (*PrototypeRequest) GetBody

func (x *PrototypeRequest) GetBody() string

func (*PrototypeRequest) MarshalJSON

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

MarshalJSON marshals the PrototypeRequest to JSON.

func (*PrototypeRequest) MarshalProtoJSON

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

MarshalProtoJSON marshals the PrototypeRequest message to JSON.

func (*PrototypeRequest) MarshalProtoText

func (x *PrototypeRequest) MarshalProtoText() string

func (*PrototypeRequest) MarshalToSizedBufferVT

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

func (*PrototypeRequest) MarshalToVT

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

func (*PrototypeRequest) MarshalVT

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

func (*PrototypeRequest) ProtoMessage

func (*PrototypeRequest) ProtoMessage()

func (*PrototypeRequest) Reset

func (x *PrototypeRequest) Reset()

func (*PrototypeRequest) SizeVT

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

func (*PrototypeRequest) String

func (x *PrototypeRequest) String() string

func (*PrototypeRequest) UnmarshalJSON

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

UnmarshalJSON unmarshals the PrototypeRequest from JSON.

func (*PrototypeRequest) UnmarshalProtoJSON

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

UnmarshalProtoJSON unmarshals the PrototypeRequest message from JSON.

func (*PrototypeRequest) UnmarshalVT

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

type PrototypeResponse

type PrototypeResponse struct {
	Body           string `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	SequenceNumber int32  `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequenceNumber,omitempty"`
	// contains filtered or unexported fields
}

PrototypeResponse is the response message for the Prototype RPC.

func (*PrototypeResponse) CloneMessageVT

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

func (*PrototypeResponse) CloneVT

func (m *PrototypeResponse) CloneVT() *PrototypeResponse

func (*PrototypeResponse) EqualMessageVT

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

func (*PrototypeResponse) EqualVT

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

func (*PrototypeResponse) GetBody

func (x *PrototypeResponse) GetBody() string

func (*PrototypeResponse) GetSequenceNumber

func (x *PrototypeResponse) GetSequenceNumber() int32

func (*PrototypeResponse) MarshalJSON

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

MarshalJSON marshals the PrototypeResponse to JSON.

func (*PrototypeResponse) MarshalProtoJSON

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

MarshalProtoJSON marshals the PrototypeResponse message to JSON.

func (*PrototypeResponse) MarshalProtoText

func (x *PrototypeResponse) MarshalProtoText() string

func (*PrototypeResponse) MarshalToSizedBufferVT

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

func (*PrototypeResponse) MarshalToVT

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

func (*PrototypeResponse) MarshalVT

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

func (*PrototypeResponse) ProtoMessage

func (*PrototypeResponse) ProtoMessage()

func (*PrototypeResponse) Reset

func (x *PrototypeResponse) Reset()

func (*PrototypeResponse) SizeVT

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

func (*PrototypeResponse) String

func (x *PrototypeResponse) String() string

func (*PrototypeResponse) UnmarshalJSON

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

UnmarshalJSON unmarshals the PrototypeResponse from JSON.

func (*PrototypeResponse) UnmarshalProtoJSON

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

UnmarshalProtoJSON unmarshals the PrototypeResponse message from JSON.

func (*PrototypeResponse) UnmarshalVT

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

type SRPCPrototypeServiceClient

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

	// Prototype is the prototype request.
	Prototype(ctx context.Context, in *PrototypeRequest) (SRPCPrototypeService_PrototypeClient, error)
}

func NewSRPCPrototypeServiceClient

func NewSRPCPrototypeServiceClient(cc srpc.Client) SRPCPrototypeServiceClient

func NewSRPCPrototypeServiceClientWithServiceID

func NewSRPCPrototypeServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCPrototypeServiceClient

type SRPCPrototypeServiceHandler

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

func (SRPCPrototypeServiceHandler) GetMethodIDs

func (SRPCPrototypeServiceHandler) GetMethodIDs() []string

func (*SRPCPrototypeServiceHandler) GetServiceID

func (d *SRPCPrototypeServiceHandler) GetServiceID() string

func (*SRPCPrototypeServiceHandler) InvokeMethod

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

func (SRPCPrototypeServiceHandler) InvokeMethod_Prototype

func (SRPCPrototypeServiceHandler) InvokeMethod_Prototype(impl SRPCPrototypeServiceServer, strm srpc.Stream) error

type SRPCPrototypeServiceServer

type SRPCPrototypeServiceServer interface {
	// Prototype is the prototype request.
	Prototype(*PrototypeRequest, SRPCPrototypeService_PrototypeStream) error
}

type SRPCPrototypeService_PrototypeClient

type SRPCPrototypeService_PrototypeClient interface {
	srpc.Stream
	Recv() (*PrototypeResponse, error)
	RecvTo(*PrototypeResponse) error
}

type SRPCPrototypeService_PrototypeStream

type SRPCPrototypeService_PrototypeStream interface {
	srpc.Stream
	Send(*PrototypeResponse) error
	SendAndClose(*PrototypeResponse) error
}

Jump to

Keyboard shortcuts

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