api_v2

package
v250.0.0-preview4 Latest Latest
Warning

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

 Go to latest Published: May 21, 2025 License: Apache-2.0 Imports: 8 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	Dgraph_Ping_FullMethodName               = "/api.v2.Dgraph/Ping"
	Dgraph_AllocateIDs_FullMethodName        = "/api.v2.Dgraph/AllocateIDs"
	Dgraph_SignInUser_FullMethodName         = "/api.v2.Dgraph/SignInUser"
	Dgraph_Alter_FullMethodName              = "/api.v2.Dgraph/Alter"
	Dgraph_RunDQL_FullMethodName             = "/api.v2.Dgraph/RunDQL"
	Dgraph_CreateNamespace_FullMethodName    = "/api.v2.Dgraph/CreateNamespace"
	Dgraph_DropNamespace_FullMethodName      = "/api.v2.Dgraph/DropNamespace"
	Dgraph_UpdateNamespace_FullMethodName    = "/api.v2.Dgraph/UpdateNamespace"
	Dgraph_ListNamespaces_FullMethodName     = "/api.v2.Dgraph/ListNamespaces"
	Dgraph_InitiatePDirStream_FullMethodName = "/api.v2.Dgraph/InitiatePDirStream"
	Dgraph_StreamPDir_FullMethodName         = "/api.v2.Dgraph/StreamPDir"
)

Variables

View Source 
var (
	LeaseType_name = map[int32]string{
		0: "NS",
		1: "UID",
		2: "TS",
	}
	LeaseType_value = map[string]int32{
		"NS":  0,
		"UID": 1,
		"TS":  2,
	}
)

Enum value maps for LeaseType.

View Source 
var (
	AlterOp_name = map[int32]string{
		0: "NONE",
		1: "DROP_ALL",
		2: "DROP_ALL_IN_NS",
		3: "DROP_DATA_IN_NS",
		4: "DROP_PREDICATE_IN_NS",
		5: "DROP_TYPE_IN_NS",
		6: "SCHEMA_IN_NS",
	}
	AlterOp_value = map[string]int32{
		"NONE":                 0,
		"DROP_ALL":             1,
		"DROP_ALL_IN_NS":       2,
		"DROP_DATA_IN_NS":      3,
		"DROP_PREDICATE_IN_NS": 4,
		"DROP_TYPE_IN_NS":      5,
		"SCHEMA_IN_NS":         6,
	}
)

Enum value maps for AlterOp.

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

Enum value maps for RespFormat.

View Source 
var Dgraph_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.v2.Dgraph",
	HandlerType: (*DgraphServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Dgraph_Ping_Handler,
		},
		{
			MethodName: "AllocateIDs",
			Handler:    _Dgraph_AllocateIDs_Handler,
		},
		{
			MethodName: "SignInUser",
			Handler:    _Dgraph_SignInUser_Handler,
		},
		{
			MethodName: "Alter",
			Handler:    _Dgraph_Alter_Handler,
		},
		{
			MethodName: "RunDQL",
			Handler:    _Dgraph_RunDQL_Handler,
		},
		{
			MethodName: "CreateNamespace",
			Handler:    _Dgraph_CreateNamespace_Handler,
		},
		{
			MethodName: "DropNamespace",
			Handler:    _Dgraph_DropNamespace_Handler,
		},
		{
			MethodName: "UpdateNamespace",
			Handler:    _Dgraph_UpdateNamespace_Handler,
		},
		{
			MethodName: "ListNamespaces",
			Handler:    _Dgraph_ListNamespaces_Handler,
		},
		{
			MethodName: "InitiatePDirStream",
			Handler:    _Dgraph_InitiatePDirStream_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamPDir",
			Handler:       _Dgraph_StreamPDir_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "api.v2.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_v2_proto protoreflect.FileDescriptor

Functions

func RegisterDgraphServer 

func RegisterDgraphServer(s grpc.ServiceRegistrar, srv DgraphServer)

Types

type AllocateIDsRequest 

type AllocateIDsRequest struct {
	HowMany   uint64    `protobuf:"varint,1,opt,name=how_many,json=howMany,proto3" json:"how_many,omitempty"`
	LeaseType LeaseType `protobuf:"varint,2,opt,name=lease_type,json=leaseType,proto3,enum=api.v2.LeaseType" json:"lease_type,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocateIDsRequest) Descriptor deprecated 

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

Deprecated: Use AllocateIDsRequest.ProtoReflect.Descriptor instead.

func (*AllocateIDsRequest) GetHowMany 

func (x *AllocateIDsRequest) GetHowMany() uint64

func (*AllocateIDsRequest) GetLeaseType 

func (x *AllocateIDsRequest) GetLeaseType() LeaseType

func (*AllocateIDsRequest) ProtoMessage 

func (*AllocateIDsRequest) ProtoMessage()

func (*AllocateIDsRequest) ProtoReflect 

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

func (*AllocateIDsRequest) Reset 

func (x *AllocateIDsRequest) Reset()

func (*AllocateIDsRequest) String 

func (x *AllocateIDsRequest) String() string

type AllocateIDsResponse 

type AllocateIDsResponse struct {
	Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	End   uint64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` // inclusive
	// contains filtered or unexported fields
}

func (*AllocateIDsResponse) Descriptor deprecated 

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

Deprecated: Use AllocateIDsResponse.ProtoReflect.Descriptor instead.

func (*AllocateIDsResponse) GetEnd 

func (x *AllocateIDsResponse) GetEnd() uint64

func (*AllocateIDsResponse) GetStart 

func (x *AllocateIDsResponse) GetStart() uint64

func (*AllocateIDsResponse) ProtoMessage 

func (*AllocateIDsResponse) ProtoMessage()

func (*AllocateIDsResponse) ProtoReflect 

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

func (*AllocateIDsResponse) Reset 

func (x *AllocateIDsResponse) Reset()

func (*AllocateIDsResponse) String 

func (x *AllocateIDsResponse) String() string

type AlterOp 

type AlterOp int32
const (
	AlterOp_NONE                 AlterOp = 0
	AlterOp_DROP_ALL             AlterOp = 1
	AlterOp_DROP_ALL_IN_NS       AlterOp = 2
	AlterOp_DROP_DATA_IN_NS      AlterOp = 3
	AlterOp_DROP_PREDICATE_IN_NS AlterOp = 4
	AlterOp_DROP_TYPE_IN_NS      AlterOp = 5
	AlterOp_SCHEMA_IN_NS         AlterOp = 6
)

func (AlterOp) Descriptor 

func (AlterOp) Descriptor() protoreflect.EnumDescriptor

func (AlterOp) Enum 

func (x AlterOp) Enum() *AlterOp

func (AlterOp) EnumDescriptor deprecated 

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

Deprecated: Use AlterOp.Descriptor instead.

func (AlterOp) Number 

func (x AlterOp) Number() protoreflect.EnumNumber

func (AlterOp) String 

func (x AlterOp) String() string

func (AlterOp) Type 

func (AlterOp) Type() protoreflect.EnumType

type AlterRequest 

type AlterRequest struct {
	Op              AlterOp `protobuf:"varint,1,opt,name=op,proto3,enum=api.v2.AlterOp" json:"op,omitempty"`
	NsName          string  `protobuf:"bytes,2,opt,name=ns_name,json=nsName,proto3" json:"ns_name,omitempty"`
	Schema          string  `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	RunInBackground bool    `protobuf:"varint,4,opt,name=run_in_background,json=runInBackground,proto3" json:"run_in_background,omitempty"`
	PredicateToDrop string  `protobuf:"bytes,5,opt,name=predicate_to_drop,json=predicateToDrop,proto3" json:"predicate_to_drop,omitempty"`
	TypeToDrop      string  `protobuf:"bytes,6,opt,name=type_to_drop,json=typeToDrop,proto3" json:"type_to_drop,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterRequest) Descriptor deprecated 

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

Deprecated: Use AlterRequest.ProtoReflect.Descriptor instead.

func (*AlterRequest) GetNsName 

func (x *AlterRequest) GetNsName() string

func (*AlterRequest) GetOp 

func (x *AlterRequest) GetOp() AlterOp

func (*AlterRequest) GetPredicateToDrop 

func (x *AlterRequest) GetPredicateToDrop() string

func (*AlterRequest) GetRunInBackground 

func (x *AlterRequest) GetRunInBackground() bool

func (*AlterRequest) GetSchema 

func (x *AlterRequest) GetSchema() string

func (*AlterRequest) GetTypeToDrop 

func (x *AlterRequest) GetTypeToDrop() string

func (*AlterRequest) ProtoMessage 

func (*AlterRequest) ProtoMessage()

func (*AlterRequest) ProtoReflect 

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

func (*AlterRequest) Reset 

func (x *AlterRequest) Reset()

func (*AlterRequest) String 

func (x *AlterRequest) String() string

type AlterResponse 

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

func (*AlterResponse) Descriptor deprecated 

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

Deprecated: Use AlterResponse.ProtoReflect.Descriptor instead.

func (*AlterResponse) ProtoMessage 

func (*AlterResponse) ProtoMessage()

func (*AlterResponse) ProtoReflect 

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

func (*AlterResponse) Reset 

func (x *AlterResponse) Reset()

func (*AlterResponse) String 

func (x *AlterResponse) String() string

type CreateNamespaceRequest 

type CreateNamespaceRequest struct {
	NsName string `protobuf:"bytes,1,opt,name=ns_name,json=nsName,proto3" json:"ns_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use CreateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*CreateNamespaceRequest) GetNsName 

func (x *CreateNamespaceRequest) GetNsName() string

func (*CreateNamespaceRequest) ProtoMessage 

func (*CreateNamespaceRequest) ProtoMessage()

func (*CreateNamespaceRequest) ProtoReflect 

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

func (*CreateNamespaceRequest) Reset 

func (x *CreateNamespaceRequest) Reset()

func (*CreateNamespaceRequest) String 

func (x *CreateNamespaceRequest) String() string

type CreateNamespaceResponse 

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

func (*CreateNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use CreateNamespaceResponse.ProtoReflect.Descriptor instead.

func (*CreateNamespaceResponse) ProtoMessage 

func (*CreateNamespaceResponse) ProtoMessage()

func (*CreateNamespaceResponse) ProtoReflect 

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

func (*CreateNamespaceResponse) Reset 

func (x *CreateNamespaceResponse) Reset()

func (*CreateNamespaceResponse) String 

func (x *CreateNamespaceResponse) String() string

type DgraphClient 

type DgraphClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	AllocateIDs(ctx context.Context, in *AllocateIDsRequest, opts ...grpc.CallOption) (*AllocateIDsResponse, error)
	SignInUser(ctx context.Context, in *SignInUserRequest, opts ...grpc.CallOption) (*SignInUserResponse, error)
	Alter(ctx context.Context, in *AlterRequest, opts ...grpc.CallOption) (*AlterResponse, error)
	RunDQL(ctx context.Context, in *RunDQLRequest, opts ...grpc.CallOption) (*RunDQLResponse, error)
	CreateNamespace(ctx context.Context, in *CreateNamespaceRequest, opts ...grpc.CallOption) (*CreateNamespaceResponse, error)
	DropNamespace(ctx context.Context, in *DropNamespaceRequest, opts ...grpc.CallOption) (*DropNamespaceResponse, error)
	UpdateNamespace(ctx context.Context, in *UpdateNamespaceRequest, opts ...grpc.CallOption) (*UpdateNamespaceResponse, error)
	ListNamespaces(ctx context.Context, in *ListNamespacesRequest, opts ...grpc.CallOption) (*ListNamespacesResponse, error)
	InitiatePDirStream(ctx context.Context, in *InitiatePDirStreamRequest, opts ...grpc.CallOption) (*InitiatePDirStreamResponse, error)
	StreamPDir(ctx context.Context, opts ...grpc.CallOption) (Dgraph_StreamPDirClient, 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 {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	AllocateIDs(context.Context, *AllocateIDsRequest) (*AllocateIDsResponse, error)
	SignInUser(context.Context, *SignInUserRequest) (*SignInUserResponse, error)
	Alter(context.Context, *AlterRequest) (*AlterResponse, error)
	RunDQL(context.Context, *RunDQLRequest) (*RunDQLResponse, error)
	CreateNamespace(context.Context, *CreateNamespaceRequest) (*CreateNamespaceResponse, error)
	DropNamespace(context.Context, *DropNamespaceRequest) (*DropNamespaceResponse, error)
	UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)
	ListNamespaces(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)
	InitiatePDirStream(context.Context, *InitiatePDirStreamRequest) (*InitiatePDirStreamResponse, error)
	StreamPDir(Dgraph_StreamPDirServer) error
	// contains filtered or unexported methods
}

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

type Dgraph_StreamPDirClient 

type Dgraph_StreamPDirClient interface {
	Send(*StreamPDirRequest) error
	CloseAndRecv() (*StreamPDirResponse, error)
	grpc.ClientStream
}

type Dgraph_StreamPDirServer 

type Dgraph_StreamPDirServer interface {
	SendAndClose(*StreamPDirResponse) error
	Recv() (*StreamPDirRequest, error)
	grpc.ServerStream
}

type DropNamespaceRequest 

type DropNamespaceRequest struct {
	NsName string `protobuf:"bytes,1,opt,name=ns_name,json=nsName,proto3" json:"ns_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DropNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use DropNamespaceRequest.ProtoReflect.Descriptor instead.

func (*DropNamespaceRequest) GetNsName 

func (x *DropNamespaceRequest) GetNsName() string

func (*DropNamespaceRequest) ProtoMessage 

func (*DropNamespaceRequest) ProtoMessage()

func (*DropNamespaceRequest) ProtoReflect 

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

func (*DropNamespaceRequest) Reset 

func (x *DropNamespaceRequest) Reset()

func (*DropNamespaceRequest) String 

func (x *DropNamespaceRequest) String() string

type DropNamespaceResponse 

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

func (*DropNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use DropNamespaceResponse.ProtoReflect.Descriptor instead.

func (*DropNamespaceResponse) ProtoMessage 

func (*DropNamespaceResponse) ProtoMessage()

func (*DropNamespaceResponse) ProtoReflect 

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

func (*DropNamespaceResponse) Reset 

func (x *DropNamespaceResponse) Reset()

func (*DropNamespaceResponse) String 

func (x *DropNamespaceResponse) String() string

type InitiatePDirStreamRequest 

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

func (*InitiatePDirStreamRequest) Descriptor deprecated 

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

Deprecated: Use InitiatePDirStreamRequest.ProtoReflect.Descriptor instead.

func (*InitiatePDirStreamRequest) ProtoMessage 

func (*InitiatePDirStreamRequest) ProtoMessage()

func (*InitiatePDirStreamRequest) ProtoReflect 

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

func (*InitiatePDirStreamRequest) Reset 

func (x *InitiatePDirStreamRequest) Reset()

func (*InitiatePDirStreamRequest) String 

func (x *InitiatePDirStreamRequest) String() string

type InitiatePDirStreamResponse 

type InitiatePDirStreamResponse struct {
	Groups []uint32 `protobuf:"varint,1,rep,packed,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

func (*InitiatePDirStreamResponse) Descriptor deprecated 

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

Deprecated: Use InitiatePDirStreamResponse.ProtoReflect.Descriptor instead.

func (*InitiatePDirStreamResponse) GetGroups 

func (x *InitiatePDirStreamResponse) GetGroups() []uint32

func (*InitiatePDirStreamResponse) ProtoMessage 

func (*InitiatePDirStreamResponse) ProtoMessage()

func (*InitiatePDirStreamResponse) ProtoReflect 

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

func (*InitiatePDirStreamResponse) Reset 

func (x *InitiatePDirStreamResponse) Reset()

func (*InitiatePDirStreamResponse) String 

func (x *InitiatePDirStreamResponse) 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"`
	RespEncodingNs    uint64 `protobuf:"varint,3,opt,name=resp_encoding_ns,json=respEncodingNs,proto3" json:"resp_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) GetParsingNs 

func (x *Latency) GetParsingNs() uint64

func (*Latency) GetProcessingNs 

func (x *Latency) GetProcessingNs() uint64

func (*Latency) GetRespEncodingNs 

func (x *Latency) GetRespEncodingNs() uint64

func (*Latency) GetTotalNs 

func (x *Latency) GetTotalNs() uint64

func (*Latency) ProtoMessage 

func (*Latency) ProtoMessage()

func (*Latency) ProtoReflect 

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

func (*Latency) Reset 

func (x *Latency) Reset()

func (*Latency) String 

func (x *Latency) String() string

type LeaseType 

type LeaseType int32
const (
	LeaseType_NS  LeaseType = 0
	LeaseType_UID LeaseType = 1
	LeaseType_TS  LeaseType = 2
)

func (LeaseType) Descriptor 

func (LeaseType) Descriptor() protoreflect.EnumDescriptor

func (LeaseType) Enum 

func (x LeaseType) Enum() *LeaseType

func (LeaseType) EnumDescriptor deprecated 

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

Deprecated: Use LeaseType.Descriptor instead.

func (LeaseType) Number 

func (x LeaseType) Number() protoreflect.EnumNumber

func (LeaseType) String 

func (x LeaseType) String() string

func (LeaseType) Type 

func (LeaseType) Type() protoreflect.EnumType

type ListNamespacesRequest 

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

func (*ListNamespacesRequest) Descriptor deprecated 

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

Deprecated: Use ListNamespacesRequest.ProtoReflect.Descriptor instead.

func (*ListNamespacesRequest) ProtoMessage 

func (*ListNamespacesRequest) ProtoMessage()

func (*ListNamespacesRequest) ProtoReflect 

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

func (*ListNamespacesRequest) Reset 

func (x *ListNamespacesRequest) Reset()

func (*ListNamespacesRequest) String 

func (x *ListNamespacesRequest) String() string

type ListNamespacesResponse 

type ListNamespacesResponse struct {
	NsList map[string]*Namespace `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListNamespacesResponse) Descriptor deprecated 

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

Deprecated: Use ListNamespacesResponse.ProtoReflect.Descriptor instead.

func (*ListNamespacesResponse) GetNsList 

func (x *ListNamespacesResponse) GetNsList() map[string]*Namespace

func (*ListNamespacesResponse) ProtoMessage 

func (*ListNamespacesResponse) ProtoMessage()

func (*ListNamespacesResponse) ProtoReflect 

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

func (*ListNamespacesResponse) Reset 

func (x *ListNamespacesResponse) Reset()

func (*ListNamespacesResponse) String 

func (x *ListNamespacesResponse) String() string

type Metrics 

type Metrics struct {

	// uids_touched is the map of number of uids read for each attribute/predicate.
	UidsTouched map[string]uint64 `` /* 169-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) GetUidsTouched 

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

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect 

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

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

type Namespace 

type Namespace struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id   uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*Namespace) Descriptor deprecated 

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

Deprecated: Use Namespace.ProtoReflect.Descriptor instead.

func (*Namespace) GetId 

func (x *Namespace) GetId() uint64

func (*Namespace) GetName 

func (x *Namespace) GetName() string

func (*Namespace) ProtoMessage 

func (*Namespace) ProtoMessage()

func (*Namespace) ProtoReflect 

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

func (*Namespace) Reset 

func (x *Namespace) Reset()

func (*Namespace) String 

func (x *Namespace) String() string

type PingRequest 

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

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

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

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetVersion 

func (x *PingResponse) GetVersion() string

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type RespFormat 

type RespFormat int32
const (
	RespFormat_JSON RespFormat = 0
	RespFormat_RDF  RespFormat = 1
)

func (RespFormat) Descriptor 

func (RespFormat) Descriptor() protoreflect.EnumDescriptor

func (RespFormat) Enum 

func (x RespFormat) Enum() *RespFormat

func (RespFormat) EnumDescriptor deprecated 

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

Deprecated: Use RespFormat.Descriptor instead.

func (RespFormat) Number 

func (x RespFormat) Number() protoreflect.EnumNumber

func (RespFormat) String 

func (x RespFormat) String() string

func (RespFormat) Type 

func (RespFormat) Type() protoreflect.EnumType

type RunDQLRequest 

type RunDQLRequest struct {
	NsName     string            `protobuf:"bytes,1,opt,name=ns_name,json=nsName,proto3" json:"ns_name,omitempty"`
	DqlQuery   string            `protobuf:"bytes,2,opt,name=dql_query,json=dqlQuery,proto3" json:"dql_query,omitempty"`
	Vars       map[string]string `` /* 135-byte string literal not displayed */
	ReadOnly   bool              `protobuf:"varint,4,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	BestEffort bool              `protobuf:"varint,5,opt,name=best_effort,json=bestEffort,proto3" json:"best_effort,omitempty"`
	RespFormat RespFormat        `protobuf:"varint,6,opt,name=resp_format,json=respFormat,proto3,enum=api.v2.RespFormat" json:"resp_format,omitempty"`
	// contains filtered or unexported fields
}

func (*RunDQLRequest) Descriptor deprecated 

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

Deprecated: Use RunDQLRequest.ProtoReflect.Descriptor instead.

func (*RunDQLRequest) GetBestEffort 

func (x *RunDQLRequest) GetBestEffort() bool

func (*RunDQLRequest) GetDqlQuery 

func (x *RunDQLRequest) GetDqlQuery() string

func (*RunDQLRequest) GetNsName 

func (x *RunDQLRequest) GetNsName() string

func (*RunDQLRequest) GetReadOnly 

func (x *RunDQLRequest) GetReadOnly() bool

func (*RunDQLRequest) GetRespFormat 

func (x *RunDQLRequest) GetRespFormat() RespFormat

func (*RunDQLRequest) GetVars 

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

func (*RunDQLRequest) ProtoMessage 

func (*RunDQLRequest) ProtoMessage()

func (*RunDQLRequest) ProtoReflect 

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

func (*RunDQLRequest) Reset 

func (x *RunDQLRequest) Reset()

func (*RunDQLRequest) String 

func (x *RunDQLRequest) String() string

type RunDQLResponse 

type RunDQLResponse struct {
	Txn         *TxnContext       `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	QueryResult []byte            `protobuf:"bytes,2,opt,name=query_result,json=queryResult,proto3" json:"query_result,omitempty"` // could be rdf or json
	BlankUids   map[string]string ``                                                                                               // mapping of blank_node => uid in hex
	/* 162-byte string literal not displayed */
	Latency *Latency `protobuf:"bytes,4,opt,name=latency,proto3" json:"latency,omitempty"`
	Metrics *Metrics `protobuf:"bytes,5,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*RunDQLResponse) Descriptor deprecated 

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

Deprecated: Use RunDQLResponse.ProtoReflect.Descriptor instead.

func (*RunDQLResponse) GetBlankUids 

func (x *RunDQLResponse) GetBlankUids() map[string]string

func (*RunDQLResponse) GetLatency 

func (x *RunDQLResponse) GetLatency() *Latency

func (*RunDQLResponse) GetMetrics 

func (x *RunDQLResponse) GetMetrics() *Metrics

func (*RunDQLResponse) GetQueryResult 

func (x *RunDQLResponse) GetQueryResult() []byte

func (*RunDQLResponse) GetTxn 

func (x *RunDQLResponse) GetTxn() *TxnContext

func (*RunDQLResponse) ProtoMessage 

func (*RunDQLResponse) ProtoMessage()

func (*RunDQLResponse) ProtoReflect 

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

func (*RunDQLResponse) Reset 

func (x *RunDQLResponse) Reset()

func (*RunDQLResponse) String 

func (x *RunDQLResponse) String() string

type SignInUserRequest 

type SignInUserRequest struct {
	UserId       string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,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"`
	// contains filtered or unexported fields
}

func (*SignInUserRequest) Descriptor deprecated 

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

Deprecated: Use SignInUserRequest.ProtoReflect.Descriptor instead.

func (*SignInUserRequest) GetPassword 

func (x *SignInUserRequest) GetPassword() string

func (*SignInUserRequest) GetRefreshToken 

func (x *SignInUserRequest) GetRefreshToken() string

func (*SignInUserRequest) GetUserId 

func (x *SignInUserRequest) GetUserId() string

func (*SignInUserRequest) ProtoMessage 

func (*SignInUserRequest) ProtoMessage()

func (*SignInUserRequest) ProtoReflect 

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

func (*SignInUserRequest) Reset 

func (x *SignInUserRequest) Reset()

func (*SignInUserRequest) String 

func (x *SignInUserRequest) String() string

type SignInUserResponse 

type SignInUserResponse 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 (*SignInUserResponse) Descriptor deprecated 

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

Deprecated: Use SignInUserResponse.ProtoReflect.Descriptor instead.

func (*SignInUserResponse) GetAccessJwt 

func (x *SignInUserResponse) GetAccessJwt() string

func (*SignInUserResponse) GetRefreshJwt 

func (x *SignInUserResponse) GetRefreshJwt() string

func (*SignInUserResponse) ProtoMessage 

func (*SignInUserResponse) ProtoMessage()

func (*SignInUserResponse) ProtoReflect 

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

func (*SignInUserResponse) Reset 

func (x *SignInUserResponse) Reset()

func (*SignInUserResponse) String 

func (x *SignInUserResponse) String() string

type StreamPDirRequest 

type StreamPDirRequest struct {
	GroupId      uint32        `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	StreamPacket *StreamPacket `protobuf:"bytes,2,opt,name=stream_packet,json=streamPacket,proto3" json:"stream_packet,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPDirRequest) Descriptor deprecated 

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

Deprecated: Use StreamPDirRequest.ProtoReflect.Descriptor instead.

func (*StreamPDirRequest) GetGroupId 

func (x *StreamPDirRequest) GetGroupId() uint32

func (*StreamPDirRequest) GetStreamPacket 

func (x *StreamPDirRequest) GetStreamPacket() *StreamPacket

func (*StreamPDirRequest) ProtoMessage 

func (*StreamPDirRequest) ProtoMessage()

func (*StreamPDirRequest) ProtoReflect 

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

func (*StreamPDirRequest) Reset 

func (x *StreamPDirRequest) Reset()

func (*StreamPDirRequest) String 

func (x *StreamPDirRequest) String() string

type StreamPDirResponse 

type StreamPDirResponse struct {
	Done bool `protobuf:"varint,1,opt,name=done,proto3" json:"done,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPDirResponse) Descriptor deprecated 

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

Deprecated: Use StreamPDirResponse.ProtoReflect.Descriptor instead.

func (*StreamPDirResponse) GetDone 

func (x *StreamPDirResponse) GetDone() bool

func (*StreamPDirResponse) ProtoMessage 

func (*StreamPDirResponse) ProtoMessage()

func (*StreamPDirResponse) ProtoReflect 

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

func (*StreamPDirResponse) Reset 

func (x *StreamPDirResponse) Reset()

func (*StreamPDirResponse) String 

func (x *StreamPDirResponse) String() string

type StreamPacket 

type StreamPacket struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Done bool   `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPacket) Descriptor deprecated 

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

Deprecated: Use StreamPacket.ProtoReflect.Descriptor instead.

func (*StreamPacket) GetData 

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

func (*StreamPacket) GetDone 

func (x *StreamPacket) GetDone() bool

func (*StreamPacket) ProtoMessage 

func (*StreamPacket) ProtoMessage()

func (*StreamPacket) ProtoReflect 

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

func (*StreamPacket) Reset 

func (x *StreamPacket) Reset()

func (*StreamPacket) String 

func (x *StreamPacket) 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 

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

func (*TxnContext) Reset 

func (x *TxnContext) Reset()

func (*TxnContext) String 

func (x *TxnContext) String() string

type UnimplementedDgraphServer 

type UnimplementedDgraphServer struct {
}

UnimplementedDgraphServer must be embedded to have forward compatible implementations.

func (UnimplementedDgraphServer) AllocateIDs 

func (UnimplementedDgraphServer) AllocateIDs(context.Context, *AllocateIDsRequest) (*AllocateIDsResponse, error)

func (UnimplementedDgraphServer) Alter 

func (UnimplementedDgraphServer) Alter(context.Context, *AlterRequest) (*AlterResponse, error)

func (UnimplementedDgraphServer) CreateNamespace 

func (UnimplementedDgraphServer) CreateNamespace(context.Context, *CreateNamespaceRequest) (*CreateNamespaceResponse, error)

func (UnimplementedDgraphServer) DropNamespace 

func (UnimplementedDgraphServer) DropNamespace(context.Context, *DropNamespaceRequest) (*DropNamespaceResponse, error)

func (UnimplementedDgraphServer) InitiatePDirStream 

func (UnimplementedDgraphServer) InitiatePDirStream(context.Context, *InitiatePDirStreamRequest) (*InitiatePDirStreamResponse, error)

func (UnimplementedDgraphServer) ListNamespaces 

func (UnimplementedDgraphServer) ListNamespaces(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)

func (UnimplementedDgraphServer) Ping 

func (UnimplementedDgraphServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (UnimplementedDgraphServer) RunDQL 

func (UnimplementedDgraphServer) RunDQL(context.Context, *RunDQLRequest) (*RunDQLResponse, error)

func (UnimplementedDgraphServer) SignInUser 

func (UnimplementedDgraphServer) SignInUser(context.Context, *SignInUserRequest) (*SignInUserResponse, error)

func (UnimplementedDgraphServer) StreamPDir 

func (UnimplementedDgraphServer) StreamPDir(Dgraph_StreamPDirServer) error

func (UnimplementedDgraphServer) UpdateNamespace 

func (UnimplementedDgraphServer) UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)

type UnsafeDgraphServer 

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 UpdateNamespaceRequest 

type UpdateNamespaceRequest struct {
	NsName     string `protobuf:"bytes,1,opt,name=ns_name,json=nsName,proto3" json:"ns_name,omitempty"`
	RenameToNs string `protobuf:"bytes,2,opt,name=rename_to_ns,json=renameToNs,proto3" json:"rename_to_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use UpdateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*UpdateNamespaceRequest) GetNsName 

func (x *UpdateNamespaceRequest) GetNsName() string

func (*UpdateNamespaceRequest) GetRenameToNs 

func (x *UpdateNamespaceRequest) GetRenameToNs() string

func (*UpdateNamespaceRequest) ProtoMessage 

func (*UpdateNamespaceRequest) ProtoMessage()

func (*UpdateNamespaceRequest) ProtoReflect 

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

func (*UpdateNamespaceRequest) Reset 

func (x *UpdateNamespaceRequest) Reset()

func (*UpdateNamespaceRequest) String 

func (x *UpdateNamespaceRequest) String() string

type UpdateNamespaceResponse 

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

func (*UpdateNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use UpdateNamespaceResponse.ProtoReflect.Descriptor instead.

func (*UpdateNamespaceResponse) ProtoMessage 

func (*UpdateNamespaceResponse) ProtoMessage()

func (*UpdateNamespaceResponse) ProtoReflect 

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

func (*UpdateNamespaceResponse) Reset 

func (x *UpdateNamespaceResponse) Reset()

func (*UpdateNamespaceResponse) String 

func (x *UpdateNamespaceResponse) 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.