Help us shape the future of Go! Take the 2026 Go Developer Survey

api

package
v2.2.0 Latest Latest
Warning

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

Go to latest
Published: Jan 29, 2020 License: Apache-2.0 Imports: 10 Imported by: 83

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthApi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group")
)
View Source
var Facet_ValType_name = map[int32]string{
	0: "STRING",
	1: "INT",
	2: "FLOAT",
	3: "BOOL",
	4: "DATETIME",
}
View Source
var Facet_ValType_value = map[string]int32{
	"STRING":   0,
	"INT":      1,
	"FLOAT":    2,
	"BOOL":     3,
	"DATETIME": 4,
}
View Source
var Operation_DropOp_name = map[int32]string{
	0: "NONE",
	1: "ALL",
	2: "DATA",
	3: "ATTR",
	4: "TYPE",
}
View Source
var Operation_DropOp_value = map[string]int32{
	"NONE": 0,
	"ALL":  1,
	"DATA": 2,
	"ATTR": 3,
	"TYPE": 4,
}

Functions

func RegisterDgraphServer

func RegisterDgraphServer(s *grpc.Server, srv DgraphServer)

Types

type Check

type Check struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Check) Descriptor

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

func (*Check) Marshal

func (m *Check) Marshal() (dAtA []byte, err error)

func (*Check) MarshalTo

func (m *Check) MarshalTo(dAtA []byte) (int, error)

func (*Check) MarshalToSizedBuffer

func (m *Check) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Check) ProtoMessage

func (*Check) ProtoMessage()

func (*Check) Reset

func (m *Check) Reset()

func (*Check) Size

func (m *Check) Size() (n int)

func (*Check) String

func (m *Check) String() string

func (*Check) Unmarshal

func (m *Check) Unmarshal(dAtA []byte) error

func (*Check) XXX_DiscardUnknown

func (m *Check) XXX_DiscardUnknown()

func (*Check) XXX_Marshal

func (m *Check) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Check) XXX_Merge

func (m *Check) XXX_Merge(src proto.Message)

func (*Check) XXX_Size

func (m *Check) XXX_Size() int

func (*Check) XXX_Unmarshal

func (m *Check) XXX_Unmarshal(b []byte) error

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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDgraphClient

func NewDgraphClient(cc *grpc.ClientConn) 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)
}

DgraphServer is the server API for Dgraph service.

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"`
	Alias                string        `protobuf:"bytes,5,opt,name=alias,proto3" json:"alias,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Facet) Descriptor

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

func (*Facet) GetAlias

func (m *Facet) GetAlias() string

func (*Facet) GetKey

func (m *Facet) GetKey() string

func (*Facet) GetTokens

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

func (*Facet) GetValType

func (m *Facet) GetValType() Facet_ValType

func (*Facet) GetValue

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

func (*Facet) Marshal

func (m *Facet) Marshal() (dAtA []byte, err error)

func (*Facet) MarshalTo

func (m *Facet) MarshalTo(dAtA []byte) (int, error)

func (*Facet) MarshalToSizedBuffer

func (m *Facet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Facet) ProtoMessage

func (*Facet) ProtoMessage()

func (*Facet) Reset

func (m *Facet) Reset()

func (*Facet) Size

func (m *Facet) Size() (n int)

func (*Facet) String

func (m *Facet) String() string

func (*Facet) Unmarshal

func (m *Facet) Unmarshal(dAtA []byte) error

func (*Facet) XXX_DiscardUnknown

func (m *Facet) XXX_DiscardUnknown()

func (*Facet) XXX_Marshal

func (m *Facet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Facet) XXX_Merge

func (m *Facet) XXX_Merge(src proto.Message)

func (*Facet) XXX_Size

func (m *Facet) XXX_Size() int

func (*Facet) XXX_Unmarshal

func (m *Facet) XXX_Unmarshal(b []byte) error

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) EnumDescriptor

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

func (Facet_ValType) String

func (x Facet_ValType) String() string

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Jwt) Descriptor

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

func (*Jwt) GetAccessJwt

func (m *Jwt) GetAccessJwt() string

func (*Jwt) GetRefreshJwt

func (m *Jwt) GetRefreshJwt() string

func (*Jwt) Marshal

func (m *Jwt) Marshal() (dAtA []byte, err error)

func (*Jwt) MarshalTo

func (m *Jwt) MarshalTo(dAtA []byte) (int, error)

func (*Jwt) MarshalToSizedBuffer

func (m *Jwt) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Jwt) ProtoMessage

func (*Jwt) ProtoMessage()

func (*Jwt) Reset

func (m *Jwt) Reset()

func (*Jwt) Size

func (m *Jwt) Size() (n int)

func (*Jwt) String

func (m *Jwt) String() string

func (*Jwt) Unmarshal

func (m *Jwt) Unmarshal(dAtA []byte) error

func (*Jwt) XXX_DiscardUnknown

func (m *Jwt) XXX_DiscardUnknown()

func (*Jwt) XXX_Marshal

func (m *Jwt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Jwt) XXX_Merge

func (m *Jwt) XXX_Merge(src proto.Message)

func (*Jwt) XXX_Size

func (m *Jwt) XXX_Size() int

func (*Jwt) XXX_Unmarshal

func (m *Jwt) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Latency) Descriptor

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

func (*Latency) GetAssignTimestampNs

func (m *Latency) GetAssignTimestampNs() uint64

func (*Latency) GetEncodingNs

func (m *Latency) GetEncodingNs() uint64

func (*Latency) GetParsingNs

func (m *Latency) GetParsingNs() uint64

func (*Latency) GetProcessingNs

func (m *Latency) GetProcessingNs() uint64

func (*Latency) GetTotalNs added in v2.2.0

func (m *Latency) GetTotalNs() uint64

func (*Latency) Marshal

func (m *Latency) Marshal() (dAtA []byte, err error)

func (*Latency) MarshalTo

func (m *Latency) MarshalTo(dAtA []byte) (int, error)

func (*Latency) MarshalToSizedBuffer

func (m *Latency) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Latency) ProtoMessage

func (*Latency) ProtoMessage()

func (*Latency) Reset

func (m *Latency) Reset()

func (*Latency) Size

func (m *Latency) Size() (n int)

func (*Latency) String

func (m *Latency) String() string

func (*Latency) Unmarshal

func (m *Latency) Unmarshal(dAtA []byte) error

func (*Latency) XXX_DiscardUnknown

func (m *Latency) XXX_DiscardUnknown()

func (*Latency) XXX_Marshal

func (m *Latency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Latency) XXX_Merge

func (m *Latency) XXX_Merge(src proto.Message)

func (*Latency) XXX_Size

func (m *Latency) XXX_Size() int

func (*Latency) XXX_Unmarshal

func (m *Latency) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoginRequest) Descriptor

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

func (*LoginRequest) GetPassword

func (m *LoginRequest) GetPassword() string

func (*LoginRequest) GetRefreshToken

func (m *LoginRequest) GetRefreshToken() string

func (*LoginRequest) GetUserid

func (m *LoginRequest) GetUserid() string

func (*LoginRequest) Marshal

func (m *LoginRequest) Marshal() (dAtA []byte, err error)

func (*LoginRequest) MarshalTo

func (m *LoginRequest) MarshalTo(dAtA []byte) (int, error)

func (*LoginRequest) MarshalToSizedBuffer

func (m *LoginRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LoginRequest) ProtoMessage

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) Reset

func (m *LoginRequest) Reset()

func (*LoginRequest) Size

func (m *LoginRequest) Size() (n int)

func (*LoginRequest) String

func (m *LoginRequest) String() string

func (*LoginRequest) Unmarshal

func (m *LoginRequest) Unmarshal(dAtA []byte) error

func (*LoginRequest) XXX_DiscardUnknown

func (m *LoginRequest) XXX_DiscardUnknown()

func (*LoginRequest) XXX_Marshal

func (m *LoginRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoginRequest) XXX_Merge

func (m *LoginRequest) XXX_Merge(src proto.Message)

func (*LoginRequest) XXX_Size

func (m *LoginRequest) XXX_Size() int

func (*LoginRequest) XXX_Unmarshal

func (m *LoginRequest) XXX_Unmarshal(b []byte) error

type Metrics added in v2.2.0

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Metrics) Descriptor added in v2.2.0

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

func (*Metrics) GetNumUids added in v2.2.0

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

func (*Metrics) Marshal added in v2.2.0

func (m *Metrics) Marshal() (dAtA []byte, err error)

func (*Metrics) MarshalTo added in v2.2.0

func (m *Metrics) MarshalTo(dAtA []byte) (int, error)

func (*Metrics) MarshalToSizedBuffer added in v2.2.0

func (m *Metrics) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metrics) ProtoMessage added in v2.2.0

func (*Metrics) ProtoMessage()

func (*Metrics) Reset added in v2.2.0

func (m *Metrics) Reset()

func (*Metrics) Size added in v2.2.0

func (m *Metrics) Size() (n int)

func (*Metrics) String added in v2.2.0

func (m *Metrics) String() string

func (*Metrics) Unmarshal added in v2.2.0

func (m *Metrics) Unmarshal(dAtA []byte) error

func (*Metrics) XXX_DiscardUnknown added in v2.2.0

func (m *Metrics) XXX_DiscardUnknown()

func (*Metrics) XXX_Marshal added in v2.2.0

func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metrics) XXX_Merge added in v2.2.0

func (m *Metrics) XXX_Merge(src proto.Message)

func (*Metrics) XXX_Size added in v2.2.0

func (m *Metrics) XXX_Size() int

func (*Metrics) XXX_Unmarshal added in v2.2.0

func (m *Metrics) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Mutation) Descriptor

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

func (*Mutation) GetCommitNow

func (m *Mutation) GetCommitNow() bool

func (*Mutation) GetCond

func (m *Mutation) GetCond() string

func (*Mutation) GetDel

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

func (*Mutation) GetDelNquads

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

func (*Mutation) GetDeleteJson

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

func (*Mutation) GetSet

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

func (*Mutation) GetSetJson

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

func (*Mutation) GetSetNquads

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

func (*Mutation) Marshal

func (m *Mutation) Marshal() (dAtA []byte, err error)

func (*Mutation) MarshalTo

func (m *Mutation) MarshalTo(dAtA []byte) (int, error)

func (*Mutation) MarshalToSizedBuffer

func (m *Mutation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Mutation) ProtoMessage

func (*Mutation) ProtoMessage()

func (*Mutation) Reset

func (m *Mutation) Reset()

func (*Mutation) Size

func (m *Mutation) Size() (n int)

func (*Mutation) String

func (m *Mutation) String() string

func (*Mutation) Unmarshal

func (m *Mutation) Unmarshal(dAtA []byte) error

func (*Mutation) XXX_DiscardUnknown

func (m *Mutation) XXX_DiscardUnknown()

func (*Mutation) XXX_Marshal

func (m *Mutation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Mutation) XXX_Merge

func (m *Mutation) XXX_Merge(src proto.Message)

func (*Mutation) XXX_Size

func (m *Mutation) XXX_Size() int

func (*Mutation) XXX_Unmarshal

func (m *Mutation) XXX_Unmarshal(b []byte) error

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"`
	Label                string   `protobuf:"bytes,5,opt,name=label,proto3" json:"label,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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NQuad) Descriptor

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

func (*NQuad) GetFacets

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

func (*NQuad) GetLabel

func (m *NQuad) GetLabel() string

func (*NQuad) GetLang

func (m *NQuad) GetLang() string

func (*NQuad) GetObjectId

func (m *NQuad) GetObjectId() string

func (*NQuad) GetObjectValue

func (m *NQuad) GetObjectValue() *Value

func (*NQuad) GetPredicate

func (m *NQuad) GetPredicate() string

func (*NQuad) GetSubject

func (m *NQuad) GetSubject() string

func (*NQuad) Marshal

func (m *NQuad) Marshal() (dAtA []byte, err error)

func (*NQuad) MarshalTo

func (m *NQuad) MarshalTo(dAtA []byte) (int, error)

func (*NQuad) MarshalToSizedBuffer

func (m *NQuad) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NQuad) ProtoMessage

func (*NQuad) ProtoMessage()

func (*NQuad) Reset

func (m *NQuad) Reset()

func (*NQuad) Size

func (m *NQuad) Size() (n int)

func (*NQuad) String

func (m *NQuad) String() string

func (*NQuad) Unmarshal

func (m *NQuad) Unmarshal(dAtA []byte) error

func (*NQuad) XXX_DiscardUnknown

func (m *NQuad) XXX_DiscardUnknown()

func (*NQuad) XXX_Marshal

func (m *NQuad) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NQuad) XXX_Merge

func (m *NQuad) XXX_Merge(src proto.Message)

func (*NQuad) XXX_Size

func (m *NQuad) XXX_Size() int

func (*NQuad) XXX_Unmarshal

func (m *NQuad) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Operation) Descriptor

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

func (*Operation) GetDropAll

func (m *Operation) GetDropAll() bool

func (*Operation) GetDropAttr

func (m *Operation) GetDropAttr() string

func (*Operation) GetDropOp

func (m *Operation) GetDropOp() Operation_DropOp

func (*Operation) GetDropValue

func (m *Operation) GetDropValue() string

func (*Operation) GetSchema

func (m *Operation) GetSchema() string

func (*Operation) Marshal

func (m *Operation) Marshal() (dAtA []byte, err error)

func (*Operation) MarshalTo

func (m *Operation) MarshalTo(dAtA []byte) (int, error)

func (*Operation) MarshalToSizedBuffer

func (m *Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operation) ProtoMessage

func (*Operation) ProtoMessage()

func (*Operation) Reset

func (m *Operation) Reset()

func (*Operation) Size

func (m *Operation) Size() (n int)

func (*Operation) String

func (m *Operation) String() string

func (*Operation) Unmarshal

func (m *Operation) Unmarshal(dAtA []byte) error

func (*Operation) XXX_DiscardUnknown

func (m *Operation) XXX_DiscardUnknown()

func (*Operation) XXX_Marshal

func (m *Operation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Operation) XXX_Merge

func (m *Operation) XXX_Merge(src proto.Message)

func (*Operation) XXX_Size

func (m *Operation) XXX_Size() int

func (*Operation) XXX_Unmarshal

func (m *Operation) XXX_Unmarshal(b []byte) error

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) EnumDescriptor

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

func (Operation_DropOp) String

func (x Operation_DropOp) String() string

type Payload

type Payload struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Worker services.

func (*Payload) Descriptor

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

func (*Payload) GetData

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

func (*Payload) Marshal

func (m *Payload) Marshal() (dAtA []byte, err error)

func (*Payload) MarshalTo

func (m *Payload) MarshalTo(dAtA []byte) (int, error)

func (*Payload) MarshalToSizedBuffer

func (m *Payload) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) Reset

func (m *Payload) Reset()

func (*Payload) Size

func (m *Payload) Size() (n int)

func (*Payload) String

func (m *Payload) String() string

func (*Payload) Unmarshal

func (m *Payload) Unmarshal(dAtA []byte) error

func (*Payload) XXX_DiscardUnknown

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal

func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Payload) XXX_Merge

func (m *Payload) XXX_Merge(src proto.Message)

func (*Payload) XXX_Size

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal

func (m *Payload) XXX_Unmarshal(b []byte) error

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 `` /* 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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Request) Descriptor

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

func (*Request) GetBestEffort

func (m *Request) GetBestEffort() bool

func (*Request) GetCommitNow

func (m *Request) GetCommitNow() bool

func (*Request) GetMutations

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

func (*Request) GetQuery

func (m *Request) GetQuery() string

func (*Request) GetReadOnly

func (m *Request) GetReadOnly() bool

func (*Request) GetStartTs

func (m *Request) GetStartTs() uint64

func (*Request) GetVars

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

func (*Request) Marshal

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) MarshalToSizedBuffer

func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) Size

func (m *Request) Size() (n int)

func (*Request) String

func (m *Request) String() string

func (*Request) Unmarshal

func (m *Request) Unmarshal(dAtA []byte) error

func (*Request) XXX_DiscardUnknown

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal

func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Request) XXX_Merge

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal

func (m *Request) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Response) Descriptor

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

func (*Response) GetJson

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

func (*Response) GetLatency

func (m *Response) GetLatency() *Latency

func (*Response) GetMetrics added in v2.2.0

func (m *Response) GetMetrics() *Metrics

func (*Response) GetTxn

func (m *Response) GetTxn() *TxnContext

func (*Response) GetUids

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

func (*Response) Marshal

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) MarshalToSizedBuffer

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) Size

func (m *Response) Size() (n int)

func (*Response) String

func (m *Response) String() string

func (*Response) Unmarshal

func (m *Response) Unmarshal(dAtA []byte) error

func (*Response) XXX_DiscardUnknown

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal

func (m *Response) XXX_Unmarshal(b []byte) error

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"`
	Preds                []string `protobuf:"bytes,5,rep,name=preds,proto3" json:"preds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TxnContext) Descriptor

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

func (*TxnContext) GetAborted

func (m *TxnContext) GetAborted() bool

func (*TxnContext) GetCommitTs

func (m *TxnContext) GetCommitTs() uint64

func (*TxnContext) GetKeys

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

func (*TxnContext) GetPreds

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

func (*TxnContext) GetStartTs

func (m *TxnContext) GetStartTs() uint64

func (*TxnContext) Marshal

func (m *TxnContext) Marshal() (dAtA []byte, err error)

func (*TxnContext) MarshalTo

func (m *TxnContext) MarshalTo(dAtA []byte) (int, error)

func (*TxnContext) MarshalToSizedBuffer

func (m *TxnContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TxnContext) ProtoMessage

func (*TxnContext) ProtoMessage()

func (*TxnContext) Reset

func (m *TxnContext) Reset()

func (*TxnContext) Size

func (m *TxnContext) Size() (n int)

func (*TxnContext) String

func (m *TxnContext) String() string

func (*TxnContext) Unmarshal

func (m *TxnContext) Unmarshal(dAtA []byte) error

func (*TxnContext) XXX_DiscardUnknown

func (m *TxnContext) XXX_DiscardUnknown()

func (*TxnContext) XXX_Marshal

func (m *TxnContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TxnContext) XXX_Merge

func (m *TxnContext) XXX_Merge(src proto.Message)

func (*TxnContext) XXX_Size

func (m *TxnContext) XXX_Size() int

func (*TxnContext) XXX_Unmarshal

func (m *TxnContext) XXX_Unmarshal(b []byte) error

type Uids added in v2.2.0

type Uids struct {
	Uids                 []string `protobuf:"bytes,1,rep,name=uids,proto3" json:"uids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Uids) Descriptor added in v2.2.0

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

func (*Uids) GetUids added in v2.2.0

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

func (*Uids) Marshal added in v2.2.0

func (m *Uids) Marshal() (dAtA []byte, err error)

func (*Uids) MarshalTo added in v2.2.0

func (m *Uids) MarshalTo(dAtA []byte) (int, error)

func (*Uids) MarshalToSizedBuffer added in v2.2.0

func (m *Uids) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Uids) ProtoMessage added in v2.2.0

func (*Uids) ProtoMessage()

func (*Uids) Reset added in v2.2.0

func (m *Uids) Reset()

func (*Uids) Size added in v2.2.0

func (m *Uids) Size() (n int)

func (*Uids) String added in v2.2.0

func (m *Uids) String() string

func (*Uids) Unmarshal added in v2.2.0

func (m *Uids) Unmarshal(dAtA []byte) error

func (*Uids) XXX_DiscardUnknown added in v2.2.0

func (m *Uids) XXX_DiscardUnknown()

func (*Uids) XXX_Marshal added in v2.2.0

func (m *Uids) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Uids) XXX_Merge added in v2.2.0

func (m *Uids) XXX_Merge(src proto.Message)

func (*Uids) XXX_Size added in v2.2.0

func (m *Uids) XXX_Size() int

func (*Uids) XXX_Unmarshal added in v2.2.0

func (m *Uids) XXX_Unmarshal(b []byte) error

type UnimplementedDgraphServer

type UnimplementedDgraphServer struct {
}

UnimplementedDgraphServer can be embedded to have forward compatible implementations.

func (*UnimplementedDgraphServer) Alter

func (*UnimplementedDgraphServer) CheckVersion

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

func (*UnimplementedDgraphServer) CommitOrAbort

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

func (*UnimplementedDgraphServer) Login

func (*UnimplementedDgraphServer) Query

type Value

type Value struct {
	// Types that are valid to be assigned to Val:
	//	*Value_DefaultVal
	//	*Value_BytesVal
	//	*Value_IntVal
	//	*Value_BoolVal
	//	*Value_StrVal
	//	*Value_DoubleVal
	//	*Value_GeoVal
	//	*Value_DateVal
	//	*Value_DatetimeVal
	//	*Value_PasswordVal
	//	*Value_UidVal
	Val                  isValue_Val `protobuf_oneof:"val"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Value) Descriptor

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

func (*Value) GetBoolVal

func (m *Value) GetBoolVal() bool

func (*Value) GetBytesVal

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

func (*Value) GetDateVal

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

func (*Value) GetDatetimeVal

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

func (*Value) GetDefaultVal

func (m *Value) GetDefaultVal() string

func (*Value) GetDoubleVal

func (m *Value) GetDoubleVal() float64

func (*Value) GetGeoVal

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

func (*Value) GetIntVal

func (m *Value) GetIntVal() int64

func (*Value) GetPasswordVal

func (m *Value) GetPasswordVal() string

func (*Value) GetStrVal

func (m *Value) GetStrVal() string

func (*Value) GetUidVal

func (m *Value) GetUidVal() uint64

func (*Value) GetVal

func (m *Value) GetVal() isValue_Val

func (*Value) Marshal

func (m *Value) Marshal() (dAtA []byte, err error)

func (*Value) MarshalTo

func (m *Value) MarshalTo(dAtA []byte) (int, error)

func (*Value) MarshalToSizedBuffer

func (m *Value) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value) ProtoMessage

func (*Value) ProtoMessage()

func (*Value) Reset

func (m *Value) Reset()

func (*Value) Size

func (m *Value) Size() (n int)

func (*Value) String

func (m *Value) String() string

func (*Value) Unmarshal

func (m *Value) Unmarshal(dAtA []byte) error

func (*Value) XXX_DiscardUnknown

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal

func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Value) XXX_Merge

func (m *Value) XXX_Merge(src proto.Message)

func (*Value) XXX_OneofWrappers added in v2.2.0

func (*Value) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Value) XXX_Size

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal

func (m *Value) XXX_Unmarshal(b []byte) error

type Value_BoolVal

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

func (*Value_BoolVal) MarshalTo

func (m *Value_BoolVal) MarshalTo(dAtA []byte) (int, error)

func (*Value_BoolVal) MarshalToSizedBuffer

func (m *Value_BoolVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_BoolVal) Size

func (m *Value_BoolVal) Size() (n int)

type Value_BytesVal

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

func (*Value_BytesVal) MarshalTo

func (m *Value_BytesVal) MarshalTo(dAtA []byte) (int, error)

func (*Value_BytesVal) MarshalToSizedBuffer

func (m *Value_BytesVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_BytesVal) Size

func (m *Value_BytesVal) Size() (n int)

type Value_DateVal

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

func (*Value_DateVal) MarshalTo

func (m *Value_DateVal) MarshalTo(dAtA []byte) (int, error)

func (*Value_DateVal) MarshalToSizedBuffer

func (m *Value_DateVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_DateVal) Size

func (m *Value_DateVal) Size() (n int)

type Value_DatetimeVal

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

func (*Value_DatetimeVal) MarshalTo

func (m *Value_DatetimeVal) MarshalTo(dAtA []byte) (int, error)

func (*Value_DatetimeVal) MarshalToSizedBuffer

func (m *Value_DatetimeVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_DatetimeVal) Size

func (m *Value_DatetimeVal) Size() (n int)

type Value_DefaultVal

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

func (*Value_DefaultVal) MarshalTo

func (m *Value_DefaultVal) MarshalTo(dAtA []byte) (int, error)

func (*Value_DefaultVal) MarshalToSizedBuffer

func (m *Value_DefaultVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_DefaultVal) Size

func (m *Value_DefaultVal) Size() (n int)

type Value_DoubleVal

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

func (*Value_DoubleVal) MarshalTo

func (m *Value_DoubleVal) MarshalTo(dAtA []byte) (int, error)

func (*Value_DoubleVal) MarshalToSizedBuffer

func (m *Value_DoubleVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_DoubleVal) Size

func (m *Value_DoubleVal) Size() (n int)

type Value_GeoVal

type Value_GeoVal struct {
	GeoVal []byte `protobuf:"bytes,7,opt,name=geo_val,json=geoVal,proto3,oneof" json:"geo_val,omitempty"`
}

func (*Value_GeoVal) MarshalTo

func (m *Value_GeoVal) MarshalTo(dAtA []byte) (int, error)

func (*Value_GeoVal) MarshalToSizedBuffer

func (m *Value_GeoVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_GeoVal) Size

func (m *Value_GeoVal) Size() (n int)

type Value_IntVal

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

func (*Value_IntVal) MarshalTo

func (m *Value_IntVal) MarshalTo(dAtA []byte) (int, error)

func (*Value_IntVal) MarshalToSizedBuffer

func (m *Value_IntVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_IntVal) Size

func (m *Value_IntVal) Size() (n int)

type Value_PasswordVal

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

func (*Value_PasswordVal) MarshalTo

func (m *Value_PasswordVal) MarshalTo(dAtA []byte) (int, error)

func (*Value_PasswordVal) MarshalToSizedBuffer

func (m *Value_PasswordVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_PasswordVal) Size

func (m *Value_PasswordVal) Size() (n int)

type Value_StrVal

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

func (*Value_StrVal) MarshalTo

func (m *Value_StrVal) MarshalTo(dAtA []byte) (int, error)

func (*Value_StrVal) MarshalToSizedBuffer

func (m *Value_StrVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_StrVal) Size

func (m *Value_StrVal) Size() (n int)

type Value_UidVal

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

func (*Value_UidVal) MarshalTo

func (m *Value_UidVal) MarshalTo(dAtA []byte) (int, error)

func (*Value_UidVal) MarshalToSizedBuffer

func (m *Value_UidVal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_UidVal) Size

func (m *Value_UidVal) Size() (n int)

type Version

type Version struct {
	Tag                  string   `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Version) Descriptor

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

func (*Version) GetTag

func (m *Version) GetTag() string

func (*Version) Marshal

func (m *Version) Marshal() (dAtA []byte, err error)

func (*Version) MarshalTo

func (m *Version) MarshalTo(dAtA []byte) (int, error)

func (*Version) MarshalToSizedBuffer

func (m *Version) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) Reset

func (m *Version) Reset()

func (*Version) Size

func (m *Version) Size() (n int)

func (*Version) String

func (m *Version) String() string

func (*Version) Unmarshal

func (m *Version) Unmarshal(dAtA []byte) error

func (*Version) XXX_DiscardUnknown

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal

func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Version) XXX_Merge

func (m *Version) XXX_Merge(src proto.Message)

func (*Version) XXX_Size

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal

func (m *Version) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL