Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterSnapshotMetadataServer(s grpc.ServiceRegistrar, srv SnapshotMetadataServer)
- type BlockMetadata
- func (*BlockMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *BlockMetadata) GetByteOffset() int64
- func (x *BlockMetadata) GetSizeBytes() int64
- func (*BlockMetadata) ProtoMessage()
- func (x *BlockMetadata) ProtoReflect() protoreflect.Message
- func (x *BlockMetadata) Reset()
- func (x *BlockMetadata) String() string
- type BlockMetadataType
- func (BlockMetadataType) Descriptor() protoreflect.EnumDescriptor
- func (x BlockMetadataType) Enum() *BlockMetadataType
- func (BlockMetadataType) EnumDescriptor() ([]byte, []int)deprecated
- func (x BlockMetadataType) Number() protoreflect.EnumNumber
- func (x BlockMetadataType) String() string
- func (BlockMetadataType) Type() protoreflect.EnumType
- type GetMetadataAllocatedRequest
- func (*GetMetadataAllocatedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetMetadataAllocatedRequest) GetMaxResults() int32
- func (x *GetMetadataAllocatedRequest) GetNamespace() string
- func (x *GetMetadataAllocatedRequest) GetSecurityToken() string
- func (x *GetMetadataAllocatedRequest) GetSnapshotName() string
- func (x *GetMetadataAllocatedRequest) GetStartingOffset() int64
- func (*GetMetadataAllocatedRequest) ProtoMessage()
- func (x *GetMetadataAllocatedRequest) ProtoReflect() protoreflect.Message
- func (x *GetMetadataAllocatedRequest) Reset()
- func (x *GetMetadataAllocatedRequest) String() string
- type GetMetadataAllocatedResponse
- func (*GetMetadataAllocatedResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetMetadataAllocatedResponse) GetBlockMetadata() []*BlockMetadata
- func (x *GetMetadataAllocatedResponse) GetBlockMetadataType() BlockMetadataType
- func (x *GetMetadataAllocatedResponse) GetVolumeCapacityBytes() int64
- func (*GetMetadataAllocatedResponse) ProtoMessage()
- func (x *GetMetadataAllocatedResponse) ProtoReflect() protoreflect.Message
- func (x *GetMetadataAllocatedResponse) Reset()
- func (x *GetMetadataAllocatedResponse) String() string
- type GetMetadataDeltaRequest
- func (*GetMetadataDeltaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetMetadataDeltaRequest) GetBaseSnapshotId() string
- func (x *GetMetadataDeltaRequest) GetMaxResults() int32
- func (x *GetMetadataDeltaRequest) GetNamespace() string
- func (x *GetMetadataDeltaRequest) GetSecurityToken() string
- func (x *GetMetadataDeltaRequest) GetStartingOffset() int64
- func (x *GetMetadataDeltaRequest) GetTargetSnapshotName() string
- func (*GetMetadataDeltaRequest) ProtoMessage()
- func (x *GetMetadataDeltaRequest) ProtoReflect() protoreflect.Message
- func (x *GetMetadataDeltaRequest) Reset()
- func (x *GetMetadataDeltaRequest) String() string
- type GetMetadataDeltaResponse
- func (*GetMetadataDeltaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetMetadataDeltaResponse) GetBlockMetadata() []*BlockMetadata
- func (x *GetMetadataDeltaResponse) GetBlockMetadataType() BlockMetadataType
- func (x *GetMetadataDeltaResponse) GetVolumeCapacityBytes() int64
- func (*GetMetadataDeltaResponse) ProtoMessage()
- func (x *GetMetadataDeltaResponse) ProtoReflect() protoreflect.Message
- func (x *GetMetadataDeltaResponse) Reset()
- func (x *GetMetadataDeltaResponse) String() string
- type SnapshotMetadataClient
- type SnapshotMetadataServer
- type SnapshotMetadata_GetMetadataAllocatedClient
- type SnapshotMetadata_GetMetadataAllocatedServer
- type SnapshotMetadata_GetMetadataDeltaClient
- type SnapshotMetadata_GetMetadataDeltaServer
- type UnimplementedSnapshotMetadataServer
- type UnsafeSnapshotMetadataServer
Constants ¶
const ( SnapshotMetadata_GetMetadataAllocated_FullMethodName = "/snapshotmetadata.SnapshotMetadata/GetMetadataAllocated" SnapshotMetadata_GetMetadataDelta_FullMethodName = "/snapshotmetadata.SnapshotMetadata/GetMetadataDelta" )
Variables ¶
var ( BlockMetadataType_name = map[int32]string{ 0: "UNKNOWN", 1: "FIXED_LENGTH", 2: "VARIABLE_LENGTH", } BlockMetadataType_value = map[string]int32{ "UNKNOWN": 0, "FIXED_LENGTH": 1, "VARIABLE_LENGTH": 2, } )
Enum value maps for BlockMetadataType.
var File_schema_proto protoreflect.FileDescriptor
var SnapshotMetadata_ServiceDesc = grpc.ServiceDesc{ ServiceName: "snapshotmetadata.SnapshotMetadata", HandlerType: (*SnapshotMetadataServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "GetMetadataAllocated", Handler: _SnapshotMetadata_GetMetadataAllocated_Handler, ServerStreams: true, }, { StreamName: "GetMetadataDelta", Handler: _SnapshotMetadata_GetMetadataDelta_Handler, ServerStreams: true, }, }, Metadata: "schema.proto", }
SnapshotMetadata_ServiceDesc is the grpc.ServiceDesc for SnapshotMetadata service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSnapshotMetadataServer ¶
func RegisterSnapshotMetadataServer(s grpc.ServiceRegistrar, srv SnapshotMetadataServer)
Types ¶
type BlockMetadata ¶
type BlockMetadata struct {
// This is the zero based byte position in the volume or snapshot,
// measured from the start of the object.
// This field is REQUIRED.
ByteOffset int64 `protobuf:"varint,1,opt,name=byte_offset,json=byteOffset,proto3" json:"byte_offset,omitempty"`
// This is the size of the data range.
// size_bytes will be greater than zero.
// This field is REQUIRED.
SizeBytes int64 `protobuf:"varint,2,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
// contains filtered or unexported fields
}
BlockMetadata specifies a data range.
func (*BlockMetadata) Descriptor
deprecated
func (*BlockMetadata) Descriptor() ([]byte, []int)
Deprecated: Use BlockMetadata.ProtoReflect.Descriptor instead.
func (*BlockMetadata) GetByteOffset ¶
func (x *BlockMetadata) GetByteOffset() int64
func (*BlockMetadata) GetSizeBytes ¶
func (x *BlockMetadata) GetSizeBytes() int64
func (*BlockMetadata) ProtoMessage ¶
func (*BlockMetadata) ProtoMessage()
func (*BlockMetadata) ProtoReflect ¶
func (x *BlockMetadata) ProtoReflect() protoreflect.Message
func (*BlockMetadata) Reset ¶
func (x *BlockMetadata) Reset()
func (*BlockMetadata) String ¶
func (x *BlockMetadata) String() string
type BlockMetadataType ¶
type BlockMetadataType int32
const ( BlockMetadataType_UNKNOWN BlockMetadataType = 0 // The FIXED_LENGTH value indicates that data ranges are // returned in fixed size blocks. BlockMetadataType_FIXED_LENGTH BlockMetadataType = 1 // The VARIABLE_LENGTH value indicates that data ranges // are returned in potentially variable sized extents. BlockMetadataType_VARIABLE_LENGTH BlockMetadataType = 2 )
func (BlockMetadataType) Descriptor ¶
func (BlockMetadataType) Descriptor() protoreflect.EnumDescriptor
func (BlockMetadataType) Enum ¶
func (x BlockMetadataType) Enum() *BlockMetadataType
func (BlockMetadataType) EnumDescriptor
deprecated
func (BlockMetadataType) EnumDescriptor() ([]byte, []int)
Deprecated: Use BlockMetadataType.Descriptor instead.
func (BlockMetadataType) Number ¶
func (x BlockMetadataType) Number() protoreflect.EnumNumber
func (BlockMetadataType) String ¶
func (x BlockMetadataType) String() string
func (BlockMetadataType) Type ¶
func (BlockMetadataType) Type() protoreflect.EnumType
type GetMetadataAllocatedRequest ¶
type GetMetadataAllocatedRequest struct {
// This field specifies an audience scoped authentication token presented by client.
// This token is used to authenticate and authorize the request at server side.
// This field is REQUIRED.
SecurityToken string `protobuf:"bytes,1,opt,name=security_token,json=securityToken,proto3" json:"security_token,omitempty"`
// This field indicates the Namespace where the VolumeSnapshot exists.
// This field is REQUIRED.
Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
// This is the VolumeSnapshot object name against which changes
// are to be computed.
// This field is REQUIRED.
SnapshotName string `protobuf:"bytes,3,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
// This indicates the zero based starting byte position in the volume
// snapshot from which the result should be computed.
// It is intended to be used to continue a previously interrupted
// call.
// The client SHOULD specify this value to be the offset of the byte
// position immediately after the last byte of the last data range
// received, if continuing an interrupted operation, or zero if not.
// The sidecar will ensure that the returned response stream does not
// contain BlockMetadata tuples that end before the requested
// starting_offset: i.e. if S is the requested starting_offset, and
// B0 is block_metadata[0] of the first message in the response
// stream, then (S < B0.byte_offset + B0.size_bytes) will be true.
// This field is REQUIRED.
StartingOffset int64 `protobuf:"varint,4,opt,name=starting_offset,json=startingOffset,proto3" json:"starting_offset,omitempty"`
// This is an optional parameter, and if non-zero it specifies the
// maximum number of tuples to be returned in each
// GetMetadataAllocatedResponse message returned by the RPC stream.
// The sidecar will determine an appropriate value if 0, and is
// always free to send less than the requested value.
// This field is OPTIONAL.
MaxResults int32 `protobuf:"varint,5,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`
// contains filtered or unexported fields
}
The GetMetadataAllocatedRequest message is used to solicit metadata on the allocated blocks of a snapshot: i.e. this identifies the data ranges that have valid data as they were the target of some previous write operation on the volume.
func (*GetMetadataAllocatedRequest) Descriptor
deprecated
func (*GetMetadataAllocatedRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMetadataAllocatedRequest.ProtoReflect.Descriptor instead.
func (*GetMetadataAllocatedRequest) GetMaxResults ¶
func (x *GetMetadataAllocatedRequest) GetMaxResults() int32
func (*GetMetadataAllocatedRequest) GetNamespace ¶
func (x *GetMetadataAllocatedRequest) GetNamespace() string
func (*GetMetadataAllocatedRequest) GetSecurityToken ¶
func (x *GetMetadataAllocatedRequest) GetSecurityToken() string
func (*GetMetadataAllocatedRequest) GetSnapshotName ¶
func (x *GetMetadataAllocatedRequest) GetSnapshotName() string
func (*GetMetadataAllocatedRequest) GetStartingOffset ¶
func (x *GetMetadataAllocatedRequest) GetStartingOffset() int64
func (*GetMetadataAllocatedRequest) ProtoMessage ¶
func (*GetMetadataAllocatedRequest) ProtoMessage()
func (*GetMetadataAllocatedRequest) ProtoReflect ¶
func (x *GetMetadataAllocatedRequest) ProtoReflect() protoreflect.Message
func (*GetMetadataAllocatedRequest) Reset ¶
func (x *GetMetadataAllocatedRequest) Reset()
func (*GetMetadataAllocatedRequest) String ¶
func (x *GetMetadataAllocatedRequest) String() string
type GetMetadataAllocatedResponse ¶
type GetMetadataAllocatedResponse struct {
// This specifies the style used in the BlockMetadata sequence.
// This value must be the same in all such messages returned by
// the stream.
// If block_metadata_type is FIXED_LENGTH, then the size_bytes field
// of each message in the block_metadata list will be constant.
// This field is REQUIRED.
BlockMetadataType BlockMetadataType `` /* 155-byte string literal not displayed */
// This returns the capacity of the underlying volume in bytes.
// This value must be the same in all such messages returned by
// the stream.
// This field is REQUIRED.
VolumeCapacityBytes int64 `protobuf:"varint,2,opt,name=volume_capacity_bytes,json=volumeCapacityBytes,proto3" json:"volume_capacity_bytes,omitempty"`
// This is a list of data range tuples.
// If the value of max_results in the GetMetadataAllocatedRequest
// message is greater than zero, then the number of entries in this
// list will be less than or equal to that value.
// The sidecar will respect the value of starting_offset in the request.
// The byte_offset fields of adjacent BlockMetadata messages
// Will be strictly increasing and messages will not overlap:
// i.e. for any two BlockMetadata messages, A and B, if A is returned
// before B, then (A.byte_offset + A.size_bytes <= B.byte_offset)
// will be true.
// This will also be true if A and B are from block_metadata lists in
// different GetMetadataAllocatedResponse messages in the gRPC stream.
// This field is OPTIONAL.
BlockMetadata []*BlockMetadata `protobuf:"bytes,3,rep,name=block_metadata,json=blockMetadata,proto3" json:"block_metadata,omitempty"`
// contains filtered or unexported fields
}
GetMetadataAllocatedResponse messages are returned in a gRPC stream. Cumulatively, they provide information on the allocated data ranges in the snapshot.
func (*GetMetadataAllocatedResponse) Descriptor
deprecated
func (*GetMetadataAllocatedResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetMetadataAllocatedResponse.ProtoReflect.Descriptor instead.
func (*GetMetadataAllocatedResponse) GetBlockMetadata ¶
func (x *GetMetadataAllocatedResponse) GetBlockMetadata() []*BlockMetadata
func (*GetMetadataAllocatedResponse) GetBlockMetadataType ¶
func (x *GetMetadataAllocatedResponse) GetBlockMetadataType() BlockMetadataType
func (*GetMetadataAllocatedResponse) GetVolumeCapacityBytes ¶
func (x *GetMetadataAllocatedResponse) GetVolumeCapacityBytes() int64
func (*GetMetadataAllocatedResponse) ProtoMessage ¶
func (*GetMetadataAllocatedResponse) ProtoMessage()
func (*GetMetadataAllocatedResponse) ProtoReflect ¶
func (x *GetMetadataAllocatedResponse) ProtoReflect() protoreflect.Message
func (*GetMetadataAllocatedResponse) Reset ¶
func (x *GetMetadataAllocatedResponse) Reset()
func (*GetMetadataAllocatedResponse) String ¶
func (x *GetMetadataAllocatedResponse) String() string
type GetMetadataDeltaRequest ¶
type GetMetadataDeltaRequest struct {
// This field specifies an audience scoped authentication token presented by client.
// This token is used to authenticate and authorize the request at server side.
// This field is REQUIRED.
SecurityToken string `protobuf:"bytes,1,opt,name=security_token,json=securityToken,proto3" json:"security_token,omitempty"`
// This field indicates the Namespace where the VolumeSnapshot exists.
// This field is REQUIRED.
Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
// This is the CSI handle of the base VolumeSnapshot object against which changes
// are to be computed.
// The value is passed on blindly to the CSI driver without any verification by
// the sidecar.
// A backup application must have obtained this value from the Status.SnapshotHandle
// field of the VolumeSnapshotContent object associated with the base VolumeSnapshot
// object at some time prior to making this request.
// It is the backup application's responsibility to determine if the underlying CSI
// driver requires the base VolumeSnapshot object to exist at the time that this
// request is made, and take that into consideration in its snapshot retention policy.
// This field is REQUIRED.
BaseSnapshotId string `protobuf:"bytes,3,opt,name=base_snapshot_id,json=baseSnapshotId,proto3" json:"base_snapshot_id,omitempty"`
// This is the name of a second VolumeSnapshot in the same volume,
// created after the base snapshot.
// This field is REQUIRED.
TargetSnapshotName string `protobuf:"bytes,4,opt,name=target_snapshot_name,json=targetSnapshotName,proto3" json:"target_snapshot_name,omitempty"`
// This indicates the zero based starting byte position in the volume
// snapshot from which the result should be computed.
// It is intended to be used to continue a previously interrupted
// call.
// The client SHOULD specify this value to be the offset of the byte
// position immediately after the last byte of the last data range
// received, if continuing an interrupted operation, or zero if not.
// The sidecar will ensure that the returned response stream does not
// contain BlockMetadata tuples that end before the requested
// starting_offset: i.e. if S is the requested starting_offset, and
// B0 is block_metadata[0] of the first message in the response
// stream, then (S < B0.byte_offset + B0.size_bytes) will be true.
// This field is REQUIRED.
StartingOffset int64 `protobuf:"varint,5,opt,name=starting_offset,json=startingOffset,proto3" json:"starting_offset,omitempty"`
// This is an optional parameter, and if non-zero it specifies the
// maximum number of tuples to be returned in each
// GetMetadataDeltaResponse message returned by the RPC stream.
// The sidecar will determine an appropriate value if 0, and is
// always free to send less than the requested value.
// This field is OPTIONAL.
MaxResults int32 `protobuf:"varint,6,opt,name=max_results,json=maxResults,proto3" json:"max_results,omitempty"`
// contains filtered or unexported fields
}
The GetMetadataDeltaRequest message is used to solicit metadata on the data ranges that have changed between two snapshots of the same PersistentVolume.
func (*GetMetadataDeltaRequest) Descriptor
deprecated
func (*GetMetadataDeltaRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMetadataDeltaRequest.ProtoReflect.Descriptor instead.
func (*GetMetadataDeltaRequest) GetBaseSnapshotId ¶ added in v0.2.0
func (x *GetMetadataDeltaRequest) GetBaseSnapshotId() string
func (*GetMetadataDeltaRequest) GetMaxResults ¶
func (x *GetMetadataDeltaRequest) GetMaxResults() int32
func (*GetMetadataDeltaRequest) GetNamespace ¶
func (x *GetMetadataDeltaRequest) GetNamespace() string
func (*GetMetadataDeltaRequest) GetSecurityToken ¶
func (x *GetMetadataDeltaRequest) GetSecurityToken() string
func (*GetMetadataDeltaRequest) GetStartingOffset ¶
func (x *GetMetadataDeltaRequest) GetStartingOffset() int64
func (*GetMetadataDeltaRequest) GetTargetSnapshotName ¶
func (x *GetMetadataDeltaRequest) GetTargetSnapshotName() string
func (*GetMetadataDeltaRequest) ProtoMessage ¶
func (*GetMetadataDeltaRequest) ProtoMessage()
func (*GetMetadataDeltaRequest) ProtoReflect ¶
func (x *GetMetadataDeltaRequest) ProtoReflect() protoreflect.Message
func (*GetMetadataDeltaRequest) Reset ¶
func (x *GetMetadataDeltaRequest) Reset()
func (*GetMetadataDeltaRequest) String ¶
func (x *GetMetadataDeltaRequest) String() string
type GetMetadataDeltaResponse ¶
type GetMetadataDeltaResponse struct {
// This specifies the style used in the BlockMetadata sequence.
// This value must be the same in all such messages returned by
// the stream.
// If block_metadata_type is FIXED_LENGTH, then the size_bytes field
// of each message in the block_metadata list will be constant.
// This field is REQUIRED.
BlockMetadataType BlockMetadataType `` /* 155-byte string literal not displayed */
// This returns the capacity of the underlying volume in bytes.
// This value must be the same in all such messages returned by
// the stream.
// This field is REQUIRED.
VolumeCapacityBytes int64 `protobuf:"varint,2,opt,name=volume_capacity_bytes,json=volumeCapacityBytes,proto3" json:"volume_capacity_bytes,omitempty"`
// This is a list of data range tuples.
// If the value of max_results in the GetMetadataDeltaRequest message
// is greater than zero, then the number of entries in this list will
// be less than or equal to that value.
// The sidecar will respect the value of starting_offset in the request.
// The byte_offset fields of adjacent BlockMetadata messages
// Will be strictly increasing and messages will not overlap:
// i.e. for any two BlockMetadata messages, A and B, if A is returned
// before B, then (A.byte_offset + A.size_bytes <= B.byte_offset)
// will be true.
// This will also be true if A and B are from block_metadata lists in
// different GetMetadataDeltaResponse messages in the gRPC stream.
// This field is OPTIONAL.
BlockMetadata []*BlockMetadata `protobuf:"bytes,3,rep,name=block_metadata,json=blockMetadata,proto3" json:"block_metadata,omitempty"`
// contains filtered or unexported fields
}
GetMetadataDeltaResponse messages are returned in a gRPC stream. Cumulatively, they provide information on the data ranges that have changed between the base and target snapshots specified in the GetMetadataDeltaRequest message.
func (*GetMetadataDeltaResponse) Descriptor
deprecated
func (*GetMetadataDeltaResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetMetadataDeltaResponse.ProtoReflect.Descriptor instead.
func (*GetMetadataDeltaResponse) GetBlockMetadata ¶
func (x *GetMetadataDeltaResponse) GetBlockMetadata() []*BlockMetadata
func (*GetMetadataDeltaResponse) GetBlockMetadataType ¶
func (x *GetMetadataDeltaResponse) GetBlockMetadataType() BlockMetadataType
func (*GetMetadataDeltaResponse) GetVolumeCapacityBytes ¶
func (x *GetMetadataDeltaResponse) GetVolumeCapacityBytes() int64
func (*GetMetadataDeltaResponse) ProtoMessage ¶
func (*GetMetadataDeltaResponse) ProtoMessage()
func (*GetMetadataDeltaResponse) ProtoReflect ¶
func (x *GetMetadataDeltaResponse) ProtoReflect() protoreflect.Message
func (*GetMetadataDeltaResponse) Reset ¶
func (x *GetMetadataDeltaResponse) Reset()
func (*GetMetadataDeltaResponse) String ¶
func (x *GetMetadataDeltaResponse) String() string
type SnapshotMetadataClient ¶
type SnapshotMetadataClient interface {
GetMetadataAllocated(ctx context.Context, in *GetMetadataAllocatedRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetMetadataAllocatedResponse], error)
GetMetadataDelta(ctx context.Context, in *GetMetadataDeltaRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetMetadataDeltaResponse], error)
}
SnapshotMetadataClient is the client API for SnapshotMetadata service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
The Kubernetes SnapshotMetadata API is very similar to the CSI SnapshotMetadata Service API. The only structural differences between the two specifications are in some message properties. Refs: https://github.com/kubernetes/enhancements/blob/ffb78131af83279b8852ae742ca60ff81498eecd/keps/sig-storage/3314-csi-changed-block-tracking/README.md#the-csi-snapshotmetadata-service-api https://github.com/container-storage-interface/spec/pull/551
func NewSnapshotMetadataClient ¶
func NewSnapshotMetadataClient(cc grpc.ClientConnInterface) SnapshotMetadataClient
type SnapshotMetadataServer ¶
type SnapshotMetadataServer interface {
GetMetadataAllocated(*GetMetadataAllocatedRequest, grpc.ServerStreamingServer[GetMetadataAllocatedResponse]) error
GetMetadataDelta(*GetMetadataDeltaRequest, grpc.ServerStreamingServer[GetMetadataDeltaResponse]) error
// contains filtered or unexported methods
}
SnapshotMetadataServer is the server API for SnapshotMetadata service. All implementations must embed UnimplementedSnapshotMetadataServer for forward compatibility.
The Kubernetes SnapshotMetadata API is very similar to the CSI SnapshotMetadata Service API. The only structural differences between the two specifications are in some message properties. Refs: https://github.com/kubernetes/enhancements/blob/ffb78131af83279b8852ae742ca60ff81498eecd/keps/sig-storage/3314-csi-changed-block-tracking/README.md#the-csi-snapshotmetadata-service-api https://github.com/container-storage-interface/spec/pull/551
type SnapshotMetadata_GetMetadataAllocatedClient ¶
type SnapshotMetadata_GetMetadataAllocatedClient = grpc.ServerStreamingClient[GetMetadataAllocatedResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SnapshotMetadata_GetMetadataAllocatedServer ¶
type SnapshotMetadata_GetMetadataAllocatedServer = grpc.ServerStreamingServer[GetMetadataAllocatedResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SnapshotMetadata_GetMetadataDeltaClient ¶
type SnapshotMetadata_GetMetadataDeltaClient = grpc.ServerStreamingClient[GetMetadataDeltaResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SnapshotMetadata_GetMetadataDeltaServer ¶
type SnapshotMetadata_GetMetadataDeltaServer = grpc.ServerStreamingServer[GetMetadataDeltaResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type UnimplementedSnapshotMetadataServer ¶
type UnimplementedSnapshotMetadataServer struct{}
UnimplementedSnapshotMetadataServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedSnapshotMetadataServer) GetMetadataAllocated ¶
func (UnimplementedSnapshotMetadataServer) GetMetadataAllocated(*GetMetadataAllocatedRequest, grpc.ServerStreamingServer[GetMetadataAllocatedResponse]) error
func (UnimplementedSnapshotMetadataServer) GetMetadataDelta ¶
func (UnimplementedSnapshotMetadataServer) GetMetadataDelta(*GetMetadataDeltaRequest, grpc.ServerStreamingServer[GetMetadataDeltaResponse]) error
type UnsafeSnapshotMetadataServer ¶
type UnsafeSnapshotMetadataServer interface {
// contains filtered or unexported methods
}
UnsafeSnapshotMetadataServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SnapshotMetadataServer will result in compilation errors.