fs

package
v0.0.0-...-c201ef6 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	BlockRecordType_name = map[int32]string{
		0: "UNKNOWN",
		1: "CREATE",
		2: "DELETE",
	}
	BlockRecordType_value = map[string]int32{
		"UNKNOWN": 0,
		"CREATE":  1,
		"DELETE":  2,
	}
)

Enum value maps for BlockRecordType.

View Source 
var File_yb_fs_fs_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BlockIdPB 

type BlockIdPB struct {
	Id *uint64 `protobuf:"fixed64,1,req,name=id" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockIdPB) Descriptor deprecated 

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

Deprecated: Use BlockIdPB.ProtoReflect.Descriptor instead.

func (*BlockIdPB) GetId 

func (x *BlockIdPB) GetId() uint64

func (*BlockIdPB) MarshalJSON 

func (m *BlockIdPB) MarshalJSON() ([]byte, error)

func (*BlockIdPB) ProtoMessage 

func (*BlockIdPB) ProtoMessage()

func (*BlockIdPB) ProtoReflect 

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

func (*BlockIdPB) Reset 

func (x *BlockIdPB) Reset()

func (*BlockIdPB) String 

func (x *BlockIdPB) String() string

func (*BlockIdPB) UnmarshalJSON 

func (m *BlockIdPB) UnmarshalJSON(b []byte) error

type BlockRecordPB 

type BlockRecordPB struct {

	// The unique identifier of the block.
	BlockId *BlockIdPB `protobuf:"bytes,1,req,name=block_id,json=blockId" json:"block_id,omitempty"`
	// Whether this is a CREATE or a DELETE.
	OpType *BlockRecordType `protobuf:"varint,2,req,name=op_type,json=opType,enum=yb.BlockRecordType" json:"op_type,omitempty"`
	// The time at which this block record was created, expressed in terms of
	// microseconds since the epoch.
	TimestampUs *uint64 `protobuf:"varint,3,req,name=timestamp_us,json=timestampUs" json:"timestamp_us,omitempty"`
	// The offset of the block in the container data file.
	//
	// Required for CREATE.
	Offset *int64 `protobuf:"varint,4,opt,name=offset" json:"offset,omitempty"`
	// The length of the block in the container data file.
	//
	// Required for CREATE.
	Length *int64 `protobuf:"varint,5,opt,name=length" json:"length,omitempty"`
	// contains filtered or unexported fields
}

An element found in a container metadata file of the log-backed block storage implementation.

Each one tracks the existence (creation) or non-existence (deletion) of a particular block. They are written sequentially, with subsequent messages taking precedence over earlier ones (e.g. "CREATE foo" followed by "DELETE foo" means that block foo does not exist).

func (*BlockRecordPB) Descriptor deprecated 

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

Deprecated: Use BlockRecordPB.ProtoReflect.Descriptor instead.

func (*BlockRecordPB) GetBlockId 

func (x *BlockRecordPB) GetBlockId() *BlockIdPB

func (*BlockRecordPB) GetLength 

func (x *BlockRecordPB) GetLength() int64

func (*BlockRecordPB) GetOffset 

func (x *BlockRecordPB) GetOffset() int64

func (*BlockRecordPB) GetOpType 

func (x *BlockRecordPB) GetOpType() BlockRecordType

func (*BlockRecordPB) GetTimestampUs 

func (x *BlockRecordPB) GetTimestampUs() uint64

func (*BlockRecordPB) MarshalJSON 

func (m *BlockRecordPB) MarshalJSON() ([]byte, error)

func (*BlockRecordPB) ProtoMessage 

func (*BlockRecordPB) ProtoMessage()

func (*BlockRecordPB) ProtoReflect 

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

func (*BlockRecordPB) Reset 

func (x *BlockRecordPB) Reset()

func (*BlockRecordPB) String 

func (x *BlockRecordPB) String() string

func (*BlockRecordPB) UnmarshalJSON 

func (m *BlockRecordPB) UnmarshalJSON(b []byte) error

type BlockRecordType 

type BlockRecordType int32

The kind of record. 

const (
	BlockRecordType_UNKNOWN BlockRecordType = 0
	BlockRecordType_CREATE  BlockRecordType = 1
	BlockRecordType_DELETE  BlockRecordType = 2
)

func (BlockRecordType) Descriptor 

func (BlockRecordType) Descriptor() protoreflect.EnumDescriptor

func (BlockRecordType) Enum 

func (x BlockRecordType) Enum() *BlockRecordType

func (BlockRecordType) EnumDescriptor deprecated 

func (BlockRecordType) EnumDescriptor() ([]byte, []int)

Deprecated: Use BlockRecordType.Descriptor instead.

func (BlockRecordType) Number 

func (x BlockRecordType) Number() protoreflect.EnumNumber

func (BlockRecordType) String 

func (x BlockRecordType) String() string

func (BlockRecordType) Type 

func (BlockRecordType) Type() protoreflect.EnumType

func (*BlockRecordType) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type InstanceMetadataPB 

type InstanceMetadataPB struct {

	// The UUID which is assigned when the instance is first formatted. This uniquely
	// identifies the node in the cluster.
	Uuid []byte `protobuf:"bytes,1,req,name=uuid" json:"uuid,omitempty"`
	// Human-readable string indicating when and where the node was first
	// initialized.
	FormatStamp *string `protobuf:"bytes,2,req,name=format_stamp,json=formatStamp" json:"format_stamp,omitempty"`
	// contains filtered or unexported fields
}

When any server initializes a new filesystem (eg a new node is created in the cluster), it creates this structure and stores it persistently.

func (*InstanceMetadataPB) Descriptor deprecated 

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

Deprecated: Use InstanceMetadataPB.ProtoReflect.Descriptor instead.

func (*InstanceMetadataPB) GetFormatStamp 

func (x *InstanceMetadataPB) GetFormatStamp() string

func (*InstanceMetadataPB) GetUuid 

func (x *InstanceMetadataPB) GetUuid() []byte

func (*InstanceMetadataPB) MarshalJSON 

func (m *InstanceMetadataPB) MarshalJSON() ([]byte, error)

func (*InstanceMetadataPB) ProtoMessage 

func (*InstanceMetadataPB) ProtoMessage()

func (*InstanceMetadataPB) ProtoReflect 

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

func (*InstanceMetadataPB) Reset 

func (x *InstanceMetadataPB) Reset()

func (*InstanceMetadataPB) String 

func (x *InstanceMetadataPB) String() string

func (*InstanceMetadataPB) UnmarshalJSON 

func (m *InstanceMetadataPB) UnmarshalJSON(b []byte) error

type PathInstanceMetadataPB 

type PathInstanceMetadataPB struct {

	// Describes this path instance as well as all of the other path instances
	// that, taken together, describe a complete set.
	PathSet *PathSetPB `protobuf:"bytes,1,req,name=path_set,json=pathSet" json:"path_set,omitempty"`
	// Textual representation of the block manager that formatted this path.
	BlockManagerType *string `protobuf:"bytes,2,req,name=block_manager_type,json=blockManagerType" json:"block_manager_type,omitempty"`
	// Block size on the filesystem where this instance was created. If the
	// instance (and its data) are ever copied to another location, the block
	// size in that location must be the same.
	FilesystemBlockSizeBytes *uint64 `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

A filesystem instance can contain multiple paths. One of these structures is persisted in each path when the filesystem instance is created.

func (*PathInstanceMetadataPB) Descriptor deprecated 

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

Deprecated: Use PathInstanceMetadataPB.ProtoReflect.Descriptor instead.

func (*PathInstanceMetadataPB) GetBlockManagerType 

func (x *PathInstanceMetadataPB) GetBlockManagerType() string

func (*PathInstanceMetadataPB) GetFilesystemBlockSizeBytes 

func (x *PathInstanceMetadataPB) GetFilesystemBlockSizeBytes() uint64

func (*PathInstanceMetadataPB) GetPathSet 

func (x *PathInstanceMetadataPB) GetPathSet() *PathSetPB

func (*PathInstanceMetadataPB) MarshalJSON 

func (m *PathInstanceMetadataPB) MarshalJSON() ([]byte, error)

func (*PathInstanceMetadataPB) ProtoMessage 

func (*PathInstanceMetadataPB) ProtoMessage()

func (*PathInstanceMetadataPB) ProtoReflect 

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

func (*PathInstanceMetadataPB) Reset 

func (x *PathInstanceMetadataPB) Reset()

func (*PathInstanceMetadataPB) String 

func (x *PathInstanceMetadataPB) String() string

func (*PathInstanceMetadataPB) UnmarshalJSON 

func (m *PathInstanceMetadataPB) UnmarshalJSON(b []byte) error

type PathSetPB 

type PathSetPB struct {

	// Globally unique identifier for this path instance.
	Uuid []byte `protobuf:"bytes,1,req,name=uuid" json:"uuid,omitempty"`
	// All UUIDs in this path instance set. In a healthy filesystem:
	// 1. There exists an on-disk PathInstanceMetadataPB for each listed UUID, and
	// 2. Every PathSetPB contains an identical copy of all_uuids.
	AllUuids [][]byte `protobuf:"bytes,2,rep,name=all_uuids,json=allUuids" json:"all_uuids,omitempty"`
	// contains filtered or unexported fields
}

Describes a collection of filesystem path instances and the membership of a particular instance in the collection.

In a healthy filesystem (see below), a path instance can be referred to via its UUID's position in all_uuids instead of via the UUID itself. This is useful when there are many such references, as the position is much shorter than the UUID.

func (*PathSetPB) Descriptor deprecated 

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

Deprecated: Use PathSetPB.ProtoReflect.Descriptor instead.

func (*PathSetPB) GetAllUuids 

func (x *PathSetPB) GetAllUuids() [][]byte

func (*PathSetPB) GetUuid 

func (x *PathSetPB) GetUuid() []byte

func (*PathSetPB) MarshalJSON 

func (m *PathSetPB) MarshalJSON() ([]byte, error)

func (*PathSetPB) ProtoMessage 

func (*PathSetPB) ProtoMessage()

func (*PathSetPB) ProtoReflect 

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

func (*PathSetPB) Reset 

func (x *PathSetPB) Reset()

func (*PathSetPB) String 

func (x *PathSetPB) String() string

func (*PathSetPB) UnmarshalJSON 

func (m *PathSetPB) UnmarshalJSON(b []byte) error

Source Files

View all Source files

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.