pbfluxdb

Documentation

Index

• Variables
• type Checkpoint
  • func (*Checkpoint) Descriptor() ([]byte, []int)
  • func (x *Checkpoint) GetBlock() *v1.BlockRef
  • func (x *Checkpoint) GetHeight() uint64
  • func (*Checkpoint) ProtoMessage()
  • func (x *Checkpoint) ProtoReflect() protoreflect.Message
  • func (x *Checkpoint) Reset()
  • func (x *Checkpoint) String() string
• type TabletIndex
  • func (*TabletIndex) Descriptor() ([]byte, []int)
  • func (x *TabletIndex) GetEntries() []*TabletIndexEntry
  • func (x *TabletIndex) GetSquelchedCount() uint64
  • func (*TabletIndex) ProtoMessage()
  • func (x *TabletIndex) ProtoReflect() protoreflect.Message
  • func (x *TabletIndex) Reset()
  • func (x *TabletIndex) String() string
• type TabletIndexEntry
  • func (*TabletIndexEntry) Descriptor() ([]byte, []int)
  • func (x *TabletIndexEntry) GetHeight() uint64
  • func (x *TabletIndexEntry) GetPrimaryKey() []byte
  • func (*TabletIndexEntry) ProtoMessage()
  • func (x *TabletIndexEntry) ProtoReflect() protoreflect.Message
  • func (x *TabletIndexEntry) Reset()
  • func (x *TabletIndexEntry) String() string
• type WriteEntry
  • func (*WriteEntry) Descriptor() ([]byte, []int)
  • func (x *WriteEntry) GetKey() []byte
  • func (x *WriteEntry) GetValue() []byte
  • func (*WriteEntry) ProtoMessage()
  • func (x *WriteEntry) ProtoReflect() protoreflect.Message
  • func (x *WriteEntry) Reset()
  • func (x *WriteEntry) String() string
• type WriteRequest
  • func (*WriteRequest) Descriptor() ([]byte, []int)
  • func (x *WriteRequest) GetBlock() *v1.BlockRef
  • func (x *WriteRequest) GetHeight() uint64
  • func (x *WriteRequest) GetSingletEntries() []*WriteEntry
  • func (x *WriteRequest) GetTabletRows() []*WriteEntry
  • func (*WriteRequest) ProtoMessage()
  • func (x *WriteRequest) ProtoReflect() protoreflect.Message
  • func (x *WriteRequest) Reset()
  • func (x *WriteRequest) String() string

Variables

var File_sf_fluxdb_v1_fluxdb_proto protoreflect.FileDescriptor

Types

type Checkpoint

type Checkpoint struct {
	Height uint64       `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Block  *v1.BlockRef `protobuf:"bytes,2,opt,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

Checkpoint represents where FluxDB did its last write information to the database. It mainly contains the latest height value written as well as the block reference where it was.

func (*Checkpoint) Descriptor

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

Deprecated: Use Checkpoint.ProtoReflect.Descriptor instead.

func (*Checkpoint) GetBlock

func (x *Checkpoint) GetBlock() *v1.BlockRef

func (*Checkpoint) GetHeight

func (x *Checkpoint) GetHeight() uint64

func (*Checkpoint) ProtoMessage

func (*Checkpoint) ProtoMessage()

func (*Checkpoint) ProtoReflect

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

func (*Checkpoint) Reset

func (x *Checkpoint) Reset()

func (*Checkpoint) String

func (x *Checkpoint) String() string

type TabletIndex

type TabletIndex struct {
	SquelchedCount uint64              `protobuf:"varint,1,opt,name=squelched_count,json=squelchedCount,proto3" json:"squelched_count,omitempty"`
	Entries        []*TabletIndexEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

TabletIndex is the binary message used to save a Tablet index value inside persisten storage.

func (*TabletIndex) Descriptor

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

Deprecated: Use TabletIndex.ProtoReflect.Descriptor instead.

func (*TabletIndex) GetEntries

func (x *TabletIndex) GetEntries() []*TabletIndexEntry

func (*TabletIndex) GetSquelchedCount

func (x *TabletIndex) GetSquelchedCount() uint64

func (*TabletIndex) ProtoMessage

func (*TabletIndex) ProtoMessage()

func (*TabletIndex) ProtoReflect

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

func (*TabletIndex) Reset

func (x *TabletIndex) Reset()

func (*TabletIndex) String

func (x *TabletIndex) String() string

type TabletIndexEntry

type TabletIndexEntry struct {
	PrimaryKey []byte `protobuf:"bytes,1,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	Height     uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	// contains filtered or unexported fields
}

TabletIndexEntry represents a single entry within a Tablet index instance.

func (*TabletIndexEntry) Descriptor

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

Deprecated: Use TabletIndexEntry.ProtoReflect.Descriptor instead.

func (*TabletIndexEntry) GetHeight

func (x *TabletIndexEntry) GetHeight() uint64

func (*TabletIndexEntry) GetPrimaryKey

func (x *TabletIndexEntry) GetPrimaryKey() []byte

func (*TabletIndexEntry) ProtoMessage

func (*TabletIndexEntry) ProtoMessage()

func (*TabletIndexEntry) ProtoReflect

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

func (*TabletIndexEntry) Reset

func (x *TabletIndexEntry) Reset()

func (*TabletIndexEntry) String

func (x *TabletIndexEntry) String() string

type WriteEntry

type WriteEntry struct {
	Key   []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteEntry) Descriptor

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

Deprecated: Use WriteEntry.ProtoReflect.Descriptor instead.

func (*WriteEntry) GetKey

func (x *WriteEntry) GetKey() []byte

func (*WriteEntry) GetValue

func (x *WriteEntry) GetValue() []byte

func (*WriteEntry) ProtoMessage

func (*WriteEntry) ProtoMessage()

func (*WriteEntry) ProtoReflect

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

func (*WriteEntry) Reset

func (x *WriteEntry) Reset()

func (*WriteEntry) String

func (x *WriteEntry) String() string

type WriteRequest

type WriteRequest struct {
	SingletEntries []*WriteEntry `protobuf:"bytes,1,rep,name=singlet_entries,json=singletEntries,proto3" json:"singlet_entries,omitempty"`
	TabletRows     []*WriteEntry `protobuf:"bytes,2,rep,name=tablet_rows,json=tabletRows,proto3" json:"tablet_rows,omitempty"`
	Height         uint64        `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
	Block          *v1.BlockRef  `protobuf:"bytes,4,opt,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

WriteRequest represents all the necessary data to write to database for a given height.

This is used by the reprocessing sharder to store write requests for a given specific shard over a bounded sequence of heights.

func (*WriteRequest) Descriptor

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

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) GetBlock

func (x *WriteRequest) GetBlock() *v1.BlockRef

func (*WriteRequest) GetHeight

func (x *WriteRequest) GetHeight() uint64

func (*WriteRequest) GetSingletEntries

func (x *WriteRequest) GetSingletEntries() []*WriteEntry

func (*WriteRequest) GetTabletRows

func (x *WriteRequest) GetTabletRows() []*WriteEntry

func (*WriteRequest) ProtoMessage

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect

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

func (*WriteRequest) Reset

func (x *WriteRequest) Reset()

func (*WriteRequest) String

func (x *WriteRequest) String() string