meta

package
v0.0.0-...-388aa53 Latest Latest
Warning

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

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

Documentation

Overview

Package meta is a generated protocol buffer package.

It is generated from these files:

pb.proto

It has these top-level messages:

Label
Peer
Epoch
VectorDB
Store

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthPb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPb   = fmt.Errorf("proto: integer overflow")
)
View Source
var DBState_name = map[int32]string{
	0: "RU",
	1: "RWU",
}
View Source
var DBState_value = map[string]int32{
	"RU":  0,
	"RWU": 1,
}
View Source
var StoreState_name = map[int32]string{
	0: "UP",
	1: "Down",
	2: "Tombstone",
}
View Source
var StoreState_value = map[string]int32{
	"UP":        0,
	"Down":      1,
	"Tombstone": 2,
}

Functions

This section is empty.

Types

type DBState

type DBState int32

DBState db state

const (
	// RU read and update
	RU DBState = 0
	// RWU read, append write and update
	RWU DBState = 1
)

func (DBState) Enum

func (x DBState) Enum() *DBState

func (DBState) EnumDescriptor

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

func (DBState) String

func (x DBState) String() string

func (*DBState) UnmarshalJSON

func (x *DBState) UnmarshalJSON(data []byte) error

type Epoch

type Epoch struct {
	Version          uint64 `protobuf:"varint,1,opt,name=version" json:"version"`
	ConfVersion      uint64 `protobuf:"varint,2,opt,name=confVersion" json:"confVersion"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Epoch) Descriptor

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

func (*Epoch) GetConfVersion

func (m *Epoch) GetConfVersion() uint64

func (*Epoch) GetVersion

func (m *Epoch) GetVersion() uint64

func (*Epoch) Marshal

func (m *Epoch) Marshal() (dAtA []byte, err error)

func (*Epoch) MarshalTo

func (m *Epoch) MarshalTo(dAtA []byte) (int, error)

func (*Epoch) ProtoMessage

func (*Epoch) ProtoMessage()

func (*Epoch) Reset

func (m *Epoch) Reset()

func (*Epoch) Size

func (m *Epoch) Size() (n int)

func (*Epoch) String

func (m *Epoch) String() string

func (*Epoch) Unmarshal

func (m *Epoch) Unmarshal(dAtA []byte) error

type Label

type Label struct {
	Key              string `protobuf:"bytes,1,opt,name=key" json:"key"`
	Value            string `protobuf:"bytes,2,opt,name=value" json:"value"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Label) Descriptor

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

func (*Label) GetKey

func (m *Label) GetKey() string

func (*Label) GetValue

func (m *Label) GetValue() string

func (*Label) Marshal

func (m *Label) Marshal() (dAtA []byte, err error)

func (*Label) MarshalTo

func (m *Label) MarshalTo(dAtA []byte) (int, error)

func (*Label) ProtoMessage

func (*Label) ProtoMessage()

func (*Label) Reset

func (m *Label) Reset()

func (*Label) Size

func (m *Label) Size() (n int)

func (*Label) String

func (m *Label) String() string

func (*Label) Unmarshal

func (m *Label) Unmarshal(dAtA []byte) error

type Peer

type Peer struct {
	ID               uint64 `protobuf:"varint,1,opt,name=id" json:"id"`
	StoreID          uint64 `protobuf:"varint,2,opt,name=storeID" json:"storeID"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Peer) Descriptor

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

func (*Peer) GetID

func (m *Peer) GetID() uint64

func (*Peer) GetStoreID

func (m *Peer) GetStoreID() uint64

func (*Peer) Marshal

func (m *Peer) Marshal() (dAtA []byte, err error)

func (*Peer) MarshalTo

func (m *Peer) MarshalTo(dAtA []byte) (int, error)

func (*Peer) ProtoMessage

func (*Peer) ProtoMessage()

func (*Peer) Reset

func (m *Peer) Reset()

func (*Peer) Size

func (m *Peer) Size() (n int)

func (*Peer) String

func (m *Peer) String() string

func (*Peer) Unmarshal

func (m *Peer) Unmarshal(dAtA []byte) error

type Store

type Store struct {
	ID               uint64     `protobuf:"varint,1,opt,name=id" json:"id"`
	Address          string     `protobuf:"bytes,2,opt,name=address" json:"address"`
	ClientAddress    string     `protobuf:"bytes,3,opt,name=clientAddress" json:"clientAddress"`
	Lables           []Label    `protobuf:"bytes,4,rep,name=lables" json:"lables"`
	State            StoreState `protobuf:"varint,5,opt,name=state,enum=meta.StoreState" json:"state"`
	XXX_unrecognized []byte     `json:"-"`
}

Store container of vectordb

func (*Store) Descriptor

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

func (*Store) GetAddress

func (m *Store) GetAddress() string

func (*Store) GetClientAddress

func (m *Store) GetClientAddress() string

func (*Store) GetID

func (m *Store) GetID() uint64

func (*Store) GetLables

func (m *Store) GetLables() []Label

func (*Store) GetState

func (m *Store) GetState() StoreState

func (*Store) Marshal

func (m *Store) Marshal() (dAtA []byte, err error)

func (*Store) MarshalTo

func (m *Store) MarshalTo(dAtA []byte) (int, error)

func (*Store) ProtoMessage

func (*Store) ProtoMessage()

func (*Store) Reset

func (m *Store) Reset()

func (*Store) Size

func (m *Store) Size() (n int)

func (*Store) String

func (m *Store) String() string

func (*Store) Unmarshal

func (m *Store) Unmarshal(dAtA []byte) error

type StoreState

type StoreState int32

StoreState store state

const (
	UP        StoreState = 0
	Down      StoreState = 1
	Tombstone StoreState = 2
)

func (StoreState) Enum

func (x StoreState) Enum() *StoreState

func (StoreState) EnumDescriptor

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

func (StoreState) String

func (x StoreState) String() string

func (*StoreState) UnmarshalJSON

func (x *StoreState) UnmarshalJSON(data []byte) error

type VectorDB

type VectorDB struct {
	ID               uint64  `protobuf:"varint,1,opt,name=id" json:"id"`
	State            DBState `protobuf:"varint,2,opt,name=state,enum=meta.DBState" json:"state"`
	Start            uint64  `protobuf:"varint,3,opt,name=start" json:"start"`
	Epoch            Epoch   `protobuf:"bytes,4,opt,name=epoch" json:"epoch"`
	Peers            []*Peer `protobuf:"bytes,5,rep,name=peers" json:"peers,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

VectorDB is a vectorDB

func (*VectorDB) Descriptor

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

func (*VectorDB) GetEpoch

func (m *VectorDB) GetEpoch() Epoch

func (*VectorDB) GetID

func (m *VectorDB) GetID() uint64

func (*VectorDB) GetPeers

func (m *VectorDB) GetPeers() []*Peer

func (*VectorDB) GetStart

func (m *VectorDB) GetStart() uint64

func (*VectorDB) GetState

func (m *VectorDB) GetState() DBState

func (*VectorDB) Marshal

func (m *VectorDB) Marshal() (dAtA []byte, err error)

func (*VectorDB) MarshalTo

func (m *VectorDB) MarshalTo(dAtA []byte) (int, error)

func (*VectorDB) ProtoMessage

func (*VectorDB) ProtoMessage()

func (*VectorDB) Reset

func (m *VectorDB) Reset()

func (*VectorDB) Size

func (m *VectorDB) Size() (n int)

func (*VectorDB) String

func (m *VectorDB) String() string

func (*VectorDB) Unmarshal

func (m *VectorDB) Unmarshal(dAtA []byte) error

Jump to

Keyboard shortcuts

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