nebula

package
v0.0.0-...-dd4567d Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const Version = "3.0.0"

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var Value_BVal_DEFAULT bool
View Source 
var Value_FVal_DEFAULT float64
View Source 
var Value_IVal_DEFAULT int64
View Source 
var Value_SVal_DEFAULT []byte

Functions

This section is empty.

Types

type CheckpointInfo 

type CheckpointInfo struct {
	SpaceID  GraphSpaceID             `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts    map[PartitionID]*LogInfo `thrift:"parts,2" db:"parts" json:"parts"`
	DataPath []byte                   `thrift:"data_path,3" db:"data_path" json:"data_path"`
}

Attributes:

  • SpaceID
  • Parts
  • DataPath

func NewCheckpointInfo 

func NewCheckpointInfo() *CheckpointInfo

func (*CheckpointInfo) Equals 

func (p *CheckpointInfo) Equals(other *CheckpointInfo) bool

func (*CheckpointInfo) GetDataPath 

func (p *CheckpointInfo) GetDataPath() []byte

func (*CheckpointInfo) GetParts 

func (p *CheckpointInfo) GetParts() map[PartitionID]*LogInfo

func (*CheckpointInfo) GetSpaceID 

func (p *CheckpointInfo) GetSpaceID() GraphSpaceID

func (*CheckpointInfo) LogValue 

func (p *CheckpointInfo) LogValue() slog.Value

func (*CheckpointInfo) Read 

func (p *CheckpointInfo) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*CheckpointInfo) ReadField1 

func (p *CheckpointInfo) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*CheckpointInfo) ReadField2 

func (p *CheckpointInfo) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*CheckpointInfo) ReadField3 

func (p *CheckpointInfo) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*CheckpointInfo) String 

func (p *CheckpointInfo) String() string

func (*CheckpointInfo) Validate 

func (p *CheckpointInfo) Validate() error

func (*CheckpointInfo) Write 

func (p *CheckpointInfo) Write(ctx context.Context, oprot thrift.TProtocol) error

type ClusterID 

type ClusterID int64

func ClusterIDPtr 

func ClusterIDPtr(v ClusterID) *ClusterID

type Coordinate 

type Coordinate struct {
	X float64 `thrift:"x,1" db:"x" json:"x"`
	Y float64 `thrift:"y,2" db:"y" json:"y"`
}

Attributes:

  • X
  • Y
var Point_Coord_DEFAULT *Coordinate

func NewCoordinate 

func NewCoordinate() *Coordinate

func (*Coordinate) Equals 

func (p *Coordinate) Equals(other *Coordinate) bool

func (*Coordinate) GetX 

func (p *Coordinate) GetX() float64

func (*Coordinate) GetY 

func (p *Coordinate) GetY() float64

func (*Coordinate) LogValue 

func (p *Coordinate) LogValue() slog.Value

func (*Coordinate) Read 

func (p *Coordinate) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Coordinate) ReadField1 

func (p *Coordinate) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Coordinate) ReadField2 

func (p *Coordinate) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Coordinate) String 

func (p *Coordinate) String() string

func (*Coordinate) Validate 

func (p *Coordinate) Validate() error

func (*Coordinate) Write 

func (p *Coordinate) Write(ctx context.Context, oprot thrift.TProtocol) error

type DataSet 

type DataSet struct {
	ColumnNames [][]byte `thrift:"column_names,1" db:"column_names" json:"column_names"`
	Rows        []*Row   `thrift:"rows,2" db:"rows" json:"rows"`
}

Attributes:

  • ColumnNames
  • Rows
var Value_GVal_DEFAULT *DataSet

func NewDataSet 

func NewDataSet() *DataSet

func (*DataSet) Equals 

func (p *DataSet) Equals(other *DataSet) bool

func (*DataSet) GetColumnNames 

func (p *DataSet) GetColumnNames() [][]byte

func (*DataSet) GetRows 

func (p *DataSet) GetRows() []*Row

func (*DataSet) LogValue 

func (p *DataSet) LogValue() slog.Value

func (*DataSet) Read 

func (p *DataSet) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*DataSet) ReadField1 

func (p *DataSet) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*DataSet) ReadField2 

func (p *DataSet) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*DataSet) String 

func (p *DataSet) String() string

func (*DataSet) Validate 

func (p *DataSet) Validate() error

func (*DataSet) Write 

func (p *DataSet) Write(ctx context.Context, oprot thrift.TProtocol) error

type Date 

type Date struct {
	Year  int16 `thrift:"year,1" db:"year" json:"year"`
	Month int8  `thrift:"month,2" db:"month" json:"month"`
	Day   int8  `thrift:"day,3" db:"day" json:"day"`
}

Attributes:

  • Year
  • Month
  • Day
var Value_DVal_DEFAULT *Date

func NewDate 

func NewDate() *Date

func (*Date) Equals 

func (p *Date) Equals(other *Date) bool

func (*Date) GetDay 

func (p *Date) GetDay() int8

func (*Date) GetMonth 

func (p *Date) GetMonth() int8

func (*Date) GetYear 

func (p *Date) GetYear() int16

func (*Date) LogValue 

func (p *Date) LogValue() slog.Value

func (*Date) Read 

func (p *Date) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Date) ReadField1 

func (p *Date) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Date) ReadField2 

func (p *Date) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Date) ReadField3 

func (p *Date) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*Date) String 

func (p *Date) String() string

func (*Date) Validate 

func (p *Date) Validate() error

func (*Date) Write 

func (p *Date) Write(ctx context.Context, oprot thrift.TProtocol) error

type DateTime 

type DateTime struct {
	Year     int16 `thrift:"year,1" db:"year" json:"year"`
	Month    int8  `thrift:"month,2" db:"month" json:"month"`
	Day      int8  `thrift:"day,3" db:"day" json:"day"`
	Hour     int8  `thrift:"hour,4" db:"hour" json:"hour"`
	Minute   int8  `thrift:"minute,5" db:"minute" json:"minute"`
	Sec      int8  `thrift:"sec,6" db:"sec" json:"sec"`
	Microsec int32 `thrift:"microsec,7" db:"microsec" json:"microsec"`
}

Attributes:

  • Year
  • Month
  • Day
  • Hour
  • Minute
  • Sec
  • Microsec
var Value_DtVal_DEFAULT *DateTime

func NewDateTime 

func NewDateTime() *DateTime

func (*DateTime) Equals 

func (p *DateTime) Equals(other *DateTime) bool

func (*DateTime) GetDay 

func (p *DateTime) GetDay() int8

func (*DateTime) GetHour 

func (p *DateTime) GetHour() int8

func (*DateTime) GetMicrosec 

func (p *DateTime) GetMicrosec() int32

func (*DateTime) GetMinute 

func (p *DateTime) GetMinute() int8

func (*DateTime) GetMonth 

func (p *DateTime) GetMonth() int8

func (*DateTime) GetSec 

func (p *DateTime) GetSec() int8

func (*DateTime) GetYear 

func (p *DateTime) GetYear() int16

func (*DateTime) LogValue 

func (p *DateTime) LogValue() slog.Value

func (*DateTime) Read 

func (p *DateTime) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*DateTime) ReadField1 

func (p *DateTime) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*DateTime) ReadField2 

func (p *DateTime) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*DateTime) ReadField3 

func (p *DateTime) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*DateTime) ReadField4 

func (p *DateTime) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*DateTime) ReadField5 

func (p *DateTime) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*DateTime) ReadField6 

func (p *DateTime) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*DateTime) ReadField7 

func (p *DateTime) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*DateTime) String 

func (p *DateTime) String() string

func (*DateTime) Validate 

func (p *DateTime) Validate() error

func (*DateTime) Write 

func (p *DateTime) Write(ctx context.Context, oprot thrift.TProtocol) error

type DirInfo 

type DirInfo struct {
	Root []byte   `thrift:"root,1" db:"root" json:"root"`
	Data [][]byte `thrift:"data,2" db:"data" json:"data"`
}

Attributes:

  • Root
  • Data

func NewDirInfo 

func NewDirInfo() *DirInfo

func (*DirInfo) Equals 

func (p *DirInfo) Equals(other *DirInfo) bool

func (*DirInfo) GetData 

func (p *DirInfo) GetData() [][]byte

func (*DirInfo) GetRoot 

func (p *DirInfo) GetRoot() []byte

func (*DirInfo) LogValue 

func (p *DirInfo) LogValue() slog.Value

func (*DirInfo) Read 

func (p *DirInfo) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*DirInfo) ReadField1 

func (p *DirInfo) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*DirInfo) ReadField2 

func (p *DirInfo) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*DirInfo) String 

func (p *DirInfo) String() string

func (*DirInfo) Validate 

func (p *DirInfo) Validate() error

func (*DirInfo) Write 

func (p *DirInfo) Write(ctx context.Context, oprot thrift.TProtocol) error

type Duration 

type Duration struct {
	Seconds      int64 `thrift:"seconds,1" db:"seconds" json:"seconds"`
	Microseconds int32 `thrift:"microseconds,2" db:"microseconds" json:"microseconds"`
	Months       int32 `thrift:"months,3" db:"months" json:"months"`
}

Attributes:

  • Seconds
  • Microseconds
  • Months
var Value_DuVal_DEFAULT *Duration

func NewDuration 

func NewDuration() *Duration

func (*Duration) Equals 

func (p *Duration) Equals(other *Duration) bool

func (*Duration) GetMicroseconds 

func (p *Duration) GetMicroseconds() int32

func (*Duration) GetMonths 

func (p *Duration) GetMonths() int32

func (*Duration) GetSeconds 

func (p *Duration) GetSeconds() int64

func (*Duration) LogValue 

func (p *Duration) LogValue() slog.Value

func (*Duration) Read 

func (p *Duration) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Duration) ReadField1 

func (p *Duration) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Duration) ReadField2 

func (p *Duration) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Duration) ReadField3 

func (p *Duration) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*Duration) String 

func (p *Duration) String() string

func (*Duration) Validate 

func (p *Duration) Validate() error

func (*Duration) Write 

func (p *Duration) Write(ctx context.Context, oprot thrift.TProtocol) error

type Edge 

type Edge struct {
	Src     *Value            `thrift:"src,1" db:"src" json:"src"`
	Dst     *Value            `thrift:"dst,2" db:"dst" json:"dst"`
	Type    EdgeType          `thrift:"type,3" db:"type" json:"type"`
	Name    []byte            `thrift:"name,4" db:"name" json:"name"`
	Ranking EdgeRanking       `thrift:"ranking,5" db:"ranking" json:"ranking"`
	Props   map[string]*Value `thrift:"props,6" db:"props" json:"props"`
}

Attributes:

  • Src
  • Dst
  • Type
  • Name
  • Ranking
  • Props
var Value_EVal_DEFAULT *Edge

func NewEdge 

func NewEdge() *Edge

func (*Edge) Equals 

func (p *Edge) Equals(other *Edge) bool

func (*Edge) GetDst 

func (p *Edge) GetDst() *Value

func (*Edge) GetName 

func (p *Edge) GetName() []byte

func (*Edge) GetProps 

func (p *Edge) GetProps() map[string]*Value

func (*Edge) GetRanking 

func (p *Edge) GetRanking() EdgeRanking

func (*Edge) GetSrc 

func (p *Edge) GetSrc() *Value

func (*Edge) GetType 

func (p *Edge) GetType() EdgeType

func (*Edge) IsSetDst 

func (p *Edge) IsSetDst() bool

func (*Edge) IsSetSrc 

func (p *Edge) IsSetSrc() bool

func (*Edge) LogValue 

func (p *Edge) LogValue() slog.Value

func (*Edge) Read 

func (p *Edge) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Edge) ReadField1 

func (p *Edge) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Edge) ReadField2 

func (p *Edge) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Edge) ReadField3 

func (p *Edge) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*Edge) ReadField4 

func (p *Edge) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*Edge) ReadField5 

func (p *Edge) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*Edge) ReadField6 

func (p *Edge) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*Edge) String 

func (p *Edge) String() string

func (*Edge) Validate 

func (p *Edge) Validate() error

func (*Edge) Write 

func (p *Edge) Write(ctx context.Context, oprot thrift.TProtocol) error

type EdgeRanking 

type EdgeRanking int64

func EdgeRankingPtr 

func EdgeRankingPtr(v EdgeRanking) *EdgeRanking

type EdgeType 

type EdgeType int32
var SchemaID_EdgeType_DEFAULT EdgeType

func EdgeTypePtr 

func EdgeTypePtr(v EdgeType) *EdgeType

type ErrorCode 

type ErrorCode int64
const (
	ErrorCode_SUCCEEDED                           ErrorCode = 0
	ErrorCode_E_DISCONNECTED                      ErrorCode = -1
	ErrorCode_E_FAIL_TO_CONNECT                   ErrorCode = -2
	ErrorCode_E_RPC_FAILURE                       ErrorCode = -3
	ErrorCode_E_LEADER_CHANGED                    ErrorCode = -4
	ErrorCode_E_SPACE_NOT_FOUND                   ErrorCode = -5
	ErrorCode_E_TAG_NOT_FOUND                     ErrorCode = -6
	ErrorCode_E_EDGE_NOT_FOUND                    ErrorCode = -7
	ErrorCode_E_INDEX_NOT_FOUND                   ErrorCode = -8
	ErrorCode_E_EDGE_PROP_NOT_FOUND               ErrorCode = -9
	ErrorCode_E_TAG_PROP_NOT_FOUND                ErrorCode = -10
	ErrorCode_E_ROLE_NOT_FOUND                    ErrorCode = -11
	ErrorCode_E_CONFIG_NOT_FOUND                  ErrorCode = -12
	ErrorCode_E_MACHINE_NOT_FOUND                 ErrorCode = -13
	ErrorCode_E_ZONE_NOT_FOUND                    ErrorCode = -14
	ErrorCode_E_LISTENER_NOT_FOUND                ErrorCode = -15
	ErrorCode_E_PART_NOT_FOUND                    ErrorCode = -16
	ErrorCode_E_KEY_NOT_FOUND                     ErrorCode = -17
	ErrorCode_E_USER_NOT_FOUND                    ErrorCode = -18
	ErrorCode_E_STATS_NOT_FOUND                   ErrorCode = -19
	ErrorCode_E_SERVICE_NOT_FOUND                 ErrorCode = -20
	ErrorCode_E_DRAINER_NOT_FOUND                 ErrorCode = -21
	ErrorCode_E_DRAINER_CLIENT_NOT_FOUND          ErrorCode = -22
	ErrorCode_E_PART_STOPPED                      ErrorCode = -23
	ErrorCode_E_BACKUP_FAILED                     ErrorCode = -24
	ErrorCode_E_BACKUP_EMPTY_TABLE                ErrorCode = -25
	ErrorCode_E_BACKUP_TABLE_FAILED               ErrorCode = -26
	ErrorCode_E_PARTIAL_RESULT                    ErrorCode = -27
	ErrorCode_E_REBUILD_INDEX_FAILED              ErrorCode = -28
	ErrorCode_E_INVALID_PASSWORD                  ErrorCode = -29
	ErrorCode_E_FAILED_GET_ABS_PATH               ErrorCode = -30
	ErrorCode_E_LISTENER_PROGRESS_FAILED          ErrorCode = -31
	ErrorCode_E_SYNC_LISTENER_NOT_FOUND           ErrorCode = -32
	ErrorCode_E_DRAINER_PROGRESS_FAILED           ErrorCode = -33
	ErrorCode_E_PART_DISABLED                     ErrorCode = -34
	ErrorCode_E_PART_ALREADY_STARTED              ErrorCode = -35
	ErrorCode_E_PART_ALREADY_STOPPED              ErrorCode = -36
	ErrorCode_E_BAD_USERNAME_PASSWORD             ErrorCode = -1001
	ErrorCode_E_SESSION_INVALID                   ErrorCode = -1002
	ErrorCode_E_SESSION_TIMEOUT                   ErrorCode = -1003
	ErrorCode_E_SYNTAX_ERROR                      ErrorCode = -1004
	ErrorCode_E_EXECUTION_ERROR                   ErrorCode = -1005
	ErrorCode_E_STATEMENT_EMPTY                   ErrorCode = -1006
	ErrorCode_E_BAD_PERMISSION                    ErrorCode = -1008
	ErrorCode_E_SEMANTIC_ERROR                    ErrorCode = -1009
	ErrorCode_E_TOO_MANY_CONNECTIONS              ErrorCode = -1010
	ErrorCode_E_PARTIAL_SUCCEEDED                 ErrorCode = -1011
	ErrorCode_E_NO_HOSTS                          ErrorCode = -2001
	ErrorCode_E_EXISTED                           ErrorCode = -2002
	ErrorCode_E_INVALID_HOST                      ErrorCode = -2003
	ErrorCode_E_UNSUPPORTED                       ErrorCode = -2004
	ErrorCode_E_NOT_DROP                          ErrorCode = -2005
	ErrorCode_E_BALANCER_RUNNING                  ErrorCode = -2006
	ErrorCode_E_CONFIG_IMMUTABLE                  ErrorCode = -2007
	ErrorCode_E_CONFLICT                          ErrorCode = -2008
	ErrorCode_E_INVALID_PARM                      ErrorCode = -2009
	ErrorCode_E_WRONGCLUSTER                      ErrorCode = -2010
	ErrorCode_E_ZONE_NOT_ENOUGH                   ErrorCode = -2011
	ErrorCode_E_ZONE_IS_EMPTY                     ErrorCode = -2012
	ErrorCode_E_LISTENER_CONFLICT                 ErrorCode = -2013
	ErrorCode_E_SCHEMA_NAME_EXISTS                ErrorCode = -2014
	ErrorCode_E_RELATED_INDEX_EXISTS              ErrorCode = -2015
	ErrorCode_E_RELATED_SPACE_EXISTS              ErrorCode = -2016
	ErrorCode_E_RELATED_FULLTEXT_INDEX_EXISTS     ErrorCode = -2017
	ErrorCode_E_HISTORY_CONFLICT                  ErrorCode = -2018
	ErrorCode_E_STORE_FAILURE                     ErrorCode = -2021
	ErrorCode_E_STORE_SEGMENT_ILLEGAL             ErrorCode = -2022
	ErrorCode_E_BAD_BALANCE_PLAN                  ErrorCode = -2023
	ErrorCode_E_BALANCED                          ErrorCode = -2024
	ErrorCode_E_NO_RUNNING_BALANCE_PLAN           ErrorCode = -2025
	ErrorCode_E_NO_VALID_HOST                     ErrorCode = -2026
	ErrorCode_E_CORRUPTED_BALANCE_PLAN            ErrorCode = -2027
	ErrorCode_E_NO_INVALID_BALANCE_PLAN           ErrorCode = -2028
	ErrorCode_E_NO_VALID_DRAINER                  ErrorCode = -2029
	ErrorCode_E_IMPROPER_ROLE                     ErrorCode = -2030
	ErrorCode_E_INVALID_PARTITION_NUM             ErrorCode = -2031
	ErrorCode_E_INVALID_REPLICA_FACTOR            ErrorCode = -2032
	ErrorCode_E_INVALID_CHARSET                   ErrorCode = -2033
	ErrorCode_E_INVALID_COLLATE                   ErrorCode = -2034
	ErrorCode_E_CHARSET_COLLATE_NOT_MATCH         ErrorCode = -2035
	ErrorCode_E_PRIVILEGE_ALL_TAG_EDGE_SETTLED    ErrorCode = -2036
	ErrorCode_E_PRIVILEGE_NOT_EXIST               ErrorCode = -2037
	ErrorCode_E_PRIVILEGE_NEED_BASIC_ROLE         ErrorCode = -2038
	ErrorCode_E_PRIVILEGE_ACTION_INVALID          ErrorCode = -2039
	ErrorCode_E_SNAPSHOT_FAILURE                  ErrorCode = -2040
	ErrorCode_E_SNAPSHOT_RUNNING_JOBS             ErrorCode = -2056
	ErrorCode_E_SNAPSHOT_NOT_FOUND                ErrorCode = -2057
	ErrorCode_E_BLOCK_WRITE_FAILURE               ErrorCode = -2041
	ErrorCode_E_REBUILD_INDEX_FAILURE             ErrorCode = -2042
	ErrorCode_E_INDEX_WITH_TTL                    ErrorCode = -2043
	ErrorCode_E_ADD_JOB_FAILURE                   ErrorCode = -2044
	ErrorCode_E_STOP_JOB_FAILURE                  ErrorCode = -2045
	ErrorCode_E_SAVE_JOB_FAILURE                  ErrorCode = -2046
	ErrorCode_E_BALANCER_FAILURE                  ErrorCode = -2047
	ErrorCode_E_JOB_NOT_FINISHED                  ErrorCode = -2048
	ErrorCode_E_TASK_REPORT_OUT_DATE              ErrorCode = -2049
	ErrorCode_E_JOB_NOT_IN_SPACE                  ErrorCode = -2050
	ErrorCode_E_JOB_NEED_RECOVER                  ErrorCode = -2051
	ErrorCode_E_JOB_ALREADY_FINISH                ErrorCode = -2052
	ErrorCode_E_JOB_SUBMITTED                     ErrorCode = -2053
	ErrorCode_E_JOB_NOT_STOPPABLE                 ErrorCode = -2054
	ErrorCode_E_JOB_HAS_NO_TARGET_STORAGE         ErrorCode = -2055
	ErrorCode_E_INVALID_JOB                       ErrorCode = -2065
	ErrorCode_E_BACKUP_RUNNING_JOBS               ErrorCode = -2066
	ErrorCode_E_BACKUP_SPACE_NOT_FOUND            ErrorCode = -2067
	ErrorCode_E_RESTORE_FAILURE                   ErrorCode = -2068
	ErrorCode_E_SESSION_NOT_FOUND                 ErrorCode = -2069
	ErrorCode_E_LIST_CLUSTER_FAILURE              ErrorCode = -2070
	ErrorCode_E_LIST_CLUSTER_GET_ABS_PATH_FAILURE ErrorCode = -2071
	ErrorCode_E_LIST_CLUSTER_NO_AGENT_FAILURE     ErrorCode = -2072
	ErrorCode_E_QUERY_NOT_FOUND                   ErrorCode = -2073
	ErrorCode_E_AGENT_HB_FAILUE                   ErrorCode = -2074
	ErrorCode_E_INVALID_VARIABLE                  ErrorCode = -2080
	ErrorCode_E_VARIABLE_TYPE_VALUE_MISMATCH      ErrorCode = -2081
	ErrorCode_E_HOST_CAN_NOT_BE_ADDED             ErrorCode = -2082
	ErrorCode_E_ACCESS_ES_FAILURE                 ErrorCode = -2090
	ErrorCode_E_GRAPH_MEMORY_EXCEEDED             ErrorCode = -2600
	ErrorCode_E_CONSENSUS_ERROR                   ErrorCode = -3001
	ErrorCode_E_KEY_HAS_EXISTS                    ErrorCode = -3002
	ErrorCode_E_DATA_TYPE_MISMATCH                ErrorCode = -3003
	ErrorCode_E_INVALID_FIELD_VALUE               ErrorCode = -3004
	ErrorCode_E_INVALID_OPERATION                 ErrorCode = -3005
	ErrorCode_E_NOT_NULLABLE                      ErrorCode = -3006
	ErrorCode_E_FIELD_UNSET                       ErrorCode = -3007
	ErrorCode_E_OUT_OF_RANGE                      ErrorCode = -3008
	ErrorCode_E_DATA_CONFLICT_ERROR               ErrorCode = -3010
	ErrorCode_E_WRITE_STALLED                     ErrorCode = -3011
	ErrorCode_E_IMPROPER_DATA_TYPE                ErrorCode = -3021
	ErrorCode_E_INVALID_SPACEVIDLEN               ErrorCode = -3022
	ErrorCode_E_INVALID_FILTER                    ErrorCode = -3031
	ErrorCode_E_INVALID_UPDATER                   ErrorCode = -3032
	ErrorCode_E_INVALID_STORE                     ErrorCode = -3033
	ErrorCode_E_INVALID_PEER                      ErrorCode = -3034
	ErrorCode_E_RETRY_EXHAUSTED                   ErrorCode = -3035
	ErrorCode_E_TRANSFER_LEADER_FAILED            ErrorCode = -3036
	ErrorCode_E_INVALID_STAT_TYPE                 ErrorCode = -3037
	ErrorCode_E_INVALID_VID                       ErrorCode = -3038
	ErrorCode_E_NO_TRANSFORMED                    ErrorCode = -3039
	ErrorCode_E_LOAD_META_FAILED                  ErrorCode = -3040
	ErrorCode_E_FAILED_TO_CHECKPOINT              ErrorCode = -3041
	ErrorCode_E_CHECKPOINT_BLOCKED                ErrorCode = -3042
	ErrorCode_E_FILTER_OUT                        ErrorCode = -3043
	ErrorCode_E_INVALID_DATA                      ErrorCode = -3044
	ErrorCode_E_MUTATE_EDGE_CONFLICT              ErrorCode = -3045
	ErrorCode_E_MUTATE_TAG_CONFLICT               ErrorCode = -3046
	ErrorCode_E_OUTDATED_LOCK                     ErrorCode = -3047
	ErrorCode_E_INVALID_TASK_PARA                 ErrorCode = -3051
	ErrorCode_E_USER_CANCEL                       ErrorCode = -3052
	ErrorCode_E_TASK_EXECUTION_FAILED             ErrorCode = -3053
	ErrorCode_E_PLAN_IS_KILLED                    ErrorCode = -3060
	ErrorCode_E_NO_TERM                           ErrorCode = -3070
	ErrorCode_E_OUTDATED_TERM                     ErrorCode = -3071
	ErrorCode_E_OUTDATED_EDGE                     ErrorCode = -3072
	ErrorCode_E_WRITE_WRITE_CONFLICT              ErrorCode = -3073
	ErrorCode_E_CLIENT_SERVER_INCOMPATIBLE        ErrorCode = -3061
	ErrorCode_E_ID_FAILED                         ErrorCode = -3062
	ErrorCode_E_RAFT_UNKNOWN_PART                 ErrorCode = -3500
	ErrorCode_E_RAFT_LOG_GAP                      ErrorCode = -3501
	ErrorCode_E_RAFT_LOG_STALE                    ErrorCode = -3502
	ErrorCode_E_RAFT_TERM_OUT_OF_DATE             ErrorCode = -3503
	ErrorCode_E_RAFT_UNKNOWN_APPEND_LOG           ErrorCode = -3504
	ErrorCode_E_RAFT_WAITING_SNAPSHOT             ErrorCode = -3511
	ErrorCode_E_RAFT_SENDING_SNAPSHOT             ErrorCode = -3512
	ErrorCode_E_RAFT_INVALID_PEER                 ErrorCode = -3513
	ErrorCode_E_RAFT_NOT_READY                    ErrorCode = -3514
	ErrorCode_E_RAFT_STOPPED                      ErrorCode = -3515
	ErrorCode_E_RAFT_BAD_ROLE                     ErrorCode = -3516
	ErrorCode_E_RAFT_WAL_FAIL                     ErrorCode = -3521
	ErrorCode_E_RAFT_HOST_STOPPED                 ErrorCode = -3522
	ErrorCode_E_RAFT_TOO_MANY_REQUESTS            ErrorCode = -3523
	ErrorCode_E_RAFT_PERSIST_SNAPSHOT_FAILED      ErrorCode = -3524
	ErrorCode_E_RAFT_RPC_EXCEPTION                ErrorCode = -3525
	ErrorCode_E_RAFT_NO_WAL_FOUND                 ErrorCode = -3526
	ErrorCode_E_RAFT_HOST_PAUSED                  ErrorCode = -3527
	ErrorCode_E_RAFT_WRITE_BLOCKED                ErrorCode = -3528
	ErrorCode_E_RAFT_BUFFER_OVERFLOW              ErrorCode = -3529
	ErrorCode_E_RAFT_ATOMIC_OP_FAILED             ErrorCode = -3530
	ErrorCode_E_LEADER_LEASE_FAILED               ErrorCode = -3531
	ErrorCode_E_RAFT_CAUGHT_UP                    ErrorCode = -3532
	ErrorCode_E_LOG_GAP                           ErrorCode = -4001
	ErrorCode_E_LOG_STALE                         ErrorCode = -4002
	ErrorCode_E_INVALID_DRAINER_STORE             ErrorCode = -4003
	ErrorCode_E_SPACE_MISMATCH                    ErrorCode = -4004
	ErrorCode_E_PART_MISMATCH                     ErrorCode = -4005
	ErrorCode_E_DATA_CONFLICT                     ErrorCode = -4006
	ErrorCode_E_REQ_CONFLICT                      ErrorCode = -4007
	ErrorCode_E_DATA_ILLEGAL                      ErrorCode = -4008
	ErrorCode_E_CACHE_CONFIG_ERROR                ErrorCode = -5001
	ErrorCode_E_NOT_ENOUGH_SPACE                  ErrorCode = -5002
	ErrorCode_E_CACHE_MISS                        ErrorCode = -5003
	ErrorCode_E_POOL_NOT_FOUND                    ErrorCode = -5004
	ErrorCode_E_CACHE_WRITE_FAILURE               ErrorCode = -5005
	ErrorCode_E_NODE_NUMBER_EXCEED_LIMIT          ErrorCode = -7001
	ErrorCode_E_PARSING_LICENSE_FAILURE           ErrorCode = -7002
	ErrorCode_E_STORAGE_MEMORY_EXCEEDED           ErrorCode = -3600
	ErrorCode_E_UNKNOWN                           ErrorCode = -8000
)

func ErrorCodeFromString 

func ErrorCodeFromString(s string) (ErrorCode, error)

func ErrorCodePtr 

func ErrorCodePtr(v ErrorCode) *ErrorCode

func (ErrorCode) MarshalText 

func (p ErrorCode) MarshalText() ([]byte, error)

func (*ErrorCode) Scan 

func (p *ErrorCode) Scan(value interface{}) error

func (ErrorCode) String 

func (p ErrorCode) String() string

func (*ErrorCode) UnmarshalText 

func (p *ErrorCode) UnmarshalText(text []byte) error

func (*ErrorCode) Value 

func (p *ErrorCode) Value() (driver.Value, error)

type ExecutionPlanID 

type ExecutionPlanID int64

func ExecutionPlanIDPtr 

func ExecutionPlanIDPtr(v ExecutionPlanID) *ExecutionPlanID

type Geography 

type Geography struct {
	PtVal *Point      `thrift:"ptVal,1" db:"ptVal" json:"ptVal,omitempty"`
	LsVal *LineString `thrift:"lsVal,2" db:"lsVal" json:"lsVal,omitempty"`
	PgVal *Polygon    `thrift:"pgVal,3" db:"pgVal" json:"pgVal,omitempty"`
}

Attributes:

  • PtVal
  • LsVal
  • PgVal
var Value_GgVal_DEFAULT *Geography

func NewGeography 

func NewGeography() *Geography

func (*Geography) CountSetFieldsGeography 

func (p *Geography) CountSetFieldsGeography() int

func (*Geography) Equals 

func (p *Geography) Equals(other *Geography) bool

func (*Geography) GetLsVal 

func (p *Geography) GetLsVal() *LineString

func (*Geography) GetPgVal 

func (p *Geography) GetPgVal() *Polygon

func (*Geography) GetPtVal 

func (p *Geography) GetPtVal() *Point

func (*Geography) IsSetLsVal 

func (p *Geography) IsSetLsVal() bool

func (*Geography) IsSetPgVal 

func (p *Geography) IsSetPgVal() bool

func (*Geography) IsSetPtVal 

func (p *Geography) IsSetPtVal() bool

func (*Geography) LogValue 

func (p *Geography) LogValue() slog.Value

func (*Geography) Read 

func (p *Geography) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Geography) ReadField1 

func (p *Geography) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Geography) ReadField2 

func (p *Geography) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Geography) ReadField3 

func (p *Geography) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*Geography) String 

func (p *Geography) String() string

func (*Geography) Validate 

func (p *Geography) Validate() error

func (*Geography) Write 

func (p *Geography) Write(ctx context.Context, oprot thrift.TProtocol) error

type GraphSpaceID 

type GraphSpaceID int32

func GraphSpaceIDPtr 

func GraphSpaceIDPtr(v GraphSpaceID) *GraphSpaceID

type HostAddr 

type HostAddr struct {
	Host string `thrift:"host,1" db:"host" json:"host"`
	Port Port   `thrift:"port,2" db:"port" json:"port"`
}

Attributes:

  • Host
  • Port

func NewHostAddr 

func NewHostAddr() *HostAddr

func (*HostAddr) Equals 

func (p *HostAddr) Equals(other *HostAddr) bool

func (*HostAddr) GetHost 

func (p *HostAddr) GetHost() string

func (*HostAddr) GetPort 

func (p *HostAddr) GetPort() Port

func (*HostAddr) LogValue 

func (p *HostAddr) LogValue() slog.Value

func (*HostAddr) Read 

func (p *HostAddr) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*HostAddr) ReadField1 

func (p *HostAddr) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*HostAddr) ReadField2 

func (p *HostAddr) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*HostAddr) String 

func (p *HostAddr) String() string

func (*HostAddr) Validate 

func (p *HostAddr) Validate() error

func (*HostAddr) Write 

func (p *HostAddr) Write(ctx context.Context, oprot thrift.TProtocol) error

type IndexID 

type IndexID int32

func IndexIDPtr 

func IndexIDPtr(v IndexID) *IndexID

type KeyValue 

type KeyValue struct {
	Key   []byte `thrift:"key,1" db:"key" json:"key"`
	Value []byte `thrift:"value,2" db:"value" json:"value"`
}

Attributes:

  • Key
  • Value

func NewKeyValue 

func NewKeyValue() *KeyValue

func (*KeyValue) Equals 

func (p *KeyValue) Equals(other *KeyValue) bool

func (*KeyValue) GetKey 

func (p *KeyValue) GetKey() []byte

func (*KeyValue) GetValue 

func (p *KeyValue) GetValue() []byte

func (*KeyValue) LogValue 

func (p *KeyValue) LogValue() slog.Value

func (*KeyValue) Read 

func (p *KeyValue) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*KeyValue) ReadField1 

func (p *KeyValue) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*KeyValue) ReadField2 

func (p *KeyValue) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*KeyValue) String 

func (p *KeyValue) String() string

func (*KeyValue) Validate 

func (p *KeyValue) Validate() error

func (*KeyValue) Write 

func (p *KeyValue) Write(ctx context.Context, oprot thrift.TProtocol) error

type LineString 

type LineString struct {
	CoordList []*Coordinate `thrift:"coordList,1" db:"coordList" json:"coordList"`
}

Attributes:

  • CoordList
var Geography_LsVal_DEFAULT *LineString

func NewLineString 

func NewLineString() *LineString

func (*LineString) Equals 

func (p *LineString) Equals(other *LineString) bool

func (*LineString) GetCoordList 

func (p *LineString) GetCoordList() []*Coordinate

func (*LineString) LogValue 

func (p *LineString) LogValue() slog.Value

func (*LineString) Read 

func (p *LineString) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*LineString) ReadField1 

func (p *LineString) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*LineString) String 

func (p *LineString) String() string

func (*LineString) Validate 

func (p *LineString) Validate() error

func (*LineString) Write 

func (p *LineString) Write(ctx context.Context, oprot thrift.TProtocol) error

type LogEntry 

type LogEntry struct {
	Cluster ClusterID `thrift:"cluster,1" db:"cluster" json:"cluster"`
	LogStr  []byte    `thrift:"log_str,2" db:"log_str" json:"log_str"`
}

Attributes:

  • Cluster
  • LogStr

func NewLogEntry 

func NewLogEntry() *LogEntry

func (*LogEntry) Equals 

func (p *LogEntry) Equals(other *LogEntry) bool

func (*LogEntry) GetCluster 

func (p *LogEntry) GetCluster() ClusterID

func (*LogEntry) GetLogStr 

func (p *LogEntry) GetLogStr() []byte

func (*LogEntry) LogValue 

func (p *LogEntry) LogValue() slog.Value

func (*LogEntry) Read 

func (p *LogEntry) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*LogEntry) ReadField1 

func (p *LogEntry) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*LogEntry) ReadField2 

func (p *LogEntry) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*LogEntry) String 

func (p *LogEntry) String() string

func (*LogEntry) Validate 

func (p *LogEntry) Validate() error

func (*LogEntry) Write 

func (p *LogEntry) Write(ctx context.Context, oprot thrift.TProtocol) error

type LogID 

type LogID int64

func LogIDPtr 

func LogIDPtr(v LogID) *LogID

type LogInfo 

type LogInfo struct {
	LogID          LogID  `thrift:"log_id,1" db:"log_id" json:"log_id"`
	TermID         TermID `thrift:"term_id,2" db:"term_id" json:"term_id"`
	CommitLogID    LogID  `thrift:"commit_log_id,3" db:"commit_log_id" json:"commit_log_id"`
	CheckpointPath []byte `thrift:"checkpoint_path,4" db:"checkpoint_path" json:"checkpoint_path"`
}

Attributes:

  • LogID
  • TermID
  • CommitLogID
  • CheckpointPath

func NewLogInfo 

func NewLogInfo() *LogInfo

func (*LogInfo) Equals 

func (p *LogInfo) Equals(other *LogInfo) bool

func (*LogInfo) GetCheckpointPath 

func (p *LogInfo) GetCheckpointPath() []byte

func (*LogInfo) GetCommitLogID 

func (p *LogInfo) GetCommitLogID() LogID

func (*LogInfo) GetLogID 

func (p *LogInfo) GetLogID() LogID

func (*LogInfo) GetTermID 

func (p *LogInfo) GetTermID() TermID

func (*LogInfo) LogValue 

func (p *LogInfo) LogValue() slog.Value

func (*LogInfo) Read 

func (p *LogInfo) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*LogInfo) ReadField1 

func (p *LogInfo) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*LogInfo) ReadField2 

func (p *LogInfo) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*LogInfo) ReadField3 

func (p *LogInfo) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*LogInfo) ReadField4 

func (p *LogInfo) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*LogInfo) String 

func (p *LogInfo) String() string

func (*LogInfo) Validate 

func (p *LogInfo) Validate() error

func (*LogInfo) Write 

func (p *LogInfo) Write(ctx context.Context, oprot thrift.TProtocol) error

type NList 

type NList struct {
	Values []*Value `thrift:"values,1" db:"values" json:"values"`
}

Attributes:

  • Values
var Value_LVal_DEFAULT *NList

func NewNList 

func NewNList() *NList

func (*NList) Equals 

func (p *NList) Equals(other *NList) bool

func (*NList) GetValues 

func (p *NList) GetValues() []*Value

func (*NList) LogValue 

func (p *NList) LogValue() slog.Value

func (*NList) Read 

func (p *NList) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*NList) ReadField1 

func (p *NList) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*NList) String 

func (p *NList) String() string

func (*NList) Validate 

func (p *NList) Validate() error

func (*NList) Write 

func (p *NList) Write(ctx context.Context, oprot thrift.TProtocol) error

type NMap 

type NMap struct {
	Kvs map[string]*Value `thrift:"kvs,1" db:"kvs" json:"kvs"`
}

Attributes:

  • Kvs
var Value_MVal_DEFAULT *NMap

func NewNMap 

func NewNMap() *NMap

func (*NMap) Equals 

func (p *NMap) Equals(other *NMap) bool

func (*NMap) GetKvs 

func (p *NMap) GetKvs() map[string]*Value

func (*NMap) LogValue 

func (p *NMap) LogValue() slog.Value

func (*NMap) Read 

func (p *NMap) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*NMap) ReadField1 

func (p *NMap) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*NMap) String 

func (p *NMap) String() string

func (*NMap) Validate 

func (p *NMap) Validate() error

func (*NMap) Write 

func (p *NMap) Write(ctx context.Context, oprot thrift.TProtocol) error

type NSet 

type NSet struct {
	Values []*Value `thrift:"values,1" db:"values" json:"values"`
}

Attributes:

  • Values
var Value_UVal_DEFAULT *NSet

func NewNSet 

func NewNSet() *NSet

func (*NSet) Equals 

func (p *NSet) Equals(other *NSet) bool

func (*NSet) GetValues 

func (p *NSet) GetValues() []*Value

func (*NSet) LogValue 

func (p *NSet) LogValue() slog.Value

func (*NSet) Read 

func (p *NSet) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*NSet) ReadField1 

func (p *NSet) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*NSet) String 

func (p *NSet) String() string

func (*NSet) Validate 

func (p *NSet) Validate() error

func (*NSet) Write 

func (p *NSet) Write(ctx context.Context, oprot thrift.TProtocol) error

type NullType 

type NullType int64
const (
	NullType___NULL__     NullType = 0
	NullType_NaN          NullType = 1
	NullType_BAD_DATA     NullType = 2
	NullType_BAD_TYPE     NullType = 3
	NullType_ERR_OVERFLOW NullType = 4
	NullType_UNKNOWN_PROP NullType = 5
	NullType_DIV_BY_ZERO  NullType = 6
	NullType_OUT_OF_RANGE NullType = 7
)
var Value_NVal_DEFAULT NullType

func NullTypeFromString 

func NullTypeFromString(s string) (NullType, error)

func NullTypePtr 

func NullTypePtr(v NullType) *NullType

func (NullType) MarshalText 

func (p NullType) MarshalText() ([]byte, error)

func (*NullType) Scan 

func (p *NullType) Scan(value interface{}) error

func (NullType) String 

func (p NullType) String() string

func (*NullType) UnmarshalText 

func (p *NullType) UnmarshalText(text []byte) error

func (*NullType) Value 

func (p *NullType) Value() (driver.Value, error)

type PartitionID 

type PartitionID int32

func PartitionIDPtr 

func PartitionIDPtr(v PartitionID) *PartitionID

type Path 

type Path struct {
	Src   *Vertex `thrift:"src,1" db:"src" json:"src"`
	Steps []*Step `thrift:"steps,2" db:"steps" json:"steps"`
}

Attributes:

  • Src
  • Steps
var Value_PVal_DEFAULT *Path

func NewPath 

func NewPath() *Path

func (*Path) Equals 

func (p *Path) Equals(other *Path) bool

func (*Path) GetSrc 

func (p *Path) GetSrc() *Vertex

func (*Path) GetSteps 

func (p *Path) GetSteps() []*Step

func (*Path) IsSetSrc 

func (p *Path) IsSetSrc() bool

func (*Path) LogValue 

func (p *Path) LogValue() slog.Value

func (*Path) Read 

func (p *Path) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Path) ReadField1 

func (p *Path) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Path) ReadField2 

func (p *Path) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Path) String 

func (p *Path) String() string

func (*Path) Validate 

func (p *Path) Validate() error

func (*Path) Write 

func (p *Path) Write(ctx context.Context, oprot thrift.TProtocol) error

type Point 

type Point struct {
	Coord *Coordinate `thrift:"coord,1" db:"coord" json:"coord"`
}

Attributes:

  • Coord
var Geography_PtVal_DEFAULT *Point

func NewPoint 

func NewPoint() *Point

func (*Point) Equals 

func (p *Point) Equals(other *Point) bool

func (*Point) GetCoord 

func (p *Point) GetCoord() *Coordinate

func (*Point) IsSetCoord 

func (p *Point) IsSetCoord() bool

func (*Point) LogValue 

func (p *Point) LogValue() slog.Value

func (*Point) Read 

func (p *Point) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Point) ReadField1 

func (p *Point) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Point) String 

func (p *Point) String() string

func (*Point) Validate 

func (p *Point) Validate() error

func (*Point) Write 

func (p *Point) Write(ctx context.Context, oprot thrift.TProtocol) error

type Polygon 

type Polygon struct {
	CoordListList [][]*Coordinate `thrift:"coordListList,1" db:"coordListList" json:"coordListList"`
}

Attributes:

  • CoordListList
var Geography_PgVal_DEFAULT *Polygon

func NewPolygon 

func NewPolygon() *Polygon

func (*Polygon) Equals 

func (p *Polygon) Equals(other *Polygon) bool

func (*Polygon) GetCoordListList 

func (p *Polygon) GetCoordListList() [][]*Coordinate

func (*Polygon) LogValue 

func (p *Polygon) LogValue() slog.Value

func (*Polygon) Read 

func (p *Polygon) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Polygon) ReadField1 

func (p *Polygon) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Polygon) String 

func (p *Polygon) String() string

func (*Polygon) Validate 

func (p *Polygon) Validate() error

func (*Polygon) Write 

func (p *Polygon) Write(ctx context.Context, oprot thrift.TProtocol) error

type Port 

type Port int32

func PortPtr 

func PortPtr(v Port) *Port

type PropertyType 

type PropertyType int64
const (
	PropertyType_UNKNOWN      PropertyType = 0
	PropertyType_BOOL         PropertyType = 1
	PropertyType_INT64        PropertyType = 2
	PropertyType_VID          PropertyType = 3
	PropertyType_FLOAT        PropertyType = 4
	PropertyType_DOUBLE       PropertyType = 5
	PropertyType_STRING       PropertyType = 6
	PropertyType_FIXED_STRING PropertyType = 7
	PropertyType_INT8         PropertyType = 8
	PropertyType_INT16        PropertyType = 9
	PropertyType_INT32        PropertyType = 10
	PropertyType_TIMESTAMP    PropertyType = 21
	PropertyType_DURATION     PropertyType = 23
	PropertyType_DATE         PropertyType = 24
	PropertyType_DATETIME     PropertyType = 25
	PropertyType_TIME         PropertyType = 26
	PropertyType_GEOGRAPHY    PropertyType = 31
)

func PropertyTypeFromString 

func PropertyTypeFromString(s string) (PropertyType, error)

func PropertyTypePtr 

func PropertyTypePtr(v PropertyType) *PropertyType

func (PropertyType) MarshalText 

func (p PropertyType) MarshalText() ([]byte, error)

func (*PropertyType) Scan 

func (p *PropertyType) Scan(value interface{}) error

func (PropertyType) String 

func (p PropertyType) String() string

func (*PropertyType) UnmarshalText 

func (p *PropertyType) UnmarshalText(text []byte) error

func (*PropertyType) Value 

func (p *PropertyType) Value() (driver.Value, error)

type Row 

type Row struct {
	Values []*Value `thrift:"values,1" db:"values" json:"values"`
}

Attributes:

  • Values

func NewRow 

func NewRow() *Row

func (*Row) Equals 

func (p *Row) Equals(other *Row) bool

func (*Row) GetValues 

func (p *Row) GetValues() []*Value

func (*Row) LogValue 

func (p *Row) LogValue() slog.Value

func (*Row) Read 

func (p *Row) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Row) ReadField1 

func (p *Row) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Row) String 

func (p *Row) String() string

func (*Row) Validate 

func (p *Row) Validate() error

func (*Row) Write 

func (p *Row) Write(ctx context.Context, oprot thrift.TProtocol) error

type SchemaID 

type SchemaID struct {
	TagID    *TagID    `thrift:"tag_id,1" db:"tag_id" json:"tag_id,omitempty"`
	EdgeType *EdgeType `thrift:"edge_type,2" db:"edge_type" json:"edge_type,omitempty"`
}

Attributes:

  • TagID
  • EdgeType

func NewSchemaID 

func NewSchemaID() *SchemaID

func (*SchemaID) CountSetFieldsSchemaID 

func (p *SchemaID) CountSetFieldsSchemaID() int

func (*SchemaID) Equals 

func (p *SchemaID) Equals(other *SchemaID) bool

func (*SchemaID) GetEdgeType 

func (p *SchemaID) GetEdgeType() EdgeType

func (*SchemaID) GetTagID 

func (p *SchemaID) GetTagID() TagID

func (*SchemaID) IsSetEdgeType 

func (p *SchemaID) IsSetEdgeType() bool

func (*SchemaID) IsSetTagID 

func (p *SchemaID) IsSetTagID() bool

func (*SchemaID) LogValue 

func (p *SchemaID) LogValue() slog.Value

func (*SchemaID) Read 

func (p *SchemaID) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*SchemaID) ReadField1 

func (p *SchemaID) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*SchemaID) ReadField2 

func (p *SchemaID) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*SchemaID) String 

func (p *SchemaID) String() string

func (*SchemaID) Validate 

func (p *SchemaID) Validate() error

func (*SchemaID) Write 

func (p *SchemaID) Write(ctx context.Context, oprot thrift.TProtocol) error

type SessionID 

type SessionID int64

func SessionIDPtr 

func SessionIDPtr(v SessionID) *SessionID

type Step 

type Step struct {
	Dst     *Vertex           `thrift:"dst,1" db:"dst" json:"dst"`
	Type    EdgeType          `thrift:"type,2" db:"type" json:"type"`
	Name    []byte            `thrift:"name,3" db:"name" json:"name"`
	Ranking EdgeRanking       `thrift:"ranking,4" db:"ranking" json:"ranking"`
	Props   map[string]*Value `thrift:"props,5" db:"props" json:"props"`
}

Attributes:

  • Dst
  • Type
  • Name
  • Ranking
  • Props

func NewStep 

func NewStep() *Step

func (*Step) Equals 

func (p *Step) Equals(other *Step) bool

func (*Step) GetDst 

func (p *Step) GetDst() *Vertex

func (*Step) GetName 

func (p *Step) GetName() []byte

func (*Step) GetProps 

func (p *Step) GetProps() map[string]*Value

func (*Step) GetRanking 

func (p *Step) GetRanking() EdgeRanking

func (*Step) GetType 

func (p *Step) GetType() EdgeType

func (*Step) IsSetDst 

func (p *Step) IsSetDst() bool

func (*Step) LogValue 

func (p *Step) LogValue() slog.Value

func (*Step) Read 

func (p *Step) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Step) ReadField1 

func (p *Step) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Step) ReadField2 

func (p *Step) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Step) ReadField3 

func (p *Step) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*Step) ReadField4 

func (p *Step) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*Step) ReadField5 

func (p *Step) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*Step) String 

func (p *Step) String() string

func (*Step) Validate 

func (p *Step) Validate() error

func (*Step) Write 

func (p *Step) Write(ctx context.Context, oprot thrift.TProtocol) error

type Tag 

type Tag struct {
	Name  []byte            `thrift:"name,1" db:"name" json:"name"`
	Props map[string]*Value `thrift:"props,2" db:"props" json:"props"`
}

Attributes:

  • Name
  • Props

func NewTag 

func NewTag() *Tag

func (*Tag) Equals 

func (p *Tag) Equals(other *Tag) bool

func (*Tag) GetName 

func (p *Tag) GetName() []byte

func (*Tag) GetProps 

func (p *Tag) GetProps() map[string]*Value

func (*Tag) LogValue 

func (p *Tag) LogValue() slog.Value

func (*Tag) Read 

func (p *Tag) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Tag) ReadField1 

func (p *Tag) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Tag) ReadField2 

func (p *Tag) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Tag) String 

func (p *Tag) String() string

func (*Tag) Validate 

func (p *Tag) Validate() error

func (*Tag) Write 

func (p *Tag) Write(ctx context.Context, oprot thrift.TProtocol) error

type TagID 

type TagID int32
var SchemaID_TagID_DEFAULT TagID

func TagIDPtr 

func TagIDPtr(v TagID) *TagID

type TermID 

type TermID int64

func TermIDPtr 

func TermIDPtr(v TermID) *TermID

type Time 

type Time struct {
	Hour     int8  `thrift:"hour,1" db:"hour" json:"hour"`
	Minute   int8  `thrift:"minute,2" db:"minute" json:"minute"`
	Sec      int8  `thrift:"sec,3" db:"sec" json:"sec"`
	Microsec int32 `thrift:"microsec,4" db:"microsec" json:"microsec"`
}

Attributes:

  • Hour
  • Minute
  • Sec
  • Microsec
var Value_TVal_DEFAULT *Time

func NewTime 

func NewTime() *Time

func (*Time) Equals 

func (p *Time) Equals(other *Time) bool

func (*Time) GetHour 

func (p *Time) GetHour() int8

func (*Time) GetMicrosec 

func (p *Time) GetMicrosec() int32

func (*Time) GetMinute 

func (p *Time) GetMinute() int8

func (*Time) GetSec 

func (p *Time) GetSec() int8

func (*Time) LogValue 

func (p *Time) LogValue() slog.Value

func (*Time) Read 

func (p *Time) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Time) ReadField1 

func (p *Time) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Time) ReadField2 

func (p *Time) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Time) ReadField3 

func (p *Time) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*Time) ReadField4 

func (p *Time) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*Time) String 

func (p *Time) String() string

func (*Time) Validate 

func (p *Time) Validate() error

func (*Time) Write 

func (p *Time) Write(ctx context.Context, oprot thrift.TProtocol) error

type Timestamp 

type Timestamp int64

func TimestampPtr 

func TimestampPtr(v Timestamp) *Timestamp

type Value 

type Value struct {
	NVal  *NullType  `thrift:"nVal,1" db:"nVal" json:"nVal,omitempty"`
	BVal  *bool      `thrift:"bVal,2" db:"bVal" json:"bVal,omitempty"`
	IVal  *int64     `thrift:"iVal,3" db:"iVal" json:"iVal,omitempty"`
	FVal  *float64   `thrift:"fVal,4" db:"fVal" json:"fVal,omitempty"`
	SVal  []byte     `thrift:"sVal,5" db:"sVal" json:"sVal,omitempty"`
	DVal  *Date      `thrift:"dVal,6" db:"dVal" json:"dVal,omitempty"`
	TVal  *Time      `thrift:"tVal,7" db:"tVal" json:"tVal,omitempty"`
	DtVal *DateTime  `thrift:"dtVal,8" db:"dtVal" json:"dtVal,omitempty"`
	VVal  *Vertex    `thrift:"vVal,9" db:"vVal" json:"vVal,omitempty"`
	EVal  *Edge      `thrift:"eVal,10" db:"eVal" json:"eVal,omitempty"`
	PVal  *Path      `thrift:"pVal,11" db:"pVal" json:"pVal,omitempty"`
	LVal  *NList     `thrift:"lVal,12" db:"lVal" json:"lVal,omitempty"`
	MVal  *NMap      `thrift:"mVal,13" db:"mVal" json:"mVal,omitempty"`
	UVal  *NSet      `thrift:"uVal,14" db:"uVal" json:"uVal,omitempty"`
	GVal  *DataSet   `thrift:"gVal,15" db:"gVal" json:"gVal,omitempty"`
	GgVal *Geography `thrift:"ggVal,16" db:"ggVal" json:"ggVal,omitempty"`
	DuVal *Duration  `thrift:"duVal,17" db:"duVal" json:"duVal,omitempty"`
}

Attributes:

  • NVal
  • BVal
  • IVal
  • FVal
  • SVal
  • DVal
  • TVal
  • DtVal
  • VVal
  • EVal
  • PVal
  • LVal
  • MVal
  • UVal
  • GVal
  • GgVal
  • DuVal
var Edge_Dst_DEFAULT *Value
var Edge_Src_DEFAULT *Value
var Vertex_Vid_DEFAULT *Value

func NewValue 

func NewValue() *Value

func (*Value) CountSetFieldsValue 

func (p *Value) CountSetFieldsValue() int

func (*Value) Equals 

func (p *Value) Equals(other *Value) bool

func (*Value) GetBVal 

func (p *Value) GetBVal() bool

func (*Value) GetDVal 

func (p *Value) GetDVal() *Date

func (*Value) GetDtVal 

func (p *Value) GetDtVal() *DateTime

func (*Value) GetDuVal 

func (p *Value) GetDuVal() *Duration

func (*Value) GetEVal 

func (p *Value) GetEVal() *Edge

func (*Value) GetFVal 

func (p *Value) GetFVal() float64

func (*Value) GetGVal 

func (p *Value) GetGVal() *DataSet

func (*Value) GetGgVal 

func (p *Value) GetGgVal() *Geography

func (*Value) GetIVal 

func (p *Value) GetIVal() int64

func (*Value) GetLVal 

func (p *Value) GetLVal() *NList

func (*Value) GetMVal 

func (p *Value) GetMVal() *NMap

func (*Value) GetNVal 

func (p *Value) GetNVal() NullType

func (*Value) GetPVal 

func (p *Value) GetPVal() *Path

func (*Value) GetSVal 

func (p *Value) GetSVal() []byte

func (*Value) GetTVal 

func (p *Value) GetTVal() *Time

func (*Value) GetUVal 

func (p *Value) GetUVal() *NSet

func (*Value) GetVVal 

func (p *Value) GetVVal() *Vertex

func (*Value) IsSetBVal 

func (p *Value) IsSetBVal() bool

func (*Value) IsSetDVal 

func (p *Value) IsSetDVal() bool

func (*Value) IsSetDtVal 

func (p *Value) IsSetDtVal() bool

func (*Value) IsSetDuVal 

func (p *Value) IsSetDuVal() bool

func (*Value) IsSetEVal 

func (p *Value) IsSetEVal() bool

func (*Value) IsSetFVal 

func (p *Value) IsSetFVal() bool

func (*Value) IsSetGVal 

func (p *Value) IsSetGVal() bool

func (*Value) IsSetGgVal 

func (p *Value) IsSetGgVal() bool

func (*Value) IsSetIVal 

func (p *Value) IsSetIVal() bool

func (*Value) IsSetLVal 

func (p *Value) IsSetLVal() bool

func (*Value) IsSetMVal 

func (p *Value) IsSetMVal() bool

func (*Value) IsSetNVal 

func (p *Value) IsSetNVal() bool

func (*Value) IsSetPVal 

func (p *Value) IsSetPVal() bool

func (*Value) IsSetSVal 

func (p *Value) IsSetSVal() bool

func (*Value) IsSetTVal 

func (p *Value) IsSetTVal() bool

func (*Value) IsSetUVal 

func (p *Value) IsSetUVal() bool

func (*Value) IsSetVVal 

func (p *Value) IsSetVVal() bool

func (*Value) LogValue 

func (p *Value) LogValue() slog.Value

func (*Value) Read 

func (p *Value) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField1 

func (p *Value) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField10 

func (p *Value) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField11 

func (p *Value) ReadField11(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField12 

func (p *Value) ReadField12(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField13 

func (p *Value) ReadField13(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField14 

func (p *Value) ReadField14(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField15 

func (p *Value) ReadField15(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField16 

func (p *Value) ReadField16(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField17 

func (p *Value) ReadField17(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField2 

func (p *Value) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField3 

func (p *Value) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField4 

func (p *Value) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField5 

func (p *Value) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField6 

func (p *Value) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField7 

func (p *Value) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField8 

func (p *Value) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) ReadField9 

func (p *Value) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*Value) String 

func (p *Value) String() string

func (*Value) Validate 

func (p *Value) Validate() error

func (*Value) Write 

func (p *Value) Write(ctx context.Context, oprot thrift.TProtocol) error

type Vertex 

type Vertex struct {
	Vid  *Value `thrift:"vid,1" db:"vid" json:"vid"`
	Tags []*Tag `thrift:"tags,2" db:"tags" json:"tags"`
}

Attributes:

  • Vid
  • Tags
var Path_Src_DEFAULT *Vertex
var Step_Dst_DEFAULT *Vertex
var Value_VVal_DEFAULT *Vertex

func NewVertex 

func NewVertex() *Vertex

func (*Vertex) Equals 

func (p *Vertex) Equals(other *Vertex) bool

func (*Vertex) GetTags 

func (p *Vertex) GetTags() []*Tag

func (*Vertex) GetVid 

func (p *Vertex) GetVid() *Value

func (*Vertex) IsSetVid 

func (p *Vertex) IsSetVid() bool

func (*Vertex) LogValue 

func (p *Vertex) LogValue() slog.Value

func (*Vertex) Read 

func (p *Vertex) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Vertex) ReadField1 

func (p *Vertex) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Vertex) ReadField2 

func (p *Vertex) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Vertex) String 

func (p *Vertex) String() string

func (*Vertex) Validate 

func (p *Vertex) Validate() error

func (*Vertex) Write 

func (p *Vertex) Write(ctx context.Context, oprot thrift.TProtocol) error

Source Files

View all Source files

Directories

Path Synopsis

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.