grpc

package
v0.0.0-...-7631d13 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_cbt_proto protoreflect.FileDescriptor
View Source 
var VolumeSnapshotDeltaService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cbt.VolumeSnapshotDeltaService",
	HandlerType: (*VolumeSnapshotDeltaServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListVolumeSnapshotDeltas",
			Handler:    _VolumeSnapshotDeltaService_ListVolumeSnapshotDeltas_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cbt.proto",
}

VolumeSnapshotDeltaService_ServiceDesc is the grpc.ServiceDesc for VolumeSnapshotDeltaService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterVolumeSnapshotDeltaServiceServer 

func RegisterVolumeSnapshotDeltaServiceServer(s grpc.ServiceRegistrar, srv VolumeSnapshotDeltaServiceServer)

Types

type BlockVolumeSnapshotDelta 

type BlockVolumeSnapshotDelta struct {

	// The list of changed blocks deltas. If empty, it means there are no
	// differences between the base and target snapshots.
	// This field is OPTIONAL.
	ChangedBlockDeltas []*ChangedBlockDelta `protobuf:"bytes,1,rep,name=changed_block_deltas,json=changedBlockDeltas,proto3" json:"changed_block_deltas,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockVolumeSnapshotDelta) Descriptor deprecated 

func (*BlockVolumeSnapshotDelta) Descriptor() ([]byte, []int)

Deprecated: Use BlockVolumeSnapshotDelta.ProtoReflect.Descriptor instead.

func (*BlockVolumeSnapshotDelta) GetChangedBlockDeltas 

func (x *BlockVolumeSnapshotDelta) GetChangedBlockDeltas() []*ChangedBlockDelta

func (*BlockVolumeSnapshotDelta) ProtoMessage 

func (*BlockVolumeSnapshotDelta) ProtoMessage()

func (*BlockVolumeSnapshotDelta) ProtoReflect 

func (x *BlockVolumeSnapshotDelta) ProtoReflect() protoreflect.Message

func (*BlockVolumeSnapshotDelta) Reset 

func (x *BlockVolumeSnapshotDelta) Reset()

func (*BlockVolumeSnapshotDelta) String 

func (x *BlockVolumeSnapshotDelta) String() string

type ChangedBlockDelta 

type ChangedBlockDelta struct {

	// The block logical offset on the volume.
	// This field is REQUIRED.
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// The size of the block in bytes.
	// This field is REQUIRED.
	BlockSizeBytes uint64 `protobuf:"varint,2,opt,name=block_size_bytes,json=blockSizeBytes,proto3" json:"block_size_bytes,omitempty"`
	// The token and other information needed to retrieve the actual data block
	// at the given offset. If the provider doesn't support token-based data
	// blocks retrieval, this should be left unspecified.
	// This field is OPTIONAL.
	DataToken *DataToken `protobuf:"bytes,3,opt,name=data_token,json=dataToken,proto3,oneof" json:"data_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangedBlockDelta) Descriptor deprecated 

func (*ChangedBlockDelta) Descriptor() ([]byte, []int)

Deprecated: Use ChangedBlockDelta.ProtoReflect.Descriptor instead.

func (*ChangedBlockDelta) GetBlockSizeBytes 

func (x *ChangedBlockDelta) GetBlockSizeBytes() uint64

func (*ChangedBlockDelta) GetDataToken 

func (x *ChangedBlockDelta) GetDataToken() *DataToken

func (*ChangedBlockDelta) GetOffset 

func (x *ChangedBlockDelta) GetOffset() uint64

func (*ChangedBlockDelta) ProtoMessage 

func (*ChangedBlockDelta) ProtoMessage()

func (*ChangedBlockDelta) ProtoReflect 

func (x *ChangedBlockDelta) ProtoReflect() protoreflect.Message

func (*ChangedBlockDelta) Reset 

func (x *ChangedBlockDelta) Reset()

func (*ChangedBlockDelta) String 

func (x *ChangedBlockDelta) String() string

type DataToken 

type DataToken struct {

	// The token to use to retrieve the actual data block at the given offset.
	// This field is REQUIRED.
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// Timestamp when the token is issued.
	// This field is REQUIRED.
	IssuanceTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=issuance_time,json=issuanceTime,proto3" json:"issuance_time,omitempty"`
	// The TTL of the token in seconds. The expiry time is calculated by adding
	// the time of issuance with this value.
	// This field is REQUIRED.
	TtlSeconds *durationpb.Duration `protobuf:"bytes,3,opt,name=ttl_seconds,json=ttlSeconds,proto3" json:"ttl_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*DataToken) Descriptor deprecated 

func (*DataToken) Descriptor() ([]byte, []int)

Deprecated: Use DataToken.ProtoReflect.Descriptor instead.

func (*DataToken) GetIssuanceTime 

func (x *DataToken) GetIssuanceTime() *timestamppb.Timestamp

func (*DataToken) GetToken 

func (x *DataToken) GetToken() string

func (*DataToken) GetTtlSeconds 

func (x *DataToken) GetTtlSeconds() *durationpb.Duration

func (*DataToken) ProtoMessage 

func (*DataToken) ProtoMessage()

func (*DataToken) ProtoReflect 

func (x *DataToken) ProtoReflect() protoreflect.Message

func (*DataToken) Reset 

func (x *DataToken) Reset()

func (*DataToken) String 

func (x *DataToken) String() string

type UnimplementedVolumeSnapshotDeltaServiceServer 

type UnimplementedVolumeSnapshotDeltaServiceServer struct {
}

UnimplementedVolumeSnapshotDeltaServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedVolumeSnapshotDeltaServiceServer) ListVolumeSnapshotDeltas 

func (UnimplementedVolumeSnapshotDeltaServiceServer) ListVolumeSnapshotDeltas(context.Context, *VolumeSnapshotDeltaRequest) (*VolumeSnapshotDeltaResponse, error)

type UnsafeVolumeSnapshotDeltaServiceServer 

type UnsafeVolumeSnapshotDeltaServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeVolumeSnapshotDeltaServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VolumeSnapshotDeltaServiceServer will result in compilation errors.

type VolumeSnapshotDeltaRequest 

type VolumeSnapshotDeltaRequest struct {

	// The name of the base snapshot handle to use for comparison.
	// If not specified, return all changed blocks.
	// This field is OPTIONAL.
	SnapshotBase *string `protobuf:"bytes,1,opt,name=snapshot_base,json=snapshotBase,proto3,oneof" json:"snapshot_base,omitempty"`
	// The name of the target snapshot handle to use for comparison.
	// If not specified, an error is returned.
	// This field is REQUIRED.
	SnapshotTarget string `protobuf:"bytes,2,opt,name=snapshot_target,json=snapshotTarget,proto3" json:"snapshot_target,omitempty"`
	// Defines the type of volume. Default to "block".
	// This field is REQUIRED.
	Mode string `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`
	// A token to specify where to start paginating. Set this field to
	// `next_token` returned by a previous `ListVolumeSnapshotDeltas` call to get
	// the next page of entries. An empty string is equal to an unspecified field
	// value.
	// This field is OPTIONAL.
	StartingToken *string `protobuf:"bytes,4,opt,name=starting_token,json=startingToken,proto3,oneof" json:"starting_token,omitempty"`
	// If specified (non-zero value), the Plugin MUST NOT return more entries than
	// this number in the response. If the actual number of entries is more than
	// this number, the Plugin MUST set `next_token` in the response which can be
	// used to get the next page of entries in the subsequent
	// `ListVolumeSnapshotDeltas` call. If not specified (zero value), it will be
	// default to 256 entries. The value of this field MUST NOT be negative.
	// This field is REQUIRED.
	MaxEntries int32 `protobuf:"varint,5,opt,name=max_entries,json=maxEntries,proto3" json:"max_entries,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeSnapshotDeltaRequest) Descriptor deprecated 

func (*VolumeSnapshotDeltaRequest) Descriptor() ([]byte, []int)

Deprecated: Use VolumeSnapshotDeltaRequest.ProtoReflect.Descriptor instead.

func (*VolumeSnapshotDeltaRequest) GetMaxEntries 

func (x *VolumeSnapshotDeltaRequest) GetMaxEntries() int32

func (*VolumeSnapshotDeltaRequest) GetMode 

func (x *VolumeSnapshotDeltaRequest) GetMode() string

func (*VolumeSnapshotDeltaRequest) GetSnapshotBase 

func (x *VolumeSnapshotDeltaRequest) GetSnapshotBase() string

func (*VolumeSnapshotDeltaRequest) GetSnapshotTarget 

func (x *VolumeSnapshotDeltaRequest) GetSnapshotTarget() string

func (*VolumeSnapshotDeltaRequest) GetStartingToken 

func (x *VolumeSnapshotDeltaRequest) GetStartingToken() string

func (*VolumeSnapshotDeltaRequest) ProtoMessage 

func (*VolumeSnapshotDeltaRequest) ProtoMessage()

func (*VolumeSnapshotDeltaRequest) ProtoReflect 

func (x *VolumeSnapshotDeltaRequest) ProtoReflect() protoreflect.Message

func (*VolumeSnapshotDeltaRequest) Reset 

func (x *VolumeSnapshotDeltaRequest) Reset()

func (*VolumeSnapshotDeltaRequest) String 

func (x *VolumeSnapshotDeltaRequest) String() string

type VolumeSnapshotDeltaResponse 

type VolumeSnapshotDeltaResponse struct {

	// Snapshot deltas for block volume snapshots. An empty list means there are
	// no block deltas between the base and target snapshots. If unspecified, it
	// means the volume isn't of block type.
	// This field is OPTIONAL.
	BlockDelta *BlockVolumeSnapshotDelta `protobuf:"bytes,1,opt,name=block_delta,json=blockDelta,proto3,oneof" json:"block_delta,omitempty"`
	// The volume size in bytes.
	// This field is OPTIONAL.
	VolumeSizeBytes *uint64 `protobuf:"varint,2,opt,name=volume_size_bytes,json=volumeSizeBytes,proto3,oneof" json:"volume_size_bytes,omitempty"`
	// This token is used to get the next page of entries for
	// `ListVolumeSnapshotDeltas` request. If the number of entries is larger than
	// `max_entries`, use the `next_token` as a value for the
	// `starting_token` field in the next `ListVolumeSnapshotDeltas` request.
	// An empty string is equal to an unspecified field value.
	// This field is OPTIONAL.
	NextToken *string `protobuf:"bytes,3,opt,name=next_token,json=nextToken,proto3,oneof" json:"next_token,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeSnapshotDeltaResponse) Descriptor deprecated 

func (*VolumeSnapshotDeltaResponse) Descriptor() ([]byte, []int)

Deprecated: Use VolumeSnapshotDeltaResponse.ProtoReflect.Descriptor instead.

func (*VolumeSnapshotDeltaResponse) GetBlockDelta 

func (x *VolumeSnapshotDeltaResponse) GetBlockDelta() *BlockVolumeSnapshotDelta

func (*VolumeSnapshotDeltaResponse) GetNextToken 

func (x *VolumeSnapshotDeltaResponse) GetNextToken() string

func (*VolumeSnapshotDeltaResponse) GetVolumeSizeBytes 

func (x *VolumeSnapshotDeltaResponse) GetVolumeSizeBytes() uint64

func (*VolumeSnapshotDeltaResponse) ProtoMessage 

func (*VolumeSnapshotDeltaResponse) ProtoMessage()

func (*VolumeSnapshotDeltaResponse) ProtoReflect 

func (x *VolumeSnapshotDeltaResponse) ProtoReflect() protoreflect.Message

func (*VolumeSnapshotDeltaResponse) Reset 

func (x *VolumeSnapshotDeltaResponse) Reset()

func (*VolumeSnapshotDeltaResponse) String 

func (x *VolumeSnapshotDeltaResponse) String() string

type VolumeSnapshotDeltaServiceClient 

type VolumeSnapshotDeltaServiceClient interface {
	ListVolumeSnapshotDeltas(ctx context.Context, in *VolumeSnapshotDeltaRequest, opts ...grpc.CallOption) (*VolumeSnapshotDeltaResponse, error)
}

VolumeSnapshotDeltaServiceClient is the client API for VolumeSnapshotDeltaService 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.

func NewVolumeSnapshotDeltaServiceClient 

func NewVolumeSnapshotDeltaServiceClient(cc grpc.ClientConnInterface) VolumeSnapshotDeltaServiceClient

type VolumeSnapshotDeltaServiceServer 

type VolumeSnapshotDeltaServiceServer interface {
	ListVolumeSnapshotDeltas(context.Context, *VolumeSnapshotDeltaRequest) (*VolumeSnapshotDeltaResponse, error)
	// contains filtered or unexported methods
}

VolumeSnapshotDeltaServiceServer is the server API for VolumeSnapshotDeltaService service. All implementations must embed UnimplementedVolumeSnapshotDeltaServiceServer for forward compatibility

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.