edgraph

func AuthSuperAdmin ¶

func AuthSuperAdmin(ctx context.Context) error

AuthSuperAdmin authorizes the operations for the users who belong to the guardians group in the galaxy namespace. This authorization is used for admin usages like creation and deletion of a namespace, resetting passwords across namespaces etc. NOTE: The caller should not wrap the error returned. If needed, propagate the GRPC error code.

func AuthorizeGuardians ¶

func AuthorizeGuardians(ctx context.Context) error

AuthorizeGuardians authorizes the operation for users which belong to Guardians group. NOTE: The caller should not wrap the error returned. If needed, propagate the GRPC error code.

func GetGQLSchema ¶

func GetGQLSchema(namespace uint64) (uid, graphQLSchema string, err error)

GetGQLSchema queries for the GraphQL schema node, and returns the uid and the GraphQL schema. If multiple schema nodes were found, it returns an error.

func Init ¶

func Init()

func InitializeAcl ¶

func InitializeAcl(closer *z.Closer)

upserts the Groot account.

func InsertDropRecord ¶

func InsertDropRecord(ctx context.Context, dropOp string) error

InsertDropRecord is used to insert a helper record when a DROP operation is performed. This helper record lets us know during backup that a DROP operation was performed and that we need to write this information in backup manifest. So that while restoring from a backup series, we can create an exact replica of the system which existed at the time the last backup was taken. Note that if the server crashes after the DROP operation & before this helper record is inserted, then restoring from the incremental backup of such a DB would restore even the dropped data back. This is also used to capture the delete namespace operation during backup.

func ParseMutationObject ¶

func ParseMutationObject(mu *api.Mutation, isGraphql bool) (*dql.Mutation, error)

ParseMutationObject tries to consolidate fields of the api.Mutation into the corresponding field of the returned dql.Mutation. For example, the 3 fields, api.Mutation#SetJson, api.Mutation#SetNquads and api.Mutation#Set are consolidated into the dql.Mutation.Set field. Similarly the 3 fields api.Mutation#DeleteJson, api.Mutation#DelNquads and api.Mutation#Del are merged into the dql.Mutation#Del field.

func ProcessPersistedQuery ¶

func ProcessPersistedQuery(ctx context.Context, gqlReq *schema.Request) error

ProcessPersistedQuery stores and retrieves persisted queries by following waterfall logic:

1. If sha256Hash is not provided process queries without persisting
2. If sha256Hash is provided try retrieving persisted queries 2a. Persisted Query not found i) If query is not provided then throw "PersistedQueryNotFound" ii) If query is provided then store query in dgraph only if sha256 of the query is correct otherwise throw "provided sha does not match query" 2b. Persisted Query found i) If query is not provided then update gqlRes with the found query and proceed ii) If query is provided then match query retrieved, if identical do nothing else throw "query does not match persisted query"

func RefreshACLs ¶

func RefreshACLs(ctx context.Context)

func SubscribeForAclUpdates ¶

func SubscribeForAclUpdates(closer *z.Closer)

SubscribeForAclUpdates subscribes for ACL predicates and updates the acl cache.

func UpdateGQLSchema ¶

func UpdateGQLSchema(ctx context.Context, gqlSchema,
	dgraphSchema string) (*pb.UpdateGraphQLSchemaResponse, error)

UpdateGQLSchema updates the GraphQL and Dgraph schemas using the given inputs. It first validates and parses the dgraphSchema given in input. If that fails, it returns an error. All this is done on the alpha on which the update request is received. Then it sends an update request to the worker, which is executed only on Group-1 leader.