api

package
v240.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 28, 2024 License: Apache-2.0 Imports: 8 Imported by: 33

Documentation

Index

Constants

View Source 
const (
	Dgraph_Login_FullMethodName         = "/api.Dgraph/Login"
	Dgraph_Query_FullMethodName         = "/api.Dgraph/Query"
	Dgraph_Alter_FullMethodName         = "/api.Dgraph/Alter"
	Dgraph_CommitOrAbort_FullMethodName = "/api.Dgraph/CommitOrAbort"
	Dgraph_CheckVersion_FullMethodName  = "/api.Dgraph/CheckVersion"
)

Variables

View Source 
var (
	Request_RespFormat_name = map[int32]string{
		0: "JSON",
		1: "RDF",
	}
	Request_RespFormat_value = map[string]int32{
		"JSON": 0,
		"RDF":  1,
	}
)

Enum value maps for Request_RespFormat.

View Source 
var (
	Operation_DropOp_name = map[int32]string{
		0: "NONE",
		1: "ALL",
		2: "DATA",
		3: "ATTR",
		4: "TYPE",
	}
	Operation_DropOp_value = map[string]int32{
		"NONE": 0,
		"ALL":  1,
		"DATA": 2,
		"ATTR": 3,
		"TYPE": 4,
	}
)

Enum value maps for Operation_DropOp.

View Source 
var (
	Facet_ValType_name = map[int32]string{
		0: "STRING",
		1: "INT",
		2: "FLOAT",
		3: "BOOL",
		4: "DATETIME",
	}
	Facet_ValType_value = map[string]int32{
		"STRING":   0,
		"INT":      1,
		"FLOAT":    2,
		"BOOL":     3,
		"DATETIME": 4,
	}
)

Enum value maps for Facet_ValType.

View Source 
var Dgraph_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.Dgraph",
	HandlerType: (*DgraphServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Login",
			Handler:    _Dgraph_Login_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _Dgraph_Query_Handler,
		},
		{
			MethodName: "Alter",
			Handler:    _Dgraph_Alter_Handler,
		},
		{
			MethodName: "CommitOrAbort",
			Handler:    _Dgraph_CommitOrAbort_Handler,
		},
		{
			MethodName: "CheckVersion",
			Handler:    _Dgraph_CheckVersion_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

Dgraph_ServiceDesc is the grpc.ServiceDesc for Dgraph service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_api_proto protoreflect.FileDescriptor

Functions

func RegisterDgraphServer 

func RegisterDgraphServer(s grpc.ServiceRegistrar, srv DgraphServer)

Types

type Check 

type Check struct {
	// contains filtered or unexported fields
}

func (*Check) Descriptor deprecated 

func (*Check) Descriptor() ([]byte, []int)

Deprecated: Use Check.ProtoReflect.Descriptor instead.

func (*Check) ProtoMessage 

func (*Check) ProtoMessage()

func (*Check) ProtoReflect added in v240.1.0 

func (x *Check) ProtoReflect() protoreflect.Message

func (*Check) Reset 

func (x *Check) Reset()

func (*Check) String 

func (x *Check) String() string

type DgraphClient 

type DgraphClient interface {
	Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*Response, error)
	Query(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	Alter(ctx context.Context, in *Operation, opts ...grpc.CallOption) (*Payload, error)
	CommitOrAbort(ctx context.Context, in *TxnContext, opts ...grpc.CallOption) (*TxnContext, error)
	CheckVersion(ctx context.Context, in *Check, opts ...grpc.CallOption) (*Version, error)
}

DgraphClient is the client API for Dgraph service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDgraphClient 

func NewDgraphClient(cc grpc.ClientConnInterface) DgraphClient

type DgraphServer 

type DgraphServer interface {
	Login(context.Context, *LoginRequest) (*Response, error)
	Query(context.Context, *Request) (*Response, error)
	Alter(context.Context, *Operation) (*Payload, error)
	CommitOrAbort(context.Context, *TxnContext) (*TxnContext, error)
	CheckVersion(context.Context, *Check) (*Version, error)
	// contains filtered or unexported methods
}

DgraphServer is the server API for Dgraph service. All implementations must embed UnimplementedDgraphServer for forward compatibility

type Facet 

type Facet struct {
	Key     string        `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte        `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	ValType Facet_ValType `protobuf:"varint,3,opt,name=val_type,json=valType,proto3,enum=api.Facet_ValType" json:"val_type,omitempty"`
	Tokens  []string      `protobuf:"bytes,4,rep,name=tokens,proto3" json:"tokens,omitempty"` // tokens of value.
	Alias   string        `protobuf:"bytes,5,opt,name=alias,proto3" json:"alias,omitempty"`   // not stored, only used for query.
	// contains filtered or unexported fields
}

func (*Facet) Descriptor deprecated 

func (*Facet) Descriptor() ([]byte, []int)

Deprecated: Use Facet.ProtoReflect.Descriptor instead.

func (*Facet) GetAlias 

func (x *Facet) GetAlias() string

func (*Facet) GetKey 

func (x *Facet) GetKey() string

func (*Facet) GetTokens 

func (x *Facet) GetTokens() []string

func (*Facet) GetValType 

func (x *Facet) GetValType() Facet_ValType

func (*Facet) GetValue 

func (x *Facet) GetValue() []byte

func (*Facet) ProtoMessage 

func (*Facet) ProtoMessage()

func (*Facet) ProtoReflect added in v240.1.0 

func (x *Facet) ProtoReflect() protoreflect.Message

func (*Facet) Reset 

func (x *Facet) Reset()

func (*Facet) String 

func (x *Facet) String() string

type Facet_ValType 

type Facet_ValType int32
const (
	Facet_STRING   Facet_ValType = 0
	Facet_INT      Facet_ValType = 1
	Facet_FLOAT    Facet_ValType = 2
	Facet_BOOL     Facet_ValType = 3
	Facet_DATETIME Facet_ValType = 4
)

func (Facet_ValType) Descriptor added in v240.1.0 

func (Facet_ValType) Descriptor() protoreflect.EnumDescriptor

func (Facet_ValType) Enum added in v240.1.0 

func (x Facet_ValType) Enum() *Facet_ValType

func (Facet_ValType) EnumDescriptor deprecated 

func (Facet_ValType) EnumDescriptor() ([]byte, []int)

Deprecated: Use Facet_ValType.Descriptor instead.

func (Facet_ValType) Number added in v240.1.0 

func (x Facet_ValType) Number() protoreflect.EnumNumber

func (Facet_ValType) String 

func (x Facet_ValType) String() string

func (Facet_ValType) Type added in v240.1.0 

func (Facet_ValType) Type() protoreflect.EnumType

type Jwt 

type Jwt struct {
	AccessJwt  string `protobuf:"bytes,1,opt,name=access_jwt,json=accessJwt,proto3" json:"access_jwt,omitempty"`
	RefreshJwt string `protobuf:"bytes,2,opt,name=refresh_jwt,json=refreshJwt,proto3" json:"refresh_jwt,omitempty"`
	// contains filtered or unexported fields
}

func (*Jwt) Descriptor deprecated 

func (*Jwt) Descriptor() ([]byte, []int)

Deprecated: Use Jwt.ProtoReflect.Descriptor instead.

func (*Jwt) GetAccessJwt 

func (x *Jwt) GetAccessJwt() string

func (*Jwt) GetRefreshJwt 

func (x *Jwt) GetRefreshJwt() string

func (*Jwt) ProtoMessage 

func (*Jwt) ProtoMessage()

func (*Jwt) ProtoReflect added in v240.1.0 

func (x *Jwt) ProtoReflect() protoreflect.Message

func (*Jwt) Reset 

func (x *Jwt) Reset()

func (*Jwt) String 

func (x *Jwt) String() string

type Latency 

type Latency struct {
	ParsingNs         uint64 `protobuf:"varint,1,opt,name=parsing_ns,json=parsingNs,proto3" json:"parsing_ns,omitempty"`
	ProcessingNs      uint64 `protobuf:"varint,2,opt,name=processing_ns,json=processingNs,proto3" json:"processing_ns,omitempty"`
	EncodingNs        uint64 `protobuf:"varint,3,opt,name=encoding_ns,json=encodingNs,proto3" json:"encoding_ns,omitempty"`
	AssignTimestampNs uint64 `protobuf:"varint,4,opt,name=assign_timestamp_ns,json=assignTimestampNs,proto3" json:"assign_timestamp_ns,omitempty"`
	TotalNs           uint64 `protobuf:"varint,5,opt,name=total_ns,json=totalNs,proto3" json:"total_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*Latency) Descriptor deprecated 

func (*Latency) Descriptor() ([]byte, []int)

Deprecated: Use Latency.ProtoReflect.Descriptor instead.

func (*Latency) GetAssignTimestampNs 

func (x *Latency) GetAssignTimestampNs() uint64

func (*Latency) GetEncodingNs 

func (x *Latency) GetEncodingNs() uint64

func (*Latency) GetParsingNs 

func (x *Latency) GetParsingNs() uint64

func (*Latency) GetProcessingNs 

func (x *Latency) GetProcessingNs() uint64

func (*Latency) GetTotalNs 

func (x *Latency) GetTotalNs() uint64

func (*Latency) ProtoMessage 

func (*Latency) ProtoMessage()

func (*Latency) ProtoReflect added in v240.1.0 

func (x *Latency) ProtoReflect() protoreflect.Message

func (*Latency) Reset 

func (x *Latency) Reset()

func (*Latency) String 

func (x *Latency) String() string

type ListOfString 

type ListOfString struct {
	Value []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOfString) Descriptor deprecated 

func (*ListOfString) Descriptor() ([]byte, []int)

Deprecated: Use ListOfString.ProtoReflect.Descriptor instead.

func (*ListOfString) GetValue 

func (x *ListOfString) GetValue() []string

func (*ListOfString) ProtoMessage 

func (*ListOfString) ProtoMessage()

func (*ListOfString) ProtoReflect added in v240.1.0 

func (x *ListOfString) ProtoReflect() protoreflect.Message

func (*ListOfString) Reset 

func (x *ListOfString) Reset()

func (*ListOfString) String 

func (x *ListOfString) String() string

type LoginRequest 

type LoginRequest struct {
	Userid       string `protobuf:"bytes,1,opt,name=userid,proto3" json:"userid,omitempty"`
	Password     string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	RefreshToken string `protobuf:"bytes,3,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"`
	Namespace    uint64 `protobuf:"varint,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginRequest) Descriptor deprecated 

func (*LoginRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.

func (*LoginRequest) GetNamespace 

func (x *LoginRequest) GetNamespace() uint64

func (*LoginRequest) GetPassword 

func (x *LoginRequest) GetPassword() string

func (*LoginRequest) GetRefreshToken 

func (x *LoginRequest) GetRefreshToken() string

func (*LoginRequest) GetUserid 

func (x *LoginRequest) GetUserid() string

func (*LoginRequest) ProtoMessage 

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) ProtoReflect added in v240.1.0 

func (x *LoginRequest) ProtoReflect() protoreflect.Message

func (*LoginRequest) Reset 

func (x *LoginRequest) Reset()

func (*LoginRequest) String 

func (x *LoginRequest) String() string

type Metrics 

type Metrics struct {

	// num_uids is the map of number of uids processed by each attribute.
	NumUids map[string]uint64 `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Metrics) Descriptor deprecated 

func (*Metrics) Descriptor() ([]byte, []int)

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetNumUids 

func (x *Metrics) GetNumUids() map[string]uint64

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect added in v240.1.0 

func (x *Metrics) ProtoReflect() protoreflect.Message

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

type Mutation 

type Mutation struct {
	SetJson    []byte   `protobuf:"bytes,1,opt,name=set_json,json=setJson,proto3" json:"set_json,omitempty"`
	DeleteJson []byte   `protobuf:"bytes,2,opt,name=delete_json,json=deleteJson,proto3" json:"delete_json,omitempty"`
	SetNquads  []byte   `protobuf:"bytes,3,opt,name=set_nquads,json=setNquads,proto3" json:"set_nquads,omitempty"`
	DelNquads  []byte   `protobuf:"bytes,4,opt,name=del_nquads,json=delNquads,proto3" json:"del_nquads,omitempty"`
	Set        []*NQuad `protobuf:"bytes,5,rep,name=set,proto3" json:"set,omitempty"`
	Del        []*NQuad `protobuf:"bytes,6,rep,name=del,proto3" json:"del,omitempty"`
	// This is being used for upserts.
	Cond string `protobuf:"bytes,9,opt,name=cond,proto3" json:"cond,omitempty"`
	// This field is a duplicate of the one in Request and placed here for convenience.
	CommitNow bool `protobuf:"varint,14,opt,name=commit_now,json=commitNow,proto3" json:"commit_now,omitempty"`
	// contains filtered or unexported fields
}

func (*Mutation) Descriptor deprecated 

func (*Mutation) Descriptor() ([]byte, []int)

Deprecated: Use Mutation.ProtoReflect.Descriptor instead.

func (*Mutation) GetCommitNow 

func (x *Mutation) GetCommitNow() bool

func (*Mutation) GetCond 

func (x *Mutation) GetCond() string

func (*Mutation) GetDel 

func (x *Mutation) GetDel() []*NQuad

func (*Mutation) GetDelNquads 

func (x *Mutation) GetDelNquads() []byte

func (*Mutation) GetDeleteJson 

func (x *Mutation) GetDeleteJson() []byte

func (*Mutation) GetSet 

func (x *Mutation) GetSet() []*NQuad

func (*Mutation) GetSetJson 

func (x *Mutation) GetSetJson() []byte

func (*Mutation) GetSetNquads 

func (x *Mutation) GetSetNquads() []byte

func (*Mutation) ProtoMessage 

func (*Mutation) ProtoMessage()

func (*Mutation) ProtoReflect added in v240.1.0 

func (x *Mutation) ProtoReflect() protoreflect.Message

func (*Mutation) Reset 

func (x *Mutation) Reset()

func (*Mutation) String 

func (x *Mutation) String() string

type NQuad 

type NQuad struct {
	Subject     string   `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Predicate   string   `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
	ObjectId    string   `protobuf:"bytes,3,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	ObjectValue *Value   `protobuf:"bytes,4,opt,name=object_value,json=objectValue,proto3" json:"object_value,omitempty"`
	Lang        string   `protobuf:"bytes,6,opt,name=lang,proto3" json:"lang,omitempty"`
	Facets      []*Facet `protobuf:"bytes,7,rep,name=facets,proto3" json:"facets,omitempty"`
	Namespace   uint64   `protobuf:"varint,8,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*NQuad) Descriptor deprecated 

func (*NQuad) Descriptor() ([]byte, []int)

Deprecated: Use NQuad.ProtoReflect.Descriptor instead.

func (*NQuad) GetFacets 

func (x *NQuad) GetFacets() []*Facet

func (*NQuad) GetLang 

func (x *NQuad) GetLang() string

func (*NQuad) GetNamespace 

func (x *NQuad) GetNamespace() uint64

func (*NQuad) GetObjectId 

func (x *NQuad) GetObjectId() string

func (*NQuad) GetObjectValue 

func (x *NQuad) GetObjectValue() *Value

func (*NQuad) GetPredicate 

func (x *NQuad) GetPredicate() string

func (*NQuad) GetSubject 

func (x *NQuad) GetSubject() string

func (*NQuad) ProtoMessage 

func (*NQuad) ProtoMessage()

func (*NQuad) ProtoReflect added in v240.1.0 

func (x *NQuad) ProtoReflect() protoreflect.Message

func (*NQuad) Reset 

func (x *NQuad) Reset()

func (*NQuad) String 

func (x *NQuad) String() string

type Operation 

type Operation struct {
	Schema   string           `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	DropAttr string           `protobuf:"bytes,2,opt,name=drop_attr,json=dropAttr,proto3" json:"drop_attr,omitempty"`
	DropAll  bool             `protobuf:"varint,3,opt,name=drop_all,json=dropAll,proto3" json:"drop_all,omitempty"`
	DropOp   Operation_DropOp `protobuf:"varint,4,opt,name=drop_op,json=dropOp,proto3,enum=api.Operation_DropOp" json:"drop_op,omitempty"`
	// If drop_op is ATTR or TYPE, drop_value holds the name of the predicate or
	// type to delete.
	DropValue string `protobuf:"bytes,5,opt,name=drop_value,json=dropValue,proto3" json:"drop_value,omitempty"`
	// run indexes in background.
	RunInBackground bool `protobuf:"varint,6,opt,name=run_in_background,json=runInBackground,proto3" json:"run_in_background,omitempty"`
	// contains filtered or unexported fields
}

func (*Operation) Descriptor deprecated 

func (*Operation) Descriptor() ([]byte, []int)

Deprecated: Use Operation.ProtoReflect.Descriptor instead.

func (*Operation) GetDropAll 

func (x *Operation) GetDropAll() bool

func (*Operation) GetDropAttr 

func (x *Operation) GetDropAttr() string

func (*Operation) GetDropOp 

func (x *Operation) GetDropOp() Operation_DropOp

func (*Operation) GetDropValue 

func (x *Operation) GetDropValue() string

func (*Operation) GetRunInBackground 

func (x *Operation) GetRunInBackground() bool

func (*Operation) GetSchema 

func (x *Operation) GetSchema() string

func (*Operation) ProtoMessage 

func (*Operation) ProtoMessage()

func (*Operation) ProtoReflect added in v240.1.0 

func (x *Operation) ProtoReflect() protoreflect.Message

func (*Operation) Reset 

func (x *Operation) Reset()

func (*Operation) String 

func (x *Operation) String() string

type Operation_DropOp 

type Operation_DropOp int32
const (
	Operation_NONE Operation_DropOp = 0
	Operation_ALL  Operation_DropOp = 1
	Operation_DATA Operation_DropOp = 2
	Operation_ATTR Operation_DropOp = 3
	Operation_TYPE Operation_DropOp = 4
)

func (Operation_DropOp) Descriptor added in v240.1.0 

func (Operation_DropOp) Descriptor() protoreflect.EnumDescriptor

func (Operation_DropOp) Enum added in v240.1.0 

func (x Operation_DropOp) Enum() *Operation_DropOp

func (Operation_DropOp) EnumDescriptor deprecated 

func (Operation_DropOp) EnumDescriptor() ([]byte, []int)

Deprecated: Use Operation_DropOp.Descriptor instead.

func (Operation_DropOp) Number added in v240.1.0 

func (x Operation_DropOp) Number() protoreflect.EnumNumber

func (Operation_DropOp) String 

func (x Operation_DropOp) String() string

func (Operation_DropOp) Type added in v240.1.0 

func (Operation_DropOp) Type() protoreflect.EnumType

type Payload 

type Payload struct {
	Data []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

Worker services.

func (*Payload) Descriptor deprecated 

func (*Payload) Descriptor() ([]byte, []int)

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetData 

func (x *Payload) GetData() []byte

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect added in v240.1.0 

func (x *Payload) ProtoReflect() protoreflect.Message

func (*Payload) Reset 

func (x *Payload) Reset()

func (*Payload) String 

func (x *Payload) String() string

type Request 

type Request struct {
	StartTs uint64            `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	Query   string            `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	Vars    map[string]string `` // Support for GraphQL like variables.
	/* 149-byte string literal not displayed */
	ReadOnly   bool               `protobuf:"varint,6,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	BestEffort bool               `protobuf:"varint,7,opt,name=best_effort,json=bestEffort,proto3" json:"best_effort,omitempty"`
	Mutations  []*Mutation        `protobuf:"bytes,12,rep,name=mutations,proto3" json:"mutations,omitempty"`
	CommitNow  bool               `protobuf:"varint,13,opt,name=commit_now,json=commitNow,proto3" json:"commit_now,omitempty"`
	RespFormat Request_RespFormat `protobuf:"varint,14,opt,name=resp_format,json=respFormat,proto3,enum=api.Request_RespFormat" json:"resp_format,omitempty"`
	Hash       string             `protobuf:"bytes,15,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated 

func (*Request) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetBestEffort 

func (x *Request) GetBestEffort() bool

func (*Request) GetCommitNow 

func (x *Request) GetCommitNow() bool

func (*Request) GetHash 

func (x *Request) GetHash() string

func (*Request) GetMutations 

func (x *Request) GetMutations() []*Mutation

func (*Request) GetQuery 

func (x *Request) GetQuery() string

func (*Request) GetReadOnly 

func (x *Request) GetReadOnly() bool

func (*Request) GetRespFormat 

func (x *Request) GetRespFormat() Request_RespFormat

func (*Request) GetStartTs 

func (x *Request) GetStartTs() uint64

func (*Request) GetVars 

func (x *Request) GetVars() map[string]string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect added in v240.1.0 

func (x *Request) ProtoReflect() protoreflect.Message

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Request_RespFormat 

type Request_RespFormat int32
const (
	Request_JSON Request_RespFormat = 0
	Request_RDF  Request_RespFormat = 1
)

func (Request_RespFormat) Descriptor added in v240.1.0 

func (Request_RespFormat) Descriptor() protoreflect.EnumDescriptor

func (Request_RespFormat) Enum added in v240.1.0 

func (x Request_RespFormat) Enum() *Request_RespFormat

func (Request_RespFormat) EnumDescriptor deprecated 

func (Request_RespFormat) EnumDescriptor() ([]byte, []int)

Deprecated: Use Request_RespFormat.Descriptor instead.

func (Request_RespFormat) Number added in v240.1.0 

func (x Request_RespFormat) Number() protoreflect.EnumNumber

func (Request_RespFormat) String 

func (x Request_RespFormat) String() string

func (Request_RespFormat) Type added in v240.1.0 

func (Request_RespFormat) Type() protoreflect.EnumType

type Response 

type Response struct {
	Json    []byte      `protobuf:"bytes,1,opt,name=json,proto3" json:"json,omitempty"`
	Txn     *TxnContext `protobuf:"bytes,2,opt,name=txn,proto3" json:"txn,omitempty"`
	Latency *Latency    `protobuf:"bytes,3,opt,name=latency,proto3" json:"latency,omitempty"`
	// Metrics contains all metrics related to the query.
	Metrics *Metrics `protobuf:"bytes,4,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// uids contains a mapping of blank_node => uid for the node. It only returns uids
	// that were created as part of a mutation.
	Uids map[string]string        `` /* 150-byte string literal not displayed */
	Rdf  []byte                   `protobuf:"bytes,13,opt,name=rdf,proto3" json:"rdf,omitempty"`
	Hdrs map[string]*ListOfString `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetHdrs 

func (x *Response) GetHdrs() map[string]*ListOfString

func (*Response) GetJson 

func (x *Response) GetJson() []byte

func (*Response) GetLatency 

func (x *Response) GetLatency() *Latency

func (*Response) GetMetrics 

func (x *Response) GetMetrics() *Metrics

func (*Response) GetRdf 

func (x *Response) GetRdf() []byte

func (*Response) GetTxn 

func (x *Response) GetTxn() *TxnContext

func (*Response) GetUids 

func (x *Response) GetUids() map[string]string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect added in v240.1.0 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type TxnContext 

type TxnContext struct {
	StartTs  uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	CommitTs uint64   `protobuf:"varint,2,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
	Aborted  bool     `protobuf:"varint,3,opt,name=aborted,proto3" json:"aborted,omitempty"`
	Keys     []string `protobuf:"bytes,4,rep,name=keys,proto3" json:"keys,omitempty"`   // List of keys to be used for conflict detection.
	Preds    []string `protobuf:"bytes,5,rep,name=preds,proto3" json:"preds,omitempty"` // List of predicates involved in this transaction.
	Hash     string   `protobuf:"bytes,6,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*TxnContext) Descriptor deprecated 

func (*TxnContext) Descriptor() ([]byte, []int)

Deprecated: Use TxnContext.ProtoReflect.Descriptor instead.

func (*TxnContext) GetAborted 

func (x *TxnContext) GetAborted() bool

func (*TxnContext) GetCommitTs 

func (x *TxnContext) GetCommitTs() uint64

func (*TxnContext) GetHash 

func (x *TxnContext) GetHash() string

func (*TxnContext) GetKeys 

func (x *TxnContext) GetKeys() []string

func (*TxnContext) GetPreds 

func (x *TxnContext) GetPreds() []string

func (*TxnContext) GetStartTs 

func (x *TxnContext) GetStartTs() uint64

func (*TxnContext) ProtoMessage 

func (*TxnContext) ProtoMessage()

func (*TxnContext) ProtoReflect added in v240.1.0 

func (x *TxnContext) ProtoReflect() protoreflect.Message

func (*TxnContext) Reset 

func (x *TxnContext) Reset()

func (*TxnContext) String 

func (x *TxnContext) String() string

type Uids 

type Uids struct {
	Uids []string `protobuf:"bytes,1,rep,name=uids,proto3" json:"uids,omitempty"`
	// contains filtered or unexported fields
}

func (*Uids) Descriptor deprecated 

func (*Uids) Descriptor() ([]byte, []int)

Deprecated: Use Uids.ProtoReflect.Descriptor instead.

func (*Uids) GetUids 

func (x *Uids) GetUids() []string

func (*Uids) ProtoMessage 

func (*Uids) ProtoMessage()

func (*Uids) ProtoReflect added in v240.1.0 

func (x *Uids) ProtoReflect() protoreflect.Message

func (*Uids) Reset 

func (x *Uids) Reset()

func (*Uids) String 

func (x *Uids) String() string

type UnimplementedDgraphServer 

type UnimplementedDgraphServer struct {
}

UnimplementedDgraphServer must be embedded to have forward compatible implementations.

func (UnimplementedDgraphServer) Alter 

func (UnimplementedDgraphServer) Alter(context.Context, *Operation) (*Payload, error)

func (UnimplementedDgraphServer) CheckVersion 

func (UnimplementedDgraphServer) CheckVersion(context.Context, *Check) (*Version, error)

func (UnimplementedDgraphServer) CommitOrAbort 

func (UnimplementedDgraphServer) CommitOrAbort(context.Context, *TxnContext) (*TxnContext, error)

func (UnimplementedDgraphServer) Login 

func (UnimplementedDgraphServer) Login(context.Context, *LoginRequest) (*Response, error)

func (UnimplementedDgraphServer) Query 

func (UnimplementedDgraphServer) Query(context.Context, *Request) (*Response, error)

type UnsafeDgraphServer added in v240.1.0 

type UnsafeDgraphServer interface {
	// contains filtered or unexported methods
}

UnsafeDgraphServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DgraphServer will result in compilation errors.

type Value 

type Value struct {

	// Types that are assignable to Val:
	//
	//	*Value_DefaultVal
	//	*Value_BytesVal
	//	*Value_IntVal
	//	*Value_BoolVal
	//	*Value_StrVal
	//	*Value_DoubleVal
	//	*Value_GeoVal
	//	*Value_DateVal
	//	*Value_DatetimeVal
	//	*Value_PasswordVal
	//	*Value_UidVal
	//	*Value_BigfloatVal
	//	*Value_Vfloat32Val
	Val isValue_Val `protobuf_oneof:"val"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated 

func (*Value) Descriptor() ([]byte, []int)

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBigfloatVal 

func (x *Value) GetBigfloatVal() []byte

func (*Value) GetBoolVal 

func (x *Value) GetBoolVal() bool

func (*Value) GetBytesVal 

func (x *Value) GetBytesVal() []byte

func (*Value) GetDateVal 

func (x *Value) GetDateVal() []byte

func (*Value) GetDatetimeVal 

func (x *Value) GetDatetimeVal() []byte

func (*Value) GetDefaultVal 

func (x *Value) GetDefaultVal() string

func (*Value) GetDoubleVal 

func (x *Value) GetDoubleVal() float64

func (*Value) GetGeoVal 

func (x *Value) GetGeoVal() []byte

func (*Value) GetIntVal 

func (x *Value) GetIntVal() int64

func (*Value) GetPasswordVal 

func (x *Value) GetPasswordVal() string

func (*Value) GetStrVal 

func (x *Value) GetStrVal() string

func (*Value) GetUidVal 

func (x *Value) GetUidVal() uint64

func (*Value) GetVal 

func (m *Value) GetVal() isValue_Val

func (*Value) GetVfloat32Val 

func (x *Value) GetVfloat32Val() []byte

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect added in v240.1.0 

func (x *Value) ProtoReflect() protoreflect.Message

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

type Value_BigfloatVal 

type Value_BigfloatVal struct {
	BigfloatVal []byte `protobuf:"bytes,12,opt,name=bigfloat_val,json=bigfloatVal,proto3,oneof"`
}

type Value_BoolVal 

type Value_BoolVal struct {
	BoolVal bool `protobuf:"varint,4,opt,name=bool_val,json=boolVal,proto3,oneof"`
}

type Value_BytesVal 

type Value_BytesVal struct {
	BytesVal []byte `protobuf:"bytes,2,opt,name=bytes_val,json=bytesVal,proto3,oneof"`
}

type Value_DateVal 

type Value_DateVal struct {
	DateVal []byte `protobuf:"bytes,8,opt,name=date_val,json=dateVal,proto3,oneof"`
}

type Value_DatetimeVal 

type Value_DatetimeVal struct {
	DatetimeVal []byte `protobuf:"bytes,9,opt,name=datetime_val,json=datetimeVal,proto3,oneof"`
}

type Value_DefaultVal 

type Value_DefaultVal struct {
	DefaultVal string `protobuf:"bytes,1,opt,name=default_val,json=defaultVal,proto3,oneof"`
}

type Value_DoubleVal 

type Value_DoubleVal struct {
	DoubleVal float64 `protobuf:"fixed64,6,opt,name=double_val,json=doubleVal,proto3,oneof"`
}

type Value_GeoVal 

type Value_GeoVal struct {
	GeoVal []byte `protobuf:"bytes,7,opt,name=geo_val,json=geoVal,proto3,oneof"` // Geo data in WKB format
}

type Value_IntVal 

type Value_IntVal struct {
	IntVal int64 `protobuf:"varint,3,opt,name=int_val,json=intVal,proto3,oneof"`
}

type Value_PasswordVal 

type Value_PasswordVal struct {
	PasswordVal string `protobuf:"bytes,10,opt,name=password_val,json=passwordVal,proto3,oneof"`
}

type Value_StrVal 

type Value_StrVal struct {
	StrVal string `protobuf:"bytes,5,opt,name=str_val,json=strVal,proto3,oneof"`
}

type Value_UidVal 

type Value_UidVal struct {
	UidVal uint64 `protobuf:"varint,11,opt,name=uid_val,json=uidVal,proto3,oneof"`
}

type Value_Vfloat32Val 

type Value_Vfloat32Val struct {
	Vfloat32Val []byte `protobuf:"bytes,13,opt,name=vfloat32_val,json=vfloat32Val,proto3,oneof"`
}

type Version 

type Version struct {
	Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*Version) Descriptor deprecated 

func (*Version) Descriptor() ([]byte, []int)

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetTag 

func (x *Version) GetTag() string

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) ProtoReflect added in v240.1.0 

func (x *Version) ProtoReflect() protoreflect.Message

func (*Version) Reset 

func (x *Version) Reset()

func (*Version) String 

func (x *Version) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.