metadata

Documentation

Index

• Constants
• func Convert2ProtoEventbus(ins ...*Eventbus) []*meta.Eventbus
• func Convert2ProtoEventlog(ins ...*Eventlog) []*meta.Eventlog
• func GetBlockMetadataKey(volumeID, blockID vanus.ID) string
• func GetEventbusMetadataKey(id vanus.ID) string
• func GetEventlogMetadataKey(elID vanus.ID) string
• func GetEventlogSegmentsMetadataKey(eventlogID, segmentID vanus.ID) string
• func GetSegmentMetadataKey(segmentID vanus.ID) string
• type Block
  • func (bl *Block) String() string
• type Eventbus
• type Eventlog
  • func (el *Eventlog) Eventbus() string
• type VolumeMetadata

Constants

const (
	VolumeKeyPrefixInKVStore         = kv.ResourceVolumeMetadata
	BlockKeyPrefixInKVStore          = kv.ResourceVolumeBlock
	VolumeInstanceKeyPrefixInKVStore = kv.ResourceVolumeInstance

	EventlogKeyPrefixInKVStore = kv.ResourceEventlog
	SegmentKeyPrefixInKVStore  = kv.ResourceSegment

	EventlogSegmentsKeyPrefixInKVStore = kv.ResourceSegmentOfEventlog
)

Functions

func Convert2ProtoEventbus

func Convert2ProtoEventbus(ins ...*Eventbus) []*meta.Eventbus

func Convert2ProtoEventlog

func Convert2ProtoEventlog(ins ...*Eventlog) []*meta.Eventlog

func GetBlockMetadataKey

func GetBlockMetadataKey(volumeID, blockID vanus.ID) string

func GetEventbusMetadataKey

func GetEventbusMetadataKey(id vanus.ID) string

func GetEventlogMetadataKey

func GetEventlogMetadataKey(elID vanus.ID) string

func GetEventlogSegmentsMetadataKey

func GetEventlogSegmentsMetadataKey(eventlogID, segmentID vanus.ID) string

func GetSegmentMetadataKey

func GetSegmentMetadataKey(segmentID vanus.ID) string

Types

type Block

type Block struct {
	ID         vanus.ID `json:"id"`
	Capacity   int64    `json:"capacity"`
	Size       int64    `json:"size"`
	VolumeID   vanus.ID `json:"volume_id"`
	EventlogID vanus.ID `json:"eventlog_id"`
	SegmentID  vanus.ID `json:"segment_id"`
}

func (*Block) String

func (bl *Block) String() string

type Eventbus

type Eventbus struct {
	ID          vanus.ID    `json:"id"`
	Name        string      `json:"name"`
	LogNumber   int         `json:"log_number"`
	Eventlogs   []*Eventlog `json:"eventlogs"`
	Description string      `json:"description"`
	CreatedAt   time.Time   `json:"created_at"`
	UpdatedAt   time.Time   `json:"updated_at"`
	NamespaceID uint64      `json:"namespace_id"`
}

type Eventlog

type Eventlog struct {
	// global unique id
	ID            vanus.ID `json:"id"`
	EventbusID    vanus.ID `json:"eventbus_id"`
	EventbusName  string   `json:"eventbus_name"`
	SegmentNumber int      `json:"segment_number"`
}

func (*Eventlog) Eventbus

func (el *Eventlog) Eventbus() string

type VolumeMetadata

type VolumeMetadata struct {
	ID       vanus.ID          `json:"id"`
	Capacity int64             `json:"capacity"`
	Used     int64             `json:"used"`
	Blocks   map[uint64]*Block `json:"blocks"`
}