schema

Documentation

Index

• func Init(ps *badger.KV)
• func LoadFromDb(gid uint32) error
• func Parse(s string) ([]*protos.SchemaUpdate, error)
• func ParseBytes(s []byte, gid uint32) (rerr error)
• func State() *state
• type SyncEntry

Functions

func Init

func Init(ps *badger.KV)

func LoadFromDb

func LoadFromDb(gid uint32) error

LoadFromDb reads schema information from db and stores it in memory

func Parse

func Parse(s string) ([]*protos.SchemaUpdate, error)

Parse parses a schema string and returns the schema representation for it.

func ParseBytes

func ParseBytes(s []byte, gid uint32) (rerr error)

ParseBytes parses the byte array which holds the schema. We will reset all the globals. Overwrites schema blindly - called only during initilization in testing

func State

func State() *state

SateFor returns the schema for given group

Types

type SyncEntry

type SyncEntry struct {
	Attr   string
	Schema protos.SchemaUpdate
	Water  *x.WaterMark
	Index  uint64
}

SyncEntry stores the schema mutation information