dgraph

Documentation

Index

• func DeleteNode(ctx context.Context, tx *dgo.Txn, id string) (*api.Response, error)
• func Dial(network, address string, timeout time.Duration) (net.Conn, error)
• func Discard(ctx context.Context, txn *dgo.Txn)
• func InitSchema()
• func IsUID(s string) bool
• func Mutate(ctx context.Context, tx *dgo.Txn, m Mutation) ([]map[string]interface{}, error)
• func NewClient(ctx context.Context) (*dgo.Dgraph, context.CancelFunc, error)
• func NewRestClient() *rest.Client
• func NodeLabel(resourceType string) string
• func ReadNode(ctx context.Context, tx *dgo.Txn, id string) (map[string]interface{}, error)
• func ReadNodeTx(ctx context.Context, id string) (map[string]interface{}, error)
• func RequestTransaction(r *http.Request) *dgo.Txn
• func TransactionMiddleware(next http.Handler) http.Handler
• func WithAuthToken(ctx context.Context) context.Context
• type ListResult
  • func ReadList(ctx context.Context, tx *dgo.Txn, label string, pg pagination.Pagination) (*ListResult, error)
• type Mutation

Functions

func DeleteNode

func DeleteNode(ctx context.Context, tx *dgo.Txn, id string) (*api.Response, error)

func Dial

func Dial(network, address string, timeout time.Duration) (net.Conn, error)

Dial to gRPC service. It is used in health checks

func Discard

func Discard(ctx context.Context, txn *dgo.Txn)

func InitSchema

func InitSchema()

func IsUID

func IsUID(s string) bool

func Mutate

func Mutate(ctx context.Context, tx *dgo.Txn, m Mutation) ([]map[string]interface{}, error)

func NewClient

func NewClient(ctx context.Context) (*dgo.Dgraph, context.CancelFunc, error)

NewClient creates new dgraph client

func NewRestClient

func NewRestClient() *rest.Client

func NodeLabel

func NodeLabel(resourceType string) string

func ReadNode

func ReadNode(ctx context.Context, tx *dgo.Txn, id string) (map[string]interface{}, error)

func ReadNodeTx

func ReadNodeTx(ctx context.Context, id string) (map[string]interface{}, error)

func RequestTransaction

func RequestTransaction(r *http.Request) *dgo.Txn

func TransactionMiddleware

func TransactionMiddleware(next http.Handler) http.Handler

func WithAuthToken

func WithAuthToken(ctx context.Context) context.Context

Types

type ListResult

type ListResult struct {
	Items []map[string]interface{} `json:"items"`
	Total int64                    `json:"total"`
}

func ReadList

func ReadList(ctx context.Context, tx *dgo.Txn, label string, pg pagination.Pagination) (*ListResult, error)

type Mutation

type Mutation struct {
	Input     orderedjson.Map
	NodeLabel string
	ID        string
	By        string
	NoCommit  bool
}