volume_rpc

package
v0.53.0 Latest Latest
Warning

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

 Go to latest Published: Jul 5, 2026 License: Apache-2.0 Imports: 19 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 AcquireCoordinatorWriteLeaseResponse added in v0.52.0 

type AcquireCoordinatorWriteLeaseResponse struct {

	// LeaseId identifies the remote lease for later lease operations.
	LeaseId string `protobuf:"bytes,1,opt,name=lease_id,json=leaseId,proto3" json:"leaseId,omitempty"`
	// Acquired is false when a try-acquire request found the lease busy.
	Acquired bool `protobuf:"varint,2,opt,name=acquired,proto3" json:"acquired,omitempty"`
	// contains filtered or unexported fields
}

AcquireCoordinatorWriteLeaseResponse is returned by lease acquisition.

func (*AcquireCoordinatorWriteLeaseResponse) CloneMessageVT added in v0.52.0 

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

func (*AcquireCoordinatorWriteLeaseResponse) CloneVT added in v0.52.0 

func (m *AcquireCoordinatorWriteLeaseResponse) CloneVT() *AcquireCoordinatorWriteLeaseResponse

func (*AcquireCoordinatorWriteLeaseResponse) EqualMessageVT added in v0.52.0 

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

func (*AcquireCoordinatorWriteLeaseResponse) EqualVT added in v0.52.0 

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

func (*AcquireCoordinatorWriteLeaseResponse) GetAcquired added in v0.52.0 

func (x *AcquireCoordinatorWriteLeaseResponse) GetAcquired() bool

func (*AcquireCoordinatorWriteLeaseResponse) GetLeaseId added in v0.52.0 

func (x *AcquireCoordinatorWriteLeaseResponse) GetLeaseId() string

func (*AcquireCoordinatorWriteLeaseResponse) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the AcquireCoordinatorWriteLeaseResponse to JSON.

func (*AcquireCoordinatorWriteLeaseResponse) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the AcquireCoordinatorWriteLeaseResponse message to JSON.

func (*AcquireCoordinatorWriteLeaseResponse) MarshalProtoText added in v0.52.0 

func (x *AcquireCoordinatorWriteLeaseResponse) MarshalProtoText() string

func (*AcquireCoordinatorWriteLeaseResponse) MarshalToSizedBufferVT added in v0.52.0 

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

func (*AcquireCoordinatorWriteLeaseResponse) MarshalToVT added in v0.52.0 

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

func (*AcquireCoordinatorWriteLeaseResponse) MarshalVT added in v0.52.0 

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

func (*AcquireCoordinatorWriteLeaseResponse) ProtoMessage added in v0.52.0 

func (*AcquireCoordinatorWriteLeaseResponse) ProtoMessage()

func (*AcquireCoordinatorWriteLeaseResponse) Reset added in v0.52.0 

func (x *AcquireCoordinatorWriteLeaseResponse) Reset()

func (*AcquireCoordinatorWriteLeaseResponse) SizeVT added in v0.52.0 

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

func (*AcquireCoordinatorWriteLeaseResponse) String added in v0.52.0 

func (x *AcquireCoordinatorWriteLeaseResponse) String() string

func (*AcquireCoordinatorWriteLeaseResponse) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the AcquireCoordinatorWriteLeaseResponse from JSON.

func (*AcquireCoordinatorWriteLeaseResponse) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the AcquireCoordinatorWriteLeaseResponse message from JSON.

func (*AcquireCoordinatorWriteLeaseResponse) UnmarshalVT added in v0.52.0 

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

type CoordinatorCapability added in v0.52.0 

type CoordinatorCapability struct {

	// Supported is true when direct coordination is available.
	Supported bool `protobuf:"varint,1,opt,name=supported,proto3" json:"supported,omitempty"`
	// Backend identifies the backend that would coordinate the scope.
	Backend string `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`
	// VolumeId is the owning Volume id.
	VolumeId string `protobuf:"bytes,3,opt,name=volume_id,json=volumeId,proto3" json:"volumeId,omitempty"`
	// ObjectStoreId is the ObjectStore id inside the Volume.
	ObjectStoreId string `protobuf:"bytes,4,opt,name=object_store_id,json=objectStoreId,proto3" json:"objectStoreId,omitempty"`
	// Generation is the latest durable generation observed by the coordinator.
	Generation uint64 `protobuf:"varint,5,opt,name=generation,proto3" json:"generation,omitempty"`
	// FallbackReason explains why Supported is false.
	FallbackReason string `protobuf:"bytes,6,opt,name=fallback_reason,json=fallbackReason,proto3" json:"fallbackReason,omitempty"`
	// contains filtered or unexported fields
}

CoordinatorCapability describes direct coordination support for a scoped ObjectStore.

func NewCoordinatorCapability added in v0.52.0 

func NewCoordinatorCapability(cap *coord.Capability) *CoordinatorCapability

NewCoordinatorCapability converts a coordination capability to its RPC form.

func (*CoordinatorCapability) CloneMessageVT added in v0.52.0 

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

func (*CoordinatorCapability) CloneVT added in v0.52.0 

func (m *CoordinatorCapability) CloneVT() *CoordinatorCapability

func (*CoordinatorCapability) EqualMessageVT added in v0.52.0 

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

func (*CoordinatorCapability) EqualVT added in v0.52.0 

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

func (*CoordinatorCapability) GetBackend added in v0.52.0 

func (x *CoordinatorCapability) GetBackend() string

func (*CoordinatorCapability) GetFallbackReason added in v0.52.0 

func (x *CoordinatorCapability) GetFallbackReason() string

func (*CoordinatorCapability) GetGeneration added in v0.52.0 

func (x *CoordinatorCapability) GetGeneration() uint64

func (*CoordinatorCapability) GetObjectStoreId added in v0.52.0 

func (x *CoordinatorCapability) GetObjectStoreId() string

func (*CoordinatorCapability) GetSupported added in v0.52.0 

func (x *CoordinatorCapability) GetSupported() bool

func (*CoordinatorCapability) GetVolumeId added in v0.52.0 

func (x *CoordinatorCapability) GetVolumeId() string

func (*CoordinatorCapability) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the CoordinatorCapability to JSON.

func (*CoordinatorCapability) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the CoordinatorCapability message to JSON.

func (*CoordinatorCapability) MarshalProtoText added in v0.52.0 

func (x *CoordinatorCapability) MarshalProtoText() string

func (*CoordinatorCapability) MarshalToSizedBufferVT added in v0.52.0 

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

func (*CoordinatorCapability) MarshalToVT added in v0.52.0 

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

func (*CoordinatorCapability) MarshalVT added in v0.52.0 

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

func (*CoordinatorCapability) ProtoMessage added in v0.52.0 

func (*CoordinatorCapability) ProtoMessage()

func (*CoordinatorCapability) Reset added in v0.52.0 

func (x *CoordinatorCapability) Reset()

func (*CoordinatorCapability) SizeVT added in v0.52.0 

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

func (*CoordinatorCapability) String added in v0.52.0 

func (x *CoordinatorCapability) String() string

func (*CoordinatorCapability) ToCoordCapability added in v0.52.0 

func (x *CoordinatorCapability) ToCoordCapability() *coord.Capability

ToCoordCapability converts the RPC coordination capability to its local form.

func (*CoordinatorCapability) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the CoordinatorCapability from JSON.

func (*CoordinatorCapability) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the CoordinatorCapability message from JSON.

func (*CoordinatorCapability) UnmarshalVT added in v0.52.0 

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

type CoordinatorEvent added in v0.52.0 

type CoordinatorEvent struct {

	// ProcessId identifies the process that produced or requested the event.
	ProcessId string `protobuf:"bytes,1,opt,name=process_id,json=processId,proto3" json:"processId,omitempty"`
	// VolumeId is the owning Volume id.
	VolumeId string `protobuf:"bytes,2,opt,name=volume_id,json=volumeId,proto3" json:"volumeId,omitempty"`
	// ObjectStoreId is the ObjectStore id inside the Volume.
	ObjectStoreId string `protobuf:"bytes,3,opt,name=object_store_id,json=objectStoreId,proto3" json:"objectStoreId,omitempty"`
	// Generation is the durable generation associated with this event.
	Generation uint64 `protobuf:"varint,4,opt,name=generation,proto3" json:"generation,omitempty"`
	// WantLock is true when another participant is waiting for the write lease.
	WantLock bool `protobuf:"varint,5,opt,name=want_lock,json=wantLock,proto3" json:"wantLock,omitempty"`
	// Unlocked is true when a participant released the write lease.
	Unlocked bool `protobuf:"varint,6,opt,name=unlocked,proto3" json:"unlocked,omitempty"`
	// RootChanged carries the accepted root after a commit.
	RootChanged *bucket.ObjectRef `protobuf:"bytes,7,opt,name=root_changed,json=rootChanged,proto3" json:"rootChanged,omitempty"`
	// KeyPrefixChanged carries a key prefix invalidated by a commit.
	KeyPrefixChanged []byte `protobuf:"bytes,8,opt,name=key_prefix_changed,json=keyPrefixChanged,proto3" json:"keyPrefixChanged,omitempty"`
	// FallbackReason carries a visible fallback reason when direct coordination fails.
	FallbackReason string `protobuf:"bytes,9,opt,name=fallback_reason,json=fallbackReason,proto3" json:"fallbackReason,omitempty"`
	// contains filtered or unexported fields
}

CoordinatorEvent reports a coordination state change for a scoped ObjectStore.

func NewCoordinatorEvent added in v0.52.0 

func NewCoordinatorEvent(event coord.Event) *CoordinatorEvent

NewCoordinatorEvent converts a coordination event to its RPC form.

func (*CoordinatorEvent) CloneMessageVT added in v0.52.0 

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

func (*CoordinatorEvent) CloneVT added in v0.52.0 

func (m *CoordinatorEvent) CloneVT() *CoordinatorEvent

func (*CoordinatorEvent) EqualMessageVT added in v0.52.0 

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

func (*CoordinatorEvent) EqualVT added in v0.52.0 

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

func (*CoordinatorEvent) GetFallbackReason added in v0.52.0 

func (x *CoordinatorEvent) GetFallbackReason() string

func (*CoordinatorEvent) GetGeneration added in v0.52.0 

func (x *CoordinatorEvent) GetGeneration() uint64

func (*CoordinatorEvent) GetKeyPrefixChanged added in v0.52.0 

func (x *CoordinatorEvent) GetKeyPrefixChanged() []byte

func (*CoordinatorEvent) GetObjectStoreId added in v0.52.0 

func (x *CoordinatorEvent) GetObjectStoreId() string

func (*CoordinatorEvent) GetProcessId added in v0.52.0 

func (x *CoordinatorEvent) GetProcessId() string

func (*CoordinatorEvent) GetRootChanged added in v0.52.0 

func (x *CoordinatorEvent) GetRootChanged() *bucket.ObjectRef

func (*CoordinatorEvent) GetUnlocked added in v0.52.0 

func (x *CoordinatorEvent) GetUnlocked() bool

func (*CoordinatorEvent) GetVolumeId added in v0.52.0 

func (x *CoordinatorEvent) GetVolumeId() string

func (*CoordinatorEvent) GetWantLock added in v0.52.0 

func (x *CoordinatorEvent) GetWantLock() bool

func (*CoordinatorEvent) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the CoordinatorEvent to JSON.

func (*CoordinatorEvent) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the CoordinatorEvent message to JSON.

func (*CoordinatorEvent) MarshalProtoText added in v0.52.0 

func (x *CoordinatorEvent) MarshalProtoText() string

func (*CoordinatorEvent) MarshalToSizedBufferVT added in v0.52.0 

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

func (*CoordinatorEvent) MarshalToVT added in v0.52.0 

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

func (*CoordinatorEvent) MarshalVT added in v0.52.0 

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

func (*CoordinatorEvent) ProtoMessage added in v0.52.0 

func (*CoordinatorEvent) ProtoMessage()

func (*CoordinatorEvent) Reset added in v0.52.0 

func (x *CoordinatorEvent) Reset()

func (*CoordinatorEvent) SizeVT added in v0.52.0 

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

func (*CoordinatorEvent) String added in v0.52.0 

func (x *CoordinatorEvent) String() string

func (*CoordinatorEvent) ToCoordEvent added in v0.52.0 

func (x *CoordinatorEvent) ToCoordEvent() coord.Event

ToCoordEvent converts the RPC coordination event to its local form.

func (*CoordinatorEvent) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the CoordinatorEvent from JSON.

func (*CoordinatorEvent) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the CoordinatorEvent message from JSON.

func (*CoordinatorEvent) UnmarshalVT added in v0.52.0 

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

type CoordinatorScope added in v0.52.0 

type CoordinatorScope struct {

	// VolumeId is the owning Volume id.
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volumeId,omitempty"`
	// ObjectStoreId is the ObjectStore id inside the Volume.
	ObjectStoreId string `protobuf:"bytes,2,opt,name=object_store_id,json=objectStoreId,proto3" json:"objectStoreId,omitempty"`
	// ParticipantId identifies the process or handle performing the operation.
	ParticipantId string `protobuf:"bytes,3,opt,name=participant_id,json=participantId,proto3" json:"participantId,omitempty"`
	// contains filtered or unexported fields
}

CoordinatorScope identifies a coordinated ObjectStore inside a Volume.

func NewCoordinatorScope added in v0.52.0 

func NewCoordinatorScope(scope coord.Scope) *CoordinatorScope

NewCoordinatorScope converts a coordination scope to its RPC form.

func (*CoordinatorScope) CloneMessageVT added in v0.52.0 

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

func (*CoordinatorScope) CloneVT added in v0.52.0 

func (m *CoordinatorScope) CloneVT() *CoordinatorScope

func (*CoordinatorScope) EqualMessageVT added in v0.52.0 

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

func (*CoordinatorScope) EqualVT added in v0.52.0 

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

func (*CoordinatorScope) GetObjectStoreId added in v0.52.0 

func (x *CoordinatorScope) GetObjectStoreId() string

func (*CoordinatorScope) GetParticipantId added in v0.52.0 

func (x *CoordinatorScope) GetParticipantId() string

func (*CoordinatorScope) GetVolumeId added in v0.52.0 

func (x *CoordinatorScope) GetVolumeId() string

func (*CoordinatorScope) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the CoordinatorScope to JSON.

func (*CoordinatorScope) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the CoordinatorScope message to JSON.

func (*CoordinatorScope) MarshalProtoText added in v0.52.0 

func (x *CoordinatorScope) MarshalProtoText() string

func (*CoordinatorScope) MarshalToSizedBufferVT added in v0.52.0 

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

func (*CoordinatorScope) MarshalToVT added in v0.52.0 

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

func (*CoordinatorScope) MarshalVT added in v0.52.0 

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

func (*CoordinatorScope) ProtoMessage added in v0.52.0 

func (*CoordinatorScope) ProtoMessage()

func (*CoordinatorScope) Reset added in v0.52.0 

func (x *CoordinatorScope) Reset()

func (*CoordinatorScope) SizeVT added in v0.52.0 

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

func (*CoordinatorScope) String added in v0.52.0 

func (x *CoordinatorScope) String() string

func (*CoordinatorScope) ToCoordScope added in v0.52.0 

func (x *CoordinatorScope) ToCoordScope() coord.Scope

ToCoordScope converts the RPC coordination scope to its local form.

func (*CoordinatorScope) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the CoordinatorScope from JSON.

func (*CoordinatorScope) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the CoordinatorScope message from JSON.

func (*CoordinatorScope) UnmarshalVT added in v0.52.0 

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

type CoordinatorSnapshot added in v0.52.0 

type CoordinatorSnapshot struct {

	// VolumeId is the owning Volume id.
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volumeId,omitempty"`
	// ObjectStoreId is the ObjectStore id inside the Volume.
	ObjectStoreId string `protobuf:"bytes,2,opt,name=object_store_id,json=objectStoreId,proto3" json:"objectStoreId,omitempty"`
	// Generation is the latest durable generation.
	Generation uint64 `protobuf:"varint,3,opt,name=generation,proto3" json:"generation,omitempty"`
	// Root is the latest durable ObjectStore root.
	Root *bucket.ObjectRef `protobuf:"bytes,4,opt,name=root,proto3" json:"root,omitempty"`
	// contains filtered or unexported fields
}

CoordinatorSnapshot captures the current durable coordination state.

func NewCoordinatorSnapshot added in v0.52.0 

func NewCoordinatorSnapshot(snapshot *coord.Snapshot) *CoordinatorSnapshot

NewCoordinatorSnapshot converts a coordination snapshot to its RPC form.

func (*CoordinatorSnapshot) CloneMessageVT added in v0.52.0 

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

func (*CoordinatorSnapshot) CloneVT added in v0.52.0 

func (m *CoordinatorSnapshot) CloneVT() *CoordinatorSnapshot

func (*CoordinatorSnapshot) EqualMessageVT added in v0.52.0 

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

func (*CoordinatorSnapshot) EqualVT added in v0.52.0 

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

func (*CoordinatorSnapshot) GetGeneration added in v0.52.0 

func (x *CoordinatorSnapshot) GetGeneration() uint64

func (*CoordinatorSnapshot) GetObjectStoreId added in v0.52.0 

func (x *CoordinatorSnapshot) GetObjectStoreId() string

func (*CoordinatorSnapshot) GetRoot added in v0.52.0 

func (x *CoordinatorSnapshot) GetRoot() *bucket.ObjectRef

func (*CoordinatorSnapshot) GetVolumeId added in v0.52.0 

func (x *CoordinatorSnapshot) GetVolumeId() string

func (*CoordinatorSnapshot) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the CoordinatorSnapshot to JSON.

func (*CoordinatorSnapshot) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the CoordinatorSnapshot message to JSON.

func (*CoordinatorSnapshot) MarshalProtoText added in v0.52.0 

func (x *CoordinatorSnapshot) MarshalProtoText() string

func (*CoordinatorSnapshot) MarshalToSizedBufferVT added in v0.52.0 

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

func (*CoordinatorSnapshot) MarshalToVT added in v0.52.0 

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

func (*CoordinatorSnapshot) MarshalVT added in v0.52.0 

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

func (*CoordinatorSnapshot) ProtoMessage added in v0.52.0 

func (*CoordinatorSnapshot) ProtoMessage()

func (*CoordinatorSnapshot) Reset added in v0.52.0 

func (x *CoordinatorSnapshot) Reset()

func (*CoordinatorSnapshot) SizeVT added in v0.52.0 

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

func (*CoordinatorSnapshot) String added in v0.52.0 

func (x *CoordinatorSnapshot) String() string

func (*CoordinatorSnapshot) ToCoordSnapshot added in v0.52.0 

func (x *CoordinatorSnapshot) ToCoordSnapshot() *coord.Snapshot

ToCoordSnapshot converts the RPC coordination snapshot to its local form.

func (*CoordinatorSnapshot) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the CoordinatorSnapshot from JSON.

func (*CoordinatorSnapshot) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the CoordinatorSnapshot message from JSON.

func (*CoordinatorSnapshot) UnmarshalVT added in v0.52.0 

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

type CoordinatorWriteLeaseRequest added in v0.52.0 

type CoordinatorWriteLeaseRequest struct {

	// LeaseId identifies the remote lease.
	LeaseId string `protobuf:"bytes,1,opt,name=lease_id,json=leaseId,proto3" json:"leaseId,omitempty"`
	// contains filtered or unexported fields
}

CoordinatorWriteLeaseRequest identifies a held remote write lease.

func (*CoordinatorWriteLeaseRequest) CloneMessageVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseRequest) CloneVT added in v0.52.0 

func (m *CoordinatorWriteLeaseRequest) CloneVT() *CoordinatorWriteLeaseRequest

func (*CoordinatorWriteLeaseRequest) EqualMessageVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseRequest) EqualVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseRequest) GetLeaseId added in v0.52.0 

func (x *CoordinatorWriteLeaseRequest) GetLeaseId() string

func (*CoordinatorWriteLeaseRequest) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the CoordinatorWriteLeaseRequest to JSON.

func (*CoordinatorWriteLeaseRequest) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the CoordinatorWriteLeaseRequest message to JSON.

func (*CoordinatorWriteLeaseRequest) MarshalProtoText added in v0.52.0 

func (x *CoordinatorWriteLeaseRequest) MarshalProtoText() string

func (*CoordinatorWriteLeaseRequest) MarshalToSizedBufferVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseRequest) MarshalToVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseRequest) MarshalVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseRequest) ProtoMessage added in v0.52.0 

func (*CoordinatorWriteLeaseRequest) ProtoMessage()

func (*CoordinatorWriteLeaseRequest) Reset added in v0.52.0 

func (x *CoordinatorWriteLeaseRequest) Reset()

func (*CoordinatorWriteLeaseRequest) SizeVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseRequest) String added in v0.52.0 

func (x *CoordinatorWriteLeaseRequest) String() string

func (*CoordinatorWriteLeaseRequest) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the CoordinatorWriteLeaseRequest from JSON.

func (*CoordinatorWriteLeaseRequest) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the CoordinatorWriteLeaseRequest message from JSON.

func (*CoordinatorWriteLeaseRequest) UnmarshalVT added in v0.52.0 

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

type CoordinatorWriteLeaseSnapshotResponse added in v0.52.0 

type CoordinatorWriteLeaseSnapshotResponse struct {

	// Snapshot is the current durable coordinator state.
	Snapshot *CoordinatorSnapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

CoordinatorWriteLeaseSnapshotResponse returns a lease operation snapshot.

func (*CoordinatorWriteLeaseSnapshotResponse) CloneMessageVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseSnapshotResponse) CloneVT added in v0.52.0 

func (m *CoordinatorWriteLeaseSnapshotResponse) CloneVT() *CoordinatorWriteLeaseSnapshotResponse

func (*CoordinatorWriteLeaseSnapshotResponse) EqualMessageVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseSnapshotResponse) EqualVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseSnapshotResponse) GetSnapshot added in v0.52.0 

func (x *CoordinatorWriteLeaseSnapshotResponse) GetSnapshot() *CoordinatorSnapshot

func (*CoordinatorWriteLeaseSnapshotResponse) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the CoordinatorWriteLeaseSnapshotResponse to JSON.

func (*CoordinatorWriteLeaseSnapshotResponse) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the CoordinatorWriteLeaseSnapshotResponse message to JSON.

func (*CoordinatorWriteLeaseSnapshotResponse) MarshalProtoText added in v0.52.0 

func (x *CoordinatorWriteLeaseSnapshotResponse) MarshalProtoText() string

func (*CoordinatorWriteLeaseSnapshotResponse) MarshalToSizedBufferVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseSnapshotResponse) MarshalToVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseSnapshotResponse) MarshalVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseSnapshotResponse) ProtoMessage added in v0.52.0 

func (*CoordinatorWriteLeaseSnapshotResponse) ProtoMessage()

func (*CoordinatorWriteLeaseSnapshotResponse) Reset added in v0.52.0 

func (x *CoordinatorWriteLeaseSnapshotResponse) Reset()

func (*CoordinatorWriteLeaseSnapshotResponse) SizeVT added in v0.52.0 

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

func (*CoordinatorWriteLeaseSnapshotResponse) String added in v0.52.0 

func (x *CoordinatorWriteLeaseSnapshotResponse) String() string

func (*CoordinatorWriteLeaseSnapshotResponse) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the CoordinatorWriteLeaseSnapshotResponse from JSON.

func (*CoordinatorWriteLeaseSnapshotResponse) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the CoordinatorWriteLeaseSnapshotResponse message from JSON.

func (*CoordinatorWriteLeaseSnapshotResponse) UnmarshalVT added in v0.52.0 

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

type GetCoordinatorCapabilityRequest added in v0.52.0 

type GetCoordinatorCapabilityRequest struct {

	// Scope identifies the coordinated ObjectStore.
	Scope *CoordinatorScope `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

GetCoordinatorCapabilityRequest is a request to get direct coordination support.

func (*GetCoordinatorCapabilityRequest) CloneMessageVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityRequest) CloneVT added in v0.52.0 

func (m *GetCoordinatorCapabilityRequest) CloneVT() *GetCoordinatorCapabilityRequest

func (*GetCoordinatorCapabilityRequest) EqualMessageVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityRequest) EqualVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityRequest) GetScope added in v0.52.0 

func (x *GetCoordinatorCapabilityRequest) GetScope() *CoordinatorScope

func (*GetCoordinatorCapabilityRequest) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the GetCoordinatorCapabilityRequest to JSON.

func (*GetCoordinatorCapabilityRequest) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the GetCoordinatorCapabilityRequest message to JSON.

func (*GetCoordinatorCapabilityRequest) MarshalProtoText added in v0.52.0 

func (x *GetCoordinatorCapabilityRequest) MarshalProtoText() string

func (*GetCoordinatorCapabilityRequest) MarshalToSizedBufferVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityRequest) MarshalToVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityRequest) MarshalVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityRequest) ProtoMessage added in v0.52.0 

func (*GetCoordinatorCapabilityRequest) ProtoMessage()

func (*GetCoordinatorCapabilityRequest) Reset added in v0.52.0 

func (x *GetCoordinatorCapabilityRequest) Reset()

func (*GetCoordinatorCapabilityRequest) SizeVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityRequest) String added in v0.52.0 

func (x *GetCoordinatorCapabilityRequest) String() string

func (*GetCoordinatorCapabilityRequest) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the GetCoordinatorCapabilityRequest from JSON.

func (*GetCoordinatorCapabilityRequest) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the GetCoordinatorCapabilityRequest message from JSON.

func (*GetCoordinatorCapabilityRequest) UnmarshalVT added in v0.52.0 

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

type GetCoordinatorCapabilityResponse added in v0.52.0 

type GetCoordinatorCapabilityResponse struct {

	// Capability contains the direct coordination support report.
	Capability *CoordinatorCapability `protobuf:"bytes,1,opt,name=capability,proto3" json:"capability,omitempty"`
	// contains filtered or unexported fields
}

GetCoordinatorCapabilityResponse is the response to coordinator capability negotiation.

func (*GetCoordinatorCapabilityResponse) CloneMessageVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityResponse) CloneVT added in v0.52.0 

func (m *GetCoordinatorCapabilityResponse) CloneVT() *GetCoordinatorCapabilityResponse

func (*GetCoordinatorCapabilityResponse) EqualMessageVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityResponse) EqualVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityResponse) GetCapability added in v0.52.0 

func (x *GetCoordinatorCapabilityResponse) GetCapability() *CoordinatorCapability

func (*GetCoordinatorCapabilityResponse) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the GetCoordinatorCapabilityResponse to JSON.

func (*GetCoordinatorCapabilityResponse) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the GetCoordinatorCapabilityResponse message to JSON.

func (*GetCoordinatorCapabilityResponse) MarshalProtoText added in v0.52.0 

func (x *GetCoordinatorCapabilityResponse) MarshalProtoText() string

func (*GetCoordinatorCapabilityResponse) MarshalToSizedBufferVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityResponse) MarshalToVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityResponse) MarshalVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityResponse) ProtoMessage added in v0.52.0 

func (*GetCoordinatorCapabilityResponse) ProtoMessage()

func (*GetCoordinatorCapabilityResponse) Reset added in v0.52.0 

func (x *GetCoordinatorCapabilityResponse) Reset()

func (*GetCoordinatorCapabilityResponse) SizeVT added in v0.52.0 

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

func (*GetCoordinatorCapabilityResponse) String added in v0.52.0 

func (x *GetCoordinatorCapabilityResponse) String() string

func (*GetCoordinatorCapabilityResponse) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the GetCoordinatorCapabilityResponse from JSON.

func (*GetCoordinatorCapabilityResponse) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the GetCoordinatorCapabilityResponse message from JSON.

func (*GetCoordinatorCapabilityResponse) UnmarshalVT added in v0.52.0 

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

type GetCoordinatorSnapshotRequest added in v0.52.0 

type GetCoordinatorSnapshotRequest struct {

	// Scope identifies the coordinated ObjectStore.
	Scope *CoordinatorScope `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

GetCoordinatorSnapshotRequest is a request to get a coordinator snapshot.

func (*GetCoordinatorSnapshotRequest) CloneMessageVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotRequest) CloneVT added in v0.52.0 

func (m *GetCoordinatorSnapshotRequest) CloneVT() *GetCoordinatorSnapshotRequest

func (*GetCoordinatorSnapshotRequest) EqualMessageVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotRequest) EqualVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotRequest) GetScope added in v0.52.0 

func (x *GetCoordinatorSnapshotRequest) GetScope() *CoordinatorScope

func (*GetCoordinatorSnapshotRequest) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the GetCoordinatorSnapshotRequest to JSON.

func (*GetCoordinatorSnapshotRequest) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the GetCoordinatorSnapshotRequest message to JSON.

func (*GetCoordinatorSnapshotRequest) MarshalProtoText added in v0.52.0 

func (x *GetCoordinatorSnapshotRequest) MarshalProtoText() string

func (*GetCoordinatorSnapshotRequest) MarshalToSizedBufferVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotRequest) MarshalToVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotRequest) MarshalVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotRequest) ProtoMessage added in v0.52.0 

func (*GetCoordinatorSnapshotRequest) ProtoMessage()

func (*GetCoordinatorSnapshotRequest) Reset added in v0.52.0 

func (x *GetCoordinatorSnapshotRequest) Reset()

func (*GetCoordinatorSnapshotRequest) SizeVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotRequest) String added in v0.52.0 

func (x *GetCoordinatorSnapshotRequest) String() string

func (*GetCoordinatorSnapshotRequest) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the GetCoordinatorSnapshotRequest from JSON.

func (*GetCoordinatorSnapshotRequest) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the GetCoordinatorSnapshotRequest message from JSON.

func (*GetCoordinatorSnapshotRequest) UnmarshalVT added in v0.52.0 

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

type GetCoordinatorSnapshotResponse added in v0.52.0 

type GetCoordinatorSnapshotResponse struct {

	// Snapshot is the current durable coordinator state.
	Snapshot *CoordinatorSnapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

GetCoordinatorSnapshotResponse is a coordinator snapshot response.

func (*GetCoordinatorSnapshotResponse) CloneMessageVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotResponse) CloneVT added in v0.52.0 

func (m *GetCoordinatorSnapshotResponse) CloneVT() *GetCoordinatorSnapshotResponse

func (*GetCoordinatorSnapshotResponse) EqualMessageVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotResponse) EqualVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotResponse) GetSnapshot added in v0.52.0 

func (x *GetCoordinatorSnapshotResponse) GetSnapshot() *CoordinatorSnapshot

func (*GetCoordinatorSnapshotResponse) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the GetCoordinatorSnapshotResponse to JSON.

func (*GetCoordinatorSnapshotResponse) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the GetCoordinatorSnapshotResponse message to JSON.

func (*GetCoordinatorSnapshotResponse) MarshalProtoText added in v0.52.0 

func (x *GetCoordinatorSnapshotResponse) MarshalProtoText() string

func (*GetCoordinatorSnapshotResponse) MarshalToSizedBufferVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotResponse) MarshalToVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotResponse) MarshalVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotResponse) ProtoMessage added in v0.52.0 

func (*GetCoordinatorSnapshotResponse) ProtoMessage()

func (*GetCoordinatorSnapshotResponse) Reset added in v0.52.0 

func (x *GetCoordinatorSnapshotResponse) Reset()

func (*GetCoordinatorSnapshotResponse) SizeVT added in v0.52.0 

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

func (*GetCoordinatorSnapshotResponse) String added in v0.52.0 

func (x *GetCoordinatorSnapshotResponse) String() string

func (*GetCoordinatorSnapshotResponse) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the GetCoordinatorSnapshotResponse from JSON.

func (*GetCoordinatorSnapshotResponse) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the GetCoordinatorSnapshotResponse message from JSON.

func (*GetCoordinatorSnapshotResponse) UnmarshalVT added in v0.52.0 

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

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 PublishCoordinatorWriteLeaseRequest added in v0.52.0 

type PublishCoordinatorWriteLeaseRequest struct {

	// LeaseId identifies the remote lease.
	LeaseId string `protobuf:"bytes,1,opt,name=lease_id,json=leaseId,proto3" json:"leaseId,omitempty"`
	// Event is the accepted coordination event.
	Event *CoordinatorEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

PublishCoordinatorWriteLeaseRequest publishes through a held remote lease.

func (*PublishCoordinatorWriteLeaseRequest) CloneMessageVT added in v0.52.0 

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

func (*PublishCoordinatorWriteLeaseRequest) CloneVT added in v0.52.0 

func (m *PublishCoordinatorWriteLeaseRequest) CloneVT() *PublishCoordinatorWriteLeaseRequest

func (*PublishCoordinatorWriteLeaseRequest) EqualMessageVT added in v0.52.0 

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

func (*PublishCoordinatorWriteLeaseRequest) EqualVT added in v0.52.0 

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

func (*PublishCoordinatorWriteLeaseRequest) GetEvent added in v0.52.0 

func (x *PublishCoordinatorWriteLeaseRequest) GetEvent() *CoordinatorEvent

func (*PublishCoordinatorWriteLeaseRequest) GetLeaseId added in v0.52.0 

func (x *PublishCoordinatorWriteLeaseRequest) GetLeaseId() string

func (*PublishCoordinatorWriteLeaseRequest) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the PublishCoordinatorWriteLeaseRequest to JSON.

func (*PublishCoordinatorWriteLeaseRequest) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the PublishCoordinatorWriteLeaseRequest message to JSON.

func (*PublishCoordinatorWriteLeaseRequest) MarshalProtoText added in v0.52.0 

func (x *PublishCoordinatorWriteLeaseRequest) MarshalProtoText() string

func (*PublishCoordinatorWriteLeaseRequest) MarshalToSizedBufferVT added in v0.52.0 

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

func (*PublishCoordinatorWriteLeaseRequest) MarshalToVT added in v0.52.0 

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

func (*PublishCoordinatorWriteLeaseRequest) MarshalVT added in v0.52.0 

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

func (*PublishCoordinatorWriteLeaseRequest) ProtoMessage added in v0.52.0 

func (*PublishCoordinatorWriteLeaseRequest) ProtoMessage()

func (*PublishCoordinatorWriteLeaseRequest) Reset added in v0.52.0 

func (x *PublishCoordinatorWriteLeaseRequest) Reset()

func (*PublishCoordinatorWriteLeaseRequest) SizeVT added in v0.52.0 

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

func (*PublishCoordinatorWriteLeaseRequest) String added in v0.52.0 

func (x *PublishCoordinatorWriteLeaseRequest) String() string

func (*PublishCoordinatorWriteLeaseRequest) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the PublishCoordinatorWriteLeaseRequest from JSON.

func (*PublishCoordinatorWriteLeaseRequest) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the PublishCoordinatorWriteLeaseRequest message from JSON.

func (*PublishCoordinatorWriteLeaseRequest) UnmarshalVT added in v0.52.0 

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

type ReleaseCoordinatorWriteLeaseResponse added in v0.52.0 

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

ReleaseCoordinatorWriteLeaseResponse is returned after releasing a lease.

func (*ReleaseCoordinatorWriteLeaseResponse) CloneMessageVT added in v0.52.0 

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

func (*ReleaseCoordinatorWriteLeaseResponse) CloneVT added in v0.52.0 

func (m *ReleaseCoordinatorWriteLeaseResponse) CloneVT() *ReleaseCoordinatorWriteLeaseResponse

func (*ReleaseCoordinatorWriteLeaseResponse) EqualMessageVT added in v0.52.0 

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

func (*ReleaseCoordinatorWriteLeaseResponse) EqualVT added in v0.52.0 

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

func (*ReleaseCoordinatorWriteLeaseResponse) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the ReleaseCoordinatorWriteLeaseResponse to JSON.

func (*ReleaseCoordinatorWriteLeaseResponse) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the ReleaseCoordinatorWriteLeaseResponse message to JSON.

func (*ReleaseCoordinatorWriteLeaseResponse) MarshalProtoText added in v0.52.0 

func (x *ReleaseCoordinatorWriteLeaseResponse) MarshalProtoText() string

func (*ReleaseCoordinatorWriteLeaseResponse) MarshalToSizedBufferVT added in v0.52.0 

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

func (*ReleaseCoordinatorWriteLeaseResponse) MarshalToVT added in v0.52.0 

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

func (*ReleaseCoordinatorWriteLeaseResponse) MarshalVT added in v0.52.0 

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

func (*ReleaseCoordinatorWriteLeaseResponse) ProtoMessage added in v0.52.0 

func (*ReleaseCoordinatorWriteLeaseResponse) ProtoMessage()

func (*ReleaseCoordinatorWriteLeaseResponse) Reset added in v0.52.0 

func (x *ReleaseCoordinatorWriteLeaseResponse) Reset()

func (*ReleaseCoordinatorWriteLeaseResponse) SizeVT added in v0.52.0 

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

func (*ReleaseCoordinatorWriteLeaseResponse) String added in v0.52.0 

func (x *ReleaseCoordinatorWriteLeaseResponse) String() string

func (*ReleaseCoordinatorWriteLeaseResponse) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the ReleaseCoordinatorWriteLeaseResponse from JSON.

func (*ReleaseCoordinatorWriteLeaseResponse) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the ReleaseCoordinatorWriteLeaseResponse message from JSON.

func (*ReleaseCoordinatorWriteLeaseResponse) UnmarshalVT added in v0.52.0 

func (m *ReleaseCoordinatorWriteLeaseResponse) 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)
	// GetCoordinatorCapability reports direct coordination support for a scoped ObjectStore.
	GetCoordinatorCapability(ctx context.Context, in *GetCoordinatorCapabilityRequest) (*GetCoordinatorCapabilityResponse, error)
	// WatchCoordinatorEvents streams coordination events for a scoped ObjectStore.
	WatchCoordinatorEvents(ctx context.Context, in *WatchCoordinatorEventsRequest) (SRPCProxyVolume_WatchCoordinatorEventsClient, error)
	// GetCoordinatorSnapshot returns the current remote coordinator snapshot.
	GetCoordinatorSnapshot(ctx context.Context, in *GetCoordinatorSnapshotRequest) (*GetCoordinatorSnapshotResponse, error)
	// TryAcquireCoordinatorWriteLease attempts to acquire the remote write lease.
	TryAcquireCoordinatorWriteLease(ctx context.Context, in *TryAcquireCoordinatorWriteLeaseRequest) (SRPCProxyVolume_TryAcquireCoordinatorWriteLeaseClient, error)
	// WaitAcquireCoordinatorWriteLease waits for the remote write lease.
	WaitAcquireCoordinatorWriteLease(ctx context.Context, in *WaitAcquireCoordinatorWriteLeaseRequest) (SRPCProxyVolume_WaitAcquireCoordinatorWriteLeaseClient, error)
	// RefreshCoordinatorWriteLease refreshes a remote write lease.
	RefreshCoordinatorWriteLease(ctx context.Context, in *CoordinatorWriteLeaseRequest) (*CoordinatorWriteLeaseSnapshotResponse, error)
	// PublishCoordinatorWriteLease publishes a remote write lease event.
	PublishCoordinatorWriteLease(ctx context.Context, in *PublishCoordinatorWriteLeaseRequest) (*CoordinatorWriteLeaseSnapshotResponse, error)
	// ReleaseCoordinatorWriteLease releases a remote write lease.
	ReleaseCoordinatorWriteLease(ctx context.Context, in *CoordinatorWriteLeaseRequest) (*ReleaseCoordinatorWriteLeaseResponse, 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_GetCoordinatorCapability added in v0.52.0 

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

func (SRPCProxyVolumeHandler) InvokeMethod_GetCoordinatorSnapshot added in v0.52.0 

func (SRPCProxyVolumeHandler) InvokeMethod_GetCoordinatorSnapshot(impl SRPCProxyVolumeServer, strm srpc.Stream) 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

func (SRPCProxyVolumeHandler) InvokeMethod_PublishCoordinatorWriteLease added in v0.52.0 

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

func (SRPCProxyVolumeHandler) InvokeMethod_RefreshCoordinatorWriteLease added in v0.52.0 

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

func (SRPCProxyVolumeHandler) InvokeMethod_ReleaseCoordinatorWriteLease added in v0.52.0 

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

func (SRPCProxyVolumeHandler) InvokeMethod_TryAcquireCoordinatorWriteLease added in v0.52.0 

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

func (SRPCProxyVolumeHandler) InvokeMethod_WaitAcquireCoordinatorWriteLease added in v0.52.0 

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

func (SRPCProxyVolumeHandler) InvokeMethod_WatchCoordinatorEvents added in v0.52.0 

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

type SRPCProxyVolumeServer 

type SRPCProxyVolumeServer interface {
	// GetVolumeInfo returns the basic volume information.
	GetVolumeInfo(context.Context, *GetVolumeInfoRequest) (*GetVolumeInfoResponse, error)
	// GetCoordinatorCapability reports direct coordination support for a scoped ObjectStore.
	GetCoordinatorCapability(context.Context, *GetCoordinatorCapabilityRequest) (*GetCoordinatorCapabilityResponse, error)
	// WatchCoordinatorEvents streams coordination events for a scoped ObjectStore.
	WatchCoordinatorEvents(*WatchCoordinatorEventsRequest, SRPCProxyVolume_WatchCoordinatorEventsStream) error
	// GetCoordinatorSnapshot returns the current remote coordinator snapshot.
	GetCoordinatorSnapshot(context.Context, *GetCoordinatorSnapshotRequest) (*GetCoordinatorSnapshotResponse, error)
	// TryAcquireCoordinatorWriteLease attempts to acquire the remote write lease.
	TryAcquireCoordinatorWriteLease(*TryAcquireCoordinatorWriteLeaseRequest, SRPCProxyVolume_TryAcquireCoordinatorWriteLeaseStream) error
	// WaitAcquireCoordinatorWriteLease waits for the remote write lease.
	WaitAcquireCoordinatorWriteLease(*WaitAcquireCoordinatorWriteLeaseRequest, SRPCProxyVolume_WaitAcquireCoordinatorWriteLeaseStream) error
	// RefreshCoordinatorWriteLease refreshes a remote write lease.
	RefreshCoordinatorWriteLease(context.Context, *CoordinatorWriteLeaseRequest) (*CoordinatorWriteLeaseSnapshotResponse, error)
	// PublishCoordinatorWriteLease publishes a remote write lease event.
	PublishCoordinatorWriteLease(context.Context, *PublishCoordinatorWriteLeaseRequest) (*CoordinatorWriteLeaseSnapshotResponse, error)
	// ReleaseCoordinatorWriteLease releases a remote write lease.
	ReleaseCoordinatorWriteLease(context.Context, *CoordinatorWriteLeaseRequest) (*ReleaseCoordinatorWriteLeaseResponse, 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_GetCoordinatorCapabilityStream added in v0.52.0 

type SRPCProxyVolume_GetCoordinatorCapabilityStream interface {
	srpc.Stream
}

type SRPCProxyVolume_GetCoordinatorSnapshotStream added in v0.52.0 

type SRPCProxyVolume_GetCoordinatorSnapshotStream interface {
	srpc.Stream
}

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 SRPCProxyVolume_PublishCoordinatorWriteLeaseStream added in v0.52.0 

type SRPCProxyVolume_PublishCoordinatorWriteLeaseStream interface {
	srpc.Stream
}

type SRPCProxyVolume_RefreshCoordinatorWriteLeaseStream added in v0.52.0 

type SRPCProxyVolume_RefreshCoordinatorWriteLeaseStream interface {
	srpc.Stream
}

type SRPCProxyVolume_ReleaseCoordinatorWriteLeaseStream added in v0.52.0 

type SRPCProxyVolume_ReleaseCoordinatorWriteLeaseStream interface {
	srpc.Stream
}

type SRPCProxyVolume_TryAcquireCoordinatorWriteLeaseClient added in v0.52.0 

type SRPCProxyVolume_TryAcquireCoordinatorWriteLeaseClient interface {
	srpc.Stream
	Recv() (*AcquireCoordinatorWriteLeaseResponse, error)
	RecvTo(*AcquireCoordinatorWriteLeaseResponse) error
}

type SRPCProxyVolume_TryAcquireCoordinatorWriteLeaseStream added in v0.52.0 

type SRPCProxyVolume_TryAcquireCoordinatorWriteLeaseStream interface {
	srpc.Stream
	Send(*AcquireCoordinatorWriteLeaseResponse) error
	SendAndClose(*AcquireCoordinatorWriteLeaseResponse) error
}

type SRPCProxyVolume_WaitAcquireCoordinatorWriteLeaseClient added in v0.52.0 

type SRPCProxyVolume_WaitAcquireCoordinatorWriteLeaseClient interface {
	srpc.Stream
	Recv() (*AcquireCoordinatorWriteLeaseResponse, error)
	RecvTo(*AcquireCoordinatorWriteLeaseResponse) error
}

type SRPCProxyVolume_WaitAcquireCoordinatorWriteLeaseStream added in v0.52.0 

type SRPCProxyVolume_WaitAcquireCoordinatorWriteLeaseStream interface {
	srpc.Stream
	Send(*AcquireCoordinatorWriteLeaseResponse) error
	SendAndClose(*AcquireCoordinatorWriteLeaseResponse) error
}

type SRPCProxyVolume_WatchCoordinatorEventsClient added in v0.52.0 

type SRPCProxyVolume_WatchCoordinatorEventsClient interface {
	srpc.Stream
	Recv() (*WatchCoordinatorEventsResponse, error)
	RecvTo(*WatchCoordinatorEventsResponse) error
}

type SRPCProxyVolume_WatchCoordinatorEventsStream added in v0.52.0 

type SRPCProxyVolume_WatchCoordinatorEventsStream interface {
	srpc.Stream
	Send(*WatchCoordinatorEventsResponse) error
	SendAndClose(*WatchCoordinatorEventsResponse) error
}

type TryAcquireCoordinatorWriteLeaseRequest added in v0.52.0 

type TryAcquireCoordinatorWriteLeaseRequest struct {

	// Scope identifies the coordinated ObjectStore.
	Scope *CoordinatorScope `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

TryAcquireCoordinatorWriteLeaseRequest is a non-blocking lease request.

func (*TryAcquireCoordinatorWriteLeaseRequest) CloneMessageVT added in v0.52.0 

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

func (*TryAcquireCoordinatorWriteLeaseRequest) CloneVT added in v0.52.0 

func (m *TryAcquireCoordinatorWriteLeaseRequest) CloneVT() *TryAcquireCoordinatorWriteLeaseRequest

func (*TryAcquireCoordinatorWriteLeaseRequest) EqualMessageVT added in v0.52.0 

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

func (*TryAcquireCoordinatorWriteLeaseRequest) EqualVT added in v0.52.0 

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

func (*TryAcquireCoordinatorWriteLeaseRequest) GetScope added in v0.52.0 

func (x *TryAcquireCoordinatorWriteLeaseRequest) GetScope() *CoordinatorScope

func (*TryAcquireCoordinatorWriteLeaseRequest) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the TryAcquireCoordinatorWriteLeaseRequest to JSON.

func (*TryAcquireCoordinatorWriteLeaseRequest) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the TryAcquireCoordinatorWriteLeaseRequest message to JSON.

func (*TryAcquireCoordinatorWriteLeaseRequest) MarshalProtoText added in v0.52.0 

func (x *TryAcquireCoordinatorWriteLeaseRequest) MarshalProtoText() string

func (*TryAcquireCoordinatorWriteLeaseRequest) MarshalToSizedBufferVT added in v0.52.0 

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

func (*TryAcquireCoordinatorWriteLeaseRequest) MarshalToVT added in v0.52.0 

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

func (*TryAcquireCoordinatorWriteLeaseRequest) MarshalVT added in v0.52.0 

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

func (*TryAcquireCoordinatorWriteLeaseRequest) ProtoMessage added in v0.52.0 

func (*TryAcquireCoordinatorWriteLeaseRequest) ProtoMessage()

func (*TryAcquireCoordinatorWriteLeaseRequest) Reset added in v0.52.0 

func (x *TryAcquireCoordinatorWriteLeaseRequest) Reset()

func (*TryAcquireCoordinatorWriteLeaseRequest) SizeVT added in v0.52.0 

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

func (*TryAcquireCoordinatorWriteLeaseRequest) String added in v0.52.0 

func (x *TryAcquireCoordinatorWriteLeaseRequest) String() string

func (*TryAcquireCoordinatorWriteLeaseRequest) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the TryAcquireCoordinatorWriteLeaseRequest from JSON.

func (*TryAcquireCoordinatorWriteLeaseRequest) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the TryAcquireCoordinatorWriteLeaseRequest message from JSON.

func (*TryAcquireCoordinatorWriteLeaseRequest) UnmarshalVT added in v0.52.0 

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

type WaitAcquireCoordinatorWriteLeaseRequest added in v0.52.0 

type WaitAcquireCoordinatorWriteLeaseRequest struct {

	// Scope identifies the coordinated ObjectStore.
	Scope *CoordinatorScope `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

WaitAcquireCoordinatorWriteLeaseRequest is a blocking lease request.

func (*WaitAcquireCoordinatorWriteLeaseRequest) CloneMessageVT added in v0.52.0 

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

func (*WaitAcquireCoordinatorWriteLeaseRequest) CloneVT added in v0.52.0 

func (m *WaitAcquireCoordinatorWriteLeaseRequest) CloneVT() *WaitAcquireCoordinatorWriteLeaseRequest

func (*WaitAcquireCoordinatorWriteLeaseRequest) EqualMessageVT added in v0.52.0 

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

func (*WaitAcquireCoordinatorWriteLeaseRequest) EqualVT added in v0.52.0 

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

func (*WaitAcquireCoordinatorWriteLeaseRequest) GetScope added in v0.52.0 

func (x *WaitAcquireCoordinatorWriteLeaseRequest) GetScope() *CoordinatorScope

func (*WaitAcquireCoordinatorWriteLeaseRequest) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the WaitAcquireCoordinatorWriteLeaseRequest to JSON.

func (*WaitAcquireCoordinatorWriteLeaseRequest) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the WaitAcquireCoordinatorWriteLeaseRequest message to JSON.

func (*WaitAcquireCoordinatorWriteLeaseRequest) MarshalProtoText added in v0.52.0 

func (x *WaitAcquireCoordinatorWriteLeaseRequest) MarshalProtoText() string

func (*WaitAcquireCoordinatorWriteLeaseRequest) MarshalToSizedBufferVT added in v0.52.0 

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

func (*WaitAcquireCoordinatorWriteLeaseRequest) MarshalToVT added in v0.52.0 

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

func (*WaitAcquireCoordinatorWriteLeaseRequest) MarshalVT added in v0.52.0 

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

func (*WaitAcquireCoordinatorWriteLeaseRequest) ProtoMessage added in v0.52.0 

func (*WaitAcquireCoordinatorWriteLeaseRequest) ProtoMessage()

func (*WaitAcquireCoordinatorWriteLeaseRequest) Reset added in v0.52.0 

func (x *WaitAcquireCoordinatorWriteLeaseRequest) Reset()

func (*WaitAcquireCoordinatorWriteLeaseRequest) SizeVT added in v0.52.0 

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

func (*WaitAcquireCoordinatorWriteLeaseRequest) String added in v0.52.0 

func (x *WaitAcquireCoordinatorWriteLeaseRequest) String() string

func (*WaitAcquireCoordinatorWriteLeaseRequest) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the WaitAcquireCoordinatorWriteLeaseRequest from JSON.

func (*WaitAcquireCoordinatorWriteLeaseRequest) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the WaitAcquireCoordinatorWriteLeaseRequest message from JSON.

func (*WaitAcquireCoordinatorWriteLeaseRequest) UnmarshalVT added in v0.52.0 

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

type WatchCoordinatorEventsRequest added in v0.52.0 

type WatchCoordinatorEventsRequest struct {

	// Scope identifies the coordinated ObjectStore.
	Scope *CoordinatorScope `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// AfterGeneration skips events at or before this generation.
	AfterGeneration uint64 `protobuf:"varint,2,opt,name=after_generation,json=afterGeneration,proto3" json:"afterGeneration,omitempty"`
	// contains filtered or unexported fields
}

WatchCoordinatorEventsRequest is a request to stream coordination events.

func (*WatchCoordinatorEventsRequest) CloneMessageVT added in v0.52.0 

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

func (*WatchCoordinatorEventsRequest) CloneVT added in v0.52.0 

func (m *WatchCoordinatorEventsRequest) CloneVT() *WatchCoordinatorEventsRequest

func (*WatchCoordinatorEventsRequest) EqualMessageVT added in v0.52.0 

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

func (*WatchCoordinatorEventsRequest) EqualVT added in v0.52.0 

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

func (*WatchCoordinatorEventsRequest) GetAfterGeneration added in v0.52.0 

func (x *WatchCoordinatorEventsRequest) GetAfterGeneration() uint64

func (*WatchCoordinatorEventsRequest) GetScope added in v0.52.0 

func (x *WatchCoordinatorEventsRequest) GetScope() *CoordinatorScope

func (*WatchCoordinatorEventsRequest) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the WatchCoordinatorEventsRequest to JSON.

func (*WatchCoordinatorEventsRequest) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the WatchCoordinatorEventsRequest message to JSON.

func (*WatchCoordinatorEventsRequest) MarshalProtoText added in v0.52.0 

func (x *WatchCoordinatorEventsRequest) MarshalProtoText() string

func (*WatchCoordinatorEventsRequest) MarshalToSizedBufferVT added in v0.52.0 

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

func (*WatchCoordinatorEventsRequest) MarshalToVT added in v0.52.0 

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

func (*WatchCoordinatorEventsRequest) MarshalVT added in v0.52.0 

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

func (*WatchCoordinatorEventsRequest) ProtoMessage added in v0.52.0 

func (*WatchCoordinatorEventsRequest) ProtoMessage()

func (*WatchCoordinatorEventsRequest) Reset added in v0.52.0 

func (x *WatchCoordinatorEventsRequest) Reset()

func (*WatchCoordinatorEventsRequest) SizeVT added in v0.52.0 

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

func (*WatchCoordinatorEventsRequest) String added in v0.52.0 

func (x *WatchCoordinatorEventsRequest) String() string

func (*WatchCoordinatorEventsRequest) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the WatchCoordinatorEventsRequest from JSON.

func (*WatchCoordinatorEventsRequest) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the WatchCoordinatorEventsRequest message from JSON.

func (*WatchCoordinatorEventsRequest) UnmarshalVT added in v0.52.0 

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

type WatchCoordinatorEventsResponse added in v0.52.0 

type WatchCoordinatorEventsResponse struct {

	// Event contains the coordination event.
	Event *CoordinatorEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

WatchCoordinatorEventsResponse is a streamed coordination event response.

func (*WatchCoordinatorEventsResponse) CloneMessageVT added in v0.52.0 

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

func (*WatchCoordinatorEventsResponse) CloneVT added in v0.52.0 

func (m *WatchCoordinatorEventsResponse) CloneVT() *WatchCoordinatorEventsResponse

func (*WatchCoordinatorEventsResponse) EqualMessageVT added in v0.52.0 

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

func (*WatchCoordinatorEventsResponse) EqualVT added in v0.52.0 

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

func (*WatchCoordinatorEventsResponse) GetEvent added in v0.52.0 

func (x *WatchCoordinatorEventsResponse) GetEvent() *CoordinatorEvent

func (*WatchCoordinatorEventsResponse) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the WatchCoordinatorEventsResponse to JSON.

func (*WatchCoordinatorEventsResponse) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the WatchCoordinatorEventsResponse message to JSON.

func (*WatchCoordinatorEventsResponse) MarshalProtoText added in v0.52.0 

func (x *WatchCoordinatorEventsResponse) MarshalProtoText() string

func (*WatchCoordinatorEventsResponse) MarshalToSizedBufferVT added in v0.52.0 

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

func (*WatchCoordinatorEventsResponse) MarshalToVT added in v0.52.0 

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

func (*WatchCoordinatorEventsResponse) MarshalVT added in v0.52.0 

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

func (*WatchCoordinatorEventsResponse) ProtoMessage added in v0.52.0 

func (*WatchCoordinatorEventsResponse) ProtoMessage()

func (*WatchCoordinatorEventsResponse) Reset added in v0.52.0 

func (x *WatchCoordinatorEventsResponse) Reset()

func (*WatchCoordinatorEventsResponse) SizeVT added in v0.52.0 

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

func (*WatchCoordinatorEventsResponse) String added in v0.52.0 

func (x *WatchCoordinatorEventsResponse) String() string

func (*WatchCoordinatorEventsResponse) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the WatchCoordinatorEventsResponse from JSON.

func (*WatchCoordinatorEventsResponse) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the WatchCoordinatorEventsResponse message from JSON.

func (*WatchCoordinatorEventsResponse) UnmarshalVT added in v0.52.0 

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

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.