web_pkg_rpc

package
v0.52.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const DefServiceIDPrefix = SRPCAccessWebPkgServiceID + "/"

DefServiceIDPrefix is the default service id prefix.

View Source
const SRPCAccessWebPkgServiceID = "web.pkg.rpc.AccessWebPkg"

Variables

This section is empty.

Functions

func NewSRPCAccessWebPkgHandler

func NewSRPCAccessWebPkgHandler(impl SRPCAccessWebPkgServer, serviceID string) srpc.Handler

NewSRPCAccessWebPkgHandler constructs a new RPC handler. serviceID: if empty, uses default: web.pkg.rpc.AccessWebPkg

func SRPCRegisterAccessWebPkg

func SRPCRegisterAccessWebPkg(mux srpc.Mux, impl SRPCAccessWebPkgServer) error

SRPCRegisterAccessWebPkg registers the implementation with the mux. Uses the default serviceID: web.pkg.rpc.AccessWebPkg

Types

type GetInfoRequest

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

GetInfoRequest is a request to get the web pkg info.

func (*GetInfoRequest) CloneMessageVT

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

func (*GetInfoRequest) CloneVT

func (m *GetInfoRequest) CloneVT() *GetInfoRequest

func (*GetInfoRequest) EqualMessageVT

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

func (*GetInfoRequest) EqualVT

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

func (*GetInfoRequest) MarshalJSON

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

MarshalJSON marshals the GetInfoRequest to JSON.

func (*GetInfoRequest) MarshalProtoJSON

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

MarshalProtoJSON marshals the GetInfoRequest message to JSON.

func (*GetInfoRequest) MarshalProtoText

func (x *GetInfoRequest) MarshalProtoText() string

func (*GetInfoRequest) MarshalToSizedBufferVT

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

func (*GetInfoRequest) MarshalToVT

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

func (*GetInfoRequest) MarshalVT

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

func (*GetInfoRequest) ProtoMessage

func (*GetInfoRequest) ProtoMessage()

func (*GetInfoRequest) Reset

func (x *GetInfoRequest) Reset()

func (*GetInfoRequest) SizeVT

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

func (*GetInfoRequest) String

func (x *GetInfoRequest) String() string

func (*GetInfoRequest) UnmarshalJSON

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

UnmarshalJSON unmarshals the GetInfoRequest from JSON.

func (*GetInfoRequest) UnmarshalProtoJSON

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

UnmarshalProtoJSON unmarshals the GetInfoRequest message from JSON.

func (*GetInfoRequest) UnmarshalVT

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

type GetInfoResponse

type GetInfoResponse struct {

	// Info contains the web package information.
	Info *pkg.WebPkgInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

GetInfoResponse is a response to getting the web pkg info.

func (*GetInfoResponse) CloneMessageVT

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

func (*GetInfoResponse) CloneVT

func (m *GetInfoResponse) CloneVT() *GetInfoResponse

func (*GetInfoResponse) EqualMessageVT

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

func (*GetInfoResponse) EqualVT

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

func (*GetInfoResponse) GetInfo

func (x *GetInfoResponse) GetInfo() *pkg.WebPkgInfo

func (*GetInfoResponse) MarshalJSON

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

MarshalJSON marshals the GetInfoResponse to JSON.

func (*GetInfoResponse) MarshalProtoJSON

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

MarshalProtoJSON marshals the GetInfoResponse message to JSON.

func (*GetInfoResponse) MarshalProtoText

func (x *GetInfoResponse) MarshalProtoText() string

func (*GetInfoResponse) MarshalToSizedBufferVT

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

func (*GetInfoResponse) MarshalToVT

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

func (*GetInfoResponse) MarshalVT

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

func (*GetInfoResponse) ProtoMessage

func (*GetInfoResponse) ProtoMessage()

func (*GetInfoResponse) Reset

func (x *GetInfoResponse) Reset()

func (*GetInfoResponse) SizeVT

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

func (*GetInfoResponse) String

func (x *GetInfoResponse) String() string

func (*GetInfoResponse) UnmarshalJSON

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

UnmarshalJSON unmarshals the GetInfoResponse from JSON.

func (*GetInfoResponse) UnmarshalProtoJSON

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

UnmarshalProtoJSON unmarshals the GetInfoResponse message from JSON.

func (*GetInfoResponse) UnmarshalVT

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

type SRPCAccessWebPkgClient

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

	// GetWebPkgInfo executes the GetInfo request.
	GetWebPkgInfo(ctx context.Context, in *GetInfoRequest) (*GetInfoResponse, error)
	// WebPkgFsRpc exposes the web pkg fs service via RPC.
	// Exposes the FSCursorService.
	// The rpc stream id is ignored.
	WebPkgFsRpc(ctx context.Context) (SRPCAccessWebPkg_WebPkgFsRpcClient, error)
}

func NewSRPCAccessWebPkgClient

func NewSRPCAccessWebPkgClient(cc srpc.Client) SRPCAccessWebPkgClient

func NewSRPCAccessWebPkgClientWithServiceID

func NewSRPCAccessWebPkgClientWithServiceID(cc srpc.Client, serviceID string) SRPCAccessWebPkgClient

type SRPCAccessWebPkgHandler

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

func (SRPCAccessWebPkgHandler) GetMethodIDs

func (SRPCAccessWebPkgHandler) GetMethodIDs() []string

func (*SRPCAccessWebPkgHandler) GetServiceID

func (d *SRPCAccessWebPkgHandler) GetServiceID() string

func (*SRPCAccessWebPkgHandler) InvokeMethod

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

func (SRPCAccessWebPkgHandler) InvokeMethod_GetWebPkgInfo

func (SRPCAccessWebPkgHandler) InvokeMethod_GetWebPkgInfo(impl SRPCAccessWebPkgServer, strm srpc.Stream) error

func (SRPCAccessWebPkgHandler) InvokeMethod_WebPkgFsRpc

func (SRPCAccessWebPkgHandler) InvokeMethod_WebPkgFsRpc(impl SRPCAccessWebPkgServer, strm srpc.Stream) error

type SRPCAccessWebPkgServer

type SRPCAccessWebPkgServer interface {
	// GetWebPkgInfo executes the GetInfo request.
	GetWebPkgInfo(context.Context, *GetInfoRequest) (*GetInfoResponse, error)
	// WebPkgFsRpc exposes the web pkg fs service via RPC.
	// Exposes the FSCursorService.
	// The rpc stream id is ignored.
	WebPkgFsRpc(SRPCAccessWebPkg_WebPkgFsRpcStream) error
}

type SRPCAccessWebPkg_GetWebPkgInfoStream

type SRPCAccessWebPkg_GetWebPkgInfoStream interface {
	srpc.Stream
}

type SRPCAccessWebPkg_WebPkgFsRpcClient

type SRPCAccessWebPkg_WebPkgFsRpcClient interface {
	srpc.Stream
	Send(*rpcstream.RpcStreamPacket) error
	Recv() (*rpcstream.RpcStreamPacket, error)
	RecvTo(*rpcstream.RpcStreamPacket) error
}

type SRPCAccessWebPkg_WebPkgFsRpcStream

type SRPCAccessWebPkg_WebPkgFsRpcStream interface {
	srpc.Stream
	Send(*rpcstream.RpcStreamPacket) error
	SendAndClose(*rpcstream.RpcStreamPacket) error
	Recv() (*rpcstream.RpcStreamPacket, error)
	RecvTo(*rpcstream.RpcStreamPacket) error
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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