kvpb

Documentation

Overview

Package kvpb is a generated protocol buffer package.

It is generated from these files:

github.com/m3db/m3/src/cluster/generated/proto/kvpb/kv.proto

It has these top-level messages:

KeyValueUpdate
KeyValueUpdateResult
QueryLimits
QueryLimit

Index

• Variables
• type KeyValueUpdate
  • func (*KeyValueUpdate) Descriptor() ([]byte, []int)
  • func (m *KeyValueUpdate) GetCommit() bool
  • func (m *KeyValueUpdate) GetKey() string
  • func (m *KeyValueUpdate) GetValue() string
  • func (m *KeyValueUpdate) Marshal() (dAtA []byte, err error)
  • func (m *KeyValueUpdate) MarshalTo(dAtA []byte) (int, error)
  • func (*KeyValueUpdate) ProtoMessage()
  • func (m *KeyValueUpdate) Reset()
  • func (m *KeyValueUpdate) Size() (n int)
  • func (m *KeyValueUpdate) String() string
  • func (m *KeyValueUpdate) Unmarshal(dAtA []byte) error
• type KeyValueUpdateResult
  • func (*KeyValueUpdateResult) Descriptor() ([]byte, []int)
  • func (m *KeyValueUpdateResult) GetKey() string
  • func (m *KeyValueUpdateResult) GetNew() string
  • func (m *KeyValueUpdateResult) GetOld() string
  • func (m *KeyValueUpdateResult) Marshal() (dAtA []byte, err error)
  • func (m *KeyValueUpdateResult) MarshalTo(dAtA []byte) (int, error)
  • func (*KeyValueUpdateResult) ProtoMessage()
  • func (m *KeyValueUpdateResult) Reset()
  • func (m *KeyValueUpdateResult) Size() (n int)
  • func (m *KeyValueUpdateResult) String() string
  • func (m *KeyValueUpdateResult) Unmarshal(dAtA []byte) error
• type QueryLimit
  • func (*QueryLimit) Descriptor() ([]byte, []int)
  • func (m *QueryLimit) GetForceExceeded() bool
  • func (m *QueryLimit) GetForceWaited() bool
  • func (m *QueryLimit) GetLimit() int64
  • func (m *QueryLimit) GetLookbackSeconds() int64
  • func (m *QueryLimit) Marshal() (dAtA []byte, err error)
  • func (m *QueryLimit) MarshalTo(dAtA []byte) (int, error)
  • func (*QueryLimit) ProtoMessage()
  • func (m *QueryLimit) Reset()
  • func (m *QueryLimit) Size() (n int)
  • func (m *QueryLimit) String() string
  • func (m *QueryLimit) Unmarshal(dAtA []byte) error
• type QueryLimits
  • func (*QueryLimits) Descriptor() ([]byte, []int)
  • func (m *QueryLimits) GetMaxRecentlyQueriedMetadataRead() *QueryLimit
  • func (m *QueryLimits) GetMaxRecentlyQueriedSeriesBlocks() *QueryLimit
  • func (m *QueryLimits) GetMaxRecentlyQueriedSeriesDiskBytesRead() *QueryLimit
  • func (m *QueryLimits) GetMaxRecentlyQueriedSeriesDiskRead() *QueryLimit
  • func (m *QueryLimits) Marshal() (dAtA []byte, err error)
  • func (m *QueryLimits) MarshalTo(dAtA []byte) (int, error)
  • func (*QueryLimits) ProtoMessage()
  • func (m *QueryLimits) Reset()
  • func (m *QueryLimits) Size() (n int)
  • func (m *QueryLimits) String() string
  • func (m *QueryLimits) Unmarshal(dAtA []byte) error

Variables

var (
	ErrInvalidLengthKv = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowKv   = fmt.Errorf("proto: integer overflow")
)

Types

type KeyValueUpdate

type KeyValueUpdate 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"`
	Commit bool   `protobuf:"varint,3,opt,name=commit,proto3" json:"commit,omitempty"`
}

func (*KeyValueUpdate) Descriptor

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

func (*KeyValueUpdate) GetCommit

func (m *KeyValueUpdate) GetCommit() bool

func (*KeyValueUpdate) GetKey

func (m *KeyValueUpdate) GetKey() string

func (*KeyValueUpdate) GetValue

func (m *KeyValueUpdate) GetValue() string

func (*KeyValueUpdate) Marshal

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

func (*KeyValueUpdate) MarshalTo

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

func (*KeyValueUpdate) ProtoMessage

func (*KeyValueUpdate) ProtoMessage()

func (*KeyValueUpdate) Reset

func (m *KeyValueUpdate) Reset()

func (*KeyValueUpdate) Size

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

func (*KeyValueUpdate) String

func (m *KeyValueUpdate) String() string

func (*KeyValueUpdate) Unmarshal

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

type KeyValueUpdateResult

type KeyValueUpdateResult struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Old string `protobuf:"bytes,2,opt,name=old,proto3" json:"old,omitempty"`
	New string `protobuf:"bytes,3,opt,name=new,proto3" json:"new,omitempty"`
}

func (*KeyValueUpdateResult) Descriptor

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

func (*KeyValueUpdateResult) GetKey

func (m *KeyValueUpdateResult) GetKey() string

func (*KeyValueUpdateResult) GetNew

func (m *KeyValueUpdateResult) GetNew() string

func (*KeyValueUpdateResult) GetOld

func (m *KeyValueUpdateResult) GetOld() string

func (*KeyValueUpdateResult) Marshal

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

func (*KeyValueUpdateResult) MarshalTo

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

func (*KeyValueUpdateResult) ProtoMessage

func (*KeyValueUpdateResult) ProtoMessage()

func (*KeyValueUpdateResult) Reset

func (m *KeyValueUpdateResult) Reset()

func (*KeyValueUpdateResult) Size

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

func (*KeyValueUpdateResult) String

func (m *KeyValueUpdateResult) String() string

func (*KeyValueUpdateResult) Unmarshal

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

type QueryLimit

type QueryLimit struct {
	Limit           int64 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	LookbackSeconds int64 `protobuf:"varint,2,opt,name=lookbackSeconds,proto3" json:"lookbackSeconds,omitempty"`
	ForceExceeded   bool  `protobuf:"varint,3,opt,name=forceExceeded,proto3" json:"forceExceeded,omitempty"`
	ForceWaited     bool  `protobuf:"varint,4,opt,name=forceWaited,proto3" json:"forceWaited,omitempty"`
}

func (*QueryLimit) Descriptor

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

func (*QueryLimit) GetForceExceeded

func (m *QueryLimit) GetForceExceeded() bool

func (*QueryLimit) GetForceWaited

func (m *QueryLimit) GetForceWaited() bool

func (*QueryLimit) GetLimit

func (m *QueryLimit) GetLimit() int64

func (*QueryLimit) GetLookbackSeconds

func (m *QueryLimit) GetLookbackSeconds() int64

func (*QueryLimit) Marshal

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

func (*QueryLimit) MarshalTo

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

func (*QueryLimit) ProtoMessage

func (*QueryLimit) ProtoMessage()

func (*QueryLimit) Reset

func (m *QueryLimit) Reset()

func (*QueryLimit) Size

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

func (*QueryLimit) String

func (m *QueryLimit) String() string

func (*QueryLimit) Unmarshal

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

type QueryLimits

type QueryLimits struct {
	MaxRecentlyQueriedSeriesBlocks        *QueryLimit `protobuf:"bytes,1,opt,name=maxRecentlyQueriedSeriesBlocks" json:"maxRecentlyQueriedSeriesBlocks,omitempty"`
	MaxRecentlyQueriedSeriesDiskBytesRead *QueryLimit `protobuf:"bytes,2,opt,name=maxRecentlyQueriedSeriesDiskBytesRead" json:"maxRecentlyQueriedSeriesDiskBytesRead,omitempty"`
	MaxRecentlyQueriedSeriesDiskRead      *QueryLimit `protobuf:"bytes,3,opt,name=maxRecentlyQueriedSeriesDiskRead" json:"maxRecentlyQueriedSeriesDiskRead,omitempty"`
	MaxRecentlyQueriedMetadataRead        *QueryLimit `protobuf:"bytes,4,opt,name=maxRecentlyQueriedMetadataRead" json:"maxRecentlyQueriedMetadataRead,omitempty"`
}

func (*QueryLimits) Descriptor

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

func (*QueryLimits) GetMaxRecentlyQueriedMetadataRead

func (m *QueryLimits) GetMaxRecentlyQueriedMetadataRead() *QueryLimit

func (*QueryLimits) GetMaxRecentlyQueriedSeriesBlocks

func (m *QueryLimits) GetMaxRecentlyQueriedSeriesBlocks() *QueryLimit

func (*QueryLimits) GetMaxRecentlyQueriedSeriesDiskBytesRead

func (m *QueryLimits) GetMaxRecentlyQueriedSeriesDiskBytesRead() *QueryLimit

func (*QueryLimits) GetMaxRecentlyQueriedSeriesDiskRead

func (m *QueryLimits) GetMaxRecentlyQueriedSeriesDiskRead() *QueryLimit

func (*QueryLimits) Marshal

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

func (*QueryLimits) MarshalTo

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

func (*QueryLimits) ProtoMessage

func (*QueryLimits) ProtoMessage()

func (*QueryLimits) Reset

func (m *QueryLimits) Reset()

func (*QueryLimits) Size

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

func (*QueryLimits) String

func (m *QueryLimits) String() string

func (*QueryLimits) Unmarshal

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