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

resource

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: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCResourceServiceServiceID = "resource.ResourceService"

Variables

View Source 
var (
	// ErrResourceNotFound is returned when a requested resource does not exist.
	ErrResourceNotFound = &ResourceFailure{Code: ResourceFailureCode_RESOURCE_FAILURE_CODE_RESOURCE_NOT_FOUND, Message: "resource not found"}
	// ErrClientReleased is returned when attempting to operate on a released client.
	ErrClientReleased = &ResourceFailure{Code: ResourceFailureCode_RESOURCE_FAILURE_CODE_CLIENT_RELEASED, Message: "client was released"}
	// ErrInvalidResourceID is returned when a resource ID is invalid or out of bounds.
	ErrInvalidResourceID = &ResourceFailure{Code: ResourceFailureCode_RESOURCE_FAILURE_CODE_INVALID_RESOURCE_ID, Message: "invalid resource id"}
	// ErrInvalidClientID is returned when a client ID is invalid or out of bounds.
	ErrInvalidClientID = &ResourceFailure{Code: ResourceFailureCode_RESOURCE_FAILURE_CODE_INVALID_CLIENT_ID, Message: "invalid client id"}
	// ErrResourceOrClientReleased is returned when either the resource or client has been released.
	ErrResourceOrClientReleased = &ResourceFailure{Code: ResourceFailureCode_RESOURCE_FAILURE_CODE_RESOURCE_OR_CLIENT_RELEASED, Message: "resource or client was released"}
	// ErrNoResourceClientContext is returned if there was no ResourceClientContext.
	ErrNoResourceClientContext = errors.New("no resource client context")
)
View Source 
var (
	ResourceFailureCode_name = map[int32]string{
		0: "RESOURCE_FAILURE_CODE_UNKNOWN",
		1: "RESOURCE_FAILURE_CODE_RESOURCE_NOT_FOUND",
		2: "RESOURCE_FAILURE_CODE_CLIENT_RELEASED",
		3: "RESOURCE_FAILURE_CODE_INVALID_RESOURCE_ID",
		4: "RESOURCE_FAILURE_CODE_INVALID_CLIENT_ID",
		5: "RESOURCE_FAILURE_CODE_RESOURCE_OR_CLIENT_RELEASED",
	}
	ResourceFailureCode_value = map[string]int32{
		"RESOURCE_FAILURE_CODE_UNKNOWN":                     0,
		"RESOURCE_FAILURE_CODE_RESOURCE_NOT_FOUND":          1,
		"RESOURCE_FAILURE_CODE_CLIENT_RELEASED":             2,
		"RESOURCE_FAILURE_CODE_INVALID_RESOURCE_ID":         3,
		"RESOURCE_FAILURE_CODE_INVALID_CLIENT_ID":           4,
		"RESOURCE_FAILURE_CODE_RESOURCE_OR_CLIENT_RELEASED": 5,
	}
)

Enum value maps for ResourceFailureCode.

Functions

func HandleResourceRpc 

func HandleResourceRpc(stream ResourceRpcStream, lookup func(context.Context, uint32) (srpc.Invoker, error)) error

HandleResourceRpc acknowledges a route before serving its SRPC data frames. The handler waits for active methods before releasing their resource context.

func NewResourceRpcClient 

func NewResourceRpcClient[T ResourceRpcStream](caller func(context.Context) (T, error), resourceID uint32) srpc.Client

NewResourceRpcClient opens a typed route for each invocation on resourceID.

func NewRoutedClient 

func NewRoutedClient(inner srpc.Client, resourceID uint32) srpc.Client

NewRoutedClient wraps an SRPC client so all calls are prefixed with the resource ID for routing to the correct attached resource mux.

func NewRoutedClientWithDone added in v0.57.2 

func NewRoutedClientWithDone(inner srpc.Client, resourceID uint32, done <-chan struct{}) srpc.Client

NewRoutedClientWithDone wraps a client with a resource route and its lifetime.

func NewSRPCResourceServiceHandler 

func NewSRPCResourceServiceHandler(impl SRPCResourceServiceServer, serviceID string) srpc.Handler

NewSRPCResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: resource.ResourceService

func SRPCRegisterResourceService 

func SRPCRegisterResourceService(mux srpc.Mux, impl SRPCResourceServiceServer) error

SRPCRegisterResourceService registers the implementation with the mux. Uses the default serviceID: resource.ResourceService

Types

type AttachMuxDataRwc 

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

AttachMuxDataRwc bridges ResourceAttach mux_data packets to io.ReadWriteCloser. Used by both server and client sides of ResourceAttach to provide a ReadWriteCloser for yamux over the bidi stream.

func NewAttachMuxDataRwc 

func NewAttachMuxDataRwc(
	sendMuxData func(data []byte) error,
	recvMuxData func() ([]byte, error),
) *AttachMuxDataRwc

NewAttachMuxDataRwc constructs a new AttachMuxDataRwc. sendMuxData sends raw bytes as a mux_data packet. recvMuxData blocks until the next mux_data packet arrives and returns its bytes.

func (*AttachMuxDataRwc) Close 

func (a *AttachMuxDataRwc) Close() error

Close is a no-op; the stream lifecycle is managed by the caller.

func (*AttachMuxDataRwc) Read 

func (a *AttachMuxDataRwc) Read(p []byte) (int, error)

Read reads from buffered mux_data, fetching more from recvMuxData as needed.

func (*AttachMuxDataRwc) Write 

func (a *AttachMuxDataRwc) Write(p []byte) (int, error)

Write sends p as a mux_data packet. Clones the data since yamux may reuse buffers.

type ResourceAttachAck 

type ResourceAttachAck struct {

	// Failure is set if the session was rejected.
	Failure *ResourceFailure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

ResourceAttachAck is sent by the server to confirm the session.

func (*ResourceAttachAck) CloneMessageVT 

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

func (*ResourceAttachAck) CloneVT 

func (m *ResourceAttachAck) CloneVT() *ResourceAttachAck

func (*ResourceAttachAck) EqualMessageVT 

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

func (*ResourceAttachAck) EqualVT 

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

func (*ResourceAttachAck) GetFailure 

func (x *ResourceAttachAck) GetFailure() *ResourceFailure

func (*ResourceAttachAck) MarshalJSON 

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

MarshalJSON marshals the ResourceAttachAck to JSON.

func (*ResourceAttachAck) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceAttachAck message to JSON.

func (*ResourceAttachAck) MarshalProtoText 

func (x *ResourceAttachAck) MarshalProtoText() string

func (*ResourceAttachAck) MarshalToSizedBufferVT 

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

func (*ResourceAttachAck) MarshalToVT 

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

func (*ResourceAttachAck) MarshalVT 

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

func (*ResourceAttachAck) ProtoMessage 

func (*ResourceAttachAck) ProtoMessage()

func (*ResourceAttachAck) Reset 

func (x *ResourceAttachAck) Reset()

func (*ResourceAttachAck) SizeVT 

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

func (*ResourceAttachAck) String 

func (x *ResourceAttachAck) String() string

func (*ResourceAttachAck) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceAttachAck from JSON.

func (*ResourceAttachAck) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceAttachAck message from JSON.

func (*ResourceAttachAck) UnmarshalVT 

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

type ResourceAttachAdd 

type ResourceAttachAdd struct {

	// AttachId is a client-chosen correlation ID.
	AttachId uint32 `protobuf:"varint,1,opt,name=attach_id,json=attachId,proto3" json:"attachId,omitempty"`
	// Label is an informational description of the attached resource.
	Label string `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	// contains filtered or unexported fields
}

ResourceAttachAdd is sent by the client to register a resource.

func (*ResourceAttachAdd) CloneMessageVT 

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

func (*ResourceAttachAdd) CloneVT 

func (m *ResourceAttachAdd) CloneVT() *ResourceAttachAdd

func (*ResourceAttachAdd) EqualMessageVT 

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

func (*ResourceAttachAdd) EqualVT 

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

func (*ResourceAttachAdd) GetAttachId 

func (x *ResourceAttachAdd) GetAttachId() uint32

func (*ResourceAttachAdd) GetLabel 

func (x *ResourceAttachAdd) GetLabel() string

func (*ResourceAttachAdd) MarshalJSON 

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

MarshalJSON marshals the ResourceAttachAdd to JSON.

func (*ResourceAttachAdd) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceAttachAdd message to JSON.

func (*ResourceAttachAdd) MarshalProtoText 

func (x *ResourceAttachAdd) MarshalProtoText() string

func (*ResourceAttachAdd) MarshalToSizedBufferVT 

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

func (*ResourceAttachAdd) MarshalToVT 

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

func (*ResourceAttachAdd) MarshalVT 

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

func (*ResourceAttachAdd) ProtoMessage 

func (*ResourceAttachAdd) ProtoMessage()

func (*ResourceAttachAdd) Reset 

func (x *ResourceAttachAdd) Reset()

func (*ResourceAttachAdd) SizeVT 

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

func (*ResourceAttachAdd) String 

func (x *ResourceAttachAdd) String() string

func (*ResourceAttachAdd) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceAttachAdd from JSON.

func (*ResourceAttachAdd) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceAttachAdd message from JSON.

func (*ResourceAttachAdd) UnmarshalVT 

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

type ResourceAttachAddAck 

type ResourceAttachAddAck struct {

	// AttachId echoes the client-chosen correlation ID.
	AttachId uint32 `protobuf:"varint,1,opt,name=attach_id,json=attachId,proto3" json:"attachId,omitempty"`
	// Failure is set if the add was rejected.
	Failure *ResourceFailure `protobuf:"bytes,2,opt,name=failure,proto3" json:"failure,omitempty"`
	// ResourceId is the server-assigned ID for the attached resource.
	ResourceId uint32 `protobuf:"varint,3,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

ResourceAttachAddAck is sent by the server to confirm a resource was added.

func (*ResourceAttachAddAck) CloneMessageVT 

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

func (*ResourceAttachAddAck) CloneVT 

func (m *ResourceAttachAddAck) CloneVT() *ResourceAttachAddAck

func (*ResourceAttachAddAck) EqualMessageVT 

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

func (*ResourceAttachAddAck) EqualVT 

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

func (*ResourceAttachAddAck) GetAttachId 

func (x *ResourceAttachAddAck) GetAttachId() uint32

func (*ResourceAttachAddAck) GetFailure 

func (x *ResourceAttachAddAck) GetFailure() *ResourceFailure

func (*ResourceAttachAddAck) GetResourceId 

func (x *ResourceAttachAddAck) GetResourceId() uint32

func (*ResourceAttachAddAck) MarshalJSON 

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

MarshalJSON marshals the ResourceAttachAddAck to JSON.

func (*ResourceAttachAddAck) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceAttachAddAck message to JSON.

func (*ResourceAttachAddAck) MarshalProtoText 

func (x *ResourceAttachAddAck) MarshalProtoText() string

func (*ResourceAttachAddAck) MarshalToSizedBufferVT 

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

func (*ResourceAttachAddAck) MarshalToVT 

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

func (*ResourceAttachAddAck) MarshalVT 

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

func (*ResourceAttachAddAck) ProtoMessage 

func (*ResourceAttachAddAck) ProtoMessage()

func (*ResourceAttachAddAck) Reset 

func (x *ResourceAttachAddAck) Reset()

func (*ResourceAttachAddAck) SizeVT 

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

func (*ResourceAttachAddAck) String 

func (x *ResourceAttachAddAck) String() string

func (*ResourceAttachAddAck) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceAttachAddAck from JSON.

func (*ResourceAttachAddAck) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceAttachAddAck message from JSON.

func (*ResourceAttachAddAck) UnmarshalVT 

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

type ResourceAttachDetach 

type ResourceAttachDetach struct {

	// ResourceId is the server-assigned ID to detach.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

ResourceAttachDetach is sent by the client to withdraw a resource.

func (*ResourceAttachDetach) CloneMessageVT 

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

func (*ResourceAttachDetach) CloneVT 

func (m *ResourceAttachDetach) CloneVT() *ResourceAttachDetach

func (*ResourceAttachDetach) EqualMessageVT 

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

func (*ResourceAttachDetach) EqualVT 

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

func (*ResourceAttachDetach) GetResourceId 

func (x *ResourceAttachDetach) GetResourceId() uint32

func (*ResourceAttachDetach) MarshalJSON 

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

MarshalJSON marshals the ResourceAttachDetach to JSON.

func (*ResourceAttachDetach) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceAttachDetach message to JSON.

func (*ResourceAttachDetach) MarshalProtoText 

func (x *ResourceAttachDetach) MarshalProtoText() string

func (*ResourceAttachDetach) MarshalToSizedBufferVT 

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

func (*ResourceAttachDetach) MarshalToVT 

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

func (*ResourceAttachDetach) MarshalVT 

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

func (*ResourceAttachDetach) ProtoMessage 

func (*ResourceAttachDetach) ProtoMessage()

func (*ResourceAttachDetach) Reset 

func (x *ResourceAttachDetach) Reset()

func (*ResourceAttachDetach) SizeVT 

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

func (*ResourceAttachDetach) String 

func (x *ResourceAttachDetach) String() string

func (*ResourceAttachDetach) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceAttachDetach from JSON.

func (*ResourceAttachDetach) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceAttachDetach message from JSON.

func (*ResourceAttachDetach) UnmarshalVT 

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

type ResourceAttachDetachAck 

type ResourceAttachDetachAck struct {

	// ResourceId confirms which resource was detached.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

ResourceAttachDetachAck is sent by the server to confirm a resource was detached.

func (*ResourceAttachDetachAck) CloneMessageVT 

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

func (*ResourceAttachDetachAck) CloneVT 

func (m *ResourceAttachDetachAck) CloneVT() *ResourceAttachDetachAck

func (*ResourceAttachDetachAck) EqualMessageVT 

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

func (*ResourceAttachDetachAck) EqualVT 

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

func (*ResourceAttachDetachAck) GetResourceId 

func (x *ResourceAttachDetachAck) GetResourceId() uint32

func (*ResourceAttachDetachAck) MarshalJSON 

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

MarshalJSON marshals the ResourceAttachDetachAck to JSON.

func (*ResourceAttachDetachAck) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceAttachDetachAck message to JSON.

func (*ResourceAttachDetachAck) MarshalProtoText 

func (x *ResourceAttachDetachAck) MarshalProtoText() string

func (*ResourceAttachDetachAck) MarshalToSizedBufferVT 

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

func (*ResourceAttachDetachAck) MarshalToVT 

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

func (*ResourceAttachDetachAck) MarshalVT 

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

func (*ResourceAttachDetachAck) ProtoMessage 

func (*ResourceAttachDetachAck) ProtoMessage()

func (*ResourceAttachDetachAck) Reset 

func (x *ResourceAttachDetachAck) Reset()

func (*ResourceAttachDetachAck) SizeVT 

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

func (*ResourceAttachDetachAck) String 

func (x *ResourceAttachDetachAck) String() string

func (*ResourceAttachDetachAck) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceAttachDetachAck from JSON.

func (*ResourceAttachDetachAck) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceAttachDetachAck message from JSON.

func (*ResourceAttachDetachAck) UnmarshalVT 

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

type ResourceAttachInit 

type ResourceAttachInit struct {

	// ClientHandleId identifies the owning client session.
	ClientHandleId uint32 `protobuf:"varint,1,opt,name=client_handle_id,json=clientHandleId,proto3" json:"clientHandleId,omitempty"`
	// contains filtered or unexported fields
}

ResourceAttachInit is sent by the client to initiate a session.

func (*ResourceAttachInit) CloneMessageVT 

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

func (*ResourceAttachInit) CloneVT 

func (m *ResourceAttachInit) CloneVT() *ResourceAttachInit

func (*ResourceAttachInit) EqualMessageVT 

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

func (*ResourceAttachInit) EqualVT 

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

func (*ResourceAttachInit) GetClientHandleId 

func (x *ResourceAttachInit) GetClientHandleId() uint32

func (*ResourceAttachInit) MarshalJSON 

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

MarshalJSON marshals the ResourceAttachInit to JSON.

func (*ResourceAttachInit) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceAttachInit message to JSON.

func (*ResourceAttachInit) MarshalProtoText 

func (x *ResourceAttachInit) MarshalProtoText() string

func (*ResourceAttachInit) MarshalToSizedBufferVT 

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

func (*ResourceAttachInit) MarshalToVT 

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

func (*ResourceAttachInit) MarshalVT 

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

func (*ResourceAttachInit) ProtoMessage 

func (*ResourceAttachInit) ProtoMessage()

func (*ResourceAttachInit) Reset 

func (x *ResourceAttachInit) Reset()

func (*ResourceAttachInit) SizeVT 

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

func (*ResourceAttachInit) String 

func (x *ResourceAttachInit) String() string

func (*ResourceAttachInit) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceAttachInit from JSON.

func (*ResourceAttachInit) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceAttachInit message from JSON.

func (*ResourceAttachInit) UnmarshalVT 

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

type ResourceAttachRequest 

type ResourceAttachRequest struct {

	// Body is the body of the request.
	//
	// Types that are assignable to Body:
	//	*ResourceAttachRequest_Init
	//	*ResourceAttachRequest_Add
	//	*ResourceAttachRequest_Detach
	//	*ResourceAttachRequest_MuxData
	Body isResourceAttachRequest_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

ResourceAttachRequest is a client-to-server message on the ResourceAttach stream.

func (*ResourceAttachRequest) CloneMessageVT 

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

func (*ResourceAttachRequest) CloneVT 

func (m *ResourceAttachRequest) CloneVT() *ResourceAttachRequest

func (*ResourceAttachRequest) EqualMessageVT 

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

func (*ResourceAttachRequest) EqualVT 

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

func (*ResourceAttachRequest) GetAdd 

func (x *ResourceAttachRequest) GetAdd() *ResourceAttachAdd

func (*ResourceAttachRequest) GetBody 

func (m *ResourceAttachRequest) GetBody() isResourceAttachRequest_Body

func (*ResourceAttachRequest) GetDetach 

func (x *ResourceAttachRequest) GetDetach() *ResourceAttachDetach

func (*ResourceAttachRequest) GetInit 

func (x *ResourceAttachRequest) GetInit() *ResourceAttachInit

func (*ResourceAttachRequest) GetMuxData 

func (x *ResourceAttachRequest) GetMuxData() []byte

func (*ResourceAttachRequest) MarshalJSON 

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

MarshalJSON marshals the ResourceAttachRequest to JSON.

func (*ResourceAttachRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceAttachRequest message to JSON.

func (*ResourceAttachRequest) MarshalProtoText 

func (x *ResourceAttachRequest) MarshalProtoText() string

func (*ResourceAttachRequest) MarshalToSizedBufferVT 

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

func (*ResourceAttachRequest) MarshalToVT 

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

func (*ResourceAttachRequest) MarshalVT 

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

func (*ResourceAttachRequest) ProtoMessage 

func (*ResourceAttachRequest) ProtoMessage()

func (*ResourceAttachRequest) Reset 

func (x *ResourceAttachRequest) Reset()

func (*ResourceAttachRequest) SizeVT 

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

func (*ResourceAttachRequest) String 

func (x *ResourceAttachRequest) String() string

func (*ResourceAttachRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceAttachRequest from JSON.

func (*ResourceAttachRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceAttachRequest message from JSON.

func (*ResourceAttachRequest) UnmarshalVT 

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

type ResourceAttachRequest_Add 

type ResourceAttachRequest_Add struct {
	// Add registers a new resource on the session.
	Add *ResourceAttachAdd `protobuf:"bytes,2,opt,name=add,proto3,oneof"`
}

func (*ResourceAttachRequest_Add) CloneOneofVT 

func (m *ResourceAttachRequest_Add) CloneOneofVT() isResourceAttachRequest_Body

func (*ResourceAttachRequest_Add) CloneVT 

func (m *ResourceAttachRequest_Add) CloneVT() *ResourceAttachRequest_Add

func (*ResourceAttachRequest_Add) EqualVT 

func (this *ResourceAttachRequest_Add) EqualVT(thatIface isResourceAttachRequest_Body) bool

func (*ResourceAttachRequest_Add) MarshalToSizedBufferVT 

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

func (*ResourceAttachRequest_Add) MarshalToVT 

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

func (*ResourceAttachRequest_Add) SizeVT 

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

type ResourceAttachRequest_Detach 

type ResourceAttachRequest_Detach struct {
	// Detach withdraws a previously added resource.
	Detach *ResourceAttachDetach `protobuf:"bytes,3,opt,name=detach,proto3,oneof"`
}

func (*ResourceAttachRequest_Detach) CloneOneofVT 

func (m *ResourceAttachRequest_Detach) CloneOneofVT() isResourceAttachRequest_Body

func (*ResourceAttachRequest_Detach) CloneVT 

func (m *ResourceAttachRequest_Detach) CloneVT() *ResourceAttachRequest_Detach

func (*ResourceAttachRequest_Detach) EqualVT 

func (this *ResourceAttachRequest_Detach) EqualVT(thatIface isResourceAttachRequest_Body) bool

func (*ResourceAttachRequest_Detach) MarshalToSizedBufferVT 

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

func (*ResourceAttachRequest_Detach) MarshalToVT 

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

func (*ResourceAttachRequest_Detach) SizeVT 

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

type ResourceAttachRequest_Init 

type ResourceAttachRequest_Init struct {
	// Init is the session initialization message.
	Init *ResourceAttachInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

func (*ResourceAttachRequest_Init) CloneOneofVT 

func (m *ResourceAttachRequest_Init) CloneOneofVT() isResourceAttachRequest_Body

func (*ResourceAttachRequest_Init) CloneVT 

func (m *ResourceAttachRequest_Init) CloneVT() *ResourceAttachRequest_Init

func (*ResourceAttachRequest_Init) EqualVT 

func (this *ResourceAttachRequest_Init) EqualVT(thatIface isResourceAttachRequest_Body) bool

func (*ResourceAttachRequest_Init) MarshalToSizedBufferVT 

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

func (*ResourceAttachRequest_Init) MarshalToVT 

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

func (*ResourceAttachRequest_Init) SizeVT 

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

type ResourceAttachRequest_MuxData 

type ResourceAttachRequest_MuxData struct {
	// MuxData carries yamux multiplexer frames after handshake.
	MuxData []byte `protobuf:"bytes,4,opt,name=mux_data,json=muxData,proto3,oneof"`
}

func (*ResourceAttachRequest_MuxData) CloneOneofVT 

func (m *ResourceAttachRequest_MuxData) CloneOneofVT() isResourceAttachRequest_Body

func (*ResourceAttachRequest_MuxData) CloneVT 

func (m *ResourceAttachRequest_MuxData) CloneVT() *ResourceAttachRequest_MuxData

func (*ResourceAttachRequest_MuxData) EqualVT 

func (this *ResourceAttachRequest_MuxData) EqualVT(thatIface isResourceAttachRequest_Body) bool

func (*ResourceAttachRequest_MuxData) MarshalToSizedBufferVT 

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

func (*ResourceAttachRequest_MuxData) MarshalToVT 

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

func (*ResourceAttachRequest_MuxData) SizeVT 

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

type ResourceAttachResponse 

type ResourceAttachResponse struct {

	// Body is the body of the response.
	//
	// Types that are assignable to Body:
	//	*ResourceAttachResponse_Ack
	//	*ResourceAttachResponse_AddAck
	//	*ResourceAttachResponse_DetachAck
	//	*ResourceAttachResponse_MuxData
	Body isResourceAttachResponse_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

ResourceAttachResponse is a server-to-client message on the ResourceAttach stream.

func (*ResourceAttachResponse) CloneMessageVT 

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

func (*ResourceAttachResponse) CloneVT 

func (m *ResourceAttachResponse) CloneVT() *ResourceAttachResponse

func (*ResourceAttachResponse) EqualMessageVT 

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

func (*ResourceAttachResponse) EqualVT 

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

func (*ResourceAttachResponse) GetAck 

func (x *ResourceAttachResponse) GetAck() *ResourceAttachAck

func (*ResourceAttachResponse) GetAddAck 

func (x *ResourceAttachResponse) GetAddAck() *ResourceAttachAddAck

func (*ResourceAttachResponse) GetBody 

func (m *ResourceAttachResponse) GetBody() isResourceAttachResponse_Body

func (*ResourceAttachResponse) GetDetachAck 

func (x *ResourceAttachResponse) GetDetachAck() *ResourceAttachDetachAck

func (*ResourceAttachResponse) GetMuxData 

func (x *ResourceAttachResponse) GetMuxData() []byte

func (*ResourceAttachResponse) MarshalJSON 

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

MarshalJSON marshals the ResourceAttachResponse to JSON.

func (*ResourceAttachResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceAttachResponse message to JSON.

func (*ResourceAttachResponse) MarshalProtoText 

func (x *ResourceAttachResponse) MarshalProtoText() string

func (*ResourceAttachResponse) MarshalToSizedBufferVT 

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

func (*ResourceAttachResponse) MarshalToVT 

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

func (*ResourceAttachResponse) MarshalVT 

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

func (*ResourceAttachResponse) ProtoMessage 

func (*ResourceAttachResponse) ProtoMessage()

func (*ResourceAttachResponse) Reset 

func (x *ResourceAttachResponse) Reset()

func (*ResourceAttachResponse) SizeVT 

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

func (*ResourceAttachResponse) String 

func (x *ResourceAttachResponse) String() string

func (*ResourceAttachResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceAttachResponse from JSON.

func (*ResourceAttachResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceAttachResponse message from JSON.

func (*ResourceAttachResponse) UnmarshalVT 

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

type ResourceAttachResponse_Ack 

type ResourceAttachResponse_Ack struct {
	// Ack is the session acknowledgment.
	Ack *ResourceAttachAck `protobuf:"bytes,1,opt,name=ack,proto3,oneof"`
}

func (*ResourceAttachResponse_Ack) CloneOneofVT 

func (m *ResourceAttachResponse_Ack) CloneOneofVT() isResourceAttachResponse_Body

func (*ResourceAttachResponse_Ack) CloneVT 

func (m *ResourceAttachResponse_Ack) CloneVT() *ResourceAttachResponse_Ack

func (*ResourceAttachResponse_Ack) EqualVT 

func (this *ResourceAttachResponse_Ack) EqualVT(thatIface isResourceAttachResponse_Body) bool

func (*ResourceAttachResponse_Ack) MarshalToSizedBufferVT 

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

func (*ResourceAttachResponse_Ack) MarshalToVT 

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

func (*ResourceAttachResponse_Ack) SizeVT 

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

type ResourceAttachResponse_AddAck 

type ResourceAttachResponse_AddAck struct {
	// AddAck confirms a resource was added.
	AddAck *ResourceAttachAddAck `protobuf:"bytes,2,opt,name=add_ack,json=addAck,proto3,oneof"`
}

func (*ResourceAttachResponse_AddAck) CloneOneofVT 

func (m *ResourceAttachResponse_AddAck) CloneOneofVT() isResourceAttachResponse_Body

func (*ResourceAttachResponse_AddAck) CloneVT 

func (m *ResourceAttachResponse_AddAck) CloneVT() *ResourceAttachResponse_AddAck

func (*ResourceAttachResponse_AddAck) EqualVT 

func (this *ResourceAttachResponse_AddAck) EqualVT(thatIface isResourceAttachResponse_Body) bool

func (*ResourceAttachResponse_AddAck) MarshalToSizedBufferVT 

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

func (*ResourceAttachResponse_AddAck) MarshalToVT 

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

func (*ResourceAttachResponse_AddAck) SizeVT 

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

type ResourceAttachResponse_DetachAck 

type ResourceAttachResponse_DetachAck struct {
	// DetachAck confirms a resource was detached.
	DetachAck *ResourceAttachDetachAck `protobuf:"bytes,3,opt,name=detach_ack,json=detachAck,proto3,oneof"`
}

func (*ResourceAttachResponse_DetachAck) CloneOneofVT 

func (m *ResourceAttachResponse_DetachAck) CloneOneofVT() isResourceAttachResponse_Body

func (*ResourceAttachResponse_DetachAck) CloneVT 

func (m *ResourceAttachResponse_DetachAck) CloneVT() *ResourceAttachResponse_DetachAck

func (*ResourceAttachResponse_DetachAck) EqualVT 

func (this *ResourceAttachResponse_DetachAck) EqualVT(thatIface isResourceAttachResponse_Body) bool

func (*ResourceAttachResponse_DetachAck) MarshalToSizedBufferVT 

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

func (*ResourceAttachResponse_DetachAck) MarshalToVT 

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

func (*ResourceAttachResponse_DetachAck) SizeVT 

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

type ResourceAttachResponse_MuxData 

type ResourceAttachResponse_MuxData struct {
	// MuxData carries yamux multiplexer frames after handshake.
	MuxData []byte `protobuf:"bytes,4,opt,name=mux_data,json=muxData,proto3,oneof"`
}

func (*ResourceAttachResponse_MuxData) CloneOneofVT 

func (m *ResourceAttachResponse_MuxData) CloneOneofVT() isResourceAttachResponse_Body

func (*ResourceAttachResponse_MuxData) CloneVT 

func (m *ResourceAttachResponse_MuxData) CloneVT() *ResourceAttachResponse_MuxData

func (*ResourceAttachResponse_MuxData) EqualVT 

func (this *ResourceAttachResponse_MuxData) EqualVT(thatIface isResourceAttachResponse_Body) bool

func (*ResourceAttachResponse_MuxData) MarshalToSizedBufferVT 

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

func (*ResourceAttachResponse_MuxData) MarshalToVT 

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

func (*ResourceAttachResponse_MuxData) SizeVT 

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

type ResourceClientAdopt added in v0.57.2 

type ResourceClientAdopt struct {

	// ResourceId identifies the pending resource to adopt.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

ResourceClientAdopt adopts a pending resource.

func (*ResourceClientAdopt) CloneMessageVT added in v0.57.2 

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

func (*ResourceClientAdopt) CloneVT added in v0.57.2 

func (m *ResourceClientAdopt) CloneVT() *ResourceClientAdopt

func (*ResourceClientAdopt) EqualMessageVT added in v0.57.2 

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

func (*ResourceClientAdopt) EqualVT added in v0.57.2 

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

func (*ResourceClientAdopt) GetResourceId added in v0.57.2 

func (x *ResourceClientAdopt) GetResourceId() uint32

func (*ResourceClientAdopt) MarshalJSON added in v0.57.2 

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

MarshalJSON marshals the ResourceClientAdopt to JSON.

func (*ResourceClientAdopt) MarshalProtoJSON added in v0.57.2 

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

MarshalProtoJSON marshals the ResourceClientAdopt message to JSON.

func (*ResourceClientAdopt) MarshalProtoText added in v0.57.2 

func (x *ResourceClientAdopt) MarshalProtoText() string

func (*ResourceClientAdopt) MarshalToSizedBufferVT added in v0.57.2 

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

func (*ResourceClientAdopt) MarshalToVT added in v0.57.2 

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

func (*ResourceClientAdopt) MarshalVT added in v0.57.2 

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

func (*ResourceClientAdopt) ProtoMessage added in v0.57.2 

func (*ResourceClientAdopt) ProtoMessage()

func (*ResourceClientAdopt) Reset added in v0.57.2 

func (x *ResourceClientAdopt) Reset()

func (*ResourceClientAdopt) SizeVT added in v0.57.2 

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

func (*ResourceClientAdopt) String added in v0.57.2 

func (x *ResourceClientAdopt) String() string

func (*ResourceClientAdopt) UnmarshalJSON added in v0.57.2 

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

UnmarshalJSON unmarshals the ResourceClientAdopt from JSON.

func (*ResourceClientAdopt) UnmarshalProtoJSON added in v0.57.2 

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

UnmarshalProtoJSON unmarshals the ResourceClientAdopt message from JSON.

func (*ResourceClientAdopt) UnmarshalVT added in v0.57.2 

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

type ResourceClientControlAck added in v0.57.2 

type ResourceClientControlAck struct {

	// ControlId matches ResourceClientRequest.control_id.
	ControlId uint32 `protobuf:"varint,1,opt,name=control_id,json=controlId,proto3" json:"controlId,omitempty"`
	// contains filtered or unexported fields
}

ResourceClientControlAck confirms a lifecycle control completed.

func (*ResourceClientControlAck) CloneMessageVT added in v0.57.2 

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

func (*ResourceClientControlAck) CloneVT added in v0.57.2 

func (m *ResourceClientControlAck) CloneVT() *ResourceClientControlAck

func (*ResourceClientControlAck) EqualMessageVT added in v0.57.2 

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

func (*ResourceClientControlAck) EqualVT added in v0.57.2 

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

func (*ResourceClientControlAck) GetControlId added in v0.57.2 

func (x *ResourceClientControlAck) GetControlId() uint32

func (*ResourceClientControlAck) MarshalJSON added in v0.57.2 

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

MarshalJSON marshals the ResourceClientControlAck to JSON.

func (*ResourceClientControlAck) MarshalProtoJSON added in v0.57.2 

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

MarshalProtoJSON marshals the ResourceClientControlAck message to JSON.

func (*ResourceClientControlAck) MarshalProtoText added in v0.57.2 

func (x *ResourceClientControlAck) MarshalProtoText() string

func (*ResourceClientControlAck) MarshalToSizedBufferVT added in v0.57.2 

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

func (*ResourceClientControlAck) MarshalToVT added in v0.57.2 

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

func (*ResourceClientControlAck) MarshalVT added in v0.57.2 

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

func (*ResourceClientControlAck) ProtoMessage added in v0.57.2 

func (*ResourceClientControlAck) ProtoMessage()

func (*ResourceClientControlAck) Reset added in v0.57.2 

func (x *ResourceClientControlAck) Reset()

func (*ResourceClientControlAck) SizeVT added in v0.57.2 

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

func (*ResourceClientControlAck) String added in v0.57.2 

func (x *ResourceClientControlAck) String() string

func (*ResourceClientControlAck) UnmarshalJSON added in v0.57.2 

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

UnmarshalJSON unmarshals the ResourceClientControlAck from JSON.

func (*ResourceClientControlAck) UnmarshalProtoJSON added in v0.57.2 

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

UnmarshalProtoJSON unmarshals the ResourceClientControlAck message from JSON.

func (*ResourceClientControlAck) UnmarshalVT added in v0.57.2 

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

type ResourceClientInit 

type ResourceClientInit struct {

	// ClientHandleId is the handle identifier for the client.
	ClientHandleId uint32 `protobuf:"varint,1,opt,name=client_handle_id,json=clientHandleId,proto3" json:"clientHandleId,omitempty"`
	// RootResourceId is the ID of the root resource for this client.
	RootResourceId uint32 `protobuf:"varint,2,opt,name=root_resource_id,json=rootResourceId,proto3" json:"rootResourceId,omitempty"`
	// contains filtered or unexported fields
}

ResourceClientInit is the initialization response to ResourceClient.

func (*ResourceClientInit) CloneMessageVT 

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

func (*ResourceClientInit) CloneVT 

func (m *ResourceClientInit) CloneVT() *ResourceClientInit

func (*ResourceClientInit) EqualMessageVT 

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

func (*ResourceClientInit) EqualVT 

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

func (*ResourceClientInit) GetClientHandleId 

func (x *ResourceClientInit) GetClientHandleId() uint32

func (*ResourceClientInit) GetRootResourceId 

func (x *ResourceClientInit) GetRootResourceId() uint32

func (*ResourceClientInit) MarshalJSON 

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

MarshalJSON marshals the ResourceClientInit to JSON.

func (*ResourceClientInit) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceClientInit message to JSON.

func (*ResourceClientInit) MarshalProtoText 

func (x *ResourceClientInit) MarshalProtoText() string

func (*ResourceClientInit) MarshalToSizedBufferVT 

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

func (*ResourceClientInit) MarshalToVT 

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

func (*ResourceClientInit) MarshalVT 

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

func (*ResourceClientInit) ProtoMessage 

func (*ResourceClientInit) ProtoMessage()

func (*ResourceClientInit) Reset 

func (x *ResourceClientInit) Reset()

func (*ResourceClientInit) SizeVT 

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

func (*ResourceClientInit) String 

func (x *ResourceClientInit) String() string

func (*ResourceClientInit) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceClientInit from JSON.

func (*ResourceClientInit) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceClientInit message from JSON.

func (*ResourceClientInit) UnmarshalVT 

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

type ResourceClientInitRequest added in v0.57.2 

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

ResourceClientInitRequest is sent first on every ResourceClient stream.

func (*ResourceClientInitRequest) CloneMessageVT added in v0.57.2 

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

func (*ResourceClientInitRequest) CloneVT added in v0.57.2 

func (m *ResourceClientInitRequest) CloneVT() *ResourceClientInitRequest

func (*ResourceClientInitRequest) EqualMessageVT added in v0.57.2 

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

func (*ResourceClientInitRequest) EqualVT added in v0.57.2 

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

func (*ResourceClientInitRequest) MarshalJSON added in v0.57.2 

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

MarshalJSON marshals the ResourceClientInitRequest to JSON.

func (*ResourceClientInitRequest) MarshalProtoJSON added in v0.57.2 

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

MarshalProtoJSON marshals the ResourceClientInitRequest message to JSON.

func (*ResourceClientInitRequest) MarshalProtoText added in v0.57.2 

func (x *ResourceClientInitRequest) MarshalProtoText() string

func (*ResourceClientInitRequest) MarshalToSizedBufferVT added in v0.57.2 

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

func (*ResourceClientInitRequest) MarshalToVT added in v0.57.2 

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

func (*ResourceClientInitRequest) MarshalVT added in v0.57.2 

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

func (*ResourceClientInitRequest) ProtoMessage added in v0.57.2 

func (*ResourceClientInitRequest) ProtoMessage()

func (*ResourceClientInitRequest) Reset added in v0.57.2 

func (x *ResourceClientInitRequest) Reset()

func (*ResourceClientInitRequest) SizeVT added in v0.57.2 

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

func (*ResourceClientInitRequest) String added in v0.57.2 

func (x *ResourceClientInitRequest) String() string

func (*ResourceClientInitRequest) UnmarshalJSON added in v0.57.2 

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

UnmarshalJSON unmarshals the ResourceClientInitRequest from JSON.

func (*ResourceClientInitRequest) UnmarshalProtoJSON added in v0.57.2 

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

UnmarshalProtoJSON unmarshals the ResourceClientInitRequest message from JSON.

func (*ResourceClientInitRequest) UnmarshalVT added in v0.57.2 

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

type ResourceClientRelease added in v0.57.2 

type ResourceClientRelease struct {

	// ResourceId identifies the resource to release.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

ResourceClientRelease releases a resource and its pending descendants.

func (*ResourceClientRelease) CloneMessageVT added in v0.57.2 

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

func (*ResourceClientRelease) CloneVT added in v0.57.2 

func (m *ResourceClientRelease) CloneVT() *ResourceClientRelease

func (*ResourceClientRelease) EqualMessageVT added in v0.57.2 

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

func (*ResourceClientRelease) EqualVT added in v0.57.2 

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

func (*ResourceClientRelease) GetResourceId added in v0.57.2 

func (x *ResourceClientRelease) GetResourceId() uint32

func (*ResourceClientRelease) MarshalJSON added in v0.57.2 

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

MarshalJSON marshals the ResourceClientRelease to JSON.

func (*ResourceClientRelease) MarshalProtoJSON added in v0.57.2 

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

MarshalProtoJSON marshals the ResourceClientRelease message to JSON.

func (*ResourceClientRelease) MarshalProtoText added in v0.57.2 

func (x *ResourceClientRelease) MarshalProtoText() string

func (*ResourceClientRelease) MarshalToSizedBufferVT added in v0.57.2 

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

func (*ResourceClientRelease) MarshalToVT added in v0.57.2 

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

func (*ResourceClientRelease) MarshalVT added in v0.57.2 

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

func (*ResourceClientRelease) ProtoMessage added in v0.57.2 

func (*ResourceClientRelease) ProtoMessage()

func (*ResourceClientRelease) Reset added in v0.57.2 

func (x *ResourceClientRelease) Reset()

func (*ResourceClientRelease) SizeVT added in v0.57.2 

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

func (*ResourceClientRelease) String added in v0.57.2 

func (x *ResourceClientRelease) String() string

func (*ResourceClientRelease) UnmarshalJSON added in v0.57.2 

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

UnmarshalJSON unmarshals the ResourceClientRelease from JSON.

func (*ResourceClientRelease) UnmarshalProtoJSON added in v0.57.2 

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

UnmarshalProtoJSON unmarshals the ResourceClientRelease message from JSON.

func (*ResourceClientRelease) UnmarshalVT added in v0.57.2 

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

type ResourceClientRequest 

type ResourceClientRequest struct {

	// ControlId orders every lifecycle control within one immutable generation.
	// Init uses zero; every later control increments the identifier by one.
	ControlId uint32 `protobuf:"varint,5,opt,name=control_id,json=controlId,proto3" json:"controlId,omitempty"`
	// Types that are assignable to Body:
	//	*ResourceClientRequest_Init
	//	*ResourceClientRequest_Adopt
	//	*ResourceClientRequest_Release
	Body isResourceClientRequest_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

ResourceClientRequest is a control packet for ResourceClient.

func (*ResourceClientRequest) CloneMessageVT 

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

func (*ResourceClientRequest) CloneVT 

func (m *ResourceClientRequest) CloneVT() *ResourceClientRequest

func (*ResourceClientRequest) EqualMessageVT 

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

func (*ResourceClientRequest) EqualVT 

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

func (*ResourceClientRequest) GetAdopt added in v0.57.2 

func (x *ResourceClientRequest) GetAdopt() *ResourceClientAdopt

func (*ResourceClientRequest) GetBody added in v0.57.2 

func (m *ResourceClientRequest) GetBody() isResourceClientRequest_Body

func (*ResourceClientRequest) GetControlId added in v0.57.2 

func (x *ResourceClientRequest) GetControlId() uint32

func (*ResourceClientRequest) GetInit added in v0.57.2 

func (x *ResourceClientRequest) GetInit() *ResourceClientInitRequest

func (*ResourceClientRequest) GetRelease added in v0.57.2 

func (x *ResourceClientRequest) GetRelease() *ResourceClientRelease

func (*ResourceClientRequest) MarshalJSON 

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

MarshalJSON marshals the ResourceClientRequest to JSON.

func (*ResourceClientRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceClientRequest message to JSON.

func (*ResourceClientRequest) MarshalProtoText 

func (x *ResourceClientRequest) MarshalProtoText() string

func (*ResourceClientRequest) MarshalToSizedBufferVT 

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

func (*ResourceClientRequest) MarshalToVT 

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

func (*ResourceClientRequest) MarshalVT 

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

func (*ResourceClientRequest) ProtoMessage 

func (*ResourceClientRequest) ProtoMessage()

func (*ResourceClientRequest) Reset 

func (x *ResourceClientRequest) Reset()

func (*ResourceClientRequest) SizeVT 

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

func (*ResourceClientRequest) String 

func (x *ResourceClientRequest) String() string

func (*ResourceClientRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceClientRequest from JSON.

func (*ResourceClientRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceClientRequest message from JSON.

func (*ResourceClientRequest) UnmarshalVT 

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

type ResourceClientRequest_Adopt added in v0.57.2 

type ResourceClientRequest_Adopt struct {
	// Adopt detaches a pending child from its parent.
	Adopt *ResourceClientAdopt `protobuf:"bytes,3,opt,name=adopt,proto3,oneof"`
}

func (*ResourceClientRequest_Adopt) CloneOneofVT added in v0.57.2 

func (m *ResourceClientRequest_Adopt) CloneOneofVT() isResourceClientRequest_Body

func (*ResourceClientRequest_Adopt) CloneVT added in v0.57.2 

func (m *ResourceClientRequest_Adopt) CloneVT() *ResourceClientRequest_Adopt

func (*ResourceClientRequest_Adopt) EqualVT added in v0.57.2 

func (this *ResourceClientRequest_Adopt) EqualVT(thatIface isResourceClientRequest_Body) bool

func (*ResourceClientRequest_Adopt) MarshalToSizedBufferVT added in v0.57.2 

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

func (*ResourceClientRequest_Adopt) MarshalToVT added in v0.57.2 

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

func (*ResourceClientRequest_Adopt) SizeVT added in v0.57.2 

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

type ResourceClientRequest_Init added in v0.57.2 

type ResourceClientRequest_Init struct {
	// Init starts a new client generation.
	Init *ResourceClientInitRequest `protobuf:"bytes,2,opt,name=init,proto3,oneof"`
}

func (*ResourceClientRequest_Init) CloneOneofVT added in v0.57.2 

func (m *ResourceClientRequest_Init) CloneOneofVT() isResourceClientRequest_Body

func (*ResourceClientRequest_Init) CloneVT added in v0.57.2 

func (m *ResourceClientRequest_Init) CloneVT() *ResourceClientRequest_Init

func (*ResourceClientRequest_Init) EqualVT added in v0.57.2 

func (this *ResourceClientRequest_Init) EqualVT(thatIface isResourceClientRequest_Body) bool

func (*ResourceClientRequest_Init) MarshalToSizedBufferVT added in v0.57.2 

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

func (*ResourceClientRequest_Init) MarshalToVT added in v0.57.2 

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

func (*ResourceClientRequest_Init) SizeVT added in v0.57.2 

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

type ResourceClientRequest_Release added in v0.57.2 

type ResourceClientRequest_Release struct {
	// Release releases a resource and its pending descendants.
	Release *ResourceClientRelease `protobuf:"bytes,4,opt,name=release,proto3,oneof"`
}

func (*ResourceClientRequest_Release) CloneOneofVT added in v0.57.2 

func (m *ResourceClientRequest_Release) CloneOneofVT() isResourceClientRequest_Body

func (*ResourceClientRequest_Release) CloneVT added in v0.57.2 

func (m *ResourceClientRequest_Release) CloneVT() *ResourceClientRequest_Release

func (*ResourceClientRequest_Release) EqualVT added in v0.57.2 

func (this *ResourceClientRequest_Release) EqualVT(thatIface isResourceClientRequest_Body) bool

func (*ResourceClientRequest_Release) MarshalToSizedBufferVT added in v0.57.2 

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

func (*ResourceClientRequest_Release) MarshalToVT added in v0.57.2 

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

func (*ResourceClientRequest_Release) SizeVT added in v0.57.2 

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

type ResourceClientResponse 

type ResourceClientResponse struct {

	// Body is the body of the event.
	//
	// Types that are assignable to Body:
	//	*ResourceClientResponse_Init
	//	*ResourceClientResponse_ResourceReleased
	//	*ResourceClientResponse_ControlAck
	Body isResourceClientResponse_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

ResourceClientResponse contains a server-client message for a ResourceClient request.

func (*ResourceClientResponse) CloneMessageVT 

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

func (*ResourceClientResponse) CloneVT 

func (m *ResourceClientResponse) CloneVT() *ResourceClientResponse

func (*ResourceClientResponse) EqualMessageVT 

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

func (*ResourceClientResponse) EqualVT 

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

func (*ResourceClientResponse) GetBody 

func (m *ResourceClientResponse) GetBody() isResourceClientResponse_Body

func (*ResourceClientResponse) GetControlAck added in v0.57.2 

func (x *ResourceClientResponse) GetControlAck() *ResourceClientControlAck

func (*ResourceClientResponse) GetInit 

func (x *ResourceClientResponse) GetInit() *ResourceClientInit

func (*ResourceClientResponse) GetResourceReleased 

func (x *ResourceClientResponse) GetResourceReleased() *ResourceReleasedResponse

func (*ResourceClientResponse) MarshalJSON 

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

MarshalJSON marshals the ResourceClientResponse to JSON.

func (*ResourceClientResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceClientResponse message to JSON.

func (*ResourceClientResponse) MarshalProtoText 

func (x *ResourceClientResponse) MarshalProtoText() string

func (*ResourceClientResponse) MarshalToSizedBufferVT 

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

func (*ResourceClientResponse) MarshalToVT 

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

func (*ResourceClientResponse) MarshalVT 

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

func (*ResourceClientResponse) ProtoMessage 

func (*ResourceClientResponse) ProtoMessage()

func (*ResourceClientResponse) Reset 

func (x *ResourceClientResponse) Reset()

func (*ResourceClientResponse) SizeVT 

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

func (*ResourceClientResponse) String 

func (x *ResourceClientResponse) String() string

func (*ResourceClientResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceClientResponse from JSON.

func (*ResourceClientResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceClientResponse message from JSON.

func (*ResourceClientResponse) UnmarshalVT 

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

type ResourceClientResponse_ControlAck added in v0.57.2 

type ResourceClientResponse_ControlAck struct {
	// ControlAck confirms that one lifecycle control and its callbacks completed.
	ControlAck *ResourceClientControlAck `protobuf:"bytes,4,opt,name=control_ack,json=controlAck,proto3,oneof"`
}

func (*ResourceClientResponse_ControlAck) CloneOneofVT added in v0.57.2 

func (m *ResourceClientResponse_ControlAck) CloneOneofVT() isResourceClientResponse_Body

func (*ResourceClientResponse_ControlAck) CloneVT added in v0.57.2 

func (m *ResourceClientResponse_ControlAck) CloneVT() *ResourceClientResponse_ControlAck

func (*ResourceClientResponse_ControlAck) EqualVT added in v0.57.2 

func (this *ResourceClientResponse_ControlAck) EqualVT(thatIface isResourceClientResponse_Body) bool

func (*ResourceClientResponse_ControlAck) MarshalToSizedBufferVT added in v0.57.2 

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

func (*ResourceClientResponse_ControlAck) MarshalToVT added in v0.57.2 

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

func (*ResourceClientResponse_ControlAck) SizeVT added in v0.57.2 

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

type ResourceClientResponse_Init 

type ResourceClientResponse_Init struct {
	// Init contains the initialization message for ResourceClient.
	// This is the first message sent on the stream and is only sent once.
	Init *ResourceClientInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

func (*ResourceClientResponse_Init) CloneOneofVT 

func (m *ResourceClientResponse_Init) CloneOneofVT() isResourceClientResponse_Body

func (*ResourceClientResponse_Init) CloneVT 

func (m *ResourceClientResponse_Init) CloneVT() *ResourceClientResponse_Init

func (*ResourceClientResponse_Init) EqualVT 

func (this *ResourceClientResponse_Init) EqualVT(thatIface isResourceClientResponse_Body) bool

func (*ResourceClientResponse_Init) MarshalToSizedBufferVT 

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

func (*ResourceClientResponse_Init) MarshalToVT 

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

func (*ResourceClientResponse_Init) SizeVT 

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

type ResourceClientResponse_ResourceReleased 

type ResourceClientResponse_ResourceReleased struct {
	// ResourceReleased is returned if a resource was released by the server.
	ResourceReleased *ResourceReleasedResponse `protobuf:"bytes,2,opt,name=resource_released,json=resourceReleased,proto3,oneof"`
}

func (*ResourceClientResponse_ResourceReleased) CloneOneofVT 

func (m *ResourceClientResponse_ResourceReleased) CloneOneofVT() isResourceClientResponse_Body

func (*ResourceClientResponse_ResourceReleased) CloneVT 

func (m *ResourceClientResponse_ResourceReleased) CloneVT() *ResourceClientResponse_ResourceReleased

func (*ResourceClientResponse_ResourceReleased) EqualVT 

func (this *ResourceClientResponse_ResourceReleased) EqualVT(thatIface isResourceClientResponse_Body) bool

func (*ResourceClientResponse_ResourceReleased) MarshalToSizedBufferVT 

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

func (*ResourceClientResponse_ResourceReleased) MarshalToVT 

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

func (*ResourceClientResponse_ResourceReleased) SizeVT 

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

type ResourceFailure 

type ResourceFailure struct {
	Code    ResourceFailureCode `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string              `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

ResourceFailure carries a stable recovery code and a diagnostic message.

func FailureFromError 

func FailureFromError(err error) *ResourceFailure

FailureFromError preserves known codes and treats other errors as diagnostics.

func (*ResourceFailure) CloneMessageVT 

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

func (*ResourceFailure) CloneVT 

func (m *ResourceFailure) CloneVT() *ResourceFailure

func (*ResourceFailure) EqualMessageVT 

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

func (*ResourceFailure) EqualVT 

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

func (*ResourceFailure) Error 

func (e *ResourceFailure) Error() string

Error returns the diagnostic without assigning it lifecycle meaning.

func (*ResourceFailure) GetCode 

func (x *ResourceFailure) GetCode() ResourceFailureCode

func (*ResourceFailure) GetMessage 

func (x *ResourceFailure) GetMessage() string

func (*ResourceFailure) Is 

func (e *ResourceFailure) Is(target error) bool

Is matches lifecycle failures by code, including failures decoded from a peer.

func (*ResourceFailure) MarshalJSON 

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

MarshalJSON marshals the ResourceFailure to JSON.

func (*ResourceFailure) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceFailure message to JSON.

func (*ResourceFailure) MarshalProtoText 

func (x *ResourceFailure) MarshalProtoText() string

func (*ResourceFailure) MarshalToSizedBufferVT 

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

func (*ResourceFailure) MarshalToVT 

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

func (*ResourceFailure) MarshalVT 

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

func (*ResourceFailure) ProtoMessage 

func (*ResourceFailure) ProtoMessage()

func (*ResourceFailure) Reset 

func (x *ResourceFailure) Reset()

func (*ResourceFailure) SizeVT 

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

func (*ResourceFailure) String 

func (x *ResourceFailure) String() string

func (*ResourceFailure) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceFailure from JSON.

func (*ResourceFailure) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceFailure message from JSON.

func (*ResourceFailure) UnmarshalVT 

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

type ResourceFailureCode 

type ResourceFailureCode int32

ResourceFailureCode controls lifecycle recovery independently of diagnostics. 

const (
	ResourceFailureCode_RESOURCE_FAILURE_CODE_UNKNOWN                     ResourceFailureCode = 0
	ResourceFailureCode_RESOURCE_FAILURE_CODE_RESOURCE_NOT_FOUND          ResourceFailureCode = 1
	ResourceFailureCode_RESOURCE_FAILURE_CODE_CLIENT_RELEASED             ResourceFailureCode = 2
	ResourceFailureCode_RESOURCE_FAILURE_CODE_INVALID_RESOURCE_ID         ResourceFailureCode = 3
	ResourceFailureCode_RESOURCE_FAILURE_CODE_INVALID_CLIENT_ID           ResourceFailureCode = 4
	ResourceFailureCode_RESOURCE_FAILURE_CODE_RESOURCE_OR_CLIENT_RELEASED ResourceFailureCode = 5
)

func (ResourceFailureCode) Enum 

func (x ResourceFailureCode) Enum() *ResourceFailureCode

func (ResourceFailureCode) MarshalJSON 

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

MarshalJSON marshals the ResourceFailureCode to JSON.

func (ResourceFailureCode) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceFailureCode to JSON.

func (ResourceFailureCode) MarshalProtoText 

func (x ResourceFailureCode) MarshalProtoText() string

func (ResourceFailureCode) MarshalText 

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

MarshalText marshals the ResourceFailureCode to text.

func (ResourceFailureCode) String 

func (x ResourceFailureCode) String() string

func (*ResourceFailureCode) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceFailureCode from JSON.

func (*ResourceFailureCode) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceFailureCode from JSON.

func (*ResourceFailureCode) UnmarshalText 

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

UnmarshalText unmarshals the ResourceFailureCode from text.

type ResourceReleasedResponse 

type ResourceReleasedResponse struct {

	// ResourceId is the ID of the resource that was released.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

ResourceReleasedResponse is a message indicating a resource was released.

func (*ResourceReleasedResponse) CloneMessageVT 

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

func (*ResourceReleasedResponse) CloneVT 

func (m *ResourceReleasedResponse) CloneVT() *ResourceReleasedResponse

func (*ResourceReleasedResponse) EqualMessageVT 

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

func (*ResourceReleasedResponse) EqualVT 

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

func (*ResourceReleasedResponse) GetResourceId 

func (x *ResourceReleasedResponse) GetResourceId() uint32

func (*ResourceReleasedResponse) MarshalJSON 

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

MarshalJSON marshals the ResourceReleasedResponse to JSON.

func (*ResourceReleasedResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceReleasedResponse message to JSON.

func (*ResourceReleasedResponse) MarshalProtoText 

func (x *ResourceReleasedResponse) MarshalProtoText() string

func (*ResourceReleasedResponse) MarshalToSizedBufferVT 

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

func (*ResourceReleasedResponse) MarshalToVT 

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

func (*ResourceReleasedResponse) MarshalVT 

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

func (*ResourceReleasedResponse) ProtoMessage 

func (*ResourceReleasedResponse) ProtoMessage()

func (*ResourceReleasedResponse) Reset 

func (x *ResourceReleasedResponse) Reset()

func (*ResourceReleasedResponse) SizeVT 

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

func (*ResourceReleasedResponse) String 

func (x *ResourceReleasedResponse) String() string

func (*ResourceReleasedResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceReleasedResponse from JSON.

func (*ResourceReleasedResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceReleasedResponse message from JSON.

func (*ResourceReleasedResponse) UnmarshalVT 

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

type ResourceRpcAck 

type ResourceRpcAck struct {
	Failure *ResourceFailure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

ResourceRpcAck accepts the route when failure is absent.

func (*ResourceRpcAck) CloneMessageVT 

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

func (*ResourceRpcAck) CloneVT 

func (m *ResourceRpcAck) CloneVT() *ResourceRpcAck

func (*ResourceRpcAck) EqualMessageVT 

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

func (*ResourceRpcAck) EqualVT 

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

func (*ResourceRpcAck) GetFailure 

func (x *ResourceRpcAck) GetFailure() *ResourceFailure

func (*ResourceRpcAck) MarshalJSON 

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

MarshalJSON marshals the ResourceRpcAck to JSON.

func (*ResourceRpcAck) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceRpcAck message to JSON.

func (*ResourceRpcAck) MarshalProtoText 

func (x *ResourceRpcAck) MarshalProtoText() string

func (*ResourceRpcAck) MarshalToSizedBufferVT 

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

func (*ResourceRpcAck) MarshalToVT 

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

func (*ResourceRpcAck) MarshalVT 

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

func (*ResourceRpcAck) ProtoMessage 

func (*ResourceRpcAck) ProtoMessage()

func (*ResourceRpcAck) Reset 

func (x *ResourceRpcAck) Reset()

func (*ResourceRpcAck) SizeVT 

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

func (*ResourceRpcAck) String 

func (x *ResourceRpcAck) String() string

func (*ResourceRpcAck) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceRpcAck from JSON.

func (*ResourceRpcAck) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceRpcAck message from JSON.

func (*ResourceRpcAck) UnmarshalVT 

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

type ResourceRpcInit 

type ResourceRpcInit struct {
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

ResourceRpcInit selects a resource opened by ResourceClient or ResourceAttach.

func (*ResourceRpcInit) CloneMessageVT 

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

func (*ResourceRpcInit) CloneVT 

func (m *ResourceRpcInit) CloneVT() *ResourceRpcInit

func (*ResourceRpcInit) EqualMessageVT 

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

func (*ResourceRpcInit) EqualVT 

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

func (*ResourceRpcInit) GetResourceId 

func (x *ResourceRpcInit) GetResourceId() uint32

func (*ResourceRpcInit) MarshalJSON 

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

MarshalJSON marshals the ResourceRpcInit to JSON.

func (*ResourceRpcInit) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceRpcInit message to JSON.

func (*ResourceRpcInit) MarshalProtoText 

func (x *ResourceRpcInit) MarshalProtoText() string

func (*ResourceRpcInit) MarshalToSizedBufferVT 

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

func (*ResourceRpcInit) MarshalToVT 

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

func (*ResourceRpcInit) MarshalVT 

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

func (*ResourceRpcInit) ProtoMessage 

func (*ResourceRpcInit) ProtoMessage()

func (*ResourceRpcInit) Reset 

func (x *ResourceRpcInit) Reset()

func (*ResourceRpcInit) SizeVT 

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

func (*ResourceRpcInit) String 

func (x *ResourceRpcInit) String() string

func (*ResourceRpcInit) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceRpcInit from JSON.

func (*ResourceRpcInit) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceRpcInit message from JSON.

func (*ResourceRpcInit) UnmarshalVT 

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

type ResourceRpcPacket 

type ResourceRpcPacket struct {

	// Types that are assignable to Body:
	//	*ResourceRpcPacket_Init
	//	*ResourceRpcPacket_Ack
	//	*ResourceRpcPacket_Data
	Body isResourceRpcPacket_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

ResourceRpcPacket negotiates a resource and carries existing SRPC data frames.

func (*ResourceRpcPacket) CloneMessageVT 

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

func (*ResourceRpcPacket) CloneVT 

func (m *ResourceRpcPacket) CloneVT() *ResourceRpcPacket

func (*ResourceRpcPacket) EqualMessageVT 

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

func (*ResourceRpcPacket) EqualVT 

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

func (*ResourceRpcPacket) GetAck 

func (x *ResourceRpcPacket) GetAck() *ResourceRpcAck

func (*ResourceRpcPacket) GetBody 

func (m *ResourceRpcPacket) GetBody() isResourceRpcPacket_Body

func (*ResourceRpcPacket) GetData 

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

func (*ResourceRpcPacket) GetInit 

func (x *ResourceRpcPacket) GetInit() *ResourceRpcInit

func (*ResourceRpcPacket) MarshalJSON 

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

MarshalJSON marshals the ResourceRpcPacket to JSON.

func (*ResourceRpcPacket) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ResourceRpcPacket message to JSON.

func (*ResourceRpcPacket) MarshalProtoText 

func (x *ResourceRpcPacket) MarshalProtoText() string

func (*ResourceRpcPacket) MarshalToSizedBufferVT 

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

func (*ResourceRpcPacket) MarshalToVT 

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

func (*ResourceRpcPacket) MarshalVT 

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

func (*ResourceRpcPacket) ProtoMessage 

func (*ResourceRpcPacket) ProtoMessage()

func (*ResourceRpcPacket) Reset 

func (x *ResourceRpcPacket) Reset()

func (*ResourceRpcPacket) SizeVT 

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

func (*ResourceRpcPacket) String 

func (x *ResourceRpcPacket) String() string

func (*ResourceRpcPacket) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ResourceRpcPacket from JSON.

func (*ResourceRpcPacket) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ResourceRpcPacket message from JSON.

func (*ResourceRpcPacket) UnmarshalVT 

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

type ResourceRpcPacket_Ack 

type ResourceRpcPacket_Ack struct {
	Ack *ResourceRpcAck `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

func (*ResourceRpcPacket_Ack) CloneOneofVT 

func (m *ResourceRpcPacket_Ack) CloneOneofVT() isResourceRpcPacket_Body

func (*ResourceRpcPacket_Ack) CloneVT 

func (m *ResourceRpcPacket_Ack) CloneVT() *ResourceRpcPacket_Ack

func (*ResourceRpcPacket_Ack) EqualVT 

func (this *ResourceRpcPacket_Ack) EqualVT(thatIface isResourceRpcPacket_Body) bool

func (*ResourceRpcPacket_Ack) MarshalToSizedBufferVT 

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

func (*ResourceRpcPacket_Ack) MarshalToVT 

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

func (*ResourceRpcPacket_Ack) SizeVT 

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

type ResourceRpcPacket_Data 

type ResourceRpcPacket_Data struct {
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3,oneof"`
}

func (*ResourceRpcPacket_Data) CloneOneofVT 

func (m *ResourceRpcPacket_Data) CloneOneofVT() isResourceRpcPacket_Body

func (*ResourceRpcPacket_Data) CloneVT 

func (m *ResourceRpcPacket_Data) CloneVT() *ResourceRpcPacket_Data

func (*ResourceRpcPacket_Data) EqualVT 

func (this *ResourceRpcPacket_Data) EqualVT(thatIface isResourceRpcPacket_Body) bool

func (*ResourceRpcPacket_Data) MarshalToSizedBufferVT 

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

func (*ResourceRpcPacket_Data) MarshalToVT 

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

func (*ResourceRpcPacket_Data) SizeVT 

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

type ResourceRpcPacket_Init 

type ResourceRpcPacket_Init struct {
	Init *ResourceRpcInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

func (*ResourceRpcPacket_Init) CloneOneofVT 

func (m *ResourceRpcPacket_Init) CloneOneofVT() isResourceRpcPacket_Body

func (*ResourceRpcPacket_Init) CloneVT 

func (m *ResourceRpcPacket_Init) CloneVT() *ResourceRpcPacket_Init

func (*ResourceRpcPacket_Init) EqualVT 

func (this *ResourceRpcPacket_Init) EqualVT(thatIface isResourceRpcPacket_Body) bool

func (*ResourceRpcPacket_Init) MarshalToSizedBufferVT 

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

func (*ResourceRpcPacket_Init) MarshalToVT 

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

func (*ResourceRpcPacket_Init) SizeVT 

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

type ResourceRpcStream 

type ResourceRpcStream interface {
	srpc.Stream
	Send(*ResourceRpcPacket) error
	Recv() (*ResourceRpcPacket, error)
}

ResourceRpcStream carries one Resource handshake followed by SRPC data frames.

type RoutedInvoker 

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

RoutedInvoker dispatches SRPC calls to the correct mux by parsing a resource ID prefix from the service ID. Used by the client to route incoming yamux sub-stream RPCs to the right attached resource.

func NewRoutedInvoker 

func NewRoutedInvoker() *RoutedInvoker

NewRoutedInvoker creates a new RoutedInvoker.

func NewRoutedInvokerWithContext added in v0.51.2 

func NewRoutedInvokerWithContext(contextFn func(context.Context, uint32) context.Context) *RoutedInvoker

NewRoutedInvokerWithContext creates a RoutedInvoker that can replace the stream context before invoking a routed mux.

func (*RoutedInvoker) InvokeMethod 

func (r *RoutedInvoker) InvokeMethod(serviceID, methodID string, strm srpc.Stream) (bool, error)

InvokeMethod parses the resource ID prefix from serviceID and dispatches.

func (*RoutedInvoker) RemoveMux 

func (r *RoutedInvoker) RemoveMux(resourceID uint32)

RemoveMux removes a mux for a resource ID.

func (*RoutedInvoker) SetMux 

func (r *RoutedInvoker) SetMux(resourceID uint32, mux srpc.Invoker)

SetMux registers or replaces a mux for a resource ID.

type SRPCResourceServiceClient 

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

	// ResourceClient starts an instance of a client for the ResourceService,
	// yielding a new client ID. The client can use that ID for future RPCs
	// accessing the Resource tree. When the streaming RPC ends, references to
	// resources opened by the client will be released.
	ResourceClient(ctx context.Context) (SRPCResourceService_ResourceClientClient, error)
	// ResourceRpc is a rpc request for an open resource handle.
	// Exposes service(s) depending on the resource type.
	// The first request selects a resource; one typed acknowledgement precedes data.
	ResourceRpc(ctx context.Context) (SRPCResourceService_ResourceRpcClient, error)
	// ResourceAttach allows a client to provide resources that server-side
	// RPC handlers can invoke via getAttachedRef(id). Session-only Init/Ack,
	// then resources registered via Add/AddAck. After Init/Ack, mux_data
	// carries yamux frames for all attached resources.
	ResourceAttach(ctx context.Context) (SRPCResourceService_ResourceAttachClient, error)
}

func NewSRPCResourceServiceClient 

func NewSRPCResourceServiceClient(cc srpc.Client) SRPCResourceServiceClient

func NewSRPCResourceServiceClientWithServiceID 

func NewSRPCResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCResourceServiceClient

type SRPCResourceServiceHandler 

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

func (SRPCResourceServiceHandler) GetMethodIDs 

func (SRPCResourceServiceHandler) GetMethodIDs() []string

func (*SRPCResourceServiceHandler) GetServiceID 

func (d *SRPCResourceServiceHandler) GetServiceID() string

func (*SRPCResourceServiceHandler) InvokeMethod 

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

func (SRPCResourceServiceHandler) InvokeMethod_ResourceAttach 

func (SRPCResourceServiceHandler) InvokeMethod_ResourceAttach(impl SRPCResourceServiceServer, strm srpc.Stream) error

func (SRPCResourceServiceHandler) InvokeMethod_ResourceClient 

func (SRPCResourceServiceHandler) InvokeMethod_ResourceClient(impl SRPCResourceServiceServer, strm srpc.Stream) error

func (SRPCResourceServiceHandler) InvokeMethod_ResourceRpc 

func (SRPCResourceServiceHandler) InvokeMethod_ResourceRpc(impl SRPCResourceServiceServer, strm srpc.Stream) error

type SRPCResourceServiceServer 

type SRPCResourceServiceServer interface {
	// ResourceClient starts an instance of a client for the ResourceService,
	// yielding a new client ID. The client can use that ID for future RPCs
	// accessing the Resource tree. When the streaming RPC ends, references to
	// resources opened by the client will be released.
	ResourceClient(SRPCResourceService_ResourceClientStream) error
	// ResourceRpc is a rpc request for an open resource handle.
	// Exposes service(s) depending on the resource type.
	// The first request selects a resource; one typed acknowledgement precedes data.
	ResourceRpc(SRPCResourceService_ResourceRpcStream) error
	// ResourceAttach allows a client to provide resources that server-side
	// RPC handlers can invoke via getAttachedRef(id). Session-only Init/Ack,
	// then resources registered via Add/AddAck. After Init/Ack, mux_data
	// carries yamux frames for all attached resources.
	ResourceAttach(SRPCResourceService_ResourceAttachStream) error
}

type SRPCResourceService_ResourceAttachClient 

type SRPCResourceService_ResourceAttachClient interface {
	srpc.Stream
	Send(*ResourceAttachRequest) error
	Recv() (*ResourceAttachResponse, error)
	RecvTo(*ResourceAttachResponse) error
}

type SRPCResourceService_ResourceAttachStream 

type SRPCResourceService_ResourceAttachStream interface {
	srpc.Stream
	Send(*ResourceAttachResponse) error
	SendAndClose(*ResourceAttachResponse) error
	Recv() (*ResourceAttachRequest, error)
	RecvTo(*ResourceAttachRequest) error
}

type SRPCResourceService_ResourceClientClient 

type SRPCResourceService_ResourceClientClient interface {
	srpc.Stream
	Send(*ResourceClientRequest) error
	Recv() (*ResourceClientResponse, error)
	RecvTo(*ResourceClientResponse) error
}

type SRPCResourceService_ResourceClientStream 

type SRPCResourceService_ResourceClientStream interface {
	srpc.Stream
	Send(*ResourceClientResponse) error
	SendAndClose(*ResourceClientResponse) error
	Recv() (*ResourceClientRequest, error)
	RecvTo(*ResourceClientRequest) error
}

type SRPCResourceService_ResourceRpcClient 

type SRPCResourceService_ResourceRpcClient interface {
	srpc.Stream
	Send(*ResourceRpcPacket) error
	Recv() (*ResourceRpcPacket, error)
	RecvTo(*ResourceRpcPacket) error
}

type SRPCResourceService_ResourceRpcStream 

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

Source Files

View all Source files

Directories

Path Synopsis

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.