x

Mar 9, 2018

Changes in this version

type Options

+ QueryEdgeLimit uint64

Feb 7, 2018

Changes in this version

+ const PortZeroGrpc

+ const PortZeroHTTP

Jan 17, 2018

Changes in this version

+ func FixedDuration(d time.Duration) string

type WaterMark

+ func (w *WaterMark) LastIndex() uint64

Dec 1, 2017

Changes in this version

+ func LoadTLSConfig(conf *TLSHelperConfig, v *viper.Viper)

+ func RegisterTLSFlags(flag *pflag.FlagSet)

+ func StartProfile(conf *viper.Viper) stopper

+ type SubCommand struct

+ Cmd *cobra.Command

+ Conf *viper.Viper

+ EnvPrefix string

Nov 14, 2017

Changes in this version

+ const PortGrpc

+ const PortHTTP

+ const PortInternal

+ const PredicateListAttr

+ func BuildDetails() string

+ func MergeLinReads(dst *protos.LinRead, src *protos.LinRead)

+ func SetTLSFlags(conf *TLSHelperConfig, flag *pflag.FlagSet)

Oct 9, 2017

Changes in this version

+ func AddCorsHeaders(w http.ResponseWriter)

+ func AppendProtoMsg(p []byte, msg ProtoMessage) ([]byte, error)

+ func AppendUvarint(p []byte, x uint64) []byte

+ func PredicatePrefix(predicate string) []byte

+ func ReserveCap(p []byte, atLeast int) []byte

+ type EmbeddedUidAllocator struct

+ func (e *EmbeddedUidAllocator) AssignUids(ctx context.Context, num *protos.Num) (*protos.AssignedIds, error)

+ func (e *EmbeddedUidAllocator) Init(kv *badger.KV)

+ type ProtoMessage interface

+ MarshalTo func([]byte) (int, error)

+ Size func() int

Sep 20, 2017

Changes in this version

+ const ByteCount

+ const ByteCountRev

+ const ByteData

+ const ByteIndex

+ const ByteReverse

+ const ErrorServiceUnavailable

+ const GrpcMaxSize

+ const Star

+ const TLSClientConfig

+ const TLSServerConfig

+ const ValidHostnameRegex

+ var ActiveMutations *expvar.Int

+ var BytesRead *expvar.Int

+ var BytesWrite *expvar.Int

+ var CacheHit *expvar.Int

+ var CacheMiss *expvar.Int

+ var CacheRace *expvar.Int

+ var Conf *expvar.Map

+ var DirtyMapSize *expvar.Int

+ var EvictedPls *expvar.Int

+ var HeapIdle *expvar.Int

+ var LcacheCapacity *expvar.Int

+ var LcacheLen *expvar.Int

+ var LcacheSize *expvar.Int

+ var Logger = log.New(os.Stderr, "", log.Lshortfile | log.Flags())

+ var MaxPlLength *expvar.Int

+ var MaxPlSize *expvar.Int

+ var MaxPlSz int64

+ var MemoryInUse *expvar.Int

+ var NumGoRoutines *expvar.Int

+ var NumQueries *expvar.Int

+ var PendingProposals *expvar.Int

+ var PendingQueries *expvar.Int

+ var PostingReads *expvar.Int

+ var PostingWrites *expvar.Int

+ var PredicateStats *expvar.Map

+ var ServerHealth *expvar.Int

+ var TotalMemory *expvar.Int

+ var TotalOSMemory *expvar.Int

+ func AssertTruefNoTrace(b bool, format string, args ...interface{})

+ func CountKey(attr string, count uint32, reverse bool) []byte

+ func GenerateTLSConfig(config TLSHelperConfig) (tlsCfg *tls.Config, reloadConfig func(), err error)

+ func HealthCheck() error

+ func LoadConfigFromYAML(file string)

+ func NewTrace(title string, ctx context.Context) (trace.Trace, context.Context)

+ func PageRange(count, offset, n int) (int, int)

+ func Println(args ...interface{})

+ func RemoveDuplicates(s []string) (out []string)

+ func SetStatusWithData(w http.ResponseWriter, code, msg string)

+ func UpdateHealthStatus(ok bool)

+ func UpdateMemoryStatus(ok bool)

+ func ValidateAddress(addr string) bool

+ func Version() string

+ func WriteFileSync(filename string, data []byte, perm os.FileMode) error

+ type BytesBuffer struct

+ func (b *BytesBuffer) CopyTo(o []byte) int

+ func (b *BytesBuffer) Length() int

+ func (b *BytesBuffer) Slice(n int) []byte

+ func (b *BytesBuffer) TruncateBy(n int)

+ type Histogram struct

+ func NewHistogram(duration time.Duration, maxVal int64, sigFigs int) *Histogram

+ func (h *Histogram) RecordValue(v int64)

+ func (h *Histogram) Stats()

+ type NonceCounter struct

+ func NewNonceCounter() NonceCounter

+ func (nc *NonceCounter) Generate() [16]byte

+ func (nc *NonceCounter) GenerationNumber(buf []byte) uint64

+ type Options struct

+ ConfigFile string

+ DebugMode bool

+ PortOffset int

+ Version bool

+ var Config Options

type ParsedKey

+ Count uint32

+ func (p ParsedKey) CountPrefix(reverse bool) []byte

+ func (p ParsedKey) IsCount() bool

+ func (p ParsedKey) IsType(typ byte) bool

+ func (p ParsedKey) ReversePrefix() []byte

+ type QueryResWithData struct

+ Data *string

+ Errors []errRes

+ type TLSHelperConfig struct

+ Cert string

+ CertRequired bool

+ ClientAuth string

+ ClientCACerts string

+ ConfigType tlsConfigType

+ Insecure bool

+ Key string

+ KeyPassphrase string

+ MaxVersion string

+ MinVersion string

+ RootCACerts string

+ ServerName string

+ UseSystemClientCACerts bool

+ UseSystemRootCACerts bool

+ type Throttle struct

+ func NewThrottle(max int) *Throttle

+ func (t *Throttle) Done()

+ func (t *Throttle) Start()

+ func (t *Throttle) Wait()

+ type ValueTypeInfo int32

+ const ValueEmpty

+ const ValueMulti

+ const ValuePlain

+ const ValueUid

+ const ValueUnknown

+ func ValueType(hasValue, hasLang, hasSpecialId bool) ValueTypeInfo

type WaterMark

+ func (w *WaterMark) Begin(index uint64)

+ func (w *WaterMark) BeginMany(indices []uint64)

+ func (w *WaterMark) Done(index uint64)

+ func (w *WaterMark) DoneMany(indices []uint64)

+ func (w *WaterMark) SetDoneUntil(val uint64)

+ func (w *WaterMark) WaitForMark(ctx context.Context, index uint64) error

Feb 22, 2017

Changes in this version

+ func Round(d time.Duration) time.Duration

+ func SchemaKey(attr string) []byte

+ func SchemaPrefix() []byte

type ParsedKey

+ func (p ParsedKey) IsSchema() bool

+ func (p ParsedKey) SkipSchema() []byte

Jan 27, 2017

Changes in this version

+ const Success

+ var WhiteSpace = strings.NewReplacer(" ", "", "\t", "")

+ func IsTestRun() bool

+ func SetTestRun()

type Mark

+ Indices []uint64

type ParsedKey

+ func (p ParsedKey) DataPrefix() []byte

type WaterMark

+ func (w *WaterMark) WaitingFor() bool

Dec 26, 2016

Changes in this version

+ func ReverseKey(attr string, uid uint64) []byte

+ type Mark struct

+ Deadline time.Time

+ Done bool

+ Index uint64

type ParsedKey

+ func (p ParsedKey) IsReverse() bool

+ type RaftValue struct

+ Group uint32

+ Index uint64

+ type WaterMark struct

+ Ch chan Mark

+ Name string

+ func (w *WaterMark) DoneUntil() uint64

+ func (w *WaterMark) Init()

Dec 8, 2016

Changes in this version

+ const ErrorInvalidMutation

+ func AssertTrue(b bool)

+ func AssertTruef(b bool, format string, args ...interface{})

+ func Check(err error)

+ func Check2(_ interface{}, err error)

+ func Check2f(_ interface{}, err error, format string, args ...interface{})

+ func Checkf(err error, format string, args ...interface{})

+ func DataKey(attr string, uid uint64) []byte

+ func Errorf(format string, args ...interface{}) error

+ func Fatalf(format string, args ...interface{})

+ func IndexKey(attr, term string) []byte

+ func Printf(format string, args ...interface{})

+ func ReadLine(r *bufio.Reader, buf *bytes.Buffer) error

+ func TraceError(ctx context.Context, err error)

+ func Wrap(err error) error

+ func Wrapf(err error, format string, args ...interface{}) error

+ type ParsedKey struct

+ Attr string

+ Term string

+ Uid uint64

+ func Parse(key []byte) *ParsedKey

+ func (p ParsedKey) IndexPrefix() []byte

+ func (p ParsedKey) IsData() bool

+ func (p ParsedKey) IsIndex() bool

+ func (p ParsedKey) SkipPredicate() []byte

+ func (p ParsedKey) SkipRangeOfSameType() []byte

+ type SafeMutex struct

+ func (s *SafeMutex) AssertLock()

+ func (s *SafeMutex) AssertRLock()

+ func (s *SafeMutex) Lock()

+ func (s *SafeMutex) RLock()

+ func (s *SafeMutex) RUnlock()

+ func (s *SafeMutex) StartWait() *SafeWait

+ func (s *SafeMutex) Unlock()

+ func (s *SafeMutex) Wait()

+ type SafeWait struct

+ func (s *SafeWait) Done()

Sep 1, 2016

Changes in this version

+ func AddInit(f func())

+ func Init()

Aug 11, 2016

Changes in this version

+ const Error

+ const ErrorInvalidMethod

+ const ErrorInvalidRequest

+ const ErrorMissingRequired

+ const ErrorNoData

+ const ErrorNoPermission

+ const ErrorOk

+ const ErrorUnauthorized

+ const ErrorUptodate

+ func PrintVersionOnly() bool

Jul 11, 2016

Changes in this version

+ const DUMMY_UUID

+ const E_ERROR

+ const E_INVALID_METHOD

+ const E_INVALID_REQUEST

+ const E_MISSING_REQUIRED

+ const E_NODATA

+ const E_NOPERMISSION

+ const E_OK

+ const E_UNAUTHORIZED

+ const E_UPTODATE

+ var Nilbyte []byte

+ func Err(entry *logrus.Entry, err error) *logrus.Entry

+ func Log(p string) *logrus.Entry

+ func ParseRequest(w http.ResponseWriter, r *http.Request, data interface{}) bool

+ func Reply(w http.ResponseWriter, rep interface{})

+ func SetError(prev *error, n error)

+ func SetStatus(w http.ResponseWriter, code, msg string)

+ func Trace(ctx context.Context, format string, args ...interface{})

+ func UidlistOffset(b *flatbuffers.Builder, sorted []uint64) flatbuffers.UOffsetT

+ type DirectedEdge struct

+ Attribute string

+ Entity uint64

+ Source string

+ Timestamp time.Time

+ Value []byte

+ ValueId uint64

+ type Elem struct

+ Idx int

+ Uid uint64

+ type Status struct

+ Code string

+ Message string

+ type Uint64Heap []Elem

+ func (h *Uint64Heap) Pop() interface{}

+ func (h *Uint64Heap) Push(x interface{})

+ func (h Uint64Heap) Len() int

+ func (h Uint64Heap) Less(i, j int) bool

+ func (h Uint64Heap) Swap(i, j int)