vtable

Documentation

Index

• type Config
• type VTable
  • func (t *VTable) BeginTxn(shard consumer.Shard, store consumer.Store) error
  • func (t *VTable) ConsumeMessage(shard consumer.Shard, store consumer.Store, envelope message.Envelope) error
  • func (t *VTable) ExecuteQuery(req *factable.ExecuteQueryRequest, stream factable.Query_ExecuteQueryServer) error
  • func (*VTable) FinalizeTxn(shard consumer.Shard, store consumer.Store) error
  • func (t *VTable) FinishTxn(consumer.Shard, consumer.Store, error) error
  • func (t *VTable) InitApplication(args runconsumer.InitArgs) error
  • func (*VTable) NewConfig() runconsumer.Config
  • func (*VTable) NewMessage(spec *pb.JournalSpec) (message.Message, error)
  • func (t *VTable) NewStore(shard consumer.Shard, dir string, rec *recoverylog.Recorder) (consumer.Store, error)
  • func (t *VTable) ResolveQuery(ctx context.Context, spec *factable.QuerySpec) (*factable.ResolvedQuery, error)

Types

type Config

type Config struct {
	Factable struct {
		CommonConfig

		MemtableBudget uint `long:"memtableBudget" default:"536870912" description:"RocksDB Memtable size budget for tuning DB performance options."`
		DisableWAL     bool `` /* 153-byte string literal not displayed */
		ArenaSize      int  `long:"arenaSize" default:"16777216" description:"Byte size of arena buffers used for on-demand, query-time sorts"`
		MaxArenas      int  `long:"maxArenas" default:"8" description:"Maximum number of arenas an on-demand query may consume before it errors"`
	} `group:"Factable" namespace:"factable"`

	runconsumer.BaseConfig
}

Config utilized by VTable.

type VTable

type VTable struct {
	// contains filtered or unexported fields
}

VTable is a runconsumer.Application which aggregates DeltaEvents into indexed relation rows, and provides gRPC query APIs against those stored relations.

func (*VTable) BeginTxn

func (t *VTable) BeginTxn(shard consumer.Shard, store consumer.Store) error

func (*VTable) ConsumeMessage

func (t *VTable) ConsumeMessage(shard consumer.Shard, store consumer.Store, envelope message.Envelope) error

func (*VTable) ExecuteQuery

func (t *VTable) ExecuteQuery(req *factable.ExecuteQueryRequest, stream factable.Query_ExecuteQueryServer) error

func (*VTable) FinalizeTxn

func (*VTable) FinalizeTxn(shard consumer.Shard, store consumer.Store) error

func (*VTable) FinishTxn

func (t *VTable) FinishTxn(consumer.Shard, consumer.Store, error) error

func (*VTable) InitApplication

func (t *VTable) InitApplication(args runconsumer.InitArgs) error

InitApplication initializes the VTable.

func (*VTable) NewConfig

func (*VTable) NewConfig() runconsumer.Config

NewConfig returns a new Spec.

func (*VTable) NewMessage

func (*VTable) NewMessage(spec *pb.JournalSpec) (message.Message, error)

func (*VTable) NewStore

func (t *VTable) NewStore(shard consumer.Shard, dir string, rec *recoverylog.Recorder) (consumer.Store, error)

func (*VTable) ResolveQuery

func (t *VTable) ResolveQuery(ctx context.Context, spec *factable.QuerySpec) (*factable.ResolvedQuery, error)