volume_rpc

package
v0.51.8 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const SRPCAccessVolumesServiceID = "volume.rpc.AccessVolumes"
View Source 
const SRPCProxyVolumeServiceID = "volume.rpc.ProxyVolume"

Variables

View Source 
var (
	// ErrUnknownVolumeID is returned if the volume id is not found.
	ErrUnknownVolumeID = errors.New("unknown volume id")
	// ErrPrivKeyUnavailable is returned if returning private keys is disabled.
	ErrPrivKeyUnavailable = errors.New("volume private key is unavailable")
)

Functions

func NewSRPCAccessVolumesHandler 

func NewSRPCAccessVolumesHandler(impl SRPCAccessVolumesServer, serviceID string) srpc.Handler

NewSRPCAccessVolumesHandler constructs a new RPC handler. serviceID: if empty, uses default: volume.rpc.AccessVolumes

func NewSRPCProxyVolumeHandler 

func NewSRPCProxyVolumeHandler(impl SRPCProxyVolumeServer, serviceID string) srpc.Handler

NewSRPCProxyVolumeHandler constructs a new RPC handler. serviceID: if empty, uses default: volume.rpc.ProxyVolume

func SRPCRegisterAccessVolumes 

func SRPCRegisterAccessVolumes(mux srpc.Mux, impl SRPCAccessVolumesServer) error

SRPCRegisterAccessVolumes registers the implementation with the mux. Uses the default serviceID: volume.rpc.AccessVolumes

func SRPCRegisterProxyVolume 

func SRPCRegisterProxyVolume(mux srpc.Mux, impl SRPCProxyVolumeServer) error

SRPCRegisterProxyVolume registers the implementation with the mux. Uses the default serviceID: volume.rpc.ProxyVolume

Types

type GetPeerPrivRequest 

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

GetPeerPrivRequest is a request to get the volume peer privkey.

func (*GetPeerPrivRequest) CloneMessageVT 

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

func (*GetPeerPrivRequest) CloneVT 

func (m *GetPeerPrivRequest) CloneVT() *GetPeerPrivRequest

func (*GetPeerPrivRequest) EqualMessageVT 

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

func (*GetPeerPrivRequest) EqualVT 

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

func (*GetPeerPrivRequest) MarshalJSON 

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

MarshalJSON marshals the GetPeerPrivRequest to JSON.

func (*GetPeerPrivRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetPeerPrivRequest message to JSON.

func (*GetPeerPrivRequest) MarshalProtoText 

func (x *GetPeerPrivRequest) MarshalProtoText() string

func (*GetPeerPrivRequest) MarshalToSizedBufferVT 

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

func (*GetPeerPrivRequest) MarshalToVT 

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

func (*GetPeerPrivRequest) MarshalVT 

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

func (*GetPeerPrivRequest) ProtoMessage 

func (*GetPeerPrivRequest) ProtoMessage()

func (*GetPeerPrivRequest) Reset 

func (x *GetPeerPrivRequest) Reset()

func (*GetPeerPrivRequest) SizeVT 

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

func (*GetPeerPrivRequest) String 

func (x *GetPeerPrivRequest) String() string

func (*GetPeerPrivRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetPeerPrivRequest from JSON.

func (*GetPeerPrivRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetPeerPrivRequest message from JSON.

func (*GetPeerPrivRequest) UnmarshalVT 

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

type GetPeerPrivResponse 

type GetPeerPrivResponse struct {

	// PrivKey is the private key.
	PrivKey string `protobuf:"bytes,1,opt,name=priv_key,json=privKey,proto3" json:"privKey,omitempty"`
	// contains filtered or unexported fields
}

GetPeerPrivResponse is the response to looking up the volume peer privkey.

func NewGetPeerPrivResponse 

func NewGetPeerPrivResponse(privKey crypto.PrivKey) (*GetPeerPrivResponse, error)

NewGetPeerPrivResponse builds a new GetPeerPriv response object.

func (*GetPeerPrivResponse) CloneMessageVT 

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

func (*GetPeerPrivResponse) CloneVT 

func (m *GetPeerPrivResponse) CloneVT() *GetPeerPrivResponse

func (*GetPeerPrivResponse) EqualMessageVT 

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

func (*GetPeerPrivResponse) EqualVT 

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

func (*GetPeerPrivResponse) GetPrivKey 

func (x *GetPeerPrivResponse) GetPrivKey() string

func (*GetPeerPrivResponse) MarshalJSON 

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

MarshalJSON marshals the GetPeerPrivResponse to JSON.

func (*GetPeerPrivResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetPeerPrivResponse message to JSON.

func (*GetPeerPrivResponse) MarshalProtoText 

func (x *GetPeerPrivResponse) MarshalProtoText() string

func (*GetPeerPrivResponse) MarshalToSizedBufferVT 

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

func (*GetPeerPrivResponse) MarshalToVT 

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

func (*GetPeerPrivResponse) MarshalVT 

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

func (*GetPeerPrivResponse) ParsePrivKey 

func (r *GetPeerPrivResponse) ParsePrivKey() (crypto.PrivKey, error)

ParsePrivKey parses the private key field. Returns nil, nil if the response field was empty.

func (*GetPeerPrivResponse) ProtoMessage 

func (*GetPeerPrivResponse) ProtoMessage()

func (*GetPeerPrivResponse) Reset 

func (x *GetPeerPrivResponse) Reset()

func (*GetPeerPrivResponse) SizeVT 

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

func (*GetPeerPrivResponse) String 

func (x *GetPeerPrivResponse) String() string

func (*GetPeerPrivResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetPeerPrivResponse from JSON.

func (*GetPeerPrivResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetPeerPrivResponse message from JSON.

func (*GetPeerPrivResponse) UnmarshalVT 

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

func (*GetPeerPrivResponse) Validate 

func (r *GetPeerPrivResponse) Validate() error

Validate validates the response object.

type GetStorageStatsRequest 

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

GetStorageStatsRequest is a request to get storage usage statistics.

func (*GetStorageStatsRequest) CloneMessageVT 

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

func (*GetStorageStatsRequest) CloneVT 

func (m *GetStorageStatsRequest) CloneVT() *GetStorageStatsRequest

func (*GetStorageStatsRequest) EqualMessageVT 

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

func (*GetStorageStatsRequest) EqualVT 

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

func (*GetStorageStatsRequest) MarshalJSON 

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

MarshalJSON marshals the GetStorageStatsRequest to JSON.

func (*GetStorageStatsRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetStorageStatsRequest message to JSON.

func (*GetStorageStatsRequest) MarshalProtoText 

func (x *GetStorageStatsRequest) MarshalProtoText() string

func (*GetStorageStatsRequest) MarshalToSizedBufferVT 

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

func (*GetStorageStatsRequest) MarshalToVT 

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

func (*GetStorageStatsRequest) MarshalVT 

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

func (*GetStorageStatsRequest) ProtoMessage 

func (*GetStorageStatsRequest) ProtoMessage()

func (*GetStorageStatsRequest) Reset 

func (x *GetStorageStatsRequest) Reset()

func (*GetStorageStatsRequest) SizeVT 

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

func (*GetStorageStatsRequest) String 

func (x *GetStorageStatsRequest) String() string

func (*GetStorageStatsRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetStorageStatsRequest from JSON.

func (*GetStorageStatsRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetStorageStatsRequest message from JSON.

func (*GetStorageStatsRequest) UnmarshalVT 

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

type GetStorageStatsResponse 

type GetStorageStatsResponse struct {

	// StorageStats contains the storage usage statistics.
	StorageStats *volume.StorageStats `protobuf:"bytes,1,opt,name=storage_stats,json=storageStats,proto3" json:"storageStats,omitempty"`
	// contains filtered or unexported fields
}

GetStorageStatsResponse is the response with storage usage statistics.

func (*GetStorageStatsResponse) CloneMessageVT 

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

func (*GetStorageStatsResponse) CloneVT 

func (m *GetStorageStatsResponse) CloneVT() *GetStorageStatsResponse

func (*GetStorageStatsResponse) EqualMessageVT 

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

func (*GetStorageStatsResponse) EqualVT 

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

func (*GetStorageStatsResponse) GetStorageStats 

func (x *GetStorageStatsResponse) GetStorageStats() *volume.StorageStats

func (*GetStorageStatsResponse) MarshalJSON 

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

MarshalJSON marshals the GetStorageStatsResponse to JSON.

func (*GetStorageStatsResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetStorageStatsResponse message to JSON.

func (*GetStorageStatsResponse) MarshalProtoText 

func (x *GetStorageStatsResponse) MarshalProtoText() string

func (*GetStorageStatsResponse) MarshalToSizedBufferVT 

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

func (*GetStorageStatsResponse) MarshalToVT 

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

func (*GetStorageStatsResponse) MarshalVT 

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

func (*GetStorageStatsResponse) ProtoMessage 

func (*GetStorageStatsResponse) ProtoMessage()

func (*GetStorageStatsResponse) Reset 

func (x *GetStorageStatsResponse) Reset()

func (*GetStorageStatsResponse) SizeVT 

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

func (*GetStorageStatsResponse) String 

func (x *GetStorageStatsResponse) String() string

func (*GetStorageStatsResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetStorageStatsResponse from JSON.

func (*GetStorageStatsResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetStorageStatsResponse message from JSON.

func (*GetStorageStatsResponse) UnmarshalVT 

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

type GetVolumeInfoRequest 

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

GetVolumeInfoRequest is a request to get volume information.

func (*GetVolumeInfoRequest) CloneMessageVT 

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

func (*GetVolumeInfoRequest) CloneVT 

func (m *GetVolumeInfoRequest) CloneVT() *GetVolumeInfoRequest

func (*GetVolumeInfoRequest) EqualMessageVT 

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

func (*GetVolumeInfoRequest) EqualVT 

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

func (*GetVolumeInfoRequest) MarshalJSON 

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

MarshalJSON marshals the GetVolumeInfoRequest to JSON.

func (*GetVolumeInfoRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetVolumeInfoRequest message to JSON.

func (*GetVolumeInfoRequest) MarshalProtoText 

func (x *GetVolumeInfoRequest) MarshalProtoText() string

func (*GetVolumeInfoRequest) MarshalToSizedBufferVT 

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

func (*GetVolumeInfoRequest) MarshalToVT 

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

func (*GetVolumeInfoRequest) MarshalVT 

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

func (*GetVolumeInfoRequest) ProtoMessage 

func (*GetVolumeInfoRequest) ProtoMessage()

func (*GetVolumeInfoRequest) Reset 

func (x *GetVolumeInfoRequest) Reset()

func (*GetVolumeInfoRequest) SizeVT 

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

func (*GetVolumeInfoRequest) String 

func (x *GetVolumeInfoRequest) String() string

func (*GetVolumeInfoRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetVolumeInfoRequest from JSON.

func (*GetVolumeInfoRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetVolumeInfoRequest message from JSON.

func (*GetVolumeInfoRequest) UnmarshalVT 

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

type GetVolumeInfoResponse 

type GetVolumeInfoResponse struct {

	// VolumeInfo is the volume information object.
	VolumeInfo *volume.VolumeInfo `protobuf:"bytes,1,opt,name=volume_info,json=volumeInfo,proto3" json:"volumeInfo,omitempty"`
	// contains filtered or unexported fields
}

GetVolumeInfoResponse is the response to the request for volume info.

func (*GetVolumeInfoResponse) CloneMessageVT 

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

func (*GetVolumeInfoResponse) CloneVT 

func (m *GetVolumeInfoResponse) CloneVT() *GetVolumeInfoResponse

func (*GetVolumeInfoResponse) EqualMessageVT 

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

func (*GetVolumeInfoResponse) EqualVT 

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

func (*GetVolumeInfoResponse) GetVolumeInfo 

func (x *GetVolumeInfoResponse) GetVolumeInfo() *volume.VolumeInfo

func (*GetVolumeInfoResponse) MarshalJSON 

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

MarshalJSON marshals the GetVolumeInfoResponse to JSON.

func (*GetVolumeInfoResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetVolumeInfoResponse message to JSON.

func (*GetVolumeInfoResponse) MarshalProtoText 

func (x *GetVolumeInfoResponse) MarshalProtoText() string

func (*GetVolumeInfoResponse) MarshalToSizedBufferVT 

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

func (*GetVolumeInfoResponse) MarshalToVT 

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

func (*GetVolumeInfoResponse) MarshalVT 

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

func (*GetVolumeInfoResponse) ProtoMessage 

func (*GetVolumeInfoResponse) ProtoMessage()

func (*GetVolumeInfoResponse) Reset 

func (x *GetVolumeInfoResponse) Reset()

func (*GetVolumeInfoResponse) SizeVT 

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

func (*GetVolumeInfoResponse) String 

func (x *GetVolumeInfoResponse) String() string

func (*GetVolumeInfoResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetVolumeInfoResponse from JSON.

func (*GetVolumeInfoResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetVolumeInfoResponse message from JSON.

func (*GetVolumeInfoResponse) UnmarshalVT 

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

type SRPCAccessVolumesClient 

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

	// WatchVolumeInfo watches information about a volume.
	// The most recent message contains the most recently known state.
	// If the volume was not found (directive is idle) returns empty.
	WatchVolumeInfo(ctx context.Context, in *WatchVolumeInfoRequest) (SRPCAccessVolumes_WatchVolumeInfoClient, error)
	// VolumeRpc uses the LookupVolume directive access a Volume handle.
	// Exposes the ProxyVolume service.
	// Id: volume id
	VolumeRpc(ctx context.Context) (SRPCAccessVolumes_VolumeRpcClient, error)
}

func NewSRPCAccessVolumesClient 

func NewSRPCAccessVolumesClient(cc srpc.Client) SRPCAccessVolumesClient

func NewSRPCAccessVolumesClientWithServiceID 

func NewSRPCAccessVolumesClientWithServiceID(cc srpc.Client, serviceID string) SRPCAccessVolumesClient

type SRPCAccessVolumesHandler 

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

func (SRPCAccessVolumesHandler) GetMethodIDs 

func (SRPCAccessVolumesHandler) GetMethodIDs() []string

func (*SRPCAccessVolumesHandler) GetServiceID 

func (d *SRPCAccessVolumesHandler) GetServiceID() string

func (*SRPCAccessVolumesHandler) InvokeMethod 

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

func (SRPCAccessVolumesHandler) InvokeMethod_VolumeRpc 

func (SRPCAccessVolumesHandler) InvokeMethod_VolumeRpc(impl SRPCAccessVolumesServer, strm srpc.Stream) error

func (SRPCAccessVolumesHandler) InvokeMethod_WatchVolumeInfo 

func (SRPCAccessVolumesHandler) InvokeMethod_WatchVolumeInfo(impl SRPCAccessVolumesServer, strm srpc.Stream) error

type SRPCAccessVolumesServer 

type SRPCAccessVolumesServer interface {
	// WatchVolumeInfo watches information about a volume.
	// The most recent message contains the most recently known state.
	// If the volume was not found (directive is idle) returns empty.
	WatchVolumeInfo(*WatchVolumeInfoRequest, SRPCAccessVolumes_WatchVolumeInfoStream) error
	// VolumeRpc uses the LookupVolume directive access a Volume handle.
	// Exposes the ProxyVolume service.
	// Id: volume id
	VolumeRpc(SRPCAccessVolumes_VolumeRpcStream) error
}

type SRPCAccessVolumes_VolumeRpcClient 

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

type SRPCAccessVolumes_VolumeRpcStream 

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

type SRPCAccessVolumes_WatchVolumeInfoClient 

type SRPCAccessVolumes_WatchVolumeInfoClient interface {
	srpc.Stream
	Recv() (*WatchVolumeInfoResponse, error)
	RecvTo(*WatchVolumeInfoResponse) error
}

type SRPCAccessVolumes_WatchVolumeInfoStream 

type SRPCAccessVolumes_WatchVolumeInfoStream interface {
	srpc.Stream
	Send(*WatchVolumeInfoResponse) error
	SendAndClose(*WatchVolumeInfoResponse) error
}

type SRPCProxyVolumeClient 

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

	// GetVolumeInfo returns the basic volume information.
	GetVolumeInfo(ctx context.Context, in *GetVolumeInfoRequest) (*GetVolumeInfoResponse, error)
	// GetPeerPriv returns the volume peer private key.
	// Returns ErrPrivKeyUnavailable if the private key is unavailable.
	GetPeerPriv(ctx context.Context, in *GetPeerPrivRequest) (*GetPeerPrivResponse, error)
	// GetStorageStats returns storage usage statistics for the volume.
	GetStorageStats(ctx context.Context, in *GetStorageStatsRequest) (*GetStorageStatsResponse, error)
}

func NewSRPCProxyVolumeClient 

func NewSRPCProxyVolumeClient(cc srpc.Client) SRPCProxyVolumeClient

func NewSRPCProxyVolumeClientWithServiceID 

func NewSRPCProxyVolumeClientWithServiceID(cc srpc.Client, serviceID string) SRPCProxyVolumeClient

type SRPCProxyVolumeHandler 

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

func (SRPCProxyVolumeHandler) GetMethodIDs 

func (SRPCProxyVolumeHandler) GetMethodIDs() []string

func (*SRPCProxyVolumeHandler) GetServiceID 

func (d *SRPCProxyVolumeHandler) GetServiceID() string

func (*SRPCProxyVolumeHandler) InvokeMethod 

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

func (SRPCProxyVolumeHandler) InvokeMethod_GetPeerPriv 

func (SRPCProxyVolumeHandler) InvokeMethod_GetPeerPriv(impl SRPCProxyVolumeServer, strm srpc.Stream) error

func (SRPCProxyVolumeHandler) InvokeMethod_GetStorageStats 

func (SRPCProxyVolumeHandler) InvokeMethod_GetStorageStats(impl SRPCProxyVolumeServer, strm srpc.Stream) error

func (SRPCProxyVolumeHandler) InvokeMethod_GetVolumeInfo 

func (SRPCProxyVolumeHandler) InvokeMethod_GetVolumeInfo(impl SRPCProxyVolumeServer, strm srpc.Stream) error

type SRPCProxyVolumeServer 

type SRPCProxyVolumeServer interface {
	// GetVolumeInfo returns the basic volume information.
	GetVolumeInfo(context.Context, *GetVolumeInfoRequest) (*GetVolumeInfoResponse, error)
	// GetPeerPriv returns the volume peer private key.
	// Returns ErrPrivKeyUnavailable if the private key is unavailable.
	GetPeerPriv(context.Context, *GetPeerPrivRequest) (*GetPeerPrivResponse, error)
	// GetStorageStats returns storage usage statistics for the volume.
	GetStorageStats(context.Context, *GetStorageStatsRequest) (*GetStorageStatsResponse, error)
}

type SRPCProxyVolume_GetPeerPrivStream 

type SRPCProxyVolume_GetPeerPrivStream interface {
	srpc.Stream
}

type SRPCProxyVolume_GetStorageStatsStream 

type SRPCProxyVolume_GetStorageStatsStream interface {
	srpc.Stream
}

type SRPCProxyVolume_GetVolumeInfoStream 

type SRPCProxyVolume_GetVolumeInfoStream interface {
	srpc.Stream
}

type WatchVolumeInfoRequest 

type WatchVolumeInfoRequest struct {

	// VolumeId is the volume id to watch.
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volumeId,omitempty"`
	// contains filtered or unexported fields
}

WatchVolumeInfoRequest is a request to watch volume information.

func (*WatchVolumeInfoRequest) CloneMessageVT 

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

func (*WatchVolumeInfoRequest) CloneVT 

func (m *WatchVolumeInfoRequest) CloneVT() *WatchVolumeInfoRequest

func (*WatchVolumeInfoRequest) EqualMessageVT 

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

func (*WatchVolumeInfoRequest) EqualVT 

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

func (*WatchVolumeInfoRequest) GetVolumeId 

func (x *WatchVolumeInfoRequest) GetVolumeId() string

func (*WatchVolumeInfoRequest) MarshalJSON 

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

MarshalJSON marshals the WatchVolumeInfoRequest to JSON.

func (*WatchVolumeInfoRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the WatchVolumeInfoRequest message to JSON.

func (*WatchVolumeInfoRequest) MarshalProtoText 

func (x *WatchVolumeInfoRequest) MarshalProtoText() string

func (*WatchVolumeInfoRequest) MarshalToSizedBufferVT 

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

func (*WatchVolumeInfoRequest) MarshalToVT 

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

func (*WatchVolumeInfoRequest) MarshalVT 

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

func (*WatchVolumeInfoRequest) ProtoMessage 

func (*WatchVolumeInfoRequest) ProtoMessage()

func (*WatchVolumeInfoRequest) Reset 

func (x *WatchVolumeInfoRequest) Reset()

func (*WatchVolumeInfoRequest) SizeVT 

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

func (*WatchVolumeInfoRequest) String 

func (x *WatchVolumeInfoRequest) String() string

func (*WatchVolumeInfoRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the WatchVolumeInfoRequest from JSON.

func (*WatchVolumeInfoRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the WatchVolumeInfoRequest message from JSON.

func (*WatchVolumeInfoRequest) UnmarshalVT 

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

type WatchVolumeInfoResponse 

type WatchVolumeInfoResponse struct {

	// NotFound is set of the volume info is empty (not found).
	NotFound bool `protobuf:"varint,1,opt,name=not_found,json=notFound,proto3" json:"notFound,omitempty"`
	// VolumeInfo contains the located volume information.
	VolumeInfo *volume.VolumeInfo `protobuf:"bytes,2,opt,name=volume_info,json=volumeInfo,proto3" json:"volumeInfo,omitempty"`
	// contains filtered or unexported fields
}

WatchVolumeInfoResponse is a state snapshot of the volume info.

func (*WatchVolumeInfoResponse) CloneMessageVT 

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

func (*WatchVolumeInfoResponse) CloneVT 

func (m *WatchVolumeInfoResponse) CloneVT() *WatchVolumeInfoResponse

func (*WatchVolumeInfoResponse) EqualMessageVT 

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

func (*WatchVolumeInfoResponse) EqualVT 

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

func (*WatchVolumeInfoResponse) GetNotFound 

func (x *WatchVolumeInfoResponse) GetNotFound() bool

func (*WatchVolumeInfoResponse) GetVolumeInfo 

func (x *WatchVolumeInfoResponse) GetVolumeInfo() *volume.VolumeInfo

func (*WatchVolumeInfoResponse) MarshalJSON 

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

MarshalJSON marshals the WatchVolumeInfoResponse to JSON.

func (*WatchVolumeInfoResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the WatchVolumeInfoResponse message to JSON.

func (*WatchVolumeInfoResponse) MarshalProtoText 

func (x *WatchVolumeInfoResponse) MarshalProtoText() string

func (*WatchVolumeInfoResponse) MarshalToSizedBufferVT 

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

func (*WatchVolumeInfoResponse) MarshalToVT 

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

func (*WatchVolumeInfoResponse) MarshalVT 

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

func (*WatchVolumeInfoResponse) ProtoMessage 

func (*WatchVolumeInfoResponse) ProtoMessage()

func (*WatchVolumeInfoResponse) Reset 

func (x *WatchVolumeInfoResponse) Reset()

func (*WatchVolumeInfoResponse) SizeVT 

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

func (*WatchVolumeInfoResponse) String 

func (x *WatchVolumeInfoResponse) String() string

func (*WatchVolumeInfoResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the WatchVolumeInfoResponse from JSON.

func (*WatchVolumeInfoResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the WatchVolumeInfoResponse message from JSON.

func (*WatchVolumeInfoResponse) UnmarshalVT 

func (m *WatchVolumeInfoResponse) UnmarshalVT(dAtA []byte) 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.