ultipa

package
v1.4.3 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2023 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ResultType_name = map[int32]string{
		0: "RESULT_TYPE_UNSET",
		1: "RESULT_TYPE_PATH",
		2: "RESULT_TYPE_NODE",
		3: "RESULT_TYPE_EDGE",
		4: "RESULT_TYPE_ATTR",
		5: "RESULT_TYPE_TABLE",
	}
	ResultType_value = map[string]int32{
		"RESULT_TYPE_UNSET": 0,
		"RESULT_TYPE_PATH":  1,
		"RESULT_TYPE_NODE":  2,
		"RESULT_TYPE_EDGE":  3,
		"RESULT_TYPE_ATTR":  4,
		"RESULT_TYPE_TABLE": 5,
	}
)

Enum value maps for ResultType.

View Source 
var (
	InsertType_name = map[int32]string{
		0: "NORMAL",
		1: "OVERWRITE",
		2: "UPSERT",
	}
	InsertType_value = map[string]int32{
		"NORMAL":    0,
		"OVERWRITE": 1,
		"UPSERT":    2,
	}
)

Enum value maps for InsertType.

View Source 
var (
	PropertyType_name = map[int32]string{
		0:  "UNSET",
		1:  "INT32",
		2:  "UINT32",
		3:  "INT64",
		4:  "UINT64",
		5:  "FLOAT",
		6:  "DOUBLE",
		7:  "STRING",
		8:  "DATETIME",
		9:  "TIMESTAMP",
		10: "TEXT",
		11: "BLOB",
		12: "POINT",
		13: "DECIMAL",
		14: "LIST",
		15: "SET",
		16: "MAP",
		17: "NULL_",
	}
	PropertyType_value = map[string]int32{
		"UNSET":     0,
		"INT32":     1,
		"UINT32":    2,
		"INT64":     3,
		"UINT64":    4,
		"FLOAT":     5,
		"DOUBLE":    6,
		"STRING":    7,
		"DATETIME":  8,
		"TIMESTAMP": 9,
		"TEXT":      10,
		"BLOB":      11,
		"POINT":     12,
		"DECIMAL":   13,
		"LIST":      14,
		"SET":       15,
		"MAP":       16,
		"NULL_":     17,
	}
)

Enum value maps for PropertyType.

View Source 
var (
	ErrorCode_name = map[int32]string{
		0:  "SUCCESS",
		1:  "FAILED",
		2:  "PARAM_ERROR",
		3:  "BASE_DB_ERROR",
		4:  "ENGINE_ERROR",
		5:  "SYSTEM_ERROR",
		6:  "RAFT_REDIRECT",
		7:  "RAFT_LEADER_NOT_YET_ELECTED",
		8:  "RAFT_LOG_ERROR",
		9:  "UQL_ERROR",
		10: "NOT_RAFT_MODE",
		11: "RAFT_NO_AVAILABLE_FOLLOWERS",
		12: "RAFT_NO_AVAILABLE_ALGO_SERVERS",
		13: "PERMISSION_DENIED",
	}
	ErrorCode_value = map[string]int32{
		"SUCCESS":                        0,
		"FAILED":                         1,
		"PARAM_ERROR":                    2,
		"BASE_DB_ERROR":                  3,
		"ENGINE_ERROR":                   4,
		"SYSTEM_ERROR":                   5,
		"RAFT_REDIRECT":                  6,
		"RAFT_LEADER_NOT_YET_ELECTED":    7,
		"RAFT_LOG_ERROR":                 8,
		"UQL_ERROR":                      9,
		"NOT_RAFT_MODE":                  10,
		"RAFT_NO_AVAILABLE_FOLLOWERS":    11,
		"RAFT_NO_AVAILABLE_ALGO_SERVERS": 12,
		"PERMISSION_DENIED":              13,
	}
)

Enum value maps for ErrorCode.

View Source 
var (
	FollowerRole_name = map[int32]string{
		0: "ROLE_UNSET",
		1: "ROLE_READABLE",
		2: "ROLE_ALGO_EXECUTABLE",
		4: "ROLE_LEARNER",
	}
	FollowerRole_value = map[string]int32{
		"ROLE_UNSET":           0,
		"ROLE_READABLE":        1,
		"ROLE_ALGO_EXECUTABLE": 2,
		"ROLE_LEARNER":         4,
	}
)

Enum value maps for FollowerRole.

View Source 
var (
	ServerStatus_name = map[int32]string{
		0: "DEAD",
		1: "ALIVE",
	}
	ServerStatus_value = map[string]int32{
		"DEAD":  0,
		"ALIVE": 1,
	}
)

Enum value maps for ServerStatus.

View Source 
var (
	DBType_name = map[int32]string{
		0: "DBNODE",
		1: "DBEDGE",
		2: "DBGLOBAL",
	}
	DBType_value = map[string]int32{
		"DBNODE":   0,
		"DBEDGE":   1,
		"DBGLOBAL": 2,
	}
)

Enum value maps for DBType.

View Source 
var (
	TASK_STATUS_name = map[int32]string{
		0: "TASK_PENDING",
		1: "TASK_COMPUTING",
		2: "TASK_WRITING",
		3: "TASK_DONE",
		4: "TASK_FAILED",
		5: "TASK_STOPPED",
	}
	TASK_STATUS_value = map[string]int32{
		"TASK_PENDING":   0,
		"TASK_COMPUTING": 1,
		"TASK_WRITING":   2,
		"TASK_DONE":      3,
		"TASK_FAILED":    4,
		"TASK_STOPPED":   5,
	}
)

Enum value maps for TASK_STATUS.

View Source 
var (
	AuthenticateType_name = map[int32]string{
		0:  "PERMISSION_TYPE_UQL",
		1:  "PERMISSION_TYPE_INSERTNODES",
		2:  "PERMISSION_TYPE_INSERTEDGES",
		3:  "PERMISSION_TYPE_EXPORT",
		4:  "PERMISSION_TYPE_DOWNLOADFILE",
		5:  "PERMISSION_TYPE_INSTALLALGO",
		6:  "PERMISSION_TYPE_UNINSTALLALGO",
		7:  "PERMISSION_TYPE_UPLOADER",
		8:  "PERMISSION_TYPE_CREATEGRAPHBYUPLOADER",
		9:  "PERMISSION_TYPE_INSTALLEXTA",
		10: "PERMISSION_TYPE_UNINSTALLEXTA",
	}
	AuthenticateType_value = map[string]int32{
		"PERMISSION_TYPE_UQL":                   0,
		"PERMISSION_TYPE_INSERTNODES":           1,
		"PERMISSION_TYPE_INSERTEDGES":           2,
		"PERMISSION_TYPE_EXPORT":                3,
		"PERMISSION_TYPE_DOWNLOADFILE":          4,
		"PERMISSION_TYPE_INSTALLALGO":           5,
		"PERMISSION_TYPE_UNINSTALLALGO":         6,
		"PERMISSION_TYPE_UPLOADER":              7,
		"PERMISSION_TYPE_CREATEGRAPHBYUPLOADER": 8,
		"PERMISSION_TYPE_INSTALLEXTA":           9,
		"PERMISSION_TYPE_UNINSTALLEXTA":         10,
	}
)

Enum value maps for AuthenticateType.

View Source 
var (
	UserSettingRequest_OPTION_name = map[int32]string{
		0: "OPT_GET",
		1: "OPT_SET",
	}
	UserSettingRequest_OPTION_value = map[string]int32{
		"OPT_GET": 0,
		"OPT_SET": 1,
	}
)

Enum value maps for UserSettingRequest_OPTION.

View Source 
var File_ultipa_proto protoreflect.FileDescriptor
View Source 
var UltipaControls_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ultipa.UltipaControls",
	HandlerType: (*UltipaControlsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SayHello",
			Handler:    _UltipaControls_SayHello_Handler,
		},
		{
			MethodName: "UserSetting",
			Handler:    _UltipaControls_UserSetting_Handler,
		},
		{
			MethodName: "GetLeader",
			Handler:    _UltipaControls_GetLeader_Handler,
		},
		{
			MethodName: "UninstallAlgo",
			Handler:    _UltipaControls_UninstallAlgo_Handler,
		},
		{
			MethodName: "CreateGraphByUploader",
			Handler:    _UltipaControls_CreateGraphByUploader_Handler,
		},
		{
			MethodName: "UninstallExta",
			Handler:    _UltipaControls_UninstallExta_Handler,
		},
		{
			MethodName: "Authenticate",
			Handler:    _UltipaControls_Authenticate_Handler,
		},
		{
			MethodName: "Backup",
			Handler:    _UltipaControls_Backup_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "UqlEx",
			Handler:       _UltipaControls_UqlEx_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Export",
			Handler:       _UltipaControls_Export_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DownloadFileV2",
			Handler:       _UltipaControls_DownloadFileV2_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "InstallAlgo",
			Handler:       _UltipaControls_InstallAlgo_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Uploader",
			Handler:       _UltipaControls_Uploader_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "InstallExta",
			Handler:       _UltipaControls_InstallExta_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "ultipa.proto",
}

UltipaControls_ServiceDesc is the grpc.ServiceDesc for UltipaControls 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 UltipaRpcs_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ultipa.UltipaRpcs",
	HandlerType: (*UltipaRpcsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SayHello",
			Handler:    _UltipaRpcs_SayHello_Handler,
		},
		{
			MethodName: "InsertNodes",
			Handler:    _UltipaRpcs_InsertNodes_Handler,
		},
		{
			MethodName: "InsertEdges",
			Handler:    _UltipaRpcs_InsertEdges_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Uql",
			Handler:       _UltipaRpcs_Uql_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "ultipa.proto",
}

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

Functions

func RegisterUltipaControlsServer 

func RegisterUltipaControlsServer(s grpc.ServiceRegistrar, srv UltipaControlsServer)

func RegisterUltipaRpcsServer 

func RegisterUltipaRpcsServer(s grpc.ServiceRegistrar, srv UltipaRpcsServer)

Types

type Attr 

type Attr struct {
	ValueType PropertyType `protobuf:"varint,1,opt,name=value_type,json=valueType,proto3,enum=ultipa.PropertyType" json:"value_type,omitempty"`
	Values    [][]byte     `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Attr) Descriptor deprecated 

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

Deprecated: Use Attr.ProtoReflect.Descriptor instead.

func (*Attr) GetValueType 

func (x *Attr) GetValueType() PropertyType

func (*Attr) GetValues 

func (x *Attr) GetValues() [][]byte

func (*Attr) ProtoMessage 

func (*Attr) ProtoMessage()

func (*Attr) ProtoReflect 

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

func (*Attr) Reset 

func (x *Attr) Reset()

func (*Attr) String 

func (x *Attr) String() string

type AttrAlias 

type AttrAlias struct {
	Alias string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	Attr  *Attr  `protobuf:"bytes,2,opt,name=attr,proto3" json:"attr,omitempty"`
	// contains filtered or unexported fields
}

key = alias.name, value = ly

func (*AttrAlias) Descriptor deprecated 

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

Deprecated: Use AttrAlias.ProtoReflect.Descriptor instead.

func (*AttrAlias) GetAlias 

func (x *AttrAlias) GetAlias() string

func (*AttrAlias) GetAttr 

func (x *AttrAlias) GetAttr() *Attr

func (*AttrAlias) ProtoMessage 

func (*AttrAlias) ProtoMessage()

func (*AttrAlias) ProtoReflect 

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

func (*AttrAlias) Reset 

func (x *AttrAlias) Reset()

func (*AttrAlias) String 

func (x *AttrAlias) String() string

type AttrListData 

type AttrListData struct {
	Type   ResultType   `protobuf:"varint,1,opt,name=type,proto3,enum=ultipa.ResultType" json:"type,omitempty"`
	Nodes  *EntityTable `protobuf:"bytes,2,opt,name=nodes,proto3" json:"nodes,omitempty"`
	Edges  *EntityTable `protobuf:"bytes,3,opt,name=edges,proto3" json:"edges,omitempty"`
	Paths  []*Path      `protobuf:"bytes,4,rep,name=paths,proto3" json:"paths,omitempty"`
	Attrs  []*Attr      `protobuf:"bytes,5,rep,name=attrs,proto3" json:"attrs,omitempty"`
	IsNull bool         `protobuf:"varint,6,opt,name=is_null,json=isNull,proto3" json:"is_null,omitempty"`
	// contains filtered or unexported fields
}

func (*AttrListData) Descriptor deprecated 

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

Deprecated: Use AttrListData.ProtoReflect.Descriptor instead.

func (*AttrListData) GetAttrs 

func (x *AttrListData) GetAttrs() []*Attr

func (*AttrListData) GetEdges 

func (x *AttrListData) GetEdges() *EntityTable

func (*AttrListData) GetIsNull 

func (x *AttrListData) GetIsNull() bool

func (*AttrListData) GetNodes 

func (x *AttrListData) GetNodes() *EntityTable

func (*AttrListData) GetPaths 

func (x *AttrListData) GetPaths() []*Path

func (*AttrListData) GetType 

func (x *AttrListData) GetType() ResultType

func (*AttrListData) ProtoMessage 

func (*AttrListData) ProtoMessage()

func (*AttrListData) ProtoReflect 

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

func (*AttrListData) Reset 

func (x *AttrListData) Reset()

func (*AttrListData) String 

func (x *AttrListData) String() string

type AttrMapData 

type AttrMapData struct {
	Key   *Attr `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *Attr `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*AttrMapData) Descriptor deprecated 

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

Deprecated: Use AttrMapData.ProtoReflect.Descriptor instead.

func (*AttrMapData) GetKey 

func (x *AttrMapData) GetKey() *Attr

func (*AttrMapData) GetValue 

func (x *AttrMapData) GetValue() *Attr

func (*AttrMapData) ProtoMessage 

func (*AttrMapData) ProtoMessage()

func (*AttrMapData) ProtoReflect 

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

func (*AttrMapData) Reset 

func (x *AttrMapData) Reset()

func (*AttrMapData) String 

func (x *AttrMapData) String() string

type AuthenticateReply 

type AuthenticateReply struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthenticateReply) Descriptor deprecated 

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

Deprecated: Use AuthenticateReply.ProtoReflect.Descriptor instead.

func (*AuthenticateReply) GetStatus 

func (x *AuthenticateReply) GetStatus() *Status

func (*AuthenticateReply) ProtoMessage 

func (*AuthenticateReply) ProtoMessage()

func (*AuthenticateReply) ProtoReflect 

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

func (*AuthenticateReply) Reset 

func (x *AuthenticateReply) Reset()

func (*AuthenticateReply) String 

func (x *AuthenticateReply) String() string

type AuthenticateRequest 

type AuthenticateRequest struct {
	Type AuthenticateType `protobuf:"varint,1,opt,name=type,proto3,enum=ultipa.AuthenticateType" json:"type,omitempty"`
	Uql  string           `protobuf:"bytes,2,opt,name=uql,proto3" json:"uql,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthenticateRequest) Descriptor deprecated 

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

Deprecated: Use AuthenticateRequest.ProtoReflect.Descriptor instead.

func (*AuthenticateRequest) GetType 

func (x *AuthenticateRequest) GetType() AuthenticateType

func (*AuthenticateRequest) GetUql 

func (x *AuthenticateRequest) GetUql() string

func (*AuthenticateRequest) ProtoMessage 

func (*AuthenticateRequest) ProtoMessage()

func (*AuthenticateRequest) ProtoReflect 

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

func (*AuthenticateRequest) Reset 

func (x *AuthenticateRequest) Reset()

func (*AuthenticateRequest) String 

func (x *AuthenticateRequest) String() string

type AuthenticateType 

type AuthenticateType int32
const (
	AuthenticateType_PERMISSION_TYPE_UQL                   AuthenticateType = 0
	AuthenticateType_PERMISSION_TYPE_INSERTNODES           AuthenticateType = 1
	AuthenticateType_PERMISSION_TYPE_INSERTEDGES           AuthenticateType = 2
	AuthenticateType_PERMISSION_TYPE_EXPORT                AuthenticateType = 3
	AuthenticateType_PERMISSION_TYPE_DOWNLOADFILE          AuthenticateType = 4
	AuthenticateType_PERMISSION_TYPE_INSTALLALGO           AuthenticateType = 5
	AuthenticateType_PERMISSION_TYPE_UNINSTALLALGO         AuthenticateType = 6
	AuthenticateType_PERMISSION_TYPE_UPLOADER              AuthenticateType = 7
	AuthenticateType_PERMISSION_TYPE_CREATEGRAPHBYUPLOADER AuthenticateType = 8
	AuthenticateType_PERMISSION_TYPE_INSTALLEXTA           AuthenticateType = 9
	AuthenticateType_PERMISSION_TYPE_UNINSTALLEXTA         AuthenticateType = 10
)

func (AuthenticateType) Descriptor 

func (AuthenticateType) Descriptor() protoreflect.EnumDescriptor

func (AuthenticateType) Enum 

func (x AuthenticateType) Enum() *AuthenticateType

func (AuthenticateType) EnumDescriptor deprecated 

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

Deprecated: Use AuthenticateType.Descriptor instead.

func (AuthenticateType) Number 

func (x AuthenticateType) Number() protoreflect.EnumNumber

func (AuthenticateType) String 

func (x AuthenticateType) String() string

func (AuthenticateType) Type 

func (AuthenticateType) Type() protoreflect.EnumType

type BackupReply 

type BackupReply struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupReply) Descriptor deprecated 

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

Deprecated: Use BackupReply.ProtoReflect.Descriptor instead.

func (*BackupReply) GetStatus 

func (x *BackupReply) GetStatus() *Status

func (*BackupReply) ProtoMessage 

func (*BackupReply) ProtoMessage()

func (*BackupReply) ProtoReflect 

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

func (*BackupReply) Reset 

func (x *BackupReply) Reset()

func (*BackupReply) String 

func (x *BackupReply) String() string

type BackupRequest 

type BackupRequest struct {
	BackupPath string `protobuf:"bytes,1,opt,name=backup_path,json=backupPath,proto3" json:"backup_path,omitempty"`
	// contains filtered or unexported fields
}

------------------------16.Backup------------------------------

func (*BackupRequest) Descriptor deprecated 

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

Deprecated: Use BackupRequest.ProtoReflect.Descriptor instead.

func (*BackupRequest) GetBackupPath 

func (x *BackupRequest) GetBackupPath() string

func (*BackupRequest) ProtoMessage 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) ProtoReflect 

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

func (*BackupRequest) Reset 

func (x *BackupRequest) Reset()

func (*BackupRequest) String 

func (x *BackupRequest) String() string

type ClusterInfo 

type ClusterInfo struct {
	Redirect      string          `protobuf:"bytes,1,opt,name=redirect,proto3" json:"redirect,omitempty"`
	LeaderAddress string          `protobuf:"bytes,2,opt,name=leader_address,json=leaderAddress,proto3" json:"leader_address,omitempty"`
	Followers     []*RaftFollower `protobuf:"bytes,3,rep,name=followers,proto3" json:"followers,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterInfo) Descriptor deprecated 

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

Deprecated: Use ClusterInfo.ProtoReflect.Descriptor instead.

func (*ClusterInfo) GetFollowers 

func (x *ClusterInfo) GetFollowers() []*RaftFollower

func (*ClusterInfo) GetLeaderAddress 

func (x *ClusterInfo) GetLeaderAddress() string

func (*ClusterInfo) GetRedirect 

func (x *ClusterInfo) GetRedirect() string

func (*ClusterInfo) ProtoMessage 

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) ProtoReflect 

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

func (*ClusterInfo) Reset 

func (x *ClusterInfo) Reset()

func (*ClusterInfo) String 

func (x *ClusterInfo) String() string

type CreateGraphByUploaderReply 

type CreateGraphByUploaderReply struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateGraphByUploaderReply) Descriptor deprecated 

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

Deprecated: Use CreateGraphByUploaderReply.ProtoReflect.Descriptor instead.

func (*CreateGraphByUploaderReply) GetStatus 

func (x *CreateGraphByUploaderReply) GetStatus() *Status

func (*CreateGraphByUploaderReply) ProtoMessage 

func (*CreateGraphByUploaderReply) ProtoMessage()

func (*CreateGraphByUploaderReply) ProtoReflect 

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

func (*CreateGraphByUploaderReply) Reset 

func (x *CreateGraphByUploaderReply) Reset()

func (*CreateGraphByUploaderReply) String 

func (x *CreateGraphByUploaderReply) String() string

type CreateGraphByUploaderRequest 

type CreateGraphByUploaderRequest struct {
	GraphName        string `protobuf:"bytes,1,opt,name=graph_name,json=graphName,proto3" json:"graph_name,omitempty"`
	GraphDescription string `protobuf:"bytes,2,opt,name=graph_description,json=graphDescription,proto3" json:"graph_description,omitempty"`
	// contains filtered or unexported fields
}

------------------------13.RemoteGraphLoader------------------------------

func (*CreateGraphByUploaderRequest) Descriptor deprecated 

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

Deprecated: Use CreateGraphByUploaderRequest.ProtoReflect.Descriptor instead.

func (*CreateGraphByUploaderRequest) GetGraphDescription 

func (x *CreateGraphByUploaderRequest) GetGraphDescription() string

func (*CreateGraphByUploaderRequest) GetGraphName 

func (x *CreateGraphByUploaderRequest) GetGraphName() string

func (*CreateGraphByUploaderRequest) ProtoMessage 

func (*CreateGraphByUploaderRequest) ProtoMessage()

func (*CreateGraphByUploaderRequest) ProtoReflect 

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

func (*CreateGraphByUploaderRequest) Reset 

func (x *CreateGraphByUploaderRequest) Reset()

func (*CreateGraphByUploaderRequest) String 

func (x *CreateGraphByUploaderRequest) String() string

type DBType 

type DBType int32
const (
	DBType_DBNODE   DBType = 0
	DBType_DBEDGE   DBType = 1
	DBType_DBGLOBAL DBType = 2
)

func (DBType) Descriptor 

func (DBType) Descriptor() protoreflect.EnumDescriptor

func (DBType) Enum 

func (x DBType) Enum() *DBType

func (DBType) EnumDescriptor deprecated 

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

Deprecated: Use DBType.Descriptor instead.

func (DBType) Number 

func (x DBType) Number() protoreflect.EnumNumber

func (DBType) String 

func (x DBType) String() string

func (DBType) Type 

func (DBType) Type() protoreflect.EnumType

type DownloadFileReply 

type DownloadFileReply struct {
	Status    *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	TotalSize int32   `protobuf:"varint,2,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	Chunk     []byte  `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadFileReply) Descriptor deprecated 

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

Deprecated: Use DownloadFileReply.ProtoReflect.Descriptor instead.

func (*DownloadFileReply) GetChunk 

func (x *DownloadFileReply) GetChunk() []byte

func (*DownloadFileReply) GetStatus 

func (x *DownloadFileReply) GetStatus() *Status

func (*DownloadFileReply) GetTotalSize 

func (x *DownloadFileReply) GetTotalSize() int32

func (*DownloadFileReply) ProtoMessage 

func (*DownloadFileReply) ProtoMessage()

func (*DownloadFileReply) ProtoReflect 

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

func (*DownloadFileReply) Reset 

func (x *DownloadFileReply) Reset()

func (*DownloadFileReply) String 

func (x *DownloadFileReply) String() string

type DownloadFileRequestV2 

type DownloadFileRequestV2 struct {
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	TaskId   string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

下载算法生成文件

func (*DownloadFileRequestV2) Descriptor deprecated 

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

Deprecated: Use DownloadFileRequestV2.ProtoReflect.Descriptor instead.

func (*DownloadFileRequestV2) GetFileName 

func (x *DownloadFileRequestV2) GetFileName() string

func (*DownloadFileRequestV2) GetTaskId 

func (x *DownloadFileRequestV2) GetTaskId() string

func (*DownloadFileRequestV2) ProtoMessage 

func (*DownloadFileRequestV2) ProtoMessage()

func (*DownloadFileRequestV2) ProtoReflect 

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

func (*DownloadFileRequestV2) Reset 

func (x *DownloadFileRequestV2) Reset()

func (*DownloadFileRequestV2) String 

func (x *DownloadFileRequestV2) String() string

type EdgeAlias 

type EdgeAlias struct {
	EdgeTable *EntityTable `protobuf:"bytes,1,opt,name=edge_table,json=edgeTable,proto3" json:"edge_table,omitempty"`
	Alias     string       `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*EdgeAlias) Descriptor deprecated 

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

Deprecated: Use EdgeAlias.ProtoReflect.Descriptor instead.

func (*EdgeAlias) GetAlias 

func (x *EdgeAlias) GetAlias() string

func (*EdgeAlias) GetEdgeTable 

func (x *EdgeAlias) GetEdgeTable() *EntityTable

func (*EdgeAlias) ProtoMessage 

func (*EdgeAlias) ProtoMessage()

func (*EdgeAlias) ProtoReflect 

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

func (*EdgeAlias) Reset 

func (x *EdgeAlias) Reset()

func (*EdgeAlias) String 

func (x *EdgeAlias) String() string

type EntityRow 

type EntityRow struct {
	Uuid       uint64   `protobuf:"varint,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Id         string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	SchemaName string   `protobuf:"bytes,3,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	FromUuid   uint64   `protobuf:"varint,4,opt,name=from_uuid,json=fromUuid,proto3" json:"from_uuid,omitempty"`
	ToUuid     uint64   `protobuf:"varint,5,opt,name=to_uuid,json=toUuid,proto3" json:"to_uuid,omitempty"`
	FromId     string   `protobuf:"bytes,6,opt,name=from_id,json=fromId,proto3" json:"from_id,omitempty"`
	ToId       string   `protobuf:"bytes,7,opt,name=to_id,json=toId,proto3" json:"to_id,omitempty"`
	Values     [][]byte `protobuf:"bytes,8,rep,name=values,proto3" json:"values,omitempty"`
	IsNull     bool     `protobuf:"varint,9,opt,name=is_null,json=isNull,proto3" json:"is_null,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityRow) Descriptor deprecated 

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

Deprecated: Use EntityRow.ProtoReflect.Descriptor instead.

func (*EntityRow) GetFromId 

func (x *EntityRow) GetFromId() string

func (*EntityRow) GetFromUuid 

func (x *EntityRow) GetFromUuid() uint64

func (*EntityRow) GetId 

func (x *EntityRow) GetId() string

func (*EntityRow) GetIsNull 

func (x *EntityRow) GetIsNull() bool

func (*EntityRow) GetSchemaName 

func (x *EntityRow) GetSchemaName() string

func (*EntityRow) GetToId 

func (x *EntityRow) GetToId() string

func (*EntityRow) GetToUuid 

func (x *EntityRow) GetToUuid() uint64

func (*EntityRow) GetUuid 

func (x *EntityRow) GetUuid() uint64

func (*EntityRow) GetValues 

func (x *EntityRow) GetValues() [][]byte

func (*EntityRow) ProtoMessage 

func (*EntityRow) ProtoMessage()

func (*EntityRow) ProtoReflect 

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

func (*EntityRow) Reset 

func (x *EntityRow) Reset()

func (*EntityRow) String 

func (x *EntityRow) String() string

type EntityTable 

type EntityTable struct {
	Schemas    []*Schema    `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
	EntityRows []*EntityRow `protobuf:"bytes,3,rep,name=entity_rows,json=entityRows,proto3" json:"entity_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityTable) Descriptor deprecated 

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

Deprecated: Use EntityTable.ProtoReflect.Descriptor instead.

func (*EntityTable) GetEntityRows 

func (x *EntityTable) GetEntityRows() []*EntityRow

func (*EntityTable) GetSchemas 

func (x *EntityTable) GetSchemas() []*Schema

func (*EntityTable) ProtoMessage 

func (*EntityTable) ProtoMessage()

func (*EntityTable) ProtoReflect 

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

func (*EntityTable) Reset 

func (x *EntityTable) Reset()

func (*EntityTable) String 

func (x *EntityTable) String() string

type ErrorCode 

type ErrorCode int32
const (
	ErrorCode_SUCCESS                        ErrorCode = 0
	ErrorCode_FAILED                         ErrorCode = 1
	ErrorCode_PARAM_ERROR                    ErrorCode = 2
	ErrorCode_BASE_DB_ERROR                  ErrorCode = 3
	ErrorCode_ENGINE_ERROR                   ErrorCode = 4
	ErrorCode_SYSTEM_ERROR                   ErrorCode = 5
	ErrorCode_RAFT_REDIRECT                  ErrorCode = 6
	ErrorCode_RAFT_LEADER_NOT_YET_ELECTED    ErrorCode = 7
	ErrorCode_RAFT_LOG_ERROR                 ErrorCode = 8
	ErrorCode_UQL_ERROR                      ErrorCode = 9
	ErrorCode_NOT_RAFT_MODE                  ErrorCode = 10
	ErrorCode_RAFT_NO_AVAILABLE_FOLLOWERS    ErrorCode = 11
	ErrorCode_RAFT_NO_AVAILABLE_ALGO_SERVERS ErrorCode = 12
	//鉴权失败
	ErrorCode_PERMISSION_DENIED ErrorCode = 13
)

func (ErrorCode) Descriptor 

func (ErrorCode) Descriptor() protoreflect.EnumDescriptor

func (ErrorCode) Enum 

func (x ErrorCode) Enum() *ErrorCode

func (ErrorCode) EnumDescriptor deprecated 

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

Deprecated: Use ErrorCode.Descriptor instead.

func (ErrorCode) Number 

func (x ErrorCode) Number() protoreflect.EnumNumber

func (ErrorCode) String 

func (x ErrorCode) String() string

func (ErrorCode) Type 

func (ErrorCode) Type() protoreflect.EnumType

type ExplainPlan 

type ExplainPlan struct {

	// 先序遍历结果
	PlanNodes []*PlanNode `protobuf:"bytes,1,rep,name=plan_nodes,json=planNodes,proto3" json:"plan_nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainPlan) Descriptor deprecated 

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

Deprecated: Use ExplainPlan.ProtoReflect.Descriptor instead.

func (*ExplainPlan) GetPlanNodes 

func (x *ExplainPlan) GetPlanNodes() []*PlanNode

func (*ExplainPlan) ProtoMessage 

func (*ExplainPlan) ProtoMessage()

func (*ExplainPlan) ProtoReflect 

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

func (*ExplainPlan) Reset 

func (x *ExplainPlan) Reset()

func (*ExplainPlan) String 

func (x *ExplainPlan) String() string

type ExportReply 

type ExportReply struct {
	Status    *Status      `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	NodeTable *EntityTable `protobuf:"bytes,2,opt,name=node_table,json=nodeTable,proto3" json:"node_table,omitempty"`
	EdgeTable *EntityTable `protobuf:"bytes,3,opt,name=edge_table,json=edgeTable,proto3" json:"edge_table,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportReply) Descriptor deprecated 

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

Deprecated: Use ExportReply.ProtoReflect.Descriptor instead.

func (*ExportReply) GetEdgeTable 

func (x *ExportReply) GetEdgeTable() *EntityTable

func (*ExportReply) GetNodeTable 

func (x *ExportReply) GetNodeTable() *EntityTable

func (*ExportReply) GetStatus 

func (x *ExportReply) GetStatus() *Status

func (*ExportReply) ProtoMessage 

func (*ExportReply) ProtoMessage()

func (*ExportReply) ProtoReflect 

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

func (*ExportReply) Reset 

func (x *ExportReply) Reset()

func (*ExportReply) String 

func (x *ExportReply) String() string

type ExportRequest 

type ExportRequest struct {
	DbType           DBType   `protobuf:"varint,1,opt,name=db_type,json=dbType,proto3,enum=ultipa.DBType" json:"db_type,omitempty"`
	Limit            int32    `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	SelectProperties []string `protobuf:"bytes,3,rep,name=select_properties,json=selectProperties,proto3" json:"select_properties,omitempty"`
	Schema           string   `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

导出数据 limit < 0 全量导出 limit >= 0 导出limit条

func (*ExportRequest) Descriptor deprecated 

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

Deprecated: Use ExportRequest.ProtoReflect.Descriptor instead.

func (*ExportRequest) GetDbType 

func (x *ExportRequest) GetDbType() DBType

func (*ExportRequest) GetLimit 

func (x *ExportRequest) GetLimit() int32

func (*ExportRequest) GetSchema 

func (x *ExportRequest) GetSchema() string

func (*ExportRequest) GetSelectProperties 

func (x *ExportRequest) GetSelectProperties() []string

func (*ExportRequest) ProtoMessage 

func (*ExportRequest) ProtoMessage()

func (*ExportRequest) ProtoReflect 

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

func (*ExportRequest) Reset 

func (x *ExportRequest) Reset()

func (*ExportRequest) String 

func (x *ExportRequest) String() string

type FollowerRole 

type FollowerRole int32
const (
	FollowerRole_ROLE_UNSET           FollowerRole = 0
	FollowerRole_ROLE_READABLE        FollowerRole = 1
	FollowerRole_ROLE_ALGO_EXECUTABLE FollowerRole = 2
	FollowerRole_ROLE_LEARNER         FollowerRole = 4
)

func (FollowerRole) Descriptor 

func (FollowerRole) Descriptor() protoreflect.EnumDescriptor

func (FollowerRole) Enum 

func (x FollowerRole) Enum() *FollowerRole

func (FollowerRole) EnumDescriptor deprecated 

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

Deprecated: Use FollowerRole.Descriptor instead.

func (FollowerRole) Number 

func (x FollowerRole) Number() protoreflect.EnumNumber

func (FollowerRole) String 

func (x FollowerRole) String() string

func (FollowerRole) Type 

func (FollowerRole) Type() protoreflect.EnumType

type GetLeaderReply 

type GetLeaderReply struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLeaderReply) Descriptor deprecated 

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

Deprecated: Use GetLeaderReply.ProtoReflect.Descriptor instead.

func (*GetLeaderReply) GetStatus 

func (x *GetLeaderReply) GetStatus() *Status

func (*GetLeaderReply) ProtoMessage 

func (*GetLeaderReply) ProtoMessage()

func (*GetLeaderReply) ProtoReflect 

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

func (*GetLeaderReply) Reset 

func (x *GetLeaderReply) Reset()

func (*GetLeaderReply) String 

func (x *GetLeaderReply) String() string

type GetLeaderRequest 

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

------------------------6.GetLeader------------------------------

func (*GetLeaderRequest) Descriptor deprecated 

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

Deprecated: Use GetLeaderRequest.ProtoReflect.Descriptor instead.

func (*GetLeaderRequest) ProtoMessage 

func (*GetLeaderRequest) ProtoMessage()

func (*GetLeaderRequest) ProtoReflect 

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

func (*GetLeaderRequest) Reset 

func (x *GetLeaderRequest) Reset()

func (*GetLeaderRequest) String 

func (x *GetLeaderRequest) String() string
type Header struct {
	PropertyName string       `protobuf:"bytes,1,opt,name=property_name,json=propertyName,proto3" json:"property_name,omitempty"`
	PropertyType PropertyType `protobuf:"varint,2,opt,name=property_type,json=propertyType,proto3,enum=ultipa.PropertyType" json:"property_type,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetPropertyName 

func (x *Header) GetPropertyName() string

func (*Header) GetPropertyType 

func (x *Header) GetPropertyType() PropertyType

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

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

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type HelloUltipaReply 

type HelloUltipaReply struct {
	Status  *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Message string  `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*HelloUltipaReply) Descriptor deprecated 

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

Deprecated: Use HelloUltipaReply.ProtoReflect.Descriptor instead.

func (*HelloUltipaReply) GetMessage 

func (x *HelloUltipaReply) GetMessage() string

func (*HelloUltipaReply) GetStatus 

func (x *HelloUltipaReply) GetStatus() *Status

func (*HelloUltipaReply) ProtoMessage 

func (*HelloUltipaReply) ProtoMessage()

func (*HelloUltipaReply) ProtoReflect 

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

func (*HelloUltipaReply) Reset 

func (x *HelloUltipaReply) Reset()

func (*HelloUltipaReply) String 

func (x *HelloUltipaReply) String() string

type HelloUltipaRequest 

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

------------------------1.SayHello------------------------------

func (*HelloUltipaRequest) Descriptor deprecated 

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

Deprecated: Use HelloUltipaRequest.ProtoReflect.Descriptor instead.

func (*HelloUltipaRequest) GetName 

func (x *HelloUltipaRequest) GetName() string

func (*HelloUltipaRequest) ProtoMessage 

func (*HelloUltipaRequest) ProtoMessage()

func (*HelloUltipaRequest) ProtoReflect 

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

func (*HelloUltipaRequest) Reset 

func (x *HelloUltipaRequest) Reset()

func (*HelloUltipaRequest) String 

func (x *HelloUltipaRequest) String() string

type InsertEdgesReply 

type InsertEdgesReply struct {
	Status          *Status  `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	TimeCost        int32    `protobuf:"varint,2,opt,name=time_cost,json=timeCost,proto3" json:"time_cost,omitempty"`
	EngineTimeCost  int32    `protobuf:"varint,3,opt,name=engine_time_cost,json=engineTimeCost,proto3" json:"engine_time_cost,omitempty"`
	Uuids           []uint64 `protobuf:"varint,4,rep,packed,name=uuids,proto3" json:"uuids,omitempty"`
	IgnoreIndexes   []uint32 `protobuf:"varint,5,rep,packed,name=ignore_indexes,json=ignoreIndexes,proto3" json:"ignore_indexes,omitempty"`
	IgnoreErrorCode []uint32 `protobuf:"varint,6,rep,packed,name=ignore_error_code,json=ignoreErrorCode,proto3" json:"ignore_error_code,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertEdgesReply) Descriptor deprecated 

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

Deprecated: Use InsertEdgesReply.ProtoReflect.Descriptor instead.

func (*InsertEdgesReply) GetEngineTimeCost 

func (x *InsertEdgesReply) GetEngineTimeCost() int32

func (*InsertEdgesReply) GetIgnoreErrorCode 

func (x *InsertEdgesReply) GetIgnoreErrorCode() []uint32

func (*InsertEdgesReply) GetIgnoreIndexes 

func (x *InsertEdgesReply) GetIgnoreIndexes() []uint32

func (*InsertEdgesReply) GetStatus 

func (x *InsertEdgesReply) GetStatus() *Status

func (*InsertEdgesReply) GetTimeCost 

func (x *InsertEdgesReply) GetTimeCost() int32

func (*InsertEdgesReply) GetUuids 

func (x *InsertEdgesReply) GetUuids() []uint64

func (*InsertEdgesReply) ProtoMessage 

func (*InsertEdgesReply) ProtoMessage()

func (*InsertEdgesReply) ProtoReflect 

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

func (*InsertEdgesReply) Reset 

func (x *InsertEdgesReply) Reset()

func (*InsertEdgesReply) String 

func (x *InsertEdgesReply) String() string

type InsertEdgesRequest 

type InsertEdgesRequest struct {
	EdgeTable *EntityTable `protobuf:"bytes,1,opt,name=edge_table,json=edgeTable,proto3" json:"edge_table,omitempty"`
	//if true return ids
	Silent               bool       `protobuf:"varint,2,opt,name=silent,proto3" json:"silent,omitempty"`
	GraphName            string     `protobuf:"bytes,3,opt,name=graph_name,json=graphName,proto3" json:"graph_name,omitempty"`
	CreateNodeIfNotExist bool       `` /* 128-byte string literal not displayed */
	InsertType           InsertType `protobuf:"varint,5,opt,name=insert_type,json=insertType,proto3,enum=ultipa.InsertType" json:"insert_type,omitempty"`
	// contains filtered or unexported fields
}

------------------------8.InsertEdges------------------------------

func (*InsertEdgesRequest) Descriptor deprecated 

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

Deprecated: Use InsertEdgesRequest.ProtoReflect.Descriptor instead.

func (*InsertEdgesRequest) GetCreateNodeIfNotExist 

func (x *InsertEdgesRequest) GetCreateNodeIfNotExist() bool

func (*InsertEdgesRequest) GetEdgeTable 

func (x *InsertEdgesRequest) GetEdgeTable() *EntityTable

func (*InsertEdgesRequest) GetGraphName 

func (x *InsertEdgesRequest) GetGraphName() string

func (*InsertEdgesRequest) GetInsertType 

func (x *InsertEdgesRequest) GetInsertType() InsertType

func (*InsertEdgesRequest) GetSilent 

func (x *InsertEdgesRequest) GetSilent() bool

func (*InsertEdgesRequest) ProtoMessage 

func (*InsertEdgesRequest) ProtoMessage()

func (*InsertEdgesRequest) ProtoReflect 

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

func (*InsertEdgesRequest) Reset 

func (x *InsertEdgesRequest) Reset()

func (*InsertEdgesRequest) String 

func (x *InsertEdgesRequest) String() string

type InsertNodesReply 

type InsertNodesReply struct {
	Status          *Status  `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	TimeCost        int32    `protobuf:"varint,2,opt,name=time_cost,json=timeCost,proto3" json:"time_cost,omitempty"`
	EngineTimeCost  int32    `protobuf:"varint,3,opt,name=engine_time_cost,json=engineTimeCost,proto3" json:"engine_time_cost,omitempty"`
	Uuids           []uint64 `protobuf:"varint,4,rep,packed,name=uuids,proto3" json:"uuids,omitempty"`
	Ids             []string `protobuf:"bytes,5,rep,name=ids,proto3" json:"ids,omitempty"`
	IgnoreIndexes   []uint32 `protobuf:"varint,6,rep,packed,name=ignore_indexes,json=ignoreIndexes,proto3" json:"ignore_indexes,omitempty"`
	IgnoreErrorCode []uint32 `protobuf:"varint,7,rep,packed,name=ignore_error_code,json=ignoreErrorCode,proto3" json:"ignore_error_code,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertNodesReply) Descriptor deprecated 

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

Deprecated: Use InsertNodesReply.ProtoReflect.Descriptor instead.

func (*InsertNodesReply) GetEngineTimeCost 

func (x *InsertNodesReply) GetEngineTimeCost() int32

func (*InsertNodesReply) GetIds 

func (x *InsertNodesReply) GetIds() []string

func (*InsertNodesReply) GetIgnoreErrorCode 

func (x *InsertNodesReply) GetIgnoreErrorCode() []uint32

func (*InsertNodesReply) GetIgnoreIndexes 

func (x *InsertNodesReply) GetIgnoreIndexes() []uint32

func (*InsertNodesReply) GetStatus 

func (x *InsertNodesReply) GetStatus() *Status

func (*InsertNodesReply) GetTimeCost 

func (x *InsertNodesReply) GetTimeCost() int32

func (*InsertNodesReply) GetUuids 

func (x *InsertNodesReply) GetUuids() []uint64

func (*InsertNodesReply) ProtoMessage 

func (*InsertNodesReply) ProtoMessage()

func (*InsertNodesReply) ProtoReflect 

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

func (*InsertNodesReply) Reset 

func (x *InsertNodesReply) Reset()

func (*InsertNodesReply) String 

func (x *InsertNodesReply) String() string

type InsertNodesRequest 

type InsertNodesRequest struct {
	NodeTable *EntityTable `protobuf:"bytes,1,opt,name=node_table,json=nodeTable,proto3" json:"node_table,omitempty"`
	//if true return ids
	Silent     bool       `protobuf:"varint,2,opt,name=silent,proto3" json:"silent,omitempty"`
	GraphName  string     `protobuf:"bytes,3,opt,name=graph_name,json=graphName,proto3" json:"graph_name,omitempty"`
	InsertType InsertType `protobuf:"varint,4,opt,name=insert_type,json=insertType,proto3,enum=ultipa.InsertType" json:"insert_type,omitempty"`
	// contains filtered or unexported fields
}

------------------------7.InsertNodes------------------------------

func (*InsertNodesRequest) Descriptor deprecated 

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

Deprecated: Use InsertNodesRequest.ProtoReflect.Descriptor instead.

func (*InsertNodesRequest) GetGraphName 

func (x *InsertNodesRequest) GetGraphName() string

func (*InsertNodesRequest) GetInsertType 

func (x *InsertNodesRequest) GetInsertType() InsertType

func (*InsertNodesRequest) GetNodeTable 

func (x *InsertNodesRequest) GetNodeTable() *EntityTable

func (*InsertNodesRequest) GetSilent 

func (x *InsertNodesRequest) GetSilent() bool

func (*InsertNodesRequest) ProtoMessage 

func (*InsertNodesRequest) ProtoMessage()

func (*InsertNodesRequest) ProtoReflect 

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

func (*InsertNodesRequest) Reset 

func (x *InsertNodesRequest) Reset()

func (*InsertNodesRequest) String 

func (x *InsertNodesRequest) String() string

type InsertType 

type InsertType int32
const (
	InsertType_NORMAL    InsertType = 0
	InsertType_OVERWRITE InsertType = 1
	InsertType_UPSERT    InsertType = 2
)

func (InsertType) Descriptor 

func (InsertType) Descriptor() protoreflect.EnumDescriptor

func (InsertType) Enum 

func (x InsertType) Enum() *InsertType

func (InsertType) EnumDescriptor deprecated 

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

Deprecated: Use InsertType.Descriptor instead.

func (InsertType) Number 

func (x InsertType) Number() protoreflect.EnumNumber

func (InsertType) String 

func (x InsertType) String() string

func (InsertType) Type 

func (InsertType) Type() protoreflect.EnumType

type InstallAlgoReply 

type InstallAlgoReply struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*InstallAlgoReply) Descriptor deprecated 

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

Deprecated: Use InstallAlgoReply.ProtoReflect.Descriptor instead.

func (*InstallAlgoReply) GetStatus 

func (x *InstallAlgoReply) GetStatus() *Status

func (*InstallAlgoReply) ProtoMessage 

func (*InstallAlgoReply) ProtoMessage()

func (*InstallAlgoReply) ProtoReflect 

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

func (*InstallAlgoReply) Reset 

func (x *InstallAlgoReply) Reset()

func (*InstallAlgoReply) String 

func (x *InstallAlgoReply) String() string

type InstallAlgoRequest 

type InstallAlgoRequest struct {
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Md5      string `protobuf:"bytes,2,opt,name=md5,proto3" json:"md5,omitempty"`
	Chunk    []byte `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

------------------------10.InstallAlgo------------------------------

func (*InstallAlgoRequest) Descriptor deprecated 

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

Deprecated: Use InstallAlgoRequest.ProtoReflect.Descriptor instead.

func (*InstallAlgoRequest) GetChunk 

func (x *InstallAlgoRequest) GetChunk() []byte

func (*InstallAlgoRequest) GetFileName 

func (x *InstallAlgoRequest) GetFileName() string

func (*InstallAlgoRequest) GetMd5 

func (x *InstallAlgoRequest) GetMd5() string

func (*InstallAlgoRequest) ProtoMessage 

func (*InstallAlgoRequest) ProtoMessage()

func (*InstallAlgoRequest) ProtoReflect 

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

func (*InstallAlgoRequest) Reset 

func (x *InstallAlgoRequest) Reset()

func (*InstallAlgoRequest) String 

func (x *InstallAlgoRequest) String() string

type InstallExtaReply 

type InstallExtaReply struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*InstallExtaReply) Descriptor deprecated 

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

Deprecated: Use InstallExtaReply.ProtoReflect.Descriptor instead.

func (*InstallExtaReply) GetStatus 

func (x *InstallExtaReply) GetStatus() *Status

func (*InstallExtaReply) ProtoMessage 

func (*InstallExtaReply) ProtoMessage()

func (*InstallExtaReply) ProtoReflect 

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

func (*InstallExtaReply) Reset 

func (x *InstallExtaReply) Reset()

func (*InstallExtaReply) String 

func (x *InstallExtaReply) String() string

type InstallExtaRequest 

type InstallExtaRequest struct {
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Md5      string `protobuf:"bytes,2,opt,name=md5,proto3" json:"md5,omitempty"`
	Chunk    []byte `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

------------------------14.InstallExta------------------------------

func (*InstallExtaRequest) Descriptor deprecated 

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

Deprecated: Use InstallExtaRequest.ProtoReflect.Descriptor instead.

func (*InstallExtaRequest) GetChunk 

func (x *InstallExtaRequest) GetChunk() []byte

func (*InstallExtaRequest) GetFileName 

func (x *InstallExtaRequest) GetFileName() string

func (*InstallExtaRequest) GetMd5 

func (x *InstallExtaRequest) GetMd5() string

func (*InstallExtaRequest) ProtoMessage 

func (*InstallExtaRequest) ProtoMessage()

func (*InstallExtaRequest) ProtoReflect 

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

func (*InstallExtaRequest) Reset 

func (x *InstallExtaRequest) Reset()

func (*InstallExtaRequest) String 

func (x *InstallExtaRequest) String() string

type ListData 

type ListData struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	IsNull bool     `protobuf:"varint,2,opt,name=is_null,json=isNull,proto3" json:"is_null,omitempty"`
	// contains filtered or unexported fields
}

for rpc insert

func (*ListData) Descriptor deprecated 

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

Deprecated: Use ListData.ProtoReflect.Descriptor instead.

func (*ListData) GetIsNull 

func (x *ListData) GetIsNull() bool

func (*ListData) GetValues 

func (x *ListData) GetValues() [][]byte

func (*ListData) ProtoMessage 

func (*ListData) ProtoMessage()

func (*ListData) ProtoReflect 

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

func (*ListData) Reset 

func (x *ListData) Reset()

func (*ListData) String 

func (x *ListData) String() string

type MapData 

type MapData struct {
	Values []*MapValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	IsNull bool        `protobuf:"varint,2,opt,name=is_null,json=isNull,proto3" json:"is_null,omitempty"`
	// contains filtered or unexported fields
}

func (*MapData) Descriptor deprecated 

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

Deprecated: Use MapData.ProtoReflect.Descriptor instead.

func (*MapData) GetIsNull 

func (x *MapData) GetIsNull() bool

func (*MapData) GetValues 

func (x *MapData) GetValues() []*MapValue

func (*MapData) ProtoMessage 

func (*MapData) ProtoMessage()

func (*MapData) ProtoReflect 

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

func (*MapData) Reset 

func (x *MapData) Reset()

func (*MapData) String 

func (x *MapData) String() string

type MapValue 

type MapValue struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*MapValue) Descriptor deprecated 

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

Deprecated: Use MapValue.ProtoReflect.Descriptor instead.

func (*MapValue) GetKey 

func (x *MapValue) GetKey() []byte

func (*MapValue) GetValue 

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

func (*MapValue) ProtoMessage 

func (*MapValue) ProtoMessage()

func (*MapValue) ProtoReflect 

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

func (*MapValue) Reset 

func (x *MapValue) Reset()

func (*MapValue) String 

func (x *MapValue) String() string

type NodeAlias 

type NodeAlias struct {
	NodeTable *EntityTable `protobuf:"bytes,1,opt,name=node_table,json=nodeTable,proto3" json:"node_table,omitempty"`
	Alias     string       `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeAlias) Descriptor deprecated 

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

Deprecated: Use NodeAlias.ProtoReflect.Descriptor instead.

func (*NodeAlias) GetAlias 

func (x *NodeAlias) GetAlias() string

func (*NodeAlias) GetNodeTable 

func (x *NodeAlias) GetNodeTable() *EntityTable

func (*NodeAlias) ProtoMessage 

func (*NodeAlias) ProtoMessage()

func (*NodeAlias) ProtoReflect 

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

func (*NodeAlias) Reset 

func (x *NodeAlias) Reset()

func (*NodeAlias) String 

func (x *NodeAlias) String() string

type Path 

type Path struct {
	NodeTable *EntityTable `protobuf:"bytes,1,opt,name=node_table,json=nodeTable,proto3" json:"node_table,omitempty"`
	EdgeTable *EntityTable `protobuf:"bytes,2,opt,name=edge_table,json=edgeTable,proto3" json:"edge_table,omitempty"`
	// contains filtered or unexported fields
}

func (*Path) Descriptor deprecated 

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

Deprecated: Use Path.ProtoReflect.Descriptor instead.

func (*Path) GetEdgeTable 

func (x *Path) GetEdgeTable() *EntityTable

func (*Path) GetNodeTable 

func (x *Path) GetNodeTable() *EntityTable

func (*Path) ProtoMessage 

func (*Path) ProtoMessage()

func (*Path) ProtoReflect 

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

func (*Path) Reset 

func (x *Path) Reset()

func (*Path) String 

func (x *Path) String() string

type PathAlias 

type PathAlias struct {
	Paths []*Path `protobuf:"bytes,1,rep,name=paths,proto3" json:"paths,omitempty"`
	Alias string  `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*PathAlias) Descriptor deprecated 

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

Deprecated: Use PathAlias.ProtoReflect.Descriptor instead.

func (*PathAlias) GetAlias 

func (x *PathAlias) GetAlias() string

func (*PathAlias) GetPaths 

func (x *PathAlias) GetPaths() []*Path

func (*PathAlias) ProtoMessage 

func (*PathAlias) ProtoMessage()

func (*PathAlias) ProtoReflect 

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

func (*PathAlias) Reset 

func (x *PathAlias) Reset()

func (*PathAlias) String 

func (x *PathAlias) String() string

type PlanNode 

type PlanNode struct {
	Alias       string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ChildrenNum uint32 `protobuf:"varint,2,opt,name=children_num,json=childrenNum,proto3" json:"children_num,omitempty"`
	Uql         string `protobuf:"bytes,3,opt,name=uql,proto3" json:"uql,omitempty"`
	Infos       string `protobuf:"bytes,4,opt,name=infos,proto3" json:"infos,omitempty"`
	// contains filtered or unexported fields
}

func (*PlanNode) Descriptor deprecated 

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

Deprecated: Use PlanNode.ProtoReflect.Descriptor instead.

func (*PlanNode) GetAlias 

func (x *PlanNode) GetAlias() string

func (*PlanNode) GetChildrenNum 

func (x *PlanNode) GetChildrenNum() uint32

func (*PlanNode) GetInfos 

func (x *PlanNode) GetInfos() string

func (*PlanNode) GetUql 

func (x *PlanNode) GetUql() string

func (*PlanNode) ProtoMessage 

func (*PlanNode) ProtoMessage()

func (*PlanNode) ProtoReflect 

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

func (*PlanNode) Reset 

func (x *PlanNode) Reset()

func (*PlanNode) String 

func (x *PlanNode) String() string

type Property 

type Property struct {
	PropertyName string         `protobuf:"bytes,1,opt,name=property_name,json=propertyName,proto3" json:"property_name,omitempty"`
	PropertyType PropertyType   `protobuf:"varint,2,opt,name=property_type,json=propertyType,proto3,enum=ultipa.PropertyType" json:"property_type,omitempty"`
	SubTypes     []PropertyType `protobuf:"varint,3,rep,packed,name=sub_types,json=subTypes,proto3,enum=ultipa.PropertyType" json:"sub_types,omitempty"`
	// contains filtered or unexported fields
}

func (*Property) Descriptor deprecated 

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

Deprecated: Use Property.ProtoReflect.Descriptor instead.

func (*Property) GetPropertyName 

func (x *Property) GetPropertyName() string

func (*Property) GetPropertyType 

func (x *Property) GetPropertyType() PropertyType

func (*Property) GetSubTypes 

func (x *Property) GetSubTypes() []PropertyType

func (*Property) ProtoMessage 

func (*Property) ProtoMessage()

func (*Property) ProtoReflect 

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

func (*Property) Reset 

func (x *Property) Reset()

func (*Property) String 

func (x *Property) String() string

type PropertyType 

type PropertyType int32
const (
	PropertyType_UNSET     PropertyType = 0
	PropertyType_INT32     PropertyType = 1
	PropertyType_UINT32    PropertyType = 2
	PropertyType_INT64     PropertyType = 3
	PropertyType_UINT64    PropertyType = 4
	PropertyType_FLOAT     PropertyType = 5
	PropertyType_DOUBLE    PropertyType = 6
	PropertyType_STRING    PropertyType = 7
	PropertyType_DATETIME  PropertyType = 8
	PropertyType_TIMESTAMP PropertyType = 9
	PropertyType_TEXT      PropertyType = 10
	PropertyType_BLOB      PropertyType = 11
	PropertyType_POINT     PropertyType = 12
	PropertyType_DECIMAL   PropertyType = 13
	PropertyType_LIST      PropertyType = 14
	PropertyType_SET       PropertyType = 15
	PropertyType_MAP       PropertyType = 16
	PropertyType_NULL_     PropertyType = 17
)

func (PropertyType) Descriptor 

func (PropertyType) Descriptor() protoreflect.EnumDescriptor

func (PropertyType) Enum 

func (x PropertyType) Enum() *PropertyType

func (PropertyType) EnumDescriptor deprecated 

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

Deprecated: Use PropertyType.Descriptor instead.

func (PropertyType) Number 

func (x PropertyType) Number() protoreflect.EnumNumber

func (PropertyType) String 

func (x PropertyType) String() string

func (PropertyType) Type 

func (PropertyType) Type() protoreflect.EnumType

type RaftFollower 

type RaftFollower struct {
	Address string       `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Role    int32        `protobuf:"varint,2,opt,name=role,proto3" json:"role,omitempty"`
	Status  ServerStatus `protobuf:"varint,3,opt,name=status,proto3,enum=ultipa.ServerStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftFollower) Descriptor deprecated 

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

Deprecated: Use RaftFollower.ProtoReflect.Descriptor instead.

func (*RaftFollower) GetAddress 

func (x *RaftFollower) GetAddress() string

func (*RaftFollower) GetRole 

func (x *RaftFollower) GetRole() int32

func (*RaftFollower) GetStatus 

func (x *RaftFollower) GetStatus() ServerStatus

func (*RaftFollower) ProtoMessage 

func (*RaftFollower) ProtoMessage()

func (*RaftFollower) ProtoReflect 

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

func (*RaftFollower) Reset 

func (x *RaftFollower) Reset()

func (*RaftFollower) String 

func (x *RaftFollower) String() string

type ResultAlias 

type ResultAlias struct {
	Alias      string     `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ResultType ResultType `protobuf:"varint,2,opt,name=result_type,json=resultType,proto3,enum=ultipa.ResultType" json:"result_type,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultAlias) Descriptor deprecated 

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

Deprecated: Use ResultAlias.ProtoReflect.Descriptor instead.

func (*ResultAlias) GetAlias 

func (x *ResultAlias) GetAlias() string

func (*ResultAlias) GetResultType 

func (x *ResultAlias) GetResultType() ResultType

func (*ResultAlias) ProtoMessage 

func (*ResultAlias) ProtoMessage()

func (*ResultAlias) ProtoReflect 

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

func (*ResultAlias) Reset 

func (x *ResultAlias) Reset()

func (*ResultAlias) String 

func (x *ResultAlias) String() string

type ResultType 

type ResultType int32
const (
	ResultType_RESULT_TYPE_UNSET ResultType = 0
	ResultType_RESULT_TYPE_PATH  ResultType = 1
	ResultType_RESULT_TYPE_NODE  ResultType = 2
	ResultType_RESULT_TYPE_EDGE  ResultType = 3
	ResultType_RESULT_TYPE_ATTR  ResultType = 4
	ResultType_RESULT_TYPE_TABLE ResultType = 5
)

func (ResultType) Descriptor 

func (ResultType) Descriptor() protoreflect.EnumDescriptor

func (ResultType) Enum 

func (x ResultType) Enum() *ResultType

func (ResultType) EnumDescriptor deprecated 

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

Deprecated: Use ResultType.Descriptor instead.

func (ResultType) Number 

func (x ResultType) Number() protoreflect.EnumNumber

func (ResultType) String 

func (x ResultType) String() string

func (ResultType) Type 

func (ResultType) Type() protoreflect.EnumType

type Schema 

type Schema struct {
	SchemaName string      `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	Properties []*Property `protobuf:"bytes,2,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetProperties 

func (x *Schema) GetProperties() []*Property

func (*Schema) GetSchemaName 

func (x *Schema) GetSchemaName() string

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect 

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

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

type ServerStatus 

type ServerStatus int32
const (
	ServerStatus_DEAD  ServerStatus = 0
	ServerStatus_ALIVE ServerStatus = 1
)

func (ServerStatus) Descriptor 

func (ServerStatus) Descriptor() protoreflect.EnumDescriptor

func (ServerStatus) Enum 

func (x ServerStatus) Enum() *ServerStatus

func (ServerStatus) EnumDescriptor deprecated 

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

Deprecated: Use ServerStatus.Descriptor instead.

func (ServerStatus) Number 

func (x ServerStatus) Number() protoreflect.EnumNumber

func (ServerStatus) String 

func (x ServerStatus) String() string

func (ServerStatus) Type 

func (ServerStatus) Type() protoreflect.EnumType

type SetData 

type SetData struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	IsNull bool     `protobuf:"varint,2,opt,name=is_null,json=isNull,proto3" json:"is_null,omitempty"`
	// contains filtered or unexported fields
}

func (*SetData) Descriptor deprecated 

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

Deprecated: Use SetData.ProtoReflect.Descriptor instead.

func (*SetData) GetIsNull 

func (x *SetData) GetIsNull() bool

func (*SetData) GetValues 

func (x *SetData) GetValues() [][]byte

func (*SetData) ProtoMessage 

func (*SetData) ProtoMessage()

func (*SetData) ProtoReflect 

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

func (*SetData) Reset 

func (x *SetData) Reset()

func (*SetData) String 

func (x *SetData) String() string

type Status 

type Status struct {
	ErrorCode   ErrorCode    `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3,enum=ultipa.ErrorCode" json:"error_code,omitempty"`
	Msg         string       `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	ClusterInfo *ClusterInfo `protobuf:"bytes,3,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetClusterInfo 

func (x *Status) GetClusterInfo() *ClusterInfo

func (*Status) GetErrorCode 

func (x *Status) GetErrorCode() ErrorCode

func (*Status) GetMsg 

func (x *Status) GetMsg() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type TASK_STATUS 

type TASK_STATUS int32
const (
	TASK_STATUS_TASK_PENDING   TASK_STATUS = 0
	TASK_STATUS_TASK_COMPUTING TASK_STATUS = 1
	TASK_STATUS_TASK_WRITING   TASK_STATUS = 2
	TASK_STATUS_TASK_DONE      TASK_STATUS = 3
	TASK_STATUS_TASK_FAILED    TASK_STATUS = 4
	TASK_STATUS_TASK_STOPPED   TASK_STATUS = 5
)

func (TASK_STATUS) Descriptor 

func (TASK_STATUS) Descriptor() protoreflect.EnumDescriptor

func (TASK_STATUS) Enum 

func (x TASK_STATUS) Enum() *TASK_STATUS

func (TASK_STATUS) EnumDescriptor deprecated 

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

Deprecated: Use TASK_STATUS.Descriptor instead.

func (TASK_STATUS) Number 

func (x TASK_STATUS) Number() protoreflect.EnumNumber

func (TASK_STATUS) String 

func (x TASK_STATUS) String() string

func (TASK_STATUS) Type 

func (TASK_STATUS) Type() protoreflect.EnumType

type Table 

type Table struct {
	TableName string      `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Headers   []*Header   `protobuf:"bytes,2,rep,name=headers,proto3" json:"headers,omitempty"`
	TableRows []*TableRow `protobuf:"bytes,3,rep,name=table_rows,json=tableRows,proto3" json:"table_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*Table) Descriptor deprecated 

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetHeaders 

func (x *Table) GetHeaders() []*Header

func (*Table) GetTableName 

func (x *Table) GetTableName() string

func (*Table) GetTableRows 

func (x *Table) GetTableRows() []*TableRow

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect 

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

func (*Table) Reset 

func (x *Table) Reset()

func (*Table) String 

func (x *Table) String() string

type TableRow 

type TableRow struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*TableRow) Descriptor deprecated 

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

Deprecated: Use TableRow.ProtoReflect.Descriptor instead.

func (*TableRow) GetValues 

func (x *TableRow) GetValues() [][]byte

func (*TableRow) ProtoMessage 

func (*TableRow) ProtoMessage()

func (*TableRow) ProtoReflect 

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

func (*TableRow) Reset 

func (x *TableRow) Reset()

func (*TableRow) String 

func (x *TableRow) String() string

type UltipaControlsClient 

type UltipaControlsClient interface {
	//1.Sends a greeting
	SayHello(ctx context.Context, in *HelloUltipaRequest, opts ...grpc.CallOption) (*HelloUltipaReply, error)
	//2.用户设置(用于存储用户配置信息,用户自主控制)
	UserSetting(ctx context.Context, in *UserSettingRequest, opts ...grpc.CallOption) (*UserSettingReply, error)
	//3. 获取raft的leader
	GetLeader(ctx context.Context, in *GetLeaderRequest, opts ...grpc.CallOption) (*GetLeaderReply, error)
	//4.uql扩展，以下命令在此接口执行执行 top, kill show().* stats
	UqlEx(ctx context.Context, in *UqlRequest, opts ...grpc.CallOption) (UltipaControls_UqlExClient, error)
	//5.导出点,边数据
	Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (UltipaControls_ExportClient, error)
	//6.下载算法生成文件
	//下载算法生成文件 v2 下载文件请求改为 算法名 + 任务号
	DownloadFileV2(ctx context.Context, in *DownloadFileRequestV2, opts ...grpc.CallOption) (UltipaControls_DownloadFileV2Client, error)
	//7.算法安装
	InstallAlgo(ctx context.Context, opts ...grpc.CallOption) (UltipaControls_InstallAlgoClient, error)
	//8.算法卸载
	UninstallAlgo(ctx context.Context, in *UninstallAlgoRequest, opts ...grpc.CallOption) (*UninstallAlgoReply, error)
	//9.remote graph loader
	Uploader(ctx context.Context, opts ...grpc.CallOption) (UltipaControls_UploaderClient, error)
	//10.create graph by uploader
	CreateGraphByUploader(ctx context.Context, in *CreateGraphByUploaderRequest, opts ...grpc.CallOption) (*CreateGraphByUploaderReply, error)
	//11.扩展算法安装
	InstallExta(ctx context.Context, opts ...grpc.CallOption) (UltipaControls_InstallExtaClient, error)
	//12.扩展算法卸载
	UninstallExta(ctx context.Context, in *UninstallExtaRequest, opts ...grpc.CallOption) (*UninstallExtaReply, error)
	//13.仅鉴权
	Authenticate(ctx context.Context, in *AuthenticateRequest, opts ...grpc.CallOption) (*AuthenticateReply, error)
	//14.backup data
	Backup(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (*BackupReply, error)
}

UltipaControlsClient is the client API for UltipaControls 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 NewUltipaControlsClient 

func NewUltipaControlsClient(cc grpc.ClientConnInterface) UltipaControlsClient

type UltipaControlsServer 

type UltipaControlsServer interface {
	//1.Sends a greeting
	SayHello(context.Context, *HelloUltipaRequest) (*HelloUltipaReply, error)
	//2.用户设置(用于存储用户配置信息,用户自主控制)
	UserSetting(context.Context, *UserSettingRequest) (*UserSettingReply, error)
	//3. 获取raft的leader
	GetLeader(context.Context, *GetLeaderRequest) (*GetLeaderReply, error)
	//4.uql扩展，以下命令在此接口执行执行 top, kill show().* stats
	UqlEx(*UqlRequest, UltipaControls_UqlExServer) error
	//5.导出点,边数据
	Export(*ExportRequest, UltipaControls_ExportServer) error
	//6.下载算法生成文件
	//下载算法生成文件 v2 下载文件请求改为 算法名 + 任务号
	DownloadFileV2(*DownloadFileRequestV2, UltipaControls_DownloadFileV2Server) error
	//7.算法安装
	InstallAlgo(UltipaControls_InstallAlgoServer) error
	//8.算法卸载
	UninstallAlgo(context.Context, *UninstallAlgoRequest) (*UninstallAlgoReply, error)
	//9.remote graph loader
	Uploader(UltipaControls_UploaderServer) error
	//10.create graph by uploader
	CreateGraphByUploader(context.Context, *CreateGraphByUploaderRequest) (*CreateGraphByUploaderReply, error)
	//11.扩展算法安装
	InstallExta(UltipaControls_InstallExtaServer) error
	//12.扩展算法卸载
	UninstallExta(context.Context, *UninstallExtaRequest) (*UninstallExtaReply, error)
	//13.仅鉴权
	Authenticate(context.Context, *AuthenticateRequest) (*AuthenticateReply, error)
	//14.backup data
	Backup(context.Context, *BackupRequest) (*BackupReply, error)
	// contains filtered or unexported methods
}

UltipaControlsServer is the server API for UltipaControls service. All implementations must embed UnimplementedUltipaControlsServer for forward compatibility

type UltipaControls_DownloadFileV2Client 

type UltipaControls_DownloadFileV2Client interface {
	Recv() (*DownloadFileReply, error)
	grpc.ClientStream
}

type UltipaControls_DownloadFileV2Server 

type UltipaControls_DownloadFileV2Server interface {
	Send(*DownloadFileReply) error
	grpc.ServerStream
}

type UltipaControls_ExportClient 

type UltipaControls_ExportClient interface {
	Recv() (*ExportReply, error)
	grpc.ClientStream
}

type UltipaControls_ExportServer 

type UltipaControls_ExportServer interface {
	Send(*ExportReply) error
	grpc.ServerStream
}

type UltipaControls_InstallAlgoClient 

type UltipaControls_InstallAlgoClient interface {
	Send(*InstallAlgoRequest) error
	CloseAndRecv() (*InstallAlgoReply, error)
	grpc.ClientStream
}

type UltipaControls_InstallAlgoServer 

type UltipaControls_InstallAlgoServer interface {
	SendAndClose(*InstallAlgoReply) error
	Recv() (*InstallAlgoRequest, error)
	grpc.ServerStream
}

type UltipaControls_InstallExtaClient 

type UltipaControls_InstallExtaClient interface {
	Send(*InstallExtaRequest) error
	CloseAndRecv() (*InstallExtaReply, error)
	grpc.ClientStream
}

type UltipaControls_InstallExtaServer 

type UltipaControls_InstallExtaServer interface {
	SendAndClose(*InstallExtaReply) error
	Recv() (*InstallExtaRequest, error)
	grpc.ServerStream
}

type UltipaControls_UploaderClient 

type UltipaControls_UploaderClient interface {
	Send(*UploaderRequest) error
	CloseAndRecv() (*UploaderReply, error)
	grpc.ClientStream
}

type UltipaControls_UploaderServer 

type UltipaControls_UploaderServer interface {
	SendAndClose(*UploaderReply) error
	Recv() (*UploaderRequest, error)
	grpc.ServerStream
}

type UltipaControls_UqlExClient 

type UltipaControls_UqlExClient interface {
	Recv() (*UqlReply, error)
	grpc.ClientStream
}

type UltipaControls_UqlExServer 

type UltipaControls_UqlExServer interface {
	Send(*UqlReply) error
	grpc.ServerStream
}

type UltipaRpcsClient 

type UltipaRpcsClient interface {
	//1.Sends a greeting
	SayHello(ctx context.Context, in *HelloUltipaRequest, opts ...grpc.CallOption) (*HelloUltipaReply, error)
	//2.uql
	Uql(ctx context.Context, in *UqlRequest, opts ...grpc.CallOption) (UltipaRpcs_UqlClient, error)
	//3.插入点
	InsertNodes(ctx context.Context, in *InsertNodesRequest, opts ...grpc.CallOption) (*InsertNodesReply, error)
	//4.插入边
	InsertEdges(ctx context.Context, in *InsertEdgesRequest, opts ...grpc.CallOption) (*InsertEdgesReply, error)
}

UltipaRpcsClient is the client API for UltipaRpcs 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 NewUltipaRpcsClient 

func NewUltipaRpcsClient(cc grpc.ClientConnInterface) UltipaRpcsClient

type UltipaRpcsServer 

type UltipaRpcsServer interface {
	//1.Sends a greeting
	SayHello(context.Context, *HelloUltipaRequest) (*HelloUltipaReply, error)
	//2.uql
	Uql(*UqlRequest, UltipaRpcs_UqlServer) error
	//3.插入点
	InsertNodes(context.Context, *InsertNodesRequest) (*InsertNodesReply, error)
	//4.插入边
	InsertEdges(context.Context, *InsertEdgesRequest) (*InsertEdgesReply, error)
	// contains filtered or unexported methods
}

UltipaRpcsServer is the server API for UltipaRpcs service. All implementations must embed UnimplementedUltipaRpcsServer for forward compatibility

type UltipaRpcs_UqlClient 

type UltipaRpcs_UqlClient interface {
	Recv() (*UqlReply, error)
	grpc.ClientStream
}

type UltipaRpcs_UqlServer 

type UltipaRpcs_UqlServer interface {
	Send(*UqlReply) error
	grpc.ServerStream
}

type UnimplementedUltipaControlsServer 

type UnimplementedUltipaControlsServer struct {
}

UnimplementedUltipaControlsServer must be embedded to have forward compatible implementations.

func (UnimplementedUltipaControlsServer) Authenticate 

func (UnimplementedUltipaControlsServer) Authenticate(context.Context, *AuthenticateRequest) (*AuthenticateReply, error)

func (UnimplementedUltipaControlsServer) Backup 

func (UnimplementedUltipaControlsServer) Backup(context.Context, *BackupRequest) (*BackupReply, error)

func (UnimplementedUltipaControlsServer) CreateGraphByUploader 

func (UnimplementedUltipaControlsServer) CreateGraphByUploader(context.Context, *CreateGraphByUploaderRequest) (*CreateGraphByUploaderReply, error)

func (UnimplementedUltipaControlsServer) DownloadFileV2 

func (UnimplementedUltipaControlsServer) DownloadFileV2(*DownloadFileRequestV2, UltipaControls_DownloadFileV2Server) error

func (UnimplementedUltipaControlsServer) Export 

func (UnimplementedUltipaControlsServer) Export(*ExportRequest, UltipaControls_ExportServer) error

func (UnimplementedUltipaControlsServer) GetLeader 

func (UnimplementedUltipaControlsServer) GetLeader(context.Context, *GetLeaderRequest) (*GetLeaderReply, error)

func (UnimplementedUltipaControlsServer) InstallAlgo 

func (UnimplementedUltipaControlsServer) InstallAlgo(UltipaControls_InstallAlgoServer) error

func (UnimplementedUltipaControlsServer) InstallExta 

func (UnimplementedUltipaControlsServer) InstallExta(UltipaControls_InstallExtaServer) error

func (UnimplementedUltipaControlsServer) SayHello 

func (UnimplementedUltipaControlsServer) SayHello(context.Context, *HelloUltipaRequest) (*HelloUltipaReply, error)

func (UnimplementedUltipaControlsServer) UninstallAlgo 

func (UnimplementedUltipaControlsServer) UninstallAlgo(context.Context, *UninstallAlgoRequest) (*UninstallAlgoReply, error)

func (UnimplementedUltipaControlsServer) UninstallExta 

func (UnimplementedUltipaControlsServer) UninstallExta(context.Context, *UninstallExtaRequest) (*UninstallExtaReply, error)

func (UnimplementedUltipaControlsServer) Uploader 

func (UnimplementedUltipaControlsServer) Uploader(UltipaControls_UploaderServer) error

func (UnimplementedUltipaControlsServer) UqlEx 

func (UnimplementedUltipaControlsServer) UqlEx(*UqlRequest, UltipaControls_UqlExServer) error

func (UnimplementedUltipaControlsServer) UserSetting 

func (UnimplementedUltipaControlsServer) UserSetting(context.Context, *UserSettingRequest) (*UserSettingReply, error)

type UnimplementedUltipaRpcsServer 

type UnimplementedUltipaRpcsServer struct {
}

UnimplementedUltipaRpcsServer must be embedded to have forward compatible implementations.

func (UnimplementedUltipaRpcsServer) InsertEdges 

func (UnimplementedUltipaRpcsServer) InsertEdges(context.Context, *InsertEdgesRequest) (*InsertEdgesReply, error)

func (UnimplementedUltipaRpcsServer) InsertNodes 

func (UnimplementedUltipaRpcsServer) InsertNodes(context.Context, *InsertNodesRequest) (*InsertNodesReply, error)

func (UnimplementedUltipaRpcsServer) SayHello 

func (UnimplementedUltipaRpcsServer) SayHello(context.Context, *HelloUltipaRequest) (*HelloUltipaReply, error)

func (UnimplementedUltipaRpcsServer) Uql 

func (UnimplementedUltipaRpcsServer) Uql(*UqlRequest, UltipaRpcs_UqlServer) error

type UninstallAlgoReply 

type UninstallAlgoReply struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UninstallAlgoReply) Descriptor deprecated 

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

Deprecated: Use UninstallAlgoReply.ProtoReflect.Descriptor instead.

func (*UninstallAlgoReply) GetStatus 

func (x *UninstallAlgoReply) GetStatus() *Status

func (*UninstallAlgoReply) ProtoMessage 

func (*UninstallAlgoReply) ProtoMessage()

func (*UninstallAlgoReply) ProtoReflect 

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

func (*UninstallAlgoReply) Reset 

func (x *UninstallAlgoReply) Reset()

func (*UninstallAlgoReply) String 

func (x *UninstallAlgoReply) String() string

type UninstallAlgoRequest 

type UninstallAlgoRequest struct {
	AlgoName string `protobuf:"bytes,1,opt,name=algo_name,json=algoName,proto3" json:"algo_name,omitempty"`
	// contains filtered or unexported fields
}

------------------------11.UninstallAlgo------------------------------

func (*UninstallAlgoRequest) Descriptor deprecated 

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

Deprecated: Use UninstallAlgoRequest.ProtoReflect.Descriptor instead.

func (*UninstallAlgoRequest) GetAlgoName 

func (x *UninstallAlgoRequest) GetAlgoName() string

func (*UninstallAlgoRequest) ProtoMessage 

func (*UninstallAlgoRequest) ProtoMessage()

func (*UninstallAlgoRequest) ProtoReflect 

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

func (*UninstallAlgoRequest) Reset 

func (x *UninstallAlgoRequest) Reset()

func (*UninstallAlgoRequest) String 

func (x *UninstallAlgoRequest) String() string

type UninstallExtaReply 

type UninstallExtaReply struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UninstallExtaReply) Descriptor deprecated 

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

Deprecated: Use UninstallExtaReply.ProtoReflect.Descriptor instead.

func (*UninstallExtaReply) GetStatus 

func (x *UninstallExtaReply) GetStatus() *Status

func (*UninstallExtaReply) ProtoMessage 

func (*UninstallExtaReply) ProtoMessage()

func (*UninstallExtaReply) ProtoReflect 

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

func (*UninstallExtaReply) Reset 

func (x *UninstallExtaReply) Reset()

func (*UninstallExtaReply) String 

func (x *UninstallExtaReply) String() string

type UninstallExtaRequest 

type UninstallExtaRequest struct {
	ExtaName string `protobuf:"bytes,1,opt,name=exta_name,json=extaName,proto3" json:"exta_name,omitempty"`
	// contains filtered or unexported fields
}

------------------------15.UninstallExta------------------------------

func (*UninstallExtaRequest) Descriptor deprecated 

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

Deprecated: Use UninstallExtaRequest.ProtoReflect.Descriptor instead.

func (*UninstallExtaRequest) GetExtaName 

func (x *UninstallExtaRequest) GetExtaName() string

func (*UninstallExtaRequest) ProtoMessage 

func (*UninstallExtaRequest) ProtoMessage()

func (*UninstallExtaRequest) ProtoReflect 

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

func (*UninstallExtaRequest) Reset 

func (x *UninstallExtaRequest) Reset()

func (*UninstallExtaRequest) String 

func (x *UninstallExtaRequest) String() string

type UnsafeUltipaControlsServer 

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

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

type UnsafeUltipaRpcsServer 

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

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

type UploaderReply 

type UploaderReply struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UploaderReply) Descriptor deprecated 

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

Deprecated: Use UploaderReply.ProtoReflect.Descriptor instead.

func (*UploaderReply) GetStatus 

func (x *UploaderReply) GetStatus() *Status

func (*UploaderReply) ProtoMessage 

func (*UploaderReply) ProtoMessage()

func (*UploaderReply) ProtoReflect 

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

func (*UploaderReply) Reset 

func (x *UploaderReply) Reset()

func (*UploaderReply) String 

func (x *UploaderReply) String() string

type UploaderRequest 

type UploaderRequest struct {
	DbType          DBType `protobuf:"varint,1,opt,name=db_type,json=dbType,proto3,enum=ultipa.DBType" json:"db_type,omitempty"`
	GraphName       string `protobuf:"bytes,2,opt,name=graph_name,json=graphName,proto3" json:"graph_name,omitempty"`
	TotalFileCounts uint64 `protobuf:"varint,3,opt,name=total_file_counts,json=totalFileCounts,proto3" json:"total_file_counts,omitempty"`
	FileName        string `protobuf:"bytes,4,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	FileSize        uint64 `protobuf:"varint,5,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	Chunk           []byte `protobuf:"bytes,6,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

------------------------12.RemoteGraphLoader------------------------------

func (*UploaderRequest) Descriptor deprecated 

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

Deprecated: Use UploaderRequest.ProtoReflect.Descriptor instead.

func (*UploaderRequest) GetChunk 

func (x *UploaderRequest) GetChunk() []byte

func (*UploaderRequest) GetDbType 

func (x *UploaderRequest) GetDbType() DBType

func (*UploaderRequest) GetFileName 

func (x *UploaderRequest) GetFileName() string

func (*UploaderRequest) GetFileSize 

func (x *UploaderRequest) GetFileSize() uint64

func (*UploaderRequest) GetGraphName 

func (x *UploaderRequest) GetGraphName() string

func (*UploaderRequest) GetTotalFileCounts 

func (x *UploaderRequest) GetTotalFileCounts() uint64

func (*UploaderRequest) ProtoMessage 

func (*UploaderRequest) ProtoMessage()

func (*UploaderRequest) ProtoReflect 

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

func (*UploaderRequest) Reset 

func (x *UploaderRequest) Reset()

func (*UploaderRequest) String 

func (x *UploaderRequest) String() string

type UqlReply 

type UqlReply struct {
	Status         *Status        `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	TotalTimeCost  int32          `protobuf:"varint,2,opt,name=total_time_cost,json=totalTimeCost,proto3" json:"total_time_cost,omitempty"`
	EngineTimeCost int32          `protobuf:"varint,3,opt,name=engine_time_cost,json=engineTimeCost,proto3" json:"engine_time_cost,omitempty"`
	Alias          []*ResultAlias `protobuf:"bytes,4,rep,name=alias,proto3" json:"alias,omitempty"`
	Paths          []*PathAlias   `protobuf:"bytes,5,rep,name=paths,proto3" json:"paths,omitempty"`
	Nodes          []*NodeAlias   `protobuf:"bytes,6,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Edges          []*EdgeAlias   `protobuf:"bytes,7,rep,name=edges,proto3" json:"edges,omitempty"`
	Attrs          []*AttrAlias   `protobuf:"bytes,8,rep,name=attrs,proto3" json:"attrs,omitempty"`
	Tables         []*Table       `protobuf:"bytes,10,rep,name=tables,proto3" json:"tables,omitempty"`
	Statistics     *Table         `protobuf:"bytes,11,opt,name=statistics,proto3" json:"statistics,omitempty"`
	ExplainPlan    *ExplainPlan   `protobuf:"bytes,12,opt,name=explain_plan,json=explainPlan,proto3" json:"explain_plan,omitempty"`
	// contains filtered or unexported fields
}

func (*UqlReply) Descriptor deprecated 

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

Deprecated: Use UqlReply.ProtoReflect.Descriptor instead.

func (*UqlReply) GetAlias 

func (x *UqlReply) GetAlias() []*ResultAlias

func (*UqlReply) GetAttrs 

func (x *UqlReply) GetAttrs() []*AttrAlias

func (*UqlReply) GetEdges 

func (x *UqlReply) GetEdges() []*EdgeAlias

func (*UqlReply) GetEngineTimeCost 

func (x *UqlReply) GetEngineTimeCost() int32

func (*UqlReply) GetExplainPlan 

func (x *UqlReply) GetExplainPlan() *ExplainPlan

func (*UqlReply) GetNodes 

func (x *UqlReply) GetNodes() []*NodeAlias

func (*UqlReply) GetPaths 

func (x *UqlReply) GetPaths() []*PathAlias

func (*UqlReply) GetStatistics 

func (x *UqlReply) GetStatistics() *Table

func (*UqlReply) GetStatus 

func (x *UqlReply) GetStatus() *Status

func (*UqlReply) GetTables 

func (x *UqlReply) GetTables() []*Table

func (*UqlReply) GetTotalTimeCost 

func (x *UqlReply) GetTotalTimeCost() int32

func (*UqlReply) ProtoMessage 

func (*UqlReply) ProtoMessage()

func (*UqlReply) ProtoReflect 

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

func (*UqlReply) Reset 

func (x *UqlReply) Reset()

func (*UqlReply) String 

func (x *UqlReply) String() string

type UqlRequest 

type UqlRequest struct {
	Uql       string `protobuf:"bytes,1,opt,name=uql,proto3" json:"uql,omitempty"`
	Timeout   uint32 `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	GraphName string `protobuf:"bytes,3,opt,name=graph_name,json=graphName,proto3" json:"graph_name,omitempty"`
	UserName  string `protobuf:"bytes,4,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	ThreadNum uint32 `protobuf:"varint,5,opt,name=thread_num,json=threadNum,proto3" json:"thread_num,omitempty"`
	Tz        string `protobuf:"bytes,6,opt,name=tz,proto3" json:"tz,omitempty"`
	TzOffset  string `protobuf:"bytes,7,opt,name=tz_offset,json=tzOffset,proto3" json:"tz_offset,omitempty"`
	// contains filtered or unexported fields
}

uql : ab.src(1).dest(2).depth(1).limit(10).select(*) db_name : default timeout 1s 单位:秒

func (*UqlRequest) Descriptor deprecated 

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

Deprecated: Use UqlRequest.ProtoReflect.Descriptor instead.

func (*UqlRequest) GetGraphName 

func (x *UqlRequest) GetGraphName() string

func (*UqlRequest) GetThreadNum 

func (x *UqlRequest) GetThreadNum() uint32

func (*UqlRequest) GetTimeout 

func (x *UqlRequest) GetTimeout() uint32

func (*UqlRequest) GetTz 

func (x *UqlRequest) GetTz() string

func (*UqlRequest) GetTzOffset 

func (x *UqlRequest) GetTzOffset() string

func (*UqlRequest) GetUql 

func (x *UqlRequest) GetUql() string

func (*UqlRequest) GetUserName 

func (x *UqlRequest) GetUserName() string

func (*UqlRequest) ProtoMessage 

func (*UqlRequest) ProtoMessage()

func (*UqlRequest) ProtoReflect 

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

func (*UqlRequest) Reset 

func (x *UqlRequest) Reset()

func (*UqlRequest) String 

func (x *UqlRequest) String() string

type UserSettingReply 

type UserSettingReply struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Data   string  `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*UserSettingReply) Descriptor deprecated 

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

Deprecated: Use UserSettingReply.ProtoReflect.Descriptor instead.

func (*UserSettingReply) GetData 

func (x *UserSettingReply) GetData() string

func (*UserSettingReply) GetStatus 

func (x *UserSettingReply) GetStatus() *Status

func (*UserSettingReply) ProtoMessage 

func (*UserSettingReply) ProtoMessage()

func (*UserSettingReply) ProtoReflect 

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

func (*UserSettingReply) Reset 

func (x *UserSettingReply) Reset()

func (*UserSettingReply) String 

func (x *UserSettingReply) String() string

type UserSettingRequest 

type UserSettingRequest struct {
	UserName string                    `protobuf:"bytes,1,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	Opt      UserSettingRequest_OPTION `protobuf:"varint,2,opt,name=opt,proto3,enum=ultipa.UserSettingRequest_OPTION" json:"opt,omitempty"`
	//key
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	//value
	Data string `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

------------------------3.UserSetting------------------------------

func (*UserSettingRequest) Descriptor deprecated 

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

Deprecated: Use UserSettingRequest.ProtoReflect.Descriptor instead.

func (*UserSettingRequest) GetData 

func (x *UserSettingRequest) GetData() string

func (*UserSettingRequest) GetOpt 

func (x *UserSettingRequest) GetOpt() UserSettingRequest_OPTION

func (*UserSettingRequest) GetType 

func (x *UserSettingRequest) GetType() string

func (*UserSettingRequest) GetUserName 

func (x *UserSettingRequest) GetUserName() string

func (*UserSettingRequest) ProtoMessage 

func (*UserSettingRequest) ProtoMessage()

func (*UserSettingRequest) ProtoReflect 

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

func (*UserSettingRequest) Reset 

func (x *UserSettingRequest) Reset()

func (*UserSettingRequest) String 

func (x *UserSettingRequest) String() string

type UserSettingRequest_OPTION 

type UserSettingRequest_OPTION int32
const (
	UserSettingRequest_OPT_GET UserSettingRequest_OPTION = 0
	UserSettingRequest_OPT_SET UserSettingRequest_OPTION = 1
)

func (UserSettingRequest_OPTION) Descriptor 

func (UserSettingRequest_OPTION) Descriptor() protoreflect.EnumDescriptor

func (UserSettingRequest_OPTION) Enum 

func (x UserSettingRequest_OPTION) Enum() *UserSettingRequest_OPTION

func (UserSettingRequest_OPTION) EnumDescriptor deprecated 

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

Deprecated: Use UserSettingRequest_OPTION.Descriptor instead.

func (UserSettingRequest_OPTION) Number 

func (x UserSettingRequest_OPTION) Number() protoreflect.EnumNumber

func (UserSettingRequest_OPTION) String 

func (x UserSettingRequest_OPTION) String() string

func (UserSettingRequest_OPTION) Type 

func (UserSettingRequest_OPTION) Type() protoreflect.EnumType

type Value 

type Value struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetKey 

func (x *Value) GetKey() string

func (*Value) GetValue 

func (x *Value) GetValue() string

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

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

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

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