proto_storage

package module
Version: v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Sep 27, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

README

proto_storage

Data Storage Protocol

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	StorageType_name = map[int32]string{
		0: "TYPE_ANY",
		1: "TYPE_FILE",
		2: "TYPE_DATABASE",
		3: "TYPE_KVSTORE",
		4: "TYPE_OBJSTORE",
	}
	StorageType_value = map[string]int32{
		"TYPE_ANY":      0,
		"TYPE_FILE":     1,
		"TYPE_DATABASE": 2,
		"TYPE_KVSTORE":  3,
		"TYPE_OBJSTORE": 4,
	}
)

Enum value maps for StorageType.

View Source
var (
	DataType_name = map[int32]string{
		0: "DATA_ANY",
		1: "DATA_LINE_APPEND",
		2: "DATA_FILE",
	}
	DataType_value = map[string]int32{
		"DATA_ANY":         0,
		"DATA_LINE_APPEND": 1,
		"DATA_FILE":        2,
	}
)

Enum value maps for DataType.

View Source
var File_storage_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BucketTag added in v0.0.2

type BucketTag struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucketName,proto3" json:"bucketName,omitempty"` // if DATA_FILE , folder name
	Tags       []*Tag `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketTag) Descriptor deprecated added in v0.0.2

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

Deprecated: Use BucketTag.ProtoReflect.Descriptor instead.

func (*BucketTag) GetBucketName added in v0.0.2

func (x *BucketTag) GetBucketName() string

func (*BucketTag) GetTags added in v0.0.2

func (x *BucketTag) GetTags() []*Tag

func (*BucketTag) ProtoMessage added in v0.0.2

func (*BucketTag) ProtoMessage()

func (*BucketTag) ProtoReflect added in v0.0.2

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

func (*BucketTag) Reset added in v0.0.2

func (x *BucketTag) Reset()

func (*BucketTag) String added in v0.0.2

func (x *BucketTag) String() string

type DataType

type DataType int32
const (
	DataType_DATA_ANY         DataType = 0 // file for each date (for each line)
	DataType_DATA_LINE_APPEND DataType = 1 // file for each date (for each line)
	DataType_DATA_FILE        DataType = 2 // file type for each record. date for direcotory
)

func (DataType) Descriptor added in v0.0.2

func (DataType) Descriptor() protoreflect.EnumDescriptor

func (DataType) Enum added in v0.0.2

func (x DataType) Enum() *DataType

func (DataType) EnumDescriptor deprecated

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

Deprecated: Use DataType.Descriptor instead.

func (DataType) Number added in v0.0.2

func (x DataType) Number() protoreflect.EnumNumber

func (DataType) String

func (x DataType) String() string

func (DataType) Type added in v0.0.2

type ObjectTag added in v0.0.2

type ObjectTag struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucketName,proto3" json:"bucketName,omitempty"`
	ObjectName string `protobuf:"bytes,2,opt,name=objectName,proto3" json:"objectName,omitempty"`
	Tags       []*Tag `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectTag) Descriptor deprecated added in v0.0.2

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

Deprecated: Use ObjectTag.ProtoReflect.Descriptor instead.

func (*ObjectTag) GetBucketName added in v0.0.2

func (x *ObjectTag) GetBucketName() string

func (*ObjectTag) GetObjectName added in v0.0.2

func (x *ObjectTag) GetObjectName() string

func (*ObjectTag) GetTags added in v0.0.2

func (x *ObjectTag) GetTags() []*Tag

func (*ObjectTag) ProtoMessage added in v0.0.2

func (*ObjectTag) ProtoMessage()

func (*ObjectTag) ProtoReflect added in v0.0.2

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

func (*ObjectTag) Reset added in v0.0.2

func (x *ObjectTag) Reset()

func (*ObjectTag) String added in v0.0.2

func (x *ObjectTag) String() string

type Record

type Record struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucketName,proto3" json:"bucketName,omitempty"` // if DATA_FILE , folder name
	ObjectName string `protobuf:"bytes,2,opt,name=objectName,proto3" json:"objectName,omitempty"` // if DATA_FILE , filename. / If KV Key
	Option     []byte `protobuf:"bytes,3,opt,name=option,proto3" json:"option,omitempty"`         // option used for each storage type.(Not yet used)
	Record     []byte `protobuf:"bytes,4,opt,name=record,proto3" json:"record,omitempty"`         // main object
	// contains filtered or unexported fields
}

Data Store message

func (*Record) Descriptor deprecated

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetBucketName added in v0.0.2

func (x *Record) GetBucketName() string

func (*Record) GetObjectName added in v0.0.2

func (x *Record) GetObjectName() string

func (*Record) GetOption added in v0.0.2

func (x *Record) GetOption() []byte

func (*Record) GetRecord

func (x *Record) GetRecord() []byte

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) ProtoReflect added in v0.0.2

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

func (*Record) Reset

func (x *Record) Reset()

func (*Record) String

func (x *Record) String() string

type RecordQuery added in v0.0.2

type RecordQuery struct {
	BucketName  string   `protobuf:"bytes,1,opt,name=bucketName,proto3" json:"bucketName,omitempty"`   // if DATA_FILE , folder name
	ObjectNames []string `protobuf:"bytes,2,rep,name=objectNames,proto3" json:"objectNames,omitempty"` // if DATA_FILE , filename. / If KV Key
	Option      []byte   `protobuf:"bytes,3,opt,name=option,proto3" json:"option,omitempty"`           // option used for each storage type.(Not yet used)
	// contains filtered or unexported fields
}

func (*RecordQuery) Descriptor deprecated added in v0.0.2

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

Deprecated: Use RecordQuery.ProtoReflect.Descriptor instead.

func (*RecordQuery) GetBucketName added in v0.0.2

func (x *RecordQuery) GetBucketName() string

func (*RecordQuery) GetObjectNames added in v0.2.0

func (x *RecordQuery) GetObjectNames() []string

func (*RecordQuery) GetOption added in v0.0.2

func (x *RecordQuery) GetOption() []byte

func (*RecordQuery) ProtoMessage added in v0.0.2

func (*RecordQuery) ProtoMessage()

func (*RecordQuery) ProtoReflect added in v0.0.2

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

func (*RecordQuery) Reset added in v0.0.2

func (x *RecordQuery) Reset()

func (*RecordQuery) String added in v0.0.2

func (x *RecordQuery) String() string

type Storage

type Storage struct {
	Tag         string      `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"` // used for master tag
	Stype       StorageType `protobuf:"varint,2,opt,name=stype,proto3,enum=proto.storage.StorageType" json:"stype,omitempty"`
	Dtype       DataType    `protobuf:"varint,3,opt,name=dtype,proto3,enum=proto.storage.DataType" json:"dtype,omitempty"`
	Datasize    uint32      `protobuf:"varint,4,opt,name=datasize,proto3" json:"datasize,omitempty"`
	StorageSize uint64      `protobuf:"varint,5,opt,name=storageSize,proto3" json:"storageSize,omitempty"`
	// contains filtered or unexported fields
}

Demand/Supply message

func (*Storage) Descriptor deprecated

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

Deprecated: Use Storage.ProtoReflect.Descriptor instead.

func (*Storage) GetDatasize

func (x *Storage) GetDatasize() uint32

func (*Storage) GetDtype

func (x *Storage) GetDtype() DataType

func (*Storage) GetStorageSize

func (x *Storage) GetStorageSize() uint64

func (*Storage) GetStype

func (x *Storage) GetStype() StorageType

func (*Storage) GetTag

func (x *Storage) GetTag() string

func (*Storage) ProtoMessage

func (*Storage) ProtoMessage()

func (*Storage) ProtoReflect added in v0.0.2

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

func (*Storage) Reset

func (x *Storage) Reset()

func (*Storage) String

func (x *Storage) String() string

type StorageType

type StorageType int32
const (
	StorageType_TYPE_ANY      StorageType = 0
	StorageType_TYPE_FILE     StorageType = 1
	StorageType_TYPE_DATABASE StorageType = 2
	StorageType_TYPE_KVSTORE  StorageType = 3
	StorageType_TYPE_OBJSTORE StorageType = 4
)

func (StorageType) Descriptor added in v0.0.2

func (StorageType) Enum added in v0.0.2

func (x StorageType) Enum() *StorageType

func (StorageType) EnumDescriptor deprecated

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

Deprecated: Use StorageType.Descriptor instead.

func (StorageType) Number added in v0.0.2

func (x StorageType) Number() protoreflect.EnumNumber

func (StorageType) String

func (x StorageType) String() string

func (StorageType) Type added in v0.0.2

type Tag added in v0.0.2

type Tag struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Tag) Descriptor deprecated added in v0.0.2

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

Deprecated: Use Tag.ProtoReflect.Descriptor instead.

func (*Tag) GetKey added in v0.0.2

func (x *Tag) GetKey() string

func (*Tag) GetValue added in v0.0.2

func (x *Tag) GetValue() string

func (*Tag) ProtoMessage added in v0.0.2

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect added in v0.0.2

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

func (*Tag) Reset added in v0.0.2

func (x *Tag) Reset()

func (*Tag) String added in v0.0.2

func (x *Tag) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL