proto_storage

package module
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 

func (DataType) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

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 

func (StorageType) Type() protoreflect.EnumType

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

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.