edgraph

Documentation

Overview

* Copyright (C) 2017 Dgraph Labs, Inc. and Contributors * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see <http://www.gnu.org/licenses/>.

* Copyright (C) 2017 Dgraph Labs, Inc. and Contributors * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see <http://www.gnu.org/licenses/>.

* Copyright (C) 2017 Dgraph Labs, Inc. and Contributors * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see <http://www.gnu.org/licenses/>.

Index

• Constants
• Variables
• func SetConfiguration(newConfig Options)
• type Options
• type Server
  • func (s *Server) Alter(ctx context.Context, op *protos.Operation) (*protos.Payload, error)
  • func (s *Server) CheckVersion(ctx context.Context, c *protos.Check) (v *protos.Version, err error)
  • func (s *Server) CommitOrAbort(ctx context.Context, tc *protos.TxnContext) (*protos.TxnContext, error)
  • func (s *Server) Mutate(ctx context.Context, mu *protos.Mutation) (resp *protos.Assigned, err error)
  • func (s *Server) Query(ctx context.Context, req *protos.Request) (resp *protos.Response, err error)
• type ServerState
  • func NewServerState() (state ServerState)
  • func (s *ServerState) Dispose() error

Constants

const MinAllottedMemory = 1024.0

Variables

var DefaultConfig = Options{
	PostingDir:    "p",
	PostingTables: "loadtoram",
	WALDir:        "w",
	Nomutations:   false,

	AllottedMemory: -1.0,

	ExportPath:          "export",
	NumPendingProposals: 2000,
	Tracing:             0.0,
	MyAddr:              "",
	ZeroAddr:            "localhost:7080",
	MaxPendingCount:     1000,
	ExpandEdge:          true,

	ConfigFile: "",
	DebugMode:  false,
}

Functions

func SetConfiguration

func SetConfiguration(newConfig Options)

Types

type Options

type Options struct {
	PostingDir    string
	PostingTables string
	WALDir        string
	Nomutations   bool

	AllottedMemory float64

	ExportPath          string
	NumPendingProposals int
	Tracing             float64
	MyAddr              string
	ZeroAddr            string
	RaftId              uint64
	MaxPendingCount     uint64
	ExpandEdge          bool

	ConfigFile string
	DebugMode  bool
}

var Config Options

TODO(tzdybal) - remove global

type Server

type Server struct{}

Server implements protos.DgraphServer

func (*Server) Alter

func (s *Server) Alter(ctx context.Context, op *protos.Operation) (*protos.Payload, error)

func (*Server) CheckVersion

func (s *Server) CheckVersion(ctx context.Context, c *protos.Check) (v *protos.Version, err error)

func (*Server) CommitOrAbort

func (s *Server) CommitOrAbort(ctx context.Context, tc *protos.TxnContext) (*protos.TxnContext,
	error)

func (*Server) Mutate

func (s *Server) Mutate(ctx context.Context, mu *protos.Mutation) (resp *protos.Assigned, err error)

func (*Server) Query

func (s *Server) Query(ctx context.Context, req *protos.Request) (resp *protos.Response, err error)

This method is used to execute the query and return the response to the client as a protocol buffer message.

type ServerState

type ServerState struct {
	FinishCh   chan struct{} // channel to wait for all pending reqs to finish.
	ShutdownCh chan struct{} // channel to signal shutdown.

	Pstore   *badger.ManagedDB
	WALstore *badger.ManagedDB
	// contains filtered or unexported fields
}

var State ServerState

TODO(tzdybal) - remove global

func NewServerState

func NewServerState() (state ServerState)

func (*ServerState) Dispose

func (s *ServerState) Dispose() error