storage

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: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AddLearnerReq_Learner_DEFAULT *nebula.HostAddr
View Source 
var AdminExecResp_Stats_DEFAULT *meta.StatsItem
View Source 
var CatchUpDataReq_Target_DEFAULT *nebula.HostAddr
View Source 
var ChainAddEdgesRequest_EdgeVersion_DEFAULT int64
View Source 
var ChainUpdateEdgeRequest_EdgeVersion_DEFAULT int64
View Source 
var DelTags_ID_DEFAULT *nebula.Value
View Source 
var EdgeKey_Dst_DEFAULT *nebula.Value
View Source 
var EdgeKey_Src_DEFAULT *nebula.Value
View Source 
var GetDstBySrcResponse_Dsts_DEFAULT *nebula.DataSet
View Source 
var GetNeighborsResponse_Vertices_DEFAULT *nebula.DataSet
View Source 
var GetPropRequest_EdgeProps_DEFAULT []*EdgeProp
View Source 
var GetPropRequest_Expressions_DEFAULT []*Expr
View Source 
var GetPropRequest_Filter_DEFAULT []byte
View Source 
var GetPropRequest_Limit_DEFAULT int64
View Source 
var GetPropRequest_OrderBy_DEFAULT []*OrderBy
View Source 
var GetPropRequest_VertexProps_DEFAULT []*VertexProp
View Source 
var GetPropResponse_Props_DEFAULT *nebula.DataSet
View Source 
var GetUUIDResp_ID_DEFAULT *nebula.Value
View Source 
var GoUnusedProtection__ int
View Source 
var IndexColumnHint_BeginValue_DEFAULT *nebula.Value
View Source 
var IndexColumnHint_EndValue_DEFAULT *nebula.Value
View Source 
var IndexSpec_SchemaID_DEFAULT *nebula.SchemaID
View Source 
var ListClusterInfoResp_Dir_DEFAULT *nebula.DirInfo
View Source 
var LookupIndexRequest_Limit_DEFAULT int64
View Source 
var LookupIndexRequest_OrderBy_DEFAULT []*OrderBy
View Source 
var LookupIndexRequest_ReturnColumns_DEFAULT [][]byte
View Source 
var LookupIndexRequest_StatColumns_DEFAULT []*StatProp
View Source 
var LookupIndexResp_Data_DEFAULT *nebula.DataSet
View Source 
var LookupIndexResp_StatData_DEFAULT *nebula.DataSet
View Source 
var MemberChangeReq_Peer_DEFAULT *nebula.HostAddr
View Source 
var NewVertex__ID_DEFAULT *nebula.Value
View Source 
var PartitionResult__Leader_DEFAULT *nebula.HostAddr
View Source 
var RequestCommon_PlanID_DEFAULT nebula.ExecutionPlanID
View Source 
var RequestCommon_ProfileDetail_DEFAULT bool
View Source 
var RequestCommon_SessionID_DEFAULT nebula.SessionID
View Source 
var ResponseCommon_LatencyDetailUs_DEFAULT map[string]int32
View Source 
var ScanCursor_NextCursor_DEFAULT []byte
View Source 
var ScanEdgeRequest_EndTime_DEFAULT int64
View Source 
var ScanEdgeRequest_Filter_DEFAULT []byte
View Source 
var ScanEdgeRequest_StartTime_DEFAULT int64
View Source 
var ScanResponse_Props_DEFAULT *nebula.DataSet
View Source 
var ScanVertexRequest_EndTime_DEFAULT int64
View Source 
var ScanVertexRequest_Filter_DEFAULT []byte
View Source 
var ScanVertexRequest_StartTime_DEFAULT int64
View Source 
var TaskPara_Parts_DEFAULT []nebula.PartitionID
View Source 
var TaskPara_TaskSpecificParas_DEFAULT [][]byte
View Source 
var TransLeaderReq_NewLeader__DEFAULT *nebula.HostAddr
View Source 
var TraverseSpec_EdgeProps_DEFAULT []*EdgeProp
View Source 
var TraverseSpec_Expressions_DEFAULT []*Expr
View Source 
var TraverseSpec_Filter_DEFAULT []byte
View Source 
var TraverseSpec_Limit_DEFAULT int64
View Source 
var TraverseSpec_OrderBy_DEFAULT []*OrderBy
View Source 
var TraverseSpec_Random_DEFAULT bool
View Source 
var TraverseSpec_StatProps_DEFAULT []*StatProp
View Source 
var TraverseSpec_TagFilter_DEFAULT []byte
View Source 
var TraverseSpec_VertexProps_DEFAULT []*VertexProp
View Source 
var UpdateEdgeRequest_Condition_DEFAULT []byte
View Source 
var UpdateEdgeRequest_Insertable_DEFAULT bool = false
View Source 
var UpdateEdgeRequest_ReturnProps_DEFAULT [][]byte
View Source 
var UpdateResponse_Props_DEFAULT *nebula.DataSet
View Source 
var UpdateVertexRequest_Condition_DEFAULT []byte
View Source 
var UpdateVertexRequest_Insertable_DEFAULT bool = false
View Source 
var UpdateVertexRequest_ReturnProps_DEFAULT [][]byte
View Source 
var UpdateVertexRequest_VertexID_DEFAULT *nebula.Value

Functions

This section is empty.

Types

type AddEdgesRequest 

type AddEdgesRequest struct {
	SpaceID            nebula.GraphSpaceID                `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts              map[nebula.PartitionID][]*NewEdge_ `thrift:"parts,2" db:"parts" json:"parts"`
	PropNames          [][]byte                           `thrift:"prop_names,3" db:"prop_names" json:"prop_names"`
	IfNotExists        bool                               `thrift:"if_not_exists,4" db:"if_not_exists" json:"if_not_exists"`
	IgnoreExistedIndex bool                               `thrift:"ignore_existed_index,5" db:"ignore_existed_index" json:"ignore_existed_index"`
	Common             *RequestCommon                     `thrift:"common,6" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • PropNames
  • IfNotExists
  • IgnoreExistedIndex
  • Common
var GraphStorageServiceAddEdgesArgs_Req_DEFAULT *AddEdgesRequest
var GraphStorageServiceChainAddEdgesArgs_Req_DEFAULT *AddEdgesRequest

func NewAddEdgesRequest 

func NewAddEdgesRequest() *AddEdgesRequest

func (*AddEdgesRequest) Equals 

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

func (*AddEdgesRequest) GetCommon 

func (p *AddEdgesRequest) GetCommon() *RequestCommon

func (*AddEdgesRequest) GetIfNotExists 

func (p *AddEdgesRequest) GetIfNotExists() bool

func (*AddEdgesRequest) GetIgnoreExistedIndex 

func (p *AddEdgesRequest) GetIgnoreExistedIndex() bool

func (*AddEdgesRequest) GetParts 

func (p *AddEdgesRequest) GetParts() map[nebula.PartitionID][]*NewEdge_

func (*AddEdgesRequest) GetPropNames 

func (p *AddEdgesRequest) GetPropNames() [][]byte

func (*AddEdgesRequest) GetSpaceID 

func (p *AddEdgesRequest) GetSpaceID() nebula.GraphSpaceID

func (*AddEdgesRequest) IsSetCommon 

func (p *AddEdgesRequest) IsSetCommon() bool

func (*AddEdgesRequest) LogValue 

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

func (*AddEdgesRequest) Read 

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

func (*AddEdgesRequest) ReadField1 

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

func (*AddEdgesRequest) ReadField2 

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

func (*AddEdgesRequest) ReadField3 

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

func (*AddEdgesRequest) ReadField4 

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

func (*AddEdgesRequest) ReadField5 

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

func (*AddEdgesRequest) ReadField6 

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

func (*AddEdgesRequest) String 

func (p *AddEdgesRequest) String() string

func (*AddEdgesRequest) Validate 

func (p *AddEdgesRequest) Validate() error

func (*AddEdgesRequest) Write 

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

type AddLearnerReq 

type AddLearnerReq struct {
	SpaceID nebula.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID  nebula.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	Learner *nebula.HostAddr    `thrift:"learner,3" db:"learner" json:"learner"`
}

Attributes:

  • SpaceID
  • PartID
  • Learner
var StorageAdminServiceAddLearnerArgs_Req_DEFAULT *AddLearnerReq

func NewAddLearnerReq 

func NewAddLearnerReq() *AddLearnerReq

func (*AddLearnerReq) Equals 

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

func (*AddLearnerReq) GetLearner 

func (p *AddLearnerReq) GetLearner() *nebula.HostAddr

func (*AddLearnerReq) GetPartID 

func (p *AddLearnerReq) GetPartID() nebula.PartitionID

func (*AddLearnerReq) GetSpaceID 

func (p *AddLearnerReq) GetSpaceID() nebula.GraphSpaceID

func (*AddLearnerReq) IsSetLearner 

func (p *AddLearnerReq) IsSetLearner() bool

func (*AddLearnerReq) LogValue 

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

func (*AddLearnerReq) Read 

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

func (*AddLearnerReq) ReadField1 

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

func (*AddLearnerReq) ReadField2 

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

func (*AddLearnerReq) ReadField3 

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

func (*AddLearnerReq) String 

func (p *AddLearnerReq) String() string

func (*AddLearnerReq) Validate 

func (p *AddLearnerReq) Validate() error

func (*AddLearnerReq) Write 

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

type AddPartReq 

type AddPartReq struct {
	SpaceID   nebula.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID    nebula.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	AsLearner bool                `thrift:"as_learner,3" db:"as_learner" json:"as_learner"`
	Peers     []*nebula.HostAddr  `thrift:"peers,4" db:"peers" json:"peers"`
}

Attributes:

  • SpaceID
  • PartID
  • AsLearner
  • Peers
var StorageAdminServiceAddPartArgs_Req_DEFAULT *AddPartReq

func NewAddPartReq 

func NewAddPartReq() *AddPartReq

func (*AddPartReq) Equals 

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

func (*AddPartReq) GetAsLearner 

func (p *AddPartReq) GetAsLearner() bool

func (*AddPartReq) GetPartID 

func (p *AddPartReq) GetPartID() nebula.PartitionID

func (*AddPartReq) GetPeers 

func (p *AddPartReq) GetPeers() []*nebula.HostAddr

func (*AddPartReq) GetSpaceID 

func (p *AddPartReq) GetSpaceID() nebula.GraphSpaceID

func (*AddPartReq) LogValue 

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

func (*AddPartReq) Read 

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

func (*AddPartReq) ReadField1 

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

func (*AddPartReq) ReadField2 

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

func (*AddPartReq) ReadField3 

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

func (*AddPartReq) ReadField4 

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

func (*AddPartReq) String 

func (p *AddPartReq) String() string

func (*AddPartReq) Validate 

func (p *AddPartReq) Validate() error

func (*AddPartReq) Write 

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

type AddTaskRequest 

type AddTaskRequest struct {
	JobType meta.JobType `thrift:"job_type,1" db:"job_type" json:"job_type"`
	JobID   int32        `thrift:"job_id,2" db:"job_id" json:"job_id"`
	TaskID  int32        `thrift:"task_id,3" db:"task_id" json:"task_id"`
	Para    *TaskPara    `thrift:"para,4" db:"para" json:"para"`
}

Attributes:

  • JobType
  • JobID
  • TaskID
  • Para
var StorageAdminServiceAddAdminTaskArgs_Req_DEFAULT *AddTaskRequest

func NewAddTaskRequest 

func NewAddTaskRequest() *AddTaskRequest

func (*AddTaskRequest) Equals 

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

func (*AddTaskRequest) GetJobID 

func (p *AddTaskRequest) GetJobID() int32

func (*AddTaskRequest) GetJobType 

func (p *AddTaskRequest) GetJobType() meta.JobType

func (*AddTaskRequest) GetPara 

func (p *AddTaskRequest) GetPara() *TaskPara

func (*AddTaskRequest) GetTaskID 

func (p *AddTaskRequest) GetTaskID() int32

func (*AddTaskRequest) IsSetPara 

func (p *AddTaskRequest) IsSetPara() bool

func (*AddTaskRequest) LogValue 

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

func (*AddTaskRequest) Read 

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

func (*AddTaskRequest) ReadField1 

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

func (*AddTaskRequest) ReadField2 

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

func (*AddTaskRequest) ReadField3 

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

func (*AddTaskRequest) ReadField4 

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

func (*AddTaskRequest) String 

func (p *AddTaskRequest) String() string

func (*AddTaskRequest) Validate 

func (p *AddTaskRequest) Validate() error

func (*AddTaskRequest) Write 

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

type AddTaskResp 

type AddTaskResp struct {
	Code nebula.ErrorCode `thrift:"code,1" db:"code" json:"code"`
}

Attributes:

  • Code
var StorageAdminServiceAddAdminTaskResult_Success_DEFAULT *AddTaskResp

func NewAddTaskResp 

func NewAddTaskResp() *AddTaskResp

func (*AddTaskResp) Equals 

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

func (*AddTaskResp) GetCode 

func (p *AddTaskResp) GetCode() nebula.ErrorCode

func (*AddTaskResp) LogValue 

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

func (*AddTaskResp) Read 

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

func (*AddTaskResp) ReadField1 

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

func (*AddTaskResp) String 

func (p *AddTaskResp) String() string

func (*AddTaskResp) Validate 

func (p *AddTaskResp) Validate() error

func (*AddTaskResp) Write 

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

type AddVerticesRequest 

type AddVerticesRequest struct {
	SpaceID            nebula.GraphSpaceID                  `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts              map[nebula.PartitionID][]*NewVertex_ `thrift:"parts,2" db:"parts" json:"parts"`
	PropNames          map[nebula.TagID][][]byte            `thrift:"prop_names,3" db:"prop_names" json:"prop_names"`
	IfNotExists        bool                                 `thrift:"if_not_exists,4" db:"if_not_exists" json:"if_not_exists"`
	IgnoreExistedIndex bool                                 `thrift:"ignore_existed_index,5" db:"ignore_existed_index" json:"ignore_existed_index"`
	Common             *RequestCommon                       `thrift:"common,6" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • PropNames
  • IfNotExists
  • IgnoreExistedIndex
  • Common
var GraphStorageServiceAddVerticesArgs_Req_DEFAULT *AddVerticesRequest

func NewAddVerticesRequest 

func NewAddVerticesRequest() *AddVerticesRequest

func (*AddVerticesRequest) Equals 

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

func (*AddVerticesRequest) GetCommon 

func (p *AddVerticesRequest) GetCommon() *RequestCommon

func (*AddVerticesRequest) GetIfNotExists 

func (p *AddVerticesRequest) GetIfNotExists() bool

func (*AddVerticesRequest) GetIgnoreExistedIndex 

func (p *AddVerticesRequest) GetIgnoreExistedIndex() bool

func (*AddVerticesRequest) GetParts 

func (p *AddVerticesRequest) GetParts() map[nebula.PartitionID][]*NewVertex_

func (*AddVerticesRequest) GetPropNames 

func (p *AddVerticesRequest) GetPropNames() map[nebula.TagID][][]byte

func (*AddVerticesRequest) GetSpaceID 

func (p *AddVerticesRequest) GetSpaceID() nebula.GraphSpaceID

func (*AddVerticesRequest) IsSetCommon 

func (p *AddVerticesRequest) IsSetCommon() bool

func (*AddVerticesRequest) LogValue 

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

func (*AddVerticesRequest) Read 

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

func (*AddVerticesRequest) ReadField1 

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

func (*AddVerticesRequest) ReadField2 

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

func (*AddVerticesRequest) ReadField3 

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

func (*AddVerticesRequest) ReadField4 

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

func (*AddVerticesRequest) ReadField5 

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

func (*AddVerticesRequest) ReadField6 

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

func (*AddVerticesRequest) String 

func (p *AddVerticesRequest) String() string

func (*AddVerticesRequest) Validate 

func (p *AddVerticesRequest) Validate() error

func (*AddVerticesRequest) Write 

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

type AdminExecResp 

type AdminExecResp struct {
	Result_ *ResponseCommon `thrift:"result,1,required" db:"result" json:"result"`
	Stats   *meta.StatsItem `thrift:"stats,2" db:"stats" json:"stats,omitempty"`
}

Attributes:

  • Result_
  • Stats
var StorageAdminServiceAddLearnerResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceAddPartResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceCheckPeersResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceMemberChangeResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceRemovePartResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceTransLeaderResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceWaitingForCatchUpDataResult_Success_DEFAULT *AdminExecResp

func NewAdminExecResp 

func NewAdminExecResp() *AdminExecResp

func (*AdminExecResp) Equals 

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

func (*AdminExecResp) GetResult_ 

func (p *AdminExecResp) GetResult_() *ResponseCommon

func (*AdminExecResp) GetStats 

func (p *AdminExecResp) GetStats() *meta.StatsItem

func (*AdminExecResp) IsSetResult_ 

func (p *AdminExecResp) IsSetResult_() bool

func (*AdminExecResp) IsSetStats 

func (p *AdminExecResp) IsSetStats() bool

func (*AdminExecResp) LogValue 

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

func (*AdminExecResp) Read 

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

func (*AdminExecResp) ReadField1 

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

func (*AdminExecResp) ReadField2 

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

func (*AdminExecResp) String 

func (p *AdminExecResp) String() string

func (*AdminExecResp) Validate 

func (p *AdminExecResp) Validate() error

func (*AdminExecResp) Write 

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

type BlockingSignRequest 

type BlockingSignRequest struct {
	SpaceIds []nebula.GraphSpaceID `thrift:"space_ids,1" db:"space_ids" json:"space_ids"`
	Sign     EngineSignType        `thrift:"sign,2,required" db:"sign" json:"sign"`
}

Attributes:

  • SpaceIds
  • Sign
var StorageAdminServiceBlockingWritesArgs_Req_DEFAULT *BlockingSignRequest

func NewBlockingSignRequest 

func NewBlockingSignRequest() *BlockingSignRequest

func (*BlockingSignRequest) Equals 

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

func (*BlockingSignRequest) GetSign 

func (p *BlockingSignRequest) GetSign() EngineSignType

func (*BlockingSignRequest) GetSpaceIds 

func (p *BlockingSignRequest) GetSpaceIds() []nebula.GraphSpaceID

func (*BlockingSignRequest) LogValue 

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

func (*BlockingSignRequest) Read 

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

func (*BlockingSignRequest) ReadField1 

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

func (*BlockingSignRequest) ReadField2 

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

func (*BlockingSignRequest) String 

func (p *BlockingSignRequest) String() string

func (*BlockingSignRequest) Validate 

func (p *BlockingSignRequest) Validate() error

func (*BlockingSignRequest) Write 

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

type BlockingSignResp 

type BlockingSignResp struct {
	Code nebula.ErrorCode `thrift:"code,1" db:"code" json:"code"`
}

Attributes:

  • Code
var StorageAdminServiceBlockingWritesResult_Success_DEFAULT *BlockingSignResp

func NewBlockingSignResp 

func NewBlockingSignResp() *BlockingSignResp

func (*BlockingSignResp) Equals 

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

func (*BlockingSignResp) GetCode 

func (p *BlockingSignResp) GetCode() nebula.ErrorCode

func (*BlockingSignResp) LogValue 

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

func (*BlockingSignResp) Read 

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

func (*BlockingSignResp) ReadField1 

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

func (*BlockingSignResp) String 

func (p *BlockingSignResp) String() string

func (*BlockingSignResp) Validate 

func (p *BlockingSignResp) Validate() error

func (*BlockingSignResp) Write 

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

type CatchUpDataReq 

type CatchUpDataReq struct {
	SpaceID nebula.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID  nebula.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	Target  *nebula.HostAddr    `thrift:"target,3" db:"target" json:"target"`
}

Attributes:

  • SpaceID
  • PartID
  • Target
var StorageAdminServiceWaitingForCatchUpDataArgs_Req_DEFAULT *CatchUpDataReq

func NewCatchUpDataReq 

func NewCatchUpDataReq() *CatchUpDataReq

func (*CatchUpDataReq) Equals 

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

func (*CatchUpDataReq) GetPartID 

func (p *CatchUpDataReq) GetPartID() nebula.PartitionID

func (*CatchUpDataReq) GetSpaceID 

func (p *CatchUpDataReq) GetSpaceID() nebula.GraphSpaceID

func (*CatchUpDataReq) GetTarget 

func (p *CatchUpDataReq) GetTarget() *nebula.HostAddr

func (*CatchUpDataReq) IsSetTarget 

func (p *CatchUpDataReq) IsSetTarget() bool

func (*CatchUpDataReq) LogValue 

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

func (*CatchUpDataReq) Read 

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

func (*CatchUpDataReq) ReadField1 

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

func (*CatchUpDataReq) ReadField2 

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

func (*CatchUpDataReq) ReadField3 

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

func (*CatchUpDataReq) String 

func (p *CatchUpDataReq) String() string

func (*CatchUpDataReq) Validate 

func (p *CatchUpDataReq) Validate() error

func (*CatchUpDataReq) Write 

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

type ChainAddEdgesRequest 

type ChainAddEdgesRequest struct {
	SpaceID     nebula.GraphSpaceID                `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts       map[nebula.PartitionID][]*NewEdge_ `thrift:"parts,2" db:"parts" json:"parts"`
	PropNames   [][]byte                           `thrift:"prop_names,3" db:"prop_names" json:"prop_names"`
	IfNotExists bool                               `thrift:"if_not_exists,4" db:"if_not_exists" json:"if_not_exists"`
	Term        int64                              `thrift:"term,5" db:"term" json:"term"`
	EdgeVersion *int64                             `thrift:"edge_version,6" db:"edge_version" json:"edge_version,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • PropNames
  • IfNotExists
  • Term
  • EdgeVersion
var InternalStorageServiceChainAddEdgesArgs_Req_DEFAULT *ChainAddEdgesRequest

func NewChainAddEdgesRequest 

func NewChainAddEdgesRequest() *ChainAddEdgesRequest

func (*ChainAddEdgesRequest) Equals 

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

func (*ChainAddEdgesRequest) GetEdgeVersion 

func (p *ChainAddEdgesRequest) GetEdgeVersion() int64

func (*ChainAddEdgesRequest) GetIfNotExists 

func (p *ChainAddEdgesRequest) GetIfNotExists() bool

func (*ChainAddEdgesRequest) GetParts 

func (p *ChainAddEdgesRequest) GetParts() map[nebula.PartitionID][]*NewEdge_

func (*ChainAddEdgesRequest) GetPropNames 

func (p *ChainAddEdgesRequest) GetPropNames() [][]byte

func (*ChainAddEdgesRequest) GetSpaceID 

func (p *ChainAddEdgesRequest) GetSpaceID() nebula.GraphSpaceID

func (*ChainAddEdgesRequest) GetTerm 

func (p *ChainAddEdgesRequest) GetTerm() int64

func (*ChainAddEdgesRequest) IsSetEdgeVersion 

func (p *ChainAddEdgesRequest) IsSetEdgeVersion() bool

func (*ChainAddEdgesRequest) LogValue 

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

func (*ChainAddEdgesRequest) Read 

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

func (*ChainAddEdgesRequest) ReadField1 

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

func (*ChainAddEdgesRequest) ReadField2 

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

func (*ChainAddEdgesRequest) ReadField3 

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

func (*ChainAddEdgesRequest) ReadField4 

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

func (*ChainAddEdgesRequest) ReadField5 

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

func (*ChainAddEdgesRequest) ReadField6 

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

func (*ChainAddEdgesRequest) String 

func (p *ChainAddEdgesRequest) String() string

func (*ChainAddEdgesRequest) Validate 

func (p *ChainAddEdgesRequest) Validate() error

func (*ChainAddEdgesRequest) Write 

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

type ChainDeleteEdgesRequest 

type ChainDeleteEdgesRequest struct {
	SpaceID nebula.GraphSpaceID               `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts   map[nebula.PartitionID][]*EdgeKey `thrift:"parts,2" db:"parts" json:"parts"`
	TxnID   []byte                            `thrift:"txn_id,3" db:"txn_id" json:"txn_id"`
	Term    int64                             `thrift:"term,4" db:"term" json:"term"`
}

Attributes:

  • SpaceID
  • Parts
  • TxnID
  • Term
var InternalStorageServiceChainDeleteEdgesArgs_Req_DEFAULT *ChainDeleteEdgesRequest

func NewChainDeleteEdgesRequest 

func NewChainDeleteEdgesRequest() *ChainDeleteEdgesRequest

func (*ChainDeleteEdgesRequest) Equals 

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

func (*ChainDeleteEdgesRequest) GetParts 

func (p *ChainDeleteEdgesRequest) GetParts() map[nebula.PartitionID][]*EdgeKey

func (*ChainDeleteEdgesRequest) GetSpaceID 

func (p *ChainDeleteEdgesRequest) GetSpaceID() nebula.GraphSpaceID

func (*ChainDeleteEdgesRequest) GetTerm 

func (p *ChainDeleteEdgesRequest) GetTerm() int64

func (*ChainDeleteEdgesRequest) GetTxnID 

func (p *ChainDeleteEdgesRequest) GetTxnID() []byte

func (*ChainDeleteEdgesRequest) LogValue 

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

func (*ChainDeleteEdgesRequest) Read 

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

func (*ChainDeleteEdgesRequest) ReadField1 

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

func (*ChainDeleteEdgesRequest) ReadField2 

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

func (*ChainDeleteEdgesRequest) ReadField3 

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

func (*ChainDeleteEdgesRequest) ReadField4 

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

func (*ChainDeleteEdgesRequest) String 

func (p *ChainDeleteEdgesRequest) String() string

func (*ChainDeleteEdgesRequest) Validate 

func (p *ChainDeleteEdgesRequest) Validate() error

func (*ChainDeleteEdgesRequest) Write 

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

type ChainUpdateEdgeRequest 

type ChainUpdateEdgeRequest struct {
	UpdateEdgeRequest *UpdateEdgeRequest   `thrift:"update_edge_request,1" db:"update_edge_request" json:"update_edge_request"`
	Term              int64                `thrift:"term,2" db:"term" json:"term"`
	EdgeVersion       *int64               `thrift:"edge_version,3" db:"edge_version" json:"edge_version,omitempty"`
	SpaceID           nebula.GraphSpaceID  `thrift:"space_id,4" db:"space_id" json:"space_id"`
	Parts             []nebula.PartitionID `thrift:"parts,5,required" db:"parts" json:"parts"`
}

Attributes:

  • UpdateEdgeRequest
  • Term
  • EdgeVersion
  • SpaceID
  • Parts
var InternalStorageServiceChainUpdateEdgeArgs_Req_DEFAULT *ChainUpdateEdgeRequest

func NewChainUpdateEdgeRequest 

func NewChainUpdateEdgeRequest() *ChainUpdateEdgeRequest

func (*ChainUpdateEdgeRequest) Equals 

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

func (*ChainUpdateEdgeRequest) GetEdgeVersion 

func (p *ChainUpdateEdgeRequest) GetEdgeVersion() int64

func (*ChainUpdateEdgeRequest) GetParts 

func (p *ChainUpdateEdgeRequest) GetParts() []nebula.PartitionID

func (*ChainUpdateEdgeRequest) GetSpaceID 

func (p *ChainUpdateEdgeRequest) GetSpaceID() nebula.GraphSpaceID

func (*ChainUpdateEdgeRequest) GetTerm 

func (p *ChainUpdateEdgeRequest) GetTerm() int64

func (*ChainUpdateEdgeRequest) GetUpdateEdgeRequest 

func (p *ChainUpdateEdgeRequest) GetUpdateEdgeRequest() *UpdateEdgeRequest

func (*ChainUpdateEdgeRequest) IsSetEdgeVersion 

func (p *ChainUpdateEdgeRequest) IsSetEdgeVersion() bool

func (*ChainUpdateEdgeRequest) IsSetUpdateEdgeRequest 

func (p *ChainUpdateEdgeRequest) IsSetUpdateEdgeRequest() bool

func (*ChainUpdateEdgeRequest) LogValue 

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

func (*ChainUpdateEdgeRequest) Read 

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

func (*ChainUpdateEdgeRequest) ReadField1 

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

func (*ChainUpdateEdgeRequest) ReadField2 

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

func (*ChainUpdateEdgeRequest) ReadField3 

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

func (*ChainUpdateEdgeRequest) ReadField4 

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

func (*ChainUpdateEdgeRequest) ReadField5 

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

func (*ChainUpdateEdgeRequest) String 

func (p *ChainUpdateEdgeRequest) String() string

func (*ChainUpdateEdgeRequest) Validate 

func (p *ChainUpdateEdgeRequest) Validate() error

func (*ChainUpdateEdgeRequest) Write 

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

type CheckPeersReq 

type CheckPeersReq struct {
	SpaceID nebula.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID  nebula.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	Peers   []*nebula.HostAddr  `thrift:"peers,3" db:"peers" json:"peers"`
}

Attributes:

  • SpaceID
  • PartID
  • Peers
var StorageAdminServiceCheckPeersArgs_Req_DEFAULT *CheckPeersReq

func NewCheckPeersReq 

func NewCheckPeersReq() *CheckPeersReq

func (*CheckPeersReq) Equals 

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

func (*CheckPeersReq) GetPartID 

func (p *CheckPeersReq) GetPartID() nebula.PartitionID

func (*CheckPeersReq) GetPeers 

func (p *CheckPeersReq) GetPeers() []*nebula.HostAddr

func (*CheckPeersReq) GetSpaceID 

func (p *CheckPeersReq) GetSpaceID() nebula.GraphSpaceID

func (*CheckPeersReq) LogValue 

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

func (*CheckPeersReq) Read 

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

func (*CheckPeersReq) ReadField1 

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

func (*CheckPeersReq) ReadField2 

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

func (*CheckPeersReq) ReadField3 

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

func (*CheckPeersReq) String 

func (p *CheckPeersReq) String() string

func (*CheckPeersReq) Validate 

func (p *CheckPeersReq) Validate() error

func (*CheckPeersReq) Write 

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

type ClearSpaceReq 

type ClearSpaceReq struct {
	SpaceID nebula.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
}

Attributes:

  • SpaceID
var StorageAdminServiceClearSpaceArgs_Req_DEFAULT *ClearSpaceReq

func NewClearSpaceReq 

func NewClearSpaceReq() *ClearSpaceReq

func (*ClearSpaceReq) Equals 

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

func (*ClearSpaceReq) GetSpaceID 

func (p *ClearSpaceReq) GetSpaceID() nebula.GraphSpaceID

func (*ClearSpaceReq) LogValue 

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

func (*ClearSpaceReq) Read 

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

func (*ClearSpaceReq) ReadField1 

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

func (*ClearSpaceReq) String 

func (p *ClearSpaceReq) String() string

func (*ClearSpaceReq) Validate 

func (p *ClearSpaceReq) Validate() error

func (*ClearSpaceReq) Write 

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

type ClearSpaceResp 

type ClearSpaceResp struct {
	Code nebula.ErrorCode `thrift:"code,1" db:"code" json:"code"`
}

Attributes:

  • Code
var StorageAdminServiceClearSpaceResult_Success_DEFAULT *ClearSpaceResp

func NewClearSpaceResp 

func NewClearSpaceResp() *ClearSpaceResp

func (*ClearSpaceResp) Equals 

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

func (*ClearSpaceResp) GetCode 

func (p *ClearSpaceResp) GetCode() nebula.ErrorCode

func (*ClearSpaceResp) LogValue 

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

func (*ClearSpaceResp) Read 

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

func (*ClearSpaceResp) ReadField1 

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

func (*ClearSpaceResp) String 

func (p *ClearSpaceResp) String() string

func (*ClearSpaceResp) Validate 

func (p *ClearSpaceResp) Validate() error

func (*ClearSpaceResp) Write 

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

type CreateCPRequest 

type CreateCPRequest struct {
	SpaceIds []nebula.GraphSpaceID `thrift:"space_ids,1" db:"space_ids" json:"space_ids"`
	Name     []byte                `thrift:"name,2" db:"name" json:"name"`
}

Attributes:

  • SpaceIds
  • Name
var StorageAdminServiceCreateCheckpointArgs_Req_DEFAULT *CreateCPRequest

func NewCreateCPRequest 

func NewCreateCPRequest() *CreateCPRequest

func (*CreateCPRequest) Equals 

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

func (*CreateCPRequest) GetName 

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

func (*CreateCPRequest) GetSpaceIds 

func (p *CreateCPRequest) GetSpaceIds() []nebula.GraphSpaceID

func (*CreateCPRequest) LogValue 

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

func (*CreateCPRequest) Read 

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

func (*CreateCPRequest) ReadField1 

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

func (*CreateCPRequest) ReadField2 

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

func (*CreateCPRequest) String 

func (p *CreateCPRequest) String() string

func (*CreateCPRequest) Validate 

func (p *CreateCPRequest) Validate() error

func (*CreateCPRequest) Write 

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

type CreateCPResp 

type CreateCPResp struct {
	Code nebula.ErrorCode         `thrift:"code,1" db:"code" json:"code"`
	Info []*nebula.CheckpointInfo `thrift:"info,2" db:"info" json:"info"`
}

Attributes:

  • Code
  • Info
var StorageAdminServiceCreateCheckpointResult_Success_DEFAULT *CreateCPResp

func NewCreateCPResp 

func NewCreateCPResp() *CreateCPResp

func (*CreateCPResp) Equals 

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

func (*CreateCPResp) GetCode 

func (p *CreateCPResp) GetCode() nebula.ErrorCode

func (*CreateCPResp) GetInfo 

func (p *CreateCPResp) GetInfo() []*nebula.CheckpointInfo

func (*CreateCPResp) LogValue 

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

func (*CreateCPResp) Read 

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

func (*CreateCPResp) ReadField1 

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

func (*CreateCPResp) ReadField2 

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

func (*CreateCPResp) String 

func (p *CreateCPResp) String() string

func (*CreateCPResp) Validate 

func (p *CreateCPResp) Validate() error

func (*CreateCPResp) Write 

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

type DelTags 

type DelTags struct {
	ID   *nebula.Value  `thrift:"id,1" db:"id" json:"id"`
	Tags []nebula.TagID `thrift:"tags,2" db:"tags" json:"tags"`
}

Attributes:

  • ID
  • Tags

func NewDelTags 

func NewDelTags() *DelTags

func (*DelTags) Equals 

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

func (*DelTags) GetID 

func (p *DelTags) GetID() *nebula.Value

func (*DelTags) GetTags 

func (p *DelTags) GetTags() []nebula.TagID

func (*DelTags) IsSetID 

func (p *DelTags) IsSetID() bool

func (*DelTags) LogValue 

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

func (*DelTags) Read 

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

func (*DelTags) ReadField1 

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

func (*DelTags) ReadField2 

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

func (*DelTags) String 

func (p *DelTags) String() string

func (*DelTags) Validate 

func (p *DelTags) Validate() error

func (*DelTags) Write 

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

type DeleteEdgesRequest 

type DeleteEdgesRequest struct {
	SpaceID nebula.GraphSpaceID               `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts   map[nebula.PartitionID][]*EdgeKey `thrift:"parts,2" db:"parts" json:"parts"`
	Common  *RequestCommon                    `thrift:"common,3" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • Common
var GraphStorageServiceChainDeleteEdgesArgs_Req_DEFAULT *DeleteEdgesRequest
var GraphStorageServiceDeleteEdgesArgs_Req_DEFAULT *DeleteEdgesRequest

func NewDeleteEdgesRequest 

func NewDeleteEdgesRequest() *DeleteEdgesRequest

func (*DeleteEdgesRequest) Equals 

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

func (*DeleteEdgesRequest) GetCommon 

func (p *DeleteEdgesRequest) GetCommon() *RequestCommon

func (*DeleteEdgesRequest) GetParts 

func (p *DeleteEdgesRequest) GetParts() map[nebula.PartitionID][]*EdgeKey

func (*DeleteEdgesRequest) GetSpaceID 

func (p *DeleteEdgesRequest) GetSpaceID() nebula.GraphSpaceID

func (*DeleteEdgesRequest) IsSetCommon 

func (p *DeleteEdgesRequest) IsSetCommon() bool

func (*DeleteEdgesRequest) LogValue 

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

func (*DeleteEdgesRequest) Read 

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

func (*DeleteEdgesRequest) ReadField1 

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

func (*DeleteEdgesRequest) ReadField2 

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

func (*DeleteEdgesRequest) ReadField3 

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

func (*DeleteEdgesRequest) String 

func (p *DeleteEdgesRequest) String() string

func (*DeleteEdgesRequest) Validate 

func (p *DeleteEdgesRequest) Validate() error

func (*DeleteEdgesRequest) Write 

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

type DeleteTagsRequest 

type DeleteTagsRequest struct {
	SpaceID nebula.GraphSpaceID               `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts   map[nebula.PartitionID][]*DelTags `thrift:"parts,2" db:"parts" json:"parts"`
	Common  *RequestCommon                    `thrift:"common,3" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • Common
var GraphStorageServiceDeleteTagsArgs_Req_DEFAULT *DeleteTagsRequest

func NewDeleteTagsRequest 

func NewDeleteTagsRequest() *DeleteTagsRequest

func (*DeleteTagsRequest) Equals 

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

func (*DeleteTagsRequest) GetCommon 

func (p *DeleteTagsRequest) GetCommon() *RequestCommon

func (*DeleteTagsRequest) GetParts 

func (p *DeleteTagsRequest) GetParts() map[nebula.PartitionID][]*DelTags

func (*DeleteTagsRequest) GetSpaceID 

func (p *DeleteTagsRequest) GetSpaceID() nebula.GraphSpaceID

func (*DeleteTagsRequest) IsSetCommon 

func (p *DeleteTagsRequest) IsSetCommon() bool

func (*DeleteTagsRequest) LogValue 

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

func (*DeleteTagsRequest) Read 

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

func (*DeleteTagsRequest) ReadField1 

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

func (*DeleteTagsRequest) ReadField2 

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

func (*DeleteTagsRequest) ReadField3 

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

func (*DeleteTagsRequest) String 

func (p *DeleteTagsRequest) String() string

func (*DeleteTagsRequest) Validate 

func (p *DeleteTagsRequest) Validate() error

func (*DeleteTagsRequest) Write 

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

type DeleteVerticesRequest 

type DeleteVerticesRequest struct {
	SpaceID nebula.GraphSpaceID                    `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts   map[nebula.PartitionID][]*nebula.Value `thrift:"parts,2" db:"parts" json:"parts"`
	Common  *RequestCommon                         `thrift:"common,3" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • Common
var GraphStorageServiceDeleteVerticesArgs_Req_DEFAULT *DeleteVerticesRequest

func NewDeleteVerticesRequest 

func NewDeleteVerticesRequest() *DeleteVerticesRequest

func (*DeleteVerticesRequest) Equals 

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

func (*DeleteVerticesRequest) GetCommon 

func (p *DeleteVerticesRequest) GetCommon() *RequestCommon

func (*DeleteVerticesRequest) GetParts 

func (p *DeleteVerticesRequest) GetParts() map[nebula.PartitionID][]*nebula.Value

func (*DeleteVerticesRequest) GetSpaceID 

func (p *DeleteVerticesRequest) GetSpaceID() nebula.GraphSpaceID

func (*DeleteVerticesRequest) IsSetCommon 

func (p *DeleteVerticesRequest) IsSetCommon() bool

func (*DeleteVerticesRequest) LogValue 

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

func (*DeleteVerticesRequest) Read 

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

func (*DeleteVerticesRequest) ReadField1 

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

func (*DeleteVerticesRequest) ReadField2 

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

func (*DeleteVerticesRequest) ReadField3 

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

func (*DeleteVerticesRequest) String 

func (p *DeleteVerticesRequest) String() string

func (*DeleteVerticesRequest) Validate 

func (p *DeleteVerticesRequest) Validate() error

func (*DeleteVerticesRequest) Write 

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

type DropCPRequest 

type DropCPRequest struct {
	SpaceIds []nebula.GraphSpaceID `thrift:"space_ids,1" db:"space_ids" json:"space_ids"`
	Name     []byte                `thrift:"name,2" db:"name" json:"name"`
}

Attributes:

  • SpaceIds
  • Name
var StorageAdminServiceDropCheckpointArgs_Req_DEFAULT *DropCPRequest

func NewDropCPRequest 

func NewDropCPRequest() *DropCPRequest

func (*DropCPRequest) Equals 

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

func (*DropCPRequest) GetName 

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

func (*DropCPRequest) GetSpaceIds 

func (p *DropCPRequest) GetSpaceIds() []nebula.GraphSpaceID

func (*DropCPRequest) LogValue 

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

func (*DropCPRequest) Read 

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

func (*DropCPRequest) ReadField1 

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

func (*DropCPRequest) ReadField2 

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

func (*DropCPRequest) String 

func (p *DropCPRequest) String() string

func (*DropCPRequest) Validate 

func (p *DropCPRequest) Validate() error

func (*DropCPRequest) Write 

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

type DropCPResp 

type DropCPResp struct {
	Code nebula.ErrorCode `thrift:"code,1" db:"code" json:"code"`
}

Attributes:

  • Code
var StorageAdminServiceDropCheckpointResult_Success_DEFAULT *DropCPResp

func NewDropCPResp 

func NewDropCPResp() *DropCPResp

func (*DropCPResp) Equals 

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

func (*DropCPResp) GetCode 

func (p *DropCPResp) GetCode() nebula.ErrorCode

func (*DropCPResp) LogValue 

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

func (*DropCPResp) Read 

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

func (*DropCPResp) ReadField1 

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

func (*DropCPResp) String 

func (p *DropCPResp) String() string

func (*DropCPResp) Validate 

func (p *DropCPResp) Validate() error

func (*DropCPResp) Write 

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

type EdgeDirection 

type EdgeDirection int64
const (
	EdgeDirection_BOTH     EdgeDirection = 1
	EdgeDirection_IN_EDGE  EdgeDirection = 2
	EdgeDirection_OUT_EDGE EdgeDirection = 3
)

func EdgeDirectionFromString 

func EdgeDirectionFromString(s string) (EdgeDirection, error)

func EdgeDirectionPtr 

func EdgeDirectionPtr(v EdgeDirection) *EdgeDirection

func (EdgeDirection) MarshalText 

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

func (*EdgeDirection) Scan 

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

func (EdgeDirection) String 

func (p EdgeDirection) String() string

func (*EdgeDirection) UnmarshalText 

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

func (*EdgeDirection) Value 

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

type EdgeKey 

type EdgeKey struct {
	Src      *nebula.Value      `thrift:"src,1" db:"src" json:"src"`
	EdgeType nebula.EdgeType    `thrift:"edge_type,2" db:"edge_type" json:"edge_type"`
	Ranking  nebula.EdgeRanking `thrift:"ranking,3" db:"ranking" json:"ranking"`
	Dst      *nebula.Value      `thrift:"dst,4" db:"dst" json:"dst"`
}

Attributes:

  • Src
  • EdgeType
  • Ranking
  • Dst
var NewEdge__Key_DEFAULT *EdgeKey
var UpdateEdgeRequest_EdgeKey_DEFAULT *EdgeKey

func NewEdgeKey 

func NewEdgeKey() *EdgeKey

func (*EdgeKey) Equals 

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

func (*EdgeKey) GetDst 

func (p *EdgeKey) GetDst() *nebula.Value

func (*EdgeKey) GetEdgeType 

func (p *EdgeKey) GetEdgeType() nebula.EdgeType

func (*EdgeKey) GetRanking 

func (p *EdgeKey) GetRanking() nebula.EdgeRanking

func (*EdgeKey) GetSrc 

func (p *EdgeKey) GetSrc() *nebula.Value

func (*EdgeKey) IsSetDst 

func (p *EdgeKey) IsSetDst() bool

func (*EdgeKey) IsSetSrc 

func (p *EdgeKey) IsSetSrc() bool

func (*EdgeKey) LogValue 

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

func (*EdgeKey) Read 

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

func (*EdgeKey) ReadField1 

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

func (*EdgeKey) ReadField2 

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

func (*EdgeKey) ReadField3 

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

func (*EdgeKey) ReadField4 

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

func (*EdgeKey) String 

func (p *EdgeKey) String() string

func (*EdgeKey) Validate 

func (p *EdgeKey) Validate() error

func (*EdgeKey) Write 

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

type EdgeProp 

type EdgeProp struct {
	Type  nebula.EdgeType `thrift:"type,1" db:"type" json:"type"`
	Props [][]byte        `thrift:"props,2" db:"props" json:"props"`
}

Attributes:

  • Type
  • Props

func NewEdgeProp 

func NewEdgeProp() *EdgeProp

func (*EdgeProp) Equals 

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

func (*EdgeProp) GetProps 

func (p *EdgeProp) GetProps() [][]byte

func (*EdgeProp) GetType 

func (p *EdgeProp) GetType() nebula.EdgeType

func (*EdgeProp) LogValue 

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

func (*EdgeProp) Read 

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

func (*EdgeProp) ReadField1 

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

func (*EdgeProp) ReadField2 

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

func (*EdgeProp) String 

func (p *EdgeProp) String() string

func (*EdgeProp) Validate 

func (p *EdgeProp) Validate() error

func (*EdgeProp) Write 

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

type EngineSignType 

type EngineSignType int64
const (
	EngineSignType_BLOCK_ON  EngineSignType = 1
	EngineSignType_BLOCK_OFF EngineSignType = 2
)

func EngineSignTypeFromString 

func EngineSignTypeFromString(s string) (EngineSignType, error)

func EngineSignTypePtr 

func EngineSignTypePtr(v EngineSignType) *EngineSignType

func (EngineSignType) MarshalText 

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

func (*EngineSignType) Scan 

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

func (EngineSignType) String 

func (p EngineSignType) String() string

func (*EngineSignType) UnmarshalText 

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

func (*EngineSignType) Value 

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

type ExecResponse 

type ExecResponse struct {
	Result_ *ResponseCommon `thrift:"result,1,required" db:"result" json:"result"`
}

Attributes:

  • Result_
var GraphStorageServiceAddEdgesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceAddVerticesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceChainAddEdgesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceChainDeleteEdgesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceDeleteEdgesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceDeleteTagsResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceDeleteVerticesResult_Success_DEFAULT *ExecResponse
var GraphStorageServicePutResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceRemoveResult_Success_DEFAULT *ExecResponse
var InternalStorageServiceChainAddEdgesResult_Success_DEFAULT *ExecResponse
var InternalStorageServiceChainDeleteEdgesResult_Success_DEFAULT *ExecResponse

func NewExecResponse 

func NewExecResponse() *ExecResponse

func (*ExecResponse) Equals 

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

func (*ExecResponse) GetResult_ 

func (p *ExecResponse) GetResult_() *ResponseCommon

func (*ExecResponse) IsSetResult_ 

func (p *ExecResponse) IsSetResult_() bool

func (*ExecResponse) LogValue 

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

func (*ExecResponse) Read 

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

func (*ExecResponse) ReadField1 

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

func (*ExecResponse) String 

func (p *ExecResponse) String() string

func (*ExecResponse) Validate 

func (p *ExecResponse) Validate() error

func (*ExecResponse) Write 

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

type Expr 

type Expr struct {
	Alias []byte `thrift:"alias,1" db:"alias" json:"alias"`
	Expr  []byte `thrift:"expr,2" db:"expr" json:"expr"`
}

Attributes:

  • Alias
  • Expr

func NewExpr 

func NewExpr() *Expr

func (*Expr) Equals 

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

func (*Expr) GetAlias 

func (p *Expr) GetAlias() []byte

func (*Expr) GetExpr 

func (p *Expr) GetExpr() []byte

func (*Expr) LogValue 

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

func (*Expr) Read 

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

func (*Expr) ReadField1 

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

func (*Expr) ReadField2 

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

func (*Expr) String 

func (p *Expr) String() string

func (*Expr) Validate 

func (p *Expr) Validate() error

func (*Expr) Write 

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

type GetDstBySrcRequest 

type GetDstBySrcRequest struct {
	SpaceID   nebula.GraphSpaceID                    `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts     map[nebula.PartitionID][]*nebula.Value `thrift:"parts,2" db:"parts" json:"parts"`
	EdgeTypes []nebula.EdgeType                      `thrift:"edge_types,3" db:"edge_types" json:"edge_types"`
	Common    *RequestCommon                         `thrift:"common,4" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • EdgeTypes
  • Common
var GraphStorageServiceGetDstBySrcArgs_Req_DEFAULT *GetDstBySrcRequest

func NewGetDstBySrcRequest 

func NewGetDstBySrcRequest() *GetDstBySrcRequest

func (*GetDstBySrcRequest) Equals 

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

func (*GetDstBySrcRequest) GetCommon 

func (p *GetDstBySrcRequest) GetCommon() *RequestCommon

func (*GetDstBySrcRequest) GetEdgeTypes 

func (p *GetDstBySrcRequest) GetEdgeTypes() []nebula.EdgeType

func (*GetDstBySrcRequest) GetParts 

func (p *GetDstBySrcRequest) GetParts() map[nebula.PartitionID][]*nebula.Value

func (*GetDstBySrcRequest) GetSpaceID 

func (p *GetDstBySrcRequest) GetSpaceID() nebula.GraphSpaceID

func (*GetDstBySrcRequest) IsSetCommon 

func (p *GetDstBySrcRequest) IsSetCommon() bool

func (*GetDstBySrcRequest) LogValue 

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

func (*GetDstBySrcRequest) Read 

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

func (*GetDstBySrcRequest) ReadField1 

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

func (*GetDstBySrcRequest) ReadField2 

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

func (*GetDstBySrcRequest) ReadField3 

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

func (*GetDstBySrcRequest) ReadField4 

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

func (*GetDstBySrcRequest) String 

func (p *GetDstBySrcRequest) String() string

func (*GetDstBySrcRequest) Validate 

func (p *GetDstBySrcRequest) Validate() error

func (*GetDstBySrcRequest) Write 

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

type GetDstBySrcResponse 

type GetDstBySrcResponse struct {
	Result_ *ResponseCommon `thrift:"result,1,required" db:"result" json:"result"`
	Dsts    *nebula.DataSet `thrift:"dsts,2" db:"dsts" json:"dsts,omitempty"`
}

Attributes:

  • Result_
  • Dsts
var GraphStorageServiceGetDstBySrcResult_Success_DEFAULT *GetDstBySrcResponse

func NewGetDstBySrcResponse 

func NewGetDstBySrcResponse() *GetDstBySrcResponse

func (*GetDstBySrcResponse) Equals 

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

func (*GetDstBySrcResponse) GetDsts 

func (p *GetDstBySrcResponse) GetDsts() *nebula.DataSet

func (*GetDstBySrcResponse) GetResult_ 

func (p *GetDstBySrcResponse) GetResult_() *ResponseCommon

func (*GetDstBySrcResponse) IsSetDsts 

func (p *GetDstBySrcResponse) IsSetDsts() bool

func (*GetDstBySrcResponse) IsSetResult_ 

func (p *GetDstBySrcResponse) IsSetResult_() bool

func (*GetDstBySrcResponse) LogValue 

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

func (*GetDstBySrcResponse) Read 

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

func (*GetDstBySrcResponse) ReadField1 

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

func (*GetDstBySrcResponse) ReadField2 

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

func (*GetDstBySrcResponse) String 

func (p *GetDstBySrcResponse) String() string

func (*GetDstBySrcResponse) Validate 

func (p *GetDstBySrcResponse) Validate() error

func (*GetDstBySrcResponse) Write 

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

type GetLeaderPartsResp 

type GetLeaderPartsResp struct {
	Code        nebula.ErrorCode                             `thrift:"code,1" db:"code" json:"code"`
	LeaderParts map[nebula.GraphSpaceID][]nebula.PartitionID `thrift:"leader_parts,2" db:"leader_parts" json:"leader_parts"`
}

Attributes:

  • Code
  • LeaderParts
var StorageAdminServiceGetLeaderPartsResult_Success_DEFAULT *GetLeaderPartsResp

func NewGetLeaderPartsResp 

func NewGetLeaderPartsResp() *GetLeaderPartsResp

func (*GetLeaderPartsResp) Equals 

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

func (*GetLeaderPartsResp) GetCode 

func (p *GetLeaderPartsResp) GetCode() nebula.ErrorCode

func (*GetLeaderPartsResp) GetLeaderParts 

func (p *GetLeaderPartsResp) GetLeaderParts() map[nebula.GraphSpaceID][]nebula.PartitionID

func (*GetLeaderPartsResp) LogValue 

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

func (*GetLeaderPartsResp) Read 

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

func (*GetLeaderPartsResp) ReadField1 

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

func (*GetLeaderPartsResp) ReadField2 

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

func (*GetLeaderPartsResp) String 

func (p *GetLeaderPartsResp) String() string

func (*GetLeaderPartsResp) Validate 

func (p *GetLeaderPartsResp) Validate() error

func (*GetLeaderPartsResp) Write 

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

type GetLeaderReq 

type GetLeaderReq struct {
}
var StorageAdminServiceGetLeaderPartsArgs_Req_DEFAULT *GetLeaderReq

func NewGetLeaderReq 

func NewGetLeaderReq() *GetLeaderReq

func (*GetLeaderReq) Equals 

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

func (*GetLeaderReq) LogValue 

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

func (*GetLeaderReq) Read 

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

func (*GetLeaderReq) String 

func (p *GetLeaderReq) String() string

func (*GetLeaderReq) Validate 

func (p *GetLeaderReq) Validate() error

func (*GetLeaderReq) Write 

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

type GetNeighborsRequest 

type GetNeighborsRequest struct {
	SpaceID      nebula.GraphSpaceID                    `thrift:"space_id,1" db:"space_id" json:"space_id"`
	ColumnNames  [][]byte                               `thrift:"column_names,2" db:"column_names" json:"column_names"`
	Parts        map[nebula.PartitionID][]*nebula.Value `thrift:"parts,3" db:"parts" json:"parts"`
	TraverseSpec *TraverseSpec                          `thrift:"traverse_spec,4" db:"traverse_spec" json:"traverse_spec"`
	Common       *RequestCommon                         `thrift:"common,5" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • ColumnNames
  • Parts
  • TraverseSpec
  • Common
var GraphStorageServiceGetNeighborsArgs_Req_DEFAULT *GetNeighborsRequest

func NewGetNeighborsRequest 

func NewGetNeighborsRequest() *GetNeighborsRequest

func (*GetNeighborsRequest) Equals 

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

func (*GetNeighborsRequest) GetColumnNames 

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

func (*GetNeighborsRequest) GetCommon 

func (p *GetNeighborsRequest) GetCommon() *RequestCommon

func (*GetNeighborsRequest) GetParts 

func (p *GetNeighborsRequest) GetParts() map[nebula.PartitionID][]*nebula.Value

func (*GetNeighborsRequest) GetSpaceID 

func (p *GetNeighborsRequest) GetSpaceID() nebula.GraphSpaceID

func (*GetNeighborsRequest) GetTraverseSpec 

func (p *GetNeighborsRequest) GetTraverseSpec() *TraverseSpec

func (*GetNeighborsRequest) IsSetCommon 

func (p *GetNeighborsRequest) IsSetCommon() bool

func (*GetNeighborsRequest) IsSetTraverseSpec 

func (p *GetNeighborsRequest) IsSetTraverseSpec() bool

func (*GetNeighborsRequest) LogValue 

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

func (*GetNeighborsRequest) Read 

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

func (*GetNeighborsRequest) ReadField1 

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

func (*GetNeighborsRequest) ReadField2 

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

func (*GetNeighborsRequest) ReadField3 

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

func (*GetNeighborsRequest) ReadField4 

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

func (*GetNeighborsRequest) ReadField5 

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

func (*GetNeighborsRequest) String 

func (p *GetNeighborsRequest) String() string

func (*GetNeighborsRequest) Validate 

func (p *GetNeighborsRequest) Validate() error

func (*GetNeighborsRequest) Write 

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

type GetNeighborsResponse 

type GetNeighborsResponse struct {
	Result_  *ResponseCommon `thrift:"result,1,required" db:"result" json:"result"`
	Vertices *nebula.DataSet `thrift:"vertices,2" db:"vertices" json:"vertices,omitempty"`
}

Attributes:

  • Result_
  • Vertices
var GraphStorageServiceGetNeighborsResult_Success_DEFAULT *GetNeighborsResponse
var GraphStorageServiceLookupAndTraverseResult_Success_DEFAULT *GetNeighborsResponse

func NewGetNeighborsResponse 

func NewGetNeighborsResponse() *GetNeighborsResponse

func (*GetNeighborsResponse) Equals 

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

func (*GetNeighborsResponse) GetResult_ 

func (p *GetNeighborsResponse) GetResult_() *ResponseCommon

func (*GetNeighborsResponse) GetVertices 

func (p *GetNeighborsResponse) GetVertices() *nebula.DataSet

func (*GetNeighborsResponse) IsSetResult_ 

func (p *GetNeighborsResponse) IsSetResult_() bool

func (*GetNeighborsResponse) IsSetVertices 

func (p *GetNeighborsResponse) IsSetVertices() bool

func (*GetNeighborsResponse) LogValue 

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

func (*GetNeighborsResponse) Read 

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

func (*GetNeighborsResponse) ReadField1 

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

func (*GetNeighborsResponse) ReadField2 

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

func (*GetNeighborsResponse) String 

func (p *GetNeighborsResponse) String() string

func (*GetNeighborsResponse) Validate 

func (p *GetNeighborsResponse) Validate() error

func (*GetNeighborsResponse) Write 

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

type GetPropRequest 

type GetPropRequest struct {
	SpaceID     nebula.GraphSpaceID                  `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts       map[nebula.PartitionID][]*nebula.Row `thrift:"parts,2" db:"parts" json:"parts"`
	VertexProps []*VertexProp                        `thrift:"vertex_props,3" db:"vertex_props" json:"vertex_props,omitempty"`
	EdgeProps   []*EdgeProp                          `thrift:"edge_props,4" db:"edge_props" json:"edge_props,omitempty"`
	Expressions []*Expr                              `thrift:"expressions,5" db:"expressions" json:"expressions,omitempty"`
	Dedup       bool                                 `thrift:"dedup,6" db:"dedup" json:"dedup"`
	OrderBy     []*OrderBy                           `thrift:"order_by,7" db:"order_by" json:"order_by,omitempty"`
	Limit       *int64                               `thrift:"limit,8" db:"limit" json:"limit,omitempty"`
	Filter      []byte                               `thrift:"filter,9" db:"filter" json:"filter,omitempty"`
	Common      *RequestCommon                       `thrift:"common,10" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • VertexProps
  • EdgeProps
  • Expressions
  • Dedup
  • OrderBy
  • Limit
  • Filter
  • Common
var GraphStorageServiceGetPropsArgs_Req_DEFAULT *GetPropRequest

func NewGetPropRequest 

func NewGetPropRequest() *GetPropRequest

func (*GetPropRequest) Equals 

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

func (*GetPropRequest) GetCommon 

func (p *GetPropRequest) GetCommon() *RequestCommon

func (*GetPropRequest) GetDedup 

func (p *GetPropRequest) GetDedup() bool

func (*GetPropRequest) GetEdgeProps 

func (p *GetPropRequest) GetEdgeProps() []*EdgeProp

func (*GetPropRequest) GetExpressions 

func (p *GetPropRequest) GetExpressions() []*Expr

func (*GetPropRequest) GetFilter 

func (p *GetPropRequest) GetFilter() []byte

func (*GetPropRequest) GetLimit 

func (p *GetPropRequest) GetLimit() int64

func (*GetPropRequest) GetOrderBy 

func (p *GetPropRequest) GetOrderBy() []*OrderBy

func (*GetPropRequest) GetParts 

func (p *GetPropRequest) GetParts() map[nebula.PartitionID][]*nebula.Row

func (*GetPropRequest) GetSpaceID 

func (p *GetPropRequest) GetSpaceID() nebula.GraphSpaceID

func (*GetPropRequest) GetVertexProps 

func (p *GetPropRequest) GetVertexProps() []*VertexProp

func (*GetPropRequest) IsSetCommon 

func (p *GetPropRequest) IsSetCommon() bool

func (*GetPropRequest) IsSetEdgeProps 

func (p *GetPropRequest) IsSetEdgeProps() bool

func (*GetPropRequest) IsSetExpressions 

func (p *GetPropRequest) IsSetExpressions() bool

func (*GetPropRequest) IsSetFilter 

func (p *GetPropRequest) IsSetFilter() bool

func (*GetPropRequest) IsSetLimit 

func (p *GetPropRequest) IsSetLimit() bool

func (*GetPropRequest) IsSetOrderBy 

func (p *GetPropRequest) IsSetOrderBy() bool

func (*GetPropRequest) IsSetVertexProps 

func (p *GetPropRequest) IsSetVertexProps() bool

func (*GetPropRequest) LogValue 

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

func (*GetPropRequest) Read 

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

func (*GetPropRequest) ReadField1 

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

func (*GetPropRequest) ReadField10 

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

func (*GetPropRequest) ReadField2 

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

func (*GetPropRequest) ReadField3 

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

func (*GetPropRequest) ReadField4 

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

func (*GetPropRequest) ReadField5 

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

func (*GetPropRequest) ReadField6 

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

func (*GetPropRequest) ReadField7 

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

func (*GetPropRequest) ReadField8 

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

func (*GetPropRequest) ReadField9 

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

func (*GetPropRequest) String 

func (p *GetPropRequest) String() string

func (*GetPropRequest) Validate 

func (p *GetPropRequest) Validate() error

func (*GetPropRequest) Write 

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

type GetPropResponse 

type GetPropResponse struct {
	Result_ *ResponseCommon `thrift:"result,1" db:"result" json:"result"`
	Props   *nebula.DataSet `thrift:"props,2" db:"props" json:"props,omitempty"`
}

Attributes:

  • Result_
  • Props
var GraphStorageServiceGetPropsResult_Success_DEFAULT *GetPropResponse

func NewGetPropResponse 

func NewGetPropResponse() *GetPropResponse

func (*GetPropResponse) Equals 

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

func (*GetPropResponse) GetProps 

func (p *GetPropResponse) GetProps() *nebula.DataSet

func (*GetPropResponse) GetResult_ 

func (p *GetPropResponse) GetResult_() *ResponseCommon

func (*GetPropResponse) IsSetProps 

func (p *GetPropResponse) IsSetProps() bool

func (*GetPropResponse) IsSetResult_ 

func (p *GetPropResponse) IsSetResult_() bool

func (*GetPropResponse) LogValue 

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

func (*GetPropResponse) Read 

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

func (*GetPropResponse) ReadField1 

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

func (*GetPropResponse) ReadField2 

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

func (*GetPropResponse) String 

func (p *GetPropResponse) String() string

func (*GetPropResponse) Validate 

func (p *GetPropResponse) Validate() error

func (*GetPropResponse) Write 

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

type GetUUIDReq 

type GetUUIDReq struct {
	SpaceID nebula.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID  nebula.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	Name    []byte              `thrift:"name,3" db:"name" json:"name"`
	Common  *RequestCommon      `thrift:"common,4" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • PartID
  • Name
  • Common
var GraphStorageServiceGetUUIDArgs_Req_DEFAULT *GetUUIDReq

func NewGetUUIDReq 

func NewGetUUIDReq() *GetUUIDReq

func (*GetUUIDReq) Equals 

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

func (*GetUUIDReq) GetCommon 

func (p *GetUUIDReq) GetCommon() *RequestCommon

func (*GetUUIDReq) GetName 

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

func (*GetUUIDReq) GetPartID 

func (p *GetUUIDReq) GetPartID() nebula.PartitionID

func (*GetUUIDReq) GetSpaceID 

func (p *GetUUIDReq) GetSpaceID() nebula.GraphSpaceID

func (*GetUUIDReq) IsSetCommon 

func (p *GetUUIDReq) IsSetCommon() bool

func (*GetUUIDReq) LogValue 

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

func (*GetUUIDReq) Read 

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

func (*GetUUIDReq) ReadField1 

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

func (*GetUUIDReq) ReadField2 

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

func (*GetUUIDReq) ReadField3 

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

func (*GetUUIDReq) ReadField4 

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

func (*GetUUIDReq) String 

func (p *GetUUIDReq) String() string

func (*GetUUIDReq) Validate 

func (p *GetUUIDReq) Validate() error

func (*GetUUIDReq) Write 

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

type GetUUIDResp 

type GetUUIDResp struct {
	Result_ *ResponseCommon `thrift:"result,1,required" db:"result" json:"result"`
	ID      *nebula.Value   `thrift:"id,2" db:"id" json:"id"`
}

Attributes:

  • Result_
  • ID
var GraphStorageServiceGetUUIDResult_Success_DEFAULT *GetUUIDResp

func NewGetUUIDResp 

func NewGetUUIDResp() *GetUUIDResp

func (*GetUUIDResp) Equals 

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

func (*GetUUIDResp) GetID 

func (p *GetUUIDResp) GetID() *nebula.Value

func (*GetUUIDResp) GetResult_ 

func (p *GetUUIDResp) GetResult_() *ResponseCommon

func (*GetUUIDResp) IsSetID 

func (p *GetUUIDResp) IsSetID() bool

func (*GetUUIDResp) IsSetResult_ 

func (p *GetUUIDResp) IsSetResult_() bool

func (*GetUUIDResp) LogValue 

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

func (*GetUUIDResp) Read 

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

func (*GetUUIDResp) ReadField1 

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

func (*GetUUIDResp) ReadField2 

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

func (*GetUUIDResp) String 

func (p *GetUUIDResp) String() string

func (*GetUUIDResp) Validate 

func (p *GetUUIDResp) Validate() error

func (*GetUUIDResp) Write 

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

type GraphStorageService 

type GraphStorageService interface {
	// Parameters:
	//  - Req
	GetNeighbors(ctx context.Context, req *GetNeighborsRequest) (_r *GetNeighborsResponse, _err error)
	// Parameters:
	//  - Req
	GetDstBySrc(ctx context.Context, req *GetDstBySrcRequest) (_r *GetDstBySrcResponse, _err error)
	// Parameters:
	//  - Req
	GetProps(ctx context.Context, req *GetPropRequest) (_r *GetPropResponse, _err error)
	// Parameters:
	//  - Req
	AddVertices(ctx context.Context, req *AddVerticesRequest) (_r *ExecResponse, _err error)
	// Parameters:
	//  - Req
	AddEdges(ctx context.Context, req *AddEdgesRequest) (_r *ExecResponse, _err error)
	// Parameters:
	//  - Req
	DeleteEdges(ctx context.Context, req *DeleteEdgesRequest) (_r *ExecResponse, _err error)
	// Parameters:
	//  - Req
	DeleteVertices(ctx context.Context, req *DeleteVerticesRequest) (_r *ExecResponse, _err error)
	// Parameters:
	//  - Req
	DeleteTags(ctx context.Context, req *DeleteTagsRequest) (_r *ExecResponse, _err error)
	// Parameters:
	//  - Req
	UpdateVertex(ctx context.Context, req *UpdateVertexRequest) (_r *UpdateResponse, _err error)
	// Parameters:
	//  - Req
	UpdateEdge(ctx context.Context, req *UpdateEdgeRequest) (_r *UpdateResponse, _err error)
	// Parameters:
	//  - Req
	ScanVertex(ctx context.Context, req *ScanVertexRequest) (_r *ScanResponse, _err error)
	// Parameters:
	//  - Req
	ScanEdge(ctx context.Context, req *ScanEdgeRequest) (_r *ScanResponse, _err error)
	// Parameters:
	//  - Req
	GetUUID(ctx context.Context, req *GetUUIDReq) (_r *GetUUIDResp, _err error)
	// Parameters:
	//  - Req
	LookupIndex(ctx context.Context, req *LookupIndexRequest) (_r *LookupIndexResp, _err error)
	// Parameters:
	//  - Req
	LookupAndTraverse(ctx context.Context, req *LookupAndTraverseRequest) (_r *GetNeighborsResponse, _err error)
	// Parameters:
	//  - Req
	ChainUpdateEdge(ctx context.Context, req *UpdateEdgeRequest) (_r *UpdateResponse, _err error)
	// Parameters:
	//  - Req
	ChainAddEdges(ctx context.Context, req *AddEdgesRequest) (_r *ExecResponse, _err error)
	// Parameters:
	//  - Req
	ChainDeleteEdges(ctx context.Context, req *DeleteEdgesRequest) (_r *ExecResponse, _err error)
	// Parameters:
	//  - Req
	Get(ctx context.Context, req *KVGetRequest) (_r *KVGetResponse, _err error)
	// Parameters:
	//  - Req
	Put(ctx context.Context, req *KVPutRequest) (_r *ExecResponse, _err error)
	// Parameters:
	//  - Req
	Remove(ctx context.Context, req *KVRemoveRequest) (_r *ExecResponse, _err error)
}

type GraphStorageServiceAddEdgesArgs 

type GraphStorageServiceAddEdgesArgs struct {
	Req *AddEdgesRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceAddEdgesArgs 

func NewGraphStorageServiceAddEdgesArgs() *GraphStorageServiceAddEdgesArgs

func (*GraphStorageServiceAddEdgesArgs) GetReq 

func (p *GraphStorageServiceAddEdgesArgs) GetReq() *AddEdgesRequest

func (*GraphStorageServiceAddEdgesArgs) IsSetReq 

func (p *GraphStorageServiceAddEdgesArgs) IsSetReq() bool

func (*GraphStorageServiceAddEdgesArgs) LogValue 

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

func (*GraphStorageServiceAddEdgesArgs) Read 

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

func (*GraphStorageServiceAddEdgesArgs) ReadField1 

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

func (*GraphStorageServiceAddEdgesArgs) String 

func (p *GraphStorageServiceAddEdgesArgs) String() string

func (*GraphStorageServiceAddEdgesArgs) Write 

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

type GraphStorageServiceAddEdgesResult 

type GraphStorageServiceAddEdgesResult struct {
	Success *ExecResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceAddEdgesResult 

func NewGraphStorageServiceAddEdgesResult() *GraphStorageServiceAddEdgesResult

func (*GraphStorageServiceAddEdgesResult) GetSuccess 

func (p *GraphStorageServiceAddEdgesResult) GetSuccess() *ExecResponse

func (*GraphStorageServiceAddEdgesResult) IsSetSuccess 

func (p *GraphStorageServiceAddEdgesResult) IsSetSuccess() bool

func (*GraphStorageServiceAddEdgesResult) LogValue 

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

func (*GraphStorageServiceAddEdgesResult) Read 

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

func (*GraphStorageServiceAddEdgesResult) ReadField0 

func (p *GraphStorageServiceAddEdgesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceAddEdgesResult) String 

func (p *GraphStorageServiceAddEdgesResult) String() string

func (*GraphStorageServiceAddEdgesResult) Write 

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

type GraphStorageServiceAddVerticesArgs 

type GraphStorageServiceAddVerticesArgs struct {
	Req *AddVerticesRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceAddVerticesArgs 

func NewGraphStorageServiceAddVerticesArgs() *GraphStorageServiceAddVerticesArgs

func (*GraphStorageServiceAddVerticesArgs) GetReq 

func (p *GraphStorageServiceAddVerticesArgs) GetReq() *AddVerticesRequest

func (*GraphStorageServiceAddVerticesArgs) IsSetReq 

func (p *GraphStorageServiceAddVerticesArgs) IsSetReq() bool

func (*GraphStorageServiceAddVerticesArgs) LogValue 

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

func (*GraphStorageServiceAddVerticesArgs) Read 

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

func (*GraphStorageServiceAddVerticesArgs) ReadField1 

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

func (*GraphStorageServiceAddVerticesArgs) String 

func (p *GraphStorageServiceAddVerticesArgs) String() string

func (*GraphStorageServiceAddVerticesArgs) Write 

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

type GraphStorageServiceAddVerticesResult 

type GraphStorageServiceAddVerticesResult struct {
	Success *ExecResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceAddVerticesResult 

func NewGraphStorageServiceAddVerticesResult() *GraphStorageServiceAddVerticesResult

func (*GraphStorageServiceAddVerticesResult) GetSuccess 

func (p *GraphStorageServiceAddVerticesResult) GetSuccess() *ExecResponse

func (*GraphStorageServiceAddVerticesResult) IsSetSuccess 

func (p *GraphStorageServiceAddVerticesResult) IsSetSuccess() bool

func (*GraphStorageServiceAddVerticesResult) LogValue 

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

func (*GraphStorageServiceAddVerticesResult) Read 

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

func (*GraphStorageServiceAddVerticesResult) ReadField0 

func (p *GraphStorageServiceAddVerticesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceAddVerticesResult) String 

func (p *GraphStorageServiceAddVerticesResult) String() string

func (*GraphStorageServiceAddVerticesResult) Write 

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

type GraphStorageServiceChainAddEdgesArgs 

type GraphStorageServiceChainAddEdgesArgs struct {
	Req *AddEdgesRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceChainAddEdgesArgs 

func NewGraphStorageServiceChainAddEdgesArgs() *GraphStorageServiceChainAddEdgesArgs

func (*GraphStorageServiceChainAddEdgesArgs) GetReq 

func (p *GraphStorageServiceChainAddEdgesArgs) GetReq() *AddEdgesRequest

func (*GraphStorageServiceChainAddEdgesArgs) IsSetReq 

func (p *GraphStorageServiceChainAddEdgesArgs) IsSetReq() bool

func (*GraphStorageServiceChainAddEdgesArgs) LogValue 

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

func (*GraphStorageServiceChainAddEdgesArgs) Read 

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

func (*GraphStorageServiceChainAddEdgesArgs) ReadField1 

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

func (*GraphStorageServiceChainAddEdgesArgs) String 

func (p *GraphStorageServiceChainAddEdgesArgs) String() string

func (*GraphStorageServiceChainAddEdgesArgs) Write 

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

type GraphStorageServiceChainAddEdgesResult 

type GraphStorageServiceChainAddEdgesResult struct {
	Success *ExecResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceChainAddEdgesResult 

func NewGraphStorageServiceChainAddEdgesResult() *GraphStorageServiceChainAddEdgesResult

func (*GraphStorageServiceChainAddEdgesResult) GetSuccess 

func (p *GraphStorageServiceChainAddEdgesResult) GetSuccess() *ExecResponse

func (*GraphStorageServiceChainAddEdgesResult) IsSetSuccess 

func (p *GraphStorageServiceChainAddEdgesResult) IsSetSuccess() bool

func (*GraphStorageServiceChainAddEdgesResult) LogValue 

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

func (*GraphStorageServiceChainAddEdgesResult) Read 

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

func (*GraphStorageServiceChainAddEdgesResult) ReadField0 

func (p *GraphStorageServiceChainAddEdgesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceChainAddEdgesResult) String 

func (p *GraphStorageServiceChainAddEdgesResult) String() string

func (*GraphStorageServiceChainAddEdgesResult) Write 

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

type GraphStorageServiceChainDeleteEdgesArgs 

type GraphStorageServiceChainDeleteEdgesArgs struct {
	Req *DeleteEdgesRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceChainDeleteEdgesArgs 

func NewGraphStorageServiceChainDeleteEdgesArgs() *GraphStorageServiceChainDeleteEdgesArgs

func (*GraphStorageServiceChainDeleteEdgesArgs) GetReq 

func (p *GraphStorageServiceChainDeleteEdgesArgs) GetReq() *DeleteEdgesRequest

func (*GraphStorageServiceChainDeleteEdgesArgs) IsSetReq 

func (p *GraphStorageServiceChainDeleteEdgesArgs) IsSetReq() bool

func (*GraphStorageServiceChainDeleteEdgesArgs) LogValue 

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

func (*GraphStorageServiceChainDeleteEdgesArgs) Read 

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

func (*GraphStorageServiceChainDeleteEdgesArgs) ReadField1 

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

func (*GraphStorageServiceChainDeleteEdgesArgs) String 

func (p *GraphStorageServiceChainDeleteEdgesArgs) String() string

func (*GraphStorageServiceChainDeleteEdgesArgs) Write 

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

type GraphStorageServiceChainDeleteEdgesResult 

type GraphStorageServiceChainDeleteEdgesResult struct {
	Success *ExecResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceChainDeleteEdgesResult 

func NewGraphStorageServiceChainDeleteEdgesResult() *GraphStorageServiceChainDeleteEdgesResult

func (*GraphStorageServiceChainDeleteEdgesResult) GetSuccess 

func (p *GraphStorageServiceChainDeleteEdgesResult) GetSuccess() *ExecResponse

func (*GraphStorageServiceChainDeleteEdgesResult) IsSetSuccess 

func (p *GraphStorageServiceChainDeleteEdgesResult) IsSetSuccess() bool

func (*GraphStorageServiceChainDeleteEdgesResult) LogValue 

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

func (*GraphStorageServiceChainDeleteEdgesResult) Read 

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

func (*GraphStorageServiceChainDeleteEdgesResult) ReadField0 

func (p *GraphStorageServiceChainDeleteEdgesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceChainDeleteEdgesResult) String 

func (p *GraphStorageServiceChainDeleteEdgesResult) String() string

func (*GraphStorageServiceChainDeleteEdgesResult) Write 

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

type GraphStorageServiceChainUpdateEdgeArgs 

type GraphStorageServiceChainUpdateEdgeArgs struct {
	Req *UpdateEdgeRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceChainUpdateEdgeArgs 

func NewGraphStorageServiceChainUpdateEdgeArgs() *GraphStorageServiceChainUpdateEdgeArgs

func (*GraphStorageServiceChainUpdateEdgeArgs) GetReq 

func (p *GraphStorageServiceChainUpdateEdgeArgs) GetReq() *UpdateEdgeRequest

func (*GraphStorageServiceChainUpdateEdgeArgs) IsSetReq 

func (p *GraphStorageServiceChainUpdateEdgeArgs) IsSetReq() bool

func (*GraphStorageServiceChainUpdateEdgeArgs) LogValue 

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

func (*GraphStorageServiceChainUpdateEdgeArgs) Read 

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

func (*GraphStorageServiceChainUpdateEdgeArgs) ReadField1 

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

func (*GraphStorageServiceChainUpdateEdgeArgs) String 

func (p *GraphStorageServiceChainUpdateEdgeArgs) String() string

func (*GraphStorageServiceChainUpdateEdgeArgs) Write 

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

type GraphStorageServiceChainUpdateEdgeResult 

type GraphStorageServiceChainUpdateEdgeResult struct {
	Success *UpdateResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceChainUpdateEdgeResult 

func NewGraphStorageServiceChainUpdateEdgeResult() *GraphStorageServiceChainUpdateEdgeResult

func (*GraphStorageServiceChainUpdateEdgeResult) GetSuccess 

func (p *GraphStorageServiceChainUpdateEdgeResult) GetSuccess() *UpdateResponse

func (*GraphStorageServiceChainUpdateEdgeResult) IsSetSuccess 

func (p *GraphStorageServiceChainUpdateEdgeResult) IsSetSuccess() bool

func (*GraphStorageServiceChainUpdateEdgeResult) LogValue 

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

func (*GraphStorageServiceChainUpdateEdgeResult) Read 

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

func (*GraphStorageServiceChainUpdateEdgeResult) ReadField0 

func (p *GraphStorageServiceChainUpdateEdgeResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceChainUpdateEdgeResult) String 

func (p *GraphStorageServiceChainUpdateEdgeResult) String() string

func (*GraphStorageServiceChainUpdateEdgeResult) Write 

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

type GraphStorageServiceClient 

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

func NewGraphStorageServiceClient 

func NewGraphStorageServiceClient(c thrift.TClient) *GraphStorageServiceClient

func NewGraphStorageServiceClientFactory 

func NewGraphStorageServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *GraphStorageServiceClient

func NewGraphStorageServiceClientProtocol 

func NewGraphStorageServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *GraphStorageServiceClient

func (*GraphStorageServiceClient) AddEdges 

func (p *GraphStorageServiceClient) AddEdges(ctx context.Context, req *AddEdgesRequest) (_r *ExecResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) AddVertices 

func (p *GraphStorageServiceClient) AddVertices(ctx context.Context, req *AddVerticesRequest) (_r *ExecResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) ChainAddEdges 

func (p *GraphStorageServiceClient) ChainAddEdges(ctx context.Context, req *AddEdgesRequest) (_r *ExecResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) ChainDeleteEdges 

func (p *GraphStorageServiceClient) ChainDeleteEdges(ctx context.Context, req *DeleteEdgesRequest) (_r *ExecResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) ChainUpdateEdge 

func (p *GraphStorageServiceClient) ChainUpdateEdge(ctx context.Context, req *UpdateEdgeRequest) (_r *UpdateResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) Client_ 

func (p *GraphStorageServiceClient) Client_() thrift.TClient

func (*GraphStorageServiceClient) DeleteEdges 

func (p *GraphStorageServiceClient) DeleteEdges(ctx context.Context, req *DeleteEdgesRequest) (_r *ExecResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) DeleteTags 

func (p *GraphStorageServiceClient) DeleteTags(ctx context.Context, req *DeleteTagsRequest) (_r *ExecResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) DeleteVertices 

func (p *GraphStorageServiceClient) DeleteVertices(ctx context.Context, req *DeleteVerticesRequest) (_r *ExecResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) Get 

func (p *GraphStorageServiceClient) Get(ctx context.Context, req *KVGetRequest) (_r *KVGetResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) GetDstBySrc 

func (p *GraphStorageServiceClient) GetDstBySrc(ctx context.Context, req *GetDstBySrcRequest) (_r *GetDstBySrcResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) GetNeighbors 

func (p *GraphStorageServiceClient) GetNeighbors(ctx context.Context, req *GetNeighborsRequest) (_r *GetNeighborsResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) GetProps 

func (p *GraphStorageServiceClient) GetProps(ctx context.Context, req *GetPropRequest) (_r *GetPropResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) GetUUID 

func (p *GraphStorageServiceClient) GetUUID(ctx context.Context, req *GetUUIDReq) (_r *GetUUIDResp, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) LastResponseMeta_ 

func (p *GraphStorageServiceClient) LastResponseMeta_() thrift.ResponseMeta

func (*GraphStorageServiceClient) LookupAndTraverse 

func (p *GraphStorageServiceClient) LookupAndTraverse(ctx context.Context, req *LookupAndTraverseRequest) (_r *GetNeighborsResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) LookupIndex 

func (p *GraphStorageServiceClient) LookupIndex(ctx context.Context, req *LookupIndexRequest) (_r *LookupIndexResp, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) Put 

func (p *GraphStorageServiceClient) Put(ctx context.Context, req *KVPutRequest) (_r *ExecResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) Remove 

func (p *GraphStorageServiceClient) Remove(ctx context.Context, req *KVRemoveRequest) (_r *ExecResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) ScanEdge 

func (p *GraphStorageServiceClient) ScanEdge(ctx context.Context, req *ScanEdgeRequest) (_r *ScanResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) ScanVertex 

func (p *GraphStorageServiceClient) ScanVertex(ctx context.Context, req *ScanVertexRequest) (_r *ScanResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) SetLastResponseMeta_ 

func (p *GraphStorageServiceClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

func (*GraphStorageServiceClient) UpdateEdge 

func (p *GraphStorageServiceClient) UpdateEdge(ctx context.Context, req *UpdateEdgeRequest) (_r *UpdateResponse, _err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) UpdateVertex 

func (p *GraphStorageServiceClient) UpdateVertex(ctx context.Context, req *UpdateVertexRequest) (_r *UpdateResponse, _err error)

Parameters:

  • Req

type GraphStorageServiceDeleteEdgesArgs 

type GraphStorageServiceDeleteEdgesArgs struct {
	Req *DeleteEdgesRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceDeleteEdgesArgs 

func NewGraphStorageServiceDeleteEdgesArgs() *GraphStorageServiceDeleteEdgesArgs

func (*GraphStorageServiceDeleteEdgesArgs) GetReq 

func (p *GraphStorageServiceDeleteEdgesArgs) GetReq() *DeleteEdgesRequest

func (*GraphStorageServiceDeleteEdgesArgs) IsSetReq 

func (p *GraphStorageServiceDeleteEdgesArgs) IsSetReq() bool

func (*GraphStorageServiceDeleteEdgesArgs) LogValue 

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

func (*GraphStorageServiceDeleteEdgesArgs) Read 

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

func (*GraphStorageServiceDeleteEdgesArgs) ReadField1 

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

func (*GraphStorageServiceDeleteEdgesArgs) String 

func (p *GraphStorageServiceDeleteEdgesArgs) String() string

func (*GraphStorageServiceDeleteEdgesArgs) Write 

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

type GraphStorageServiceDeleteEdgesResult 

type GraphStorageServiceDeleteEdgesResult struct {
	Success *ExecResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceDeleteEdgesResult 

func NewGraphStorageServiceDeleteEdgesResult() *GraphStorageServiceDeleteEdgesResult

func (*GraphStorageServiceDeleteEdgesResult) GetSuccess 

func (p *GraphStorageServiceDeleteEdgesResult) GetSuccess() *ExecResponse

func (*GraphStorageServiceDeleteEdgesResult) IsSetSuccess 

func (p *GraphStorageServiceDeleteEdgesResult) IsSetSuccess() bool

func (*GraphStorageServiceDeleteEdgesResult) LogValue 

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

func (*GraphStorageServiceDeleteEdgesResult) Read 

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

func (*GraphStorageServiceDeleteEdgesResult) ReadField0 

func (p *GraphStorageServiceDeleteEdgesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceDeleteEdgesResult) String 

func (p *GraphStorageServiceDeleteEdgesResult) String() string

func (*GraphStorageServiceDeleteEdgesResult) Write 

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

type GraphStorageServiceDeleteTagsArgs 

type GraphStorageServiceDeleteTagsArgs struct {
	Req *DeleteTagsRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceDeleteTagsArgs 

func NewGraphStorageServiceDeleteTagsArgs() *GraphStorageServiceDeleteTagsArgs

func (*GraphStorageServiceDeleteTagsArgs) GetReq 

func (p *GraphStorageServiceDeleteTagsArgs) GetReq() *DeleteTagsRequest

func (*GraphStorageServiceDeleteTagsArgs) IsSetReq 

func (p *GraphStorageServiceDeleteTagsArgs) IsSetReq() bool

func (*GraphStorageServiceDeleteTagsArgs) LogValue 

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

func (*GraphStorageServiceDeleteTagsArgs) Read 

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

func (*GraphStorageServiceDeleteTagsArgs) ReadField1 

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

func (*GraphStorageServiceDeleteTagsArgs) String 

func (p *GraphStorageServiceDeleteTagsArgs) String() string

func (*GraphStorageServiceDeleteTagsArgs) Write 

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

type GraphStorageServiceDeleteTagsResult 

type GraphStorageServiceDeleteTagsResult struct {
	Success *ExecResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceDeleteTagsResult 

func NewGraphStorageServiceDeleteTagsResult() *GraphStorageServiceDeleteTagsResult

func (*GraphStorageServiceDeleteTagsResult) GetSuccess 

func (p *GraphStorageServiceDeleteTagsResult) GetSuccess() *ExecResponse

func (*GraphStorageServiceDeleteTagsResult) IsSetSuccess 

func (p *GraphStorageServiceDeleteTagsResult) IsSetSuccess() bool

func (*GraphStorageServiceDeleteTagsResult) LogValue 

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

func (*GraphStorageServiceDeleteTagsResult) Read 

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

func (*GraphStorageServiceDeleteTagsResult) ReadField0 

func (p *GraphStorageServiceDeleteTagsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceDeleteTagsResult) String 

func (p *GraphStorageServiceDeleteTagsResult) String() string

func (*GraphStorageServiceDeleteTagsResult) Write 

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

type GraphStorageServiceDeleteVerticesArgs 

type GraphStorageServiceDeleteVerticesArgs struct {
	Req *DeleteVerticesRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceDeleteVerticesArgs 

func NewGraphStorageServiceDeleteVerticesArgs() *GraphStorageServiceDeleteVerticesArgs

func (*GraphStorageServiceDeleteVerticesArgs) GetReq 

func (p *GraphStorageServiceDeleteVerticesArgs) GetReq() *DeleteVerticesRequest

func (*GraphStorageServiceDeleteVerticesArgs) IsSetReq 

func (p *GraphStorageServiceDeleteVerticesArgs) IsSetReq() bool

func (*GraphStorageServiceDeleteVerticesArgs) LogValue 

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

func (*GraphStorageServiceDeleteVerticesArgs) Read 

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

func (*GraphStorageServiceDeleteVerticesArgs) ReadField1 

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

func (*GraphStorageServiceDeleteVerticesArgs) String 

func (p *GraphStorageServiceDeleteVerticesArgs) String() string

func (*GraphStorageServiceDeleteVerticesArgs) Write 

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

type GraphStorageServiceDeleteVerticesResult 

type GraphStorageServiceDeleteVerticesResult struct {
	Success *ExecResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceDeleteVerticesResult 

func NewGraphStorageServiceDeleteVerticesResult() *GraphStorageServiceDeleteVerticesResult

func (*GraphStorageServiceDeleteVerticesResult) GetSuccess 

func (p *GraphStorageServiceDeleteVerticesResult) GetSuccess() *ExecResponse

func (*GraphStorageServiceDeleteVerticesResult) IsSetSuccess 

func (p *GraphStorageServiceDeleteVerticesResult) IsSetSuccess() bool

func (*GraphStorageServiceDeleteVerticesResult) LogValue 

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

func (*GraphStorageServiceDeleteVerticesResult) Read 

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

func (*GraphStorageServiceDeleteVerticesResult) ReadField0 

func (p *GraphStorageServiceDeleteVerticesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceDeleteVerticesResult) String 

func (p *GraphStorageServiceDeleteVerticesResult) String() string

func (*GraphStorageServiceDeleteVerticesResult) Write 

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

type GraphStorageServiceGetArgs 

type GraphStorageServiceGetArgs struct {
	Req *KVGetRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceGetArgs 

func NewGraphStorageServiceGetArgs() *GraphStorageServiceGetArgs

func (*GraphStorageServiceGetArgs) GetReq 

func (p *GraphStorageServiceGetArgs) GetReq() *KVGetRequest

func (*GraphStorageServiceGetArgs) IsSetReq 

func (p *GraphStorageServiceGetArgs) IsSetReq() bool

func (*GraphStorageServiceGetArgs) LogValue 

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

func (*GraphStorageServiceGetArgs) Read 

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

func (*GraphStorageServiceGetArgs) ReadField1 

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

func (*GraphStorageServiceGetArgs) String 

func (p *GraphStorageServiceGetArgs) String() string

func (*GraphStorageServiceGetArgs) Write 

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

type GraphStorageServiceGetDstBySrcArgs 

type GraphStorageServiceGetDstBySrcArgs struct {
	Req *GetDstBySrcRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceGetDstBySrcArgs 

func NewGraphStorageServiceGetDstBySrcArgs() *GraphStorageServiceGetDstBySrcArgs

func (*GraphStorageServiceGetDstBySrcArgs) GetReq 

func (p *GraphStorageServiceGetDstBySrcArgs) GetReq() *GetDstBySrcRequest

func (*GraphStorageServiceGetDstBySrcArgs) IsSetReq 

func (p *GraphStorageServiceGetDstBySrcArgs) IsSetReq() bool

func (*GraphStorageServiceGetDstBySrcArgs) LogValue 

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

func (*GraphStorageServiceGetDstBySrcArgs) Read 

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

func (*GraphStorageServiceGetDstBySrcArgs) ReadField1 

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

func (*GraphStorageServiceGetDstBySrcArgs) String 

func (p *GraphStorageServiceGetDstBySrcArgs) String() string

func (*GraphStorageServiceGetDstBySrcArgs) Write 

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

type GraphStorageServiceGetDstBySrcResult 

type GraphStorageServiceGetDstBySrcResult struct {
	Success *GetDstBySrcResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceGetDstBySrcResult 

func NewGraphStorageServiceGetDstBySrcResult() *GraphStorageServiceGetDstBySrcResult

func (*GraphStorageServiceGetDstBySrcResult) GetSuccess 

func (p *GraphStorageServiceGetDstBySrcResult) GetSuccess() *GetDstBySrcResponse

func (*GraphStorageServiceGetDstBySrcResult) IsSetSuccess 

func (p *GraphStorageServiceGetDstBySrcResult) IsSetSuccess() bool

func (*GraphStorageServiceGetDstBySrcResult) LogValue 

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

func (*GraphStorageServiceGetDstBySrcResult) Read 

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

func (*GraphStorageServiceGetDstBySrcResult) ReadField0 

func (p *GraphStorageServiceGetDstBySrcResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceGetDstBySrcResult) String 

func (p *GraphStorageServiceGetDstBySrcResult) String() string

func (*GraphStorageServiceGetDstBySrcResult) Write 

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

type GraphStorageServiceGetNeighborsArgs 

type GraphStorageServiceGetNeighborsArgs struct {
	Req *GetNeighborsRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceGetNeighborsArgs 

func NewGraphStorageServiceGetNeighborsArgs() *GraphStorageServiceGetNeighborsArgs

func (*GraphStorageServiceGetNeighborsArgs) GetReq 

func (p *GraphStorageServiceGetNeighborsArgs) GetReq() *GetNeighborsRequest

func (*GraphStorageServiceGetNeighborsArgs) IsSetReq 

func (p *GraphStorageServiceGetNeighborsArgs) IsSetReq() bool

func (*GraphStorageServiceGetNeighborsArgs) LogValue 

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

func (*GraphStorageServiceGetNeighborsArgs) Read 

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

func (*GraphStorageServiceGetNeighborsArgs) ReadField1 

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

func (*GraphStorageServiceGetNeighborsArgs) String 

func (p *GraphStorageServiceGetNeighborsArgs) String() string

func (*GraphStorageServiceGetNeighborsArgs) Write 

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

type GraphStorageServiceGetNeighborsResult 

type GraphStorageServiceGetNeighborsResult struct {
	Success *GetNeighborsResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceGetNeighborsResult 

func NewGraphStorageServiceGetNeighborsResult() *GraphStorageServiceGetNeighborsResult

func (*GraphStorageServiceGetNeighborsResult) GetSuccess 

func (p *GraphStorageServiceGetNeighborsResult) GetSuccess() *GetNeighborsResponse

func (*GraphStorageServiceGetNeighborsResult) IsSetSuccess 

func (p *GraphStorageServiceGetNeighborsResult) IsSetSuccess() bool

func (*GraphStorageServiceGetNeighborsResult) LogValue 

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

func (*GraphStorageServiceGetNeighborsResult) Read 

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

func (*GraphStorageServiceGetNeighborsResult) ReadField0 

func (p *GraphStorageServiceGetNeighborsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceGetNeighborsResult) String 

func (p *GraphStorageServiceGetNeighborsResult) String() string

func (*GraphStorageServiceGetNeighborsResult) Write 

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

type GraphStorageServiceGetPropsArgs 

type GraphStorageServiceGetPropsArgs struct {
	Req *GetPropRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceGetPropsArgs 

func NewGraphStorageServiceGetPropsArgs() *GraphStorageServiceGetPropsArgs

func (*GraphStorageServiceGetPropsArgs) GetReq 

func (p *GraphStorageServiceGetPropsArgs) GetReq() *GetPropRequest

func (*GraphStorageServiceGetPropsArgs) IsSetReq 

func (p *GraphStorageServiceGetPropsArgs) IsSetReq() bool

func (*GraphStorageServiceGetPropsArgs) LogValue 

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

func (*GraphStorageServiceGetPropsArgs) Read 

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

func (*GraphStorageServiceGetPropsArgs) ReadField1 

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

func (*GraphStorageServiceGetPropsArgs) String 

func (p *GraphStorageServiceGetPropsArgs) String() string

func (*GraphStorageServiceGetPropsArgs) Write 

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

type GraphStorageServiceGetPropsResult 

type GraphStorageServiceGetPropsResult struct {
	Success *GetPropResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceGetPropsResult 

func NewGraphStorageServiceGetPropsResult() *GraphStorageServiceGetPropsResult

func (*GraphStorageServiceGetPropsResult) GetSuccess 

func (p *GraphStorageServiceGetPropsResult) GetSuccess() *GetPropResponse

func (*GraphStorageServiceGetPropsResult) IsSetSuccess 

func (p *GraphStorageServiceGetPropsResult) IsSetSuccess() bool

func (*GraphStorageServiceGetPropsResult) LogValue 

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

func (*GraphStorageServiceGetPropsResult) Read 

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

func (*GraphStorageServiceGetPropsResult) ReadField0 

func (p *GraphStorageServiceGetPropsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceGetPropsResult) String 

func (p *GraphStorageServiceGetPropsResult) String() string

func (*GraphStorageServiceGetPropsResult) Write 

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

type GraphStorageServiceGetResult 

type GraphStorageServiceGetResult struct {
	Success *KVGetResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceGetResult 

func NewGraphStorageServiceGetResult() *GraphStorageServiceGetResult

func (*GraphStorageServiceGetResult) GetSuccess 

func (p *GraphStorageServiceGetResult) GetSuccess() *KVGetResponse

func (*GraphStorageServiceGetResult) IsSetSuccess 

func (p *GraphStorageServiceGetResult) IsSetSuccess() bool

func (*GraphStorageServiceGetResult) LogValue 

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

func (*GraphStorageServiceGetResult) Read 

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

func (*GraphStorageServiceGetResult) ReadField0 

func (p *GraphStorageServiceGetResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceGetResult) String 

func (p *GraphStorageServiceGetResult) String() string

func (*GraphStorageServiceGetResult) Write 

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

type GraphStorageServiceGetUUIDArgs 

type GraphStorageServiceGetUUIDArgs struct {
	Req *GetUUIDReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceGetUUIDArgs 

func NewGraphStorageServiceGetUUIDArgs() *GraphStorageServiceGetUUIDArgs

func (*GraphStorageServiceGetUUIDArgs) GetReq 

func (p *GraphStorageServiceGetUUIDArgs) GetReq() *GetUUIDReq

func (*GraphStorageServiceGetUUIDArgs) IsSetReq 

func (p *GraphStorageServiceGetUUIDArgs) IsSetReq() bool

func (*GraphStorageServiceGetUUIDArgs) LogValue 

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

func (*GraphStorageServiceGetUUIDArgs) Read 

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

func (*GraphStorageServiceGetUUIDArgs) ReadField1 

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

func (*GraphStorageServiceGetUUIDArgs) String 

func (p *GraphStorageServiceGetUUIDArgs) String() string

func (*GraphStorageServiceGetUUIDArgs) Write 

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

type GraphStorageServiceGetUUIDResult 

type GraphStorageServiceGetUUIDResult struct {
	Success *GetUUIDResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceGetUUIDResult 

func NewGraphStorageServiceGetUUIDResult() *GraphStorageServiceGetUUIDResult

func (*GraphStorageServiceGetUUIDResult) GetSuccess 

func (p *GraphStorageServiceGetUUIDResult) GetSuccess() *GetUUIDResp

func (*GraphStorageServiceGetUUIDResult) IsSetSuccess 

func (p *GraphStorageServiceGetUUIDResult) IsSetSuccess() bool

func (*GraphStorageServiceGetUUIDResult) LogValue 

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

func (*GraphStorageServiceGetUUIDResult) Read 

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

func (*GraphStorageServiceGetUUIDResult) ReadField0 

func (p *GraphStorageServiceGetUUIDResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceGetUUIDResult) String 

func (p *GraphStorageServiceGetUUIDResult) String() string

func (*GraphStorageServiceGetUUIDResult) Write 

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

type GraphStorageServiceLookupAndTraverseArgs 

type GraphStorageServiceLookupAndTraverseArgs struct {
	Req *LookupAndTraverseRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceLookupAndTraverseArgs 

func NewGraphStorageServiceLookupAndTraverseArgs() *GraphStorageServiceLookupAndTraverseArgs

func (*GraphStorageServiceLookupAndTraverseArgs) GetReq 

func (p *GraphStorageServiceLookupAndTraverseArgs) GetReq() *LookupAndTraverseRequest

func (*GraphStorageServiceLookupAndTraverseArgs) IsSetReq 

func (p *GraphStorageServiceLookupAndTraverseArgs) IsSetReq() bool

func (*GraphStorageServiceLookupAndTraverseArgs) LogValue 

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

func (*GraphStorageServiceLookupAndTraverseArgs) Read 

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

func (*GraphStorageServiceLookupAndTraverseArgs) ReadField1 

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

func (*GraphStorageServiceLookupAndTraverseArgs) String 

func (p *GraphStorageServiceLookupAndTraverseArgs) String() string

func (*GraphStorageServiceLookupAndTraverseArgs) Write 

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

type GraphStorageServiceLookupAndTraverseResult 

type GraphStorageServiceLookupAndTraverseResult struct {
	Success *GetNeighborsResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceLookupAndTraverseResult 

func NewGraphStorageServiceLookupAndTraverseResult() *GraphStorageServiceLookupAndTraverseResult

func (*GraphStorageServiceLookupAndTraverseResult) GetSuccess 

func (p *GraphStorageServiceLookupAndTraverseResult) GetSuccess() *GetNeighborsResponse

func (*GraphStorageServiceLookupAndTraverseResult) IsSetSuccess 

func (p *GraphStorageServiceLookupAndTraverseResult) IsSetSuccess() bool

func (*GraphStorageServiceLookupAndTraverseResult) LogValue 

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

func (*GraphStorageServiceLookupAndTraverseResult) Read 

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

func (*GraphStorageServiceLookupAndTraverseResult) ReadField0 

func (p *GraphStorageServiceLookupAndTraverseResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceLookupAndTraverseResult) String 

func (p *GraphStorageServiceLookupAndTraverseResult) String() string

func (*GraphStorageServiceLookupAndTraverseResult) Write 

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

type GraphStorageServiceLookupIndexArgs 

type GraphStorageServiceLookupIndexArgs struct {
	Req *LookupIndexRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceLookupIndexArgs 

func NewGraphStorageServiceLookupIndexArgs() *GraphStorageServiceLookupIndexArgs

func (*GraphStorageServiceLookupIndexArgs) GetReq 

func (p *GraphStorageServiceLookupIndexArgs) GetReq() *LookupIndexRequest

func (*GraphStorageServiceLookupIndexArgs) IsSetReq 

func (p *GraphStorageServiceLookupIndexArgs) IsSetReq() bool

func (*GraphStorageServiceLookupIndexArgs) LogValue 

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

func (*GraphStorageServiceLookupIndexArgs) Read 

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

func (*GraphStorageServiceLookupIndexArgs) ReadField1 

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

func (*GraphStorageServiceLookupIndexArgs) String 

func (p *GraphStorageServiceLookupIndexArgs) String() string

func (*GraphStorageServiceLookupIndexArgs) Write 

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

type GraphStorageServiceLookupIndexResult 

type GraphStorageServiceLookupIndexResult struct {
	Success *LookupIndexResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceLookupIndexResult 

func NewGraphStorageServiceLookupIndexResult() *GraphStorageServiceLookupIndexResult

func (*GraphStorageServiceLookupIndexResult) GetSuccess 

func (p *GraphStorageServiceLookupIndexResult) GetSuccess() *LookupIndexResp

func (*GraphStorageServiceLookupIndexResult) IsSetSuccess 

func (p *GraphStorageServiceLookupIndexResult) IsSetSuccess() bool

func (*GraphStorageServiceLookupIndexResult) LogValue 

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

func (*GraphStorageServiceLookupIndexResult) Read 

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

func (*GraphStorageServiceLookupIndexResult) ReadField0 

func (p *GraphStorageServiceLookupIndexResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceLookupIndexResult) String 

func (p *GraphStorageServiceLookupIndexResult) String() string

func (*GraphStorageServiceLookupIndexResult) Write 

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

type GraphStorageServiceProcessor 

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

func NewGraphStorageServiceProcessor 

func NewGraphStorageServiceProcessor(handler GraphStorageService) *GraphStorageServiceProcessor

func (*GraphStorageServiceProcessor) AddToProcessorMap 

func (p *GraphStorageServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*GraphStorageServiceProcessor) GetProcessorFunction 

func (p *GraphStorageServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*GraphStorageServiceProcessor) Process 

func (p *GraphStorageServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*GraphStorageServiceProcessor) ProcessorMap 

func (p *GraphStorageServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type GraphStorageServicePutArgs 

type GraphStorageServicePutArgs struct {
	Req *KVPutRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServicePutArgs 

func NewGraphStorageServicePutArgs() *GraphStorageServicePutArgs

func (*GraphStorageServicePutArgs) GetReq 

func (p *GraphStorageServicePutArgs) GetReq() *KVPutRequest

func (*GraphStorageServicePutArgs) IsSetReq 

func (p *GraphStorageServicePutArgs) IsSetReq() bool

func (*GraphStorageServicePutArgs) LogValue 

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

func (*GraphStorageServicePutArgs) Read 

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

func (*GraphStorageServicePutArgs) ReadField1 

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

func (*GraphStorageServicePutArgs) String 

func (p *GraphStorageServicePutArgs) String() string

func (*GraphStorageServicePutArgs) Write 

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

type GraphStorageServicePutResult 

type GraphStorageServicePutResult struct {
	Success *ExecResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServicePutResult 

func NewGraphStorageServicePutResult() *GraphStorageServicePutResult

func (*GraphStorageServicePutResult) GetSuccess 

func (p *GraphStorageServicePutResult) GetSuccess() *ExecResponse

func (*GraphStorageServicePutResult) IsSetSuccess 

func (p *GraphStorageServicePutResult) IsSetSuccess() bool

func (*GraphStorageServicePutResult) LogValue 

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

func (*GraphStorageServicePutResult) Read 

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

func (*GraphStorageServicePutResult) ReadField0 

func (p *GraphStorageServicePutResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServicePutResult) String 

func (p *GraphStorageServicePutResult) String() string

func (*GraphStorageServicePutResult) Write 

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

type GraphStorageServiceRemoveArgs 

type GraphStorageServiceRemoveArgs struct {
	Req *KVRemoveRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceRemoveArgs 

func NewGraphStorageServiceRemoveArgs() *GraphStorageServiceRemoveArgs

func (*GraphStorageServiceRemoveArgs) GetReq 

func (p *GraphStorageServiceRemoveArgs) GetReq() *KVRemoveRequest

func (*GraphStorageServiceRemoveArgs) IsSetReq 

func (p *GraphStorageServiceRemoveArgs) IsSetReq() bool

func (*GraphStorageServiceRemoveArgs) LogValue 

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

func (*GraphStorageServiceRemoveArgs) Read 

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

func (*GraphStorageServiceRemoveArgs) ReadField1 

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

func (*GraphStorageServiceRemoveArgs) String 

func (p *GraphStorageServiceRemoveArgs) String() string

func (*GraphStorageServiceRemoveArgs) Write 

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

type GraphStorageServiceRemoveResult 

type GraphStorageServiceRemoveResult struct {
	Success *ExecResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceRemoveResult 

func NewGraphStorageServiceRemoveResult() *GraphStorageServiceRemoveResult

func (*GraphStorageServiceRemoveResult) GetSuccess 

func (p *GraphStorageServiceRemoveResult) GetSuccess() *ExecResponse

func (*GraphStorageServiceRemoveResult) IsSetSuccess 

func (p *GraphStorageServiceRemoveResult) IsSetSuccess() bool

func (*GraphStorageServiceRemoveResult) LogValue 

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

func (*GraphStorageServiceRemoveResult) Read 

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

func (*GraphStorageServiceRemoveResult) ReadField0 

func (p *GraphStorageServiceRemoveResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceRemoveResult) String 

func (p *GraphStorageServiceRemoveResult) String() string

func (*GraphStorageServiceRemoveResult) Write 

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

type GraphStorageServiceScanEdgeArgs 

type GraphStorageServiceScanEdgeArgs struct {
	Req *ScanEdgeRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceScanEdgeArgs 

func NewGraphStorageServiceScanEdgeArgs() *GraphStorageServiceScanEdgeArgs

func (*GraphStorageServiceScanEdgeArgs) GetReq 

func (p *GraphStorageServiceScanEdgeArgs) GetReq() *ScanEdgeRequest

func (*GraphStorageServiceScanEdgeArgs) IsSetReq 

func (p *GraphStorageServiceScanEdgeArgs) IsSetReq() bool

func (*GraphStorageServiceScanEdgeArgs) LogValue 

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

func (*GraphStorageServiceScanEdgeArgs) Read 

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

func (*GraphStorageServiceScanEdgeArgs) ReadField1 

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

func (*GraphStorageServiceScanEdgeArgs) String 

func (p *GraphStorageServiceScanEdgeArgs) String() string

func (*GraphStorageServiceScanEdgeArgs) Write 

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

type GraphStorageServiceScanEdgeResult 

type GraphStorageServiceScanEdgeResult struct {
	Success *ScanResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceScanEdgeResult 

func NewGraphStorageServiceScanEdgeResult() *GraphStorageServiceScanEdgeResult

func (*GraphStorageServiceScanEdgeResult) GetSuccess 

func (p *GraphStorageServiceScanEdgeResult) GetSuccess() *ScanResponse

func (*GraphStorageServiceScanEdgeResult) IsSetSuccess 

func (p *GraphStorageServiceScanEdgeResult) IsSetSuccess() bool

func (*GraphStorageServiceScanEdgeResult) LogValue 

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

func (*GraphStorageServiceScanEdgeResult) Read 

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

func (*GraphStorageServiceScanEdgeResult) ReadField0 

func (p *GraphStorageServiceScanEdgeResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceScanEdgeResult) String 

func (p *GraphStorageServiceScanEdgeResult) String() string

func (*GraphStorageServiceScanEdgeResult) Write 

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

type GraphStorageServiceScanVertexArgs 

type GraphStorageServiceScanVertexArgs struct {
	Req *ScanVertexRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceScanVertexArgs 

func NewGraphStorageServiceScanVertexArgs() *GraphStorageServiceScanVertexArgs

func (*GraphStorageServiceScanVertexArgs) GetReq 

func (p *GraphStorageServiceScanVertexArgs) GetReq() *ScanVertexRequest

func (*GraphStorageServiceScanVertexArgs) IsSetReq 

func (p *GraphStorageServiceScanVertexArgs) IsSetReq() bool

func (*GraphStorageServiceScanVertexArgs) LogValue 

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

func (*GraphStorageServiceScanVertexArgs) Read 

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

func (*GraphStorageServiceScanVertexArgs) ReadField1 

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

func (*GraphStorageServiceScanVertexArgs) String 

func (p *GraphStorageServiceScanVertexArgs) String() string

func (*GraphStorageServiceScanVertexArgs) Write 

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

type GraphStorageServiceScanVertexResult 

type GraphStorageServiceScanVertexResult struct {
	Success *ScanResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceScanVertexResult 

func NewGraphStorageServiceScanVertexResult() *GraphStorageServiceScanVertexResult

func (*GraphStorageServiceScanVertexResult) GetSuccess 

func (p *GraphStorageServiceScanVertexResult) GetSuccess() *ScanResponse

func (*GraphStorageServiceScanVertexResult) IsSetSuccess 

func (p *GraphStorageServiceScanVertexResult) IsSetSuccess() bool

func (*GraphStorageServiceScanVertexResult) LogValue 

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

func (*GraphStorageServiceScanVertexResult) Read 

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

func (*GraphStorageServiceScanVertexResult) ReadField0 

func (p *GraphStorageServiceScanVertexResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceScanVertexResult) String 

func (p *GraphStorageServiceScanVertexResult) String() string

func (*GraphStorageServiceScanVertexResult) Write 

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

type GraphStorageServiceUpdateEdgeArgs 

type GraphStorageServiceUpdateEdgeArgs struct {
	Req *UpdateEdgeRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceUpdateEdgeArgs 

func NewGraphStorageServiceUpdateEdgeArgs() *GraphStorageServiceUpdateEdgeArgs

func (*GraphStorageServiceUpdateEdgeArgs) GetReq 

func (p *GraphStorageServiceUpdateEdgeArgs) GetReq() *UpdateEdgeRequest

func (*GraphStorageServiceUpdateEdgeArgs) IsSetReq 

func (p *GraphStorageServiceUpdateEdgeArgs) IsSetReq() bool

func (*GraphStorageServiceUpdateEdgeArgs) LogValue 

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

func (*GraphStorageServiceUpdateEdgeArgs) Read 

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

func (*GraphStorageServiceUpdateEdgeArgs) ReadField1 

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

func (*GraphStorageServiceUpdateEdgeArgs) String 

func (p *GraphStorageServiceUpdateEdgeArgs) String() string

func (*GraphStorageServiceUpdateEdgeArgs) Write 

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

type GraphStorageServiceUpdateEdgeResult 

type GraphStorageServiceUpdateEdgeResult struct {
	Success *UpdateResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceUpdateEdgeResult 

func NewGraphStorageServiceUpdateEdgeResult() *GraphStorageServiceUpdateEdgeResult

func (*GraphStorageServiceUpdateEdgeResult) GetSuccess 

func (p *GraphStorageServiceUpdateEdgeResult) GetSuccess() *UpdateResponse

func (*GraphStorageServiceUpdateEdgeResult) IsSetSuccess 

func (p *GraphStorageServiceUpdateEdgeResult) IsSetSuccess() bool

func (*GraphStorageServiceUpdateEdgeResult) LogValue 

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

func (*GraphStorageServiceUpdateEdgeResult) Read 

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

func (*GraphStorageServiceUpdateEdgeResult) ReadField0 

func (p *GraphStorageServiceUpdateEdgeResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceUpdateEdgeResult) String 

func (p *GraphStorageServiceUpdateEdgeResult) String() string

func (*GraphStorageServiceUpdateEdgeResult) Write 

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

type GraphStorageServiceUpdateVertexArgs 

type GraphStorageServiceUpdateVertexArgs struct {
	Req *UpdateVertexRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewGraphStorageServiceUpdateVertexArgs 

func NewGraphStorageServiceUpdateVertexArgs() *GraphStorageServiceUpdateVertexArgs

func (*GraphStorageServiceUpdateVertexArgs) GetReq 

func (p *GraphStorageServiceUpdateVertexArgs) GetReq() *UpdateVertexRequest

func (*GraphStorageServiceUpdateVertexArgs) IsSetReq 

func (p *GraphStorageServiceUpdateVertexArgs) IsSetReq() bool

func (*GraphStorageServiceUpdateVertexArgs) LogValue 

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

func (*GraphStorageServiceUpdateVertexArgs) Read 

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

func (*GraphStorageServiceUpdateVertexArgs) ReadField1 

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

func (*GraphStorageServiceUpdateVertexArgs) String 

func (p *GraphStorageServiceUpdateVertexArgs) String() string

func (*GraphStorageServiceUpdateVertexArgs) Write 

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

type GraphStorageServiceUpdateVertexResult 

type GraphStorageServiceUpdateVertexResult struct {
	Success *UpdateResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphStorageServiceUpdateVertexResult 

func NewGraphStorageServiceUpdateVertexResult() *GraphStorageServiceUpdateVertexResult

func (*GraphStorageServiceUpdateVertexResult) GetSuccess 

func (p *GraphStorageServiceUpdateVertexResult) GetSuccess() *UpdateResponse

func (*GraphStorageServiceUpdateVertexResult) IsSetSuccess 

func (p *GraphStorageServiceUpdateVertexResult) IsSetSuccess() bool

func (*GraphStorageServiceUpdateVertexResult) LogValue 

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

func (*GraphStorageServiceUpdateVertexResult) Read 

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

func (*GraphStorageServiceUpdateVertexResult) ReadField0 

func (p *GraphStorageServiceUpdateVertexResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*GraphStorageServiceUpdateVertexResult) String 

func (p *GraphStorageServiceUpdateVertexResult) String() string

func (*GraphStorageServiceUpdateVertexResult) Write 

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

type IndexColumnHint 

type IndexColumnHint struct {
	ColumnName   []byte        `thrift:"column_name,1" db:"column_name" json:"column_name"`
	ScanType     ScanType      `thrift:"scan_type,2" db:"scan_type" json:"scan_type"`
	BeginValue   *nebula.Value `thrift:"begin_value,3" db:"begin_value" json:"begin_value"`
	EndValue     *nebula.Value `thrift:"end_value,4" db:"end_value" json:"end_value"`
	IncludeBegin bool          `thrift:"include_begin,5" db:"include_begin" json:"include_begin"`
	IncludeEnd   bool          `thrift:"include_end,6" db:"include_end" json:"include_end"`
}

Attributes:

  • ColumnName
  • ScanType
  • BeginValue
  • EndValue
  • IncludeBegin
  • IncludeEnd

func NewIndexColumnHint 

func NewIndexColumnHint() *IndexColumnHint

func (*IndexColumnHint) Equals 

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

func (*IndexColumnHint) GetBeginValue 

func (p *IndexColumnHint) GetBeginValue() *nebula.Value

func (*IndexColumnHint) GetColumnName 

func (p *IndexColumnHint) GetColumnName() []byte

func (*IndexColumnHint) GetEndValue 

func (p *IndexColumnHint) GetEndValue() *nebula.Value

func (*IndexColumnHint) GetIncludeBegin 

func (p *IndexColumnHint) GetIncludeBegin() bool

func (*IndexColumnHint) GetIncludeEnd 

func (p *IndexColumnHint) GetIncludeEnd() bool

func (*IndexColumnHint) GetScanType 

func (p *IndexColumnHint) GetScanType() ScanType

func (*IndexColumnHint) IsSetBeginValue 

func (p *IndexColumnHint) IsSetBeginValue() bool

func (*IndexColumnHint) IsSetEndValue 

func (p *IndexColumnHint) IsSetEndValue() bool

func (*IndexColumnHint) LogValue 

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

func (*IndexColumnHint) Read 

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

func (*IndexColumnHint) ReadField1 

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

func (*IndexColumnHint) ReadField2 

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

func (*IndexColumnHint) ReadField3 

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

func (*IndexColumnHint) ReadField4 

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

func (*IndexColumnHint) ReadField5 

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

func (*IndexColumnHint) ReadField6 

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

func (*IndexColumnHint) String 

func (p *IndexColumnHint) String() string

func (*IndexColumnHint) Validate 

func (p *IndexColumnHint) Validate() error

func (*IndexColumnHint) Write 

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

type IndexQueryContext 

type IndexQueryContext struct {
	IndexID     nebula.IndexID     `thrift:"index_id,1" db:"index_id" json:"index_id"`
	Filter      []byte             `thrift:"filter,2" db:"filter" json:"filter"`
	ColumnHints []*IndexColumnHint `thrift:"column_hints,3" db:"column_hints" json:"column_hints"`
}

Attributes:

  • IndexID
  • Filter
  • ColumnHints

func NewIndexQueryContext 

func NewIndexQueryContext() *IndexQueryContext

func (*IndexQueryContext) Equals 

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

func (*IndexQueryContext) GetColumnHints 

func (p *IndexQueryContext) GetColumnHints() []*IndexColumnHint

func (*IndexQueryContext) GetFilter 

func (p *IndexQueryContext) GetFilter() []byte

func (*IndexQueryContext) GetIndexID 

func (p *IndexQueryContext) GetIndexID() nebula.IndexID

func (*IndexQueryContext) LogValue 

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

func (*IndexQueryContext) Read 

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

func (*IndexQueryContext) ReadField1 

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

func (*IndexQueryContext) ReadField2 

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

func (*IndexQueryContext) ReadField3 

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

func (*IndexQueryContext) String 

func (p *IndexQueryContext) String() string

func (*IndexQueryContext) Validate 

func (p *IndexQueryContext) Validate() error

func (*IndexQueryContext) Write 

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

type IndexSpec 

type IndexSpec struct {
	Contexts []*IndexQueryContext `thrift:"contexts,1,required" db:"contexts" json:"contexts"`
	SchemaID *nebula.SchemaID     `thrift:"schema_id,2" db:"schema_id" json:"schema_id"`
}

Attributes:

  • Contexts
  • SchemaID
var LookupAndTraverseRequest_Indices_DEFAULT *IndexSpec
var LookupIndexRequest_Indices_DEFAULT *IndexSpec

func NewIndexSpec 

func NewIndexSpec() *IndexSpec

func (*IndexSpec) Equals 

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

func (*IndexSpec) GetContexts 

func (p *IndexSpec) GetContexts() []*IndexQueryContext

func (*IndexSpec) GetSchemaID 

func (p *IndexSpec) GetSchemaID() *nebula.SchemaID

func (*IndexSpec) IsSetSchemaID 

func (p *IndexSpec) IsSetSchemaID() bool

func (*IndexSpec) LogValue 

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

func (*IndexSpec) Read 

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

func (*IndexSpec) ReadField1 

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

func (*IndexSpec) ReadField2 

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

func (*IndexSpec) String 

func (p *IndexSpec) String() string

func (*IndexSpec) Validate 

func (p *IndexSpec) Validate() error

func (*IndexSpec) Write 

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

type InternalStorageService 

type InternalStorageService interface {
	// Parameters:
	//  - Req
	ChainAddEdges(ctx context.Context, req *ChainAddEdgesRequest) (_r *ExecResponse, _err error)
	// Parameters:
	//  - Req
	ChainUpdateEdge(ctx context.Context, req *ChainUpdateEdgeRequest) (_r *UpdateResponse, _err error)
	// Parameters:
	//  - Req
	ChainDeleteEdges(ctx context.Context, req *ChainDeleteEdgesRequest) (_r *ExecResponse, _err error)
}

type InternalStorageServiceChainAddEdgesArgs 

type InternalStorageServiceChainAddEdgesArgs struct {
	Req *ChainAddEdgesRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewInternalStorageServiceChainAddEdgesArgs 

func NewInternalStorageServiceChainAddEdgesArgs() *InternalStorageServiceChainAddEdgesArgs

func (*InternalStorageServiceChainAddEdgesArgs) GetReq 

func (p *InternalStorageServiceChainAddEdgesArgs) GetReq() *ChainAddEdgesRequest

func (*InternalStorageServiceChainAddEdgesArgs) IsSetReq 

func (p *InternalStorageServiceChainAddEdgesArgs) IsSetReq() bool

func (*InternalStorageServiceChainAddEdgesArgs) LogValue 

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

func (*InternalStorageServiceChainAddEdgesArgs) Read 

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

func (*InternalStorageServiceChainAddEdgesArgs) ReadField1 

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

func (*InternalStorageServiceChainAddEdgesArgs) String 

func (p *InternalStorageServiceChainAddEdgesArgs) String() string

func (*InternalStorageServiceChainAddEdgesArgs) Write 

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

type InternalStorageServiceChainAddEdgesResult 

type InternalStorageServiceChainAddEdgesResult struct {
	Success *ExecResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewInternalStorageServiceChainAddEdgesResult 

func NewInternalStorageServiceChainAddEdgesResult() *InternalStorageServiceChainAddEdgesResult

func (*InternalStorageServiceChainAddEdgesResult) GetSuccess 

func (p *InternalStorageServiceChainAddEdgesResult) GetSuccess() *ExecResponse

func (*InternalStorageServiceChainAddEdgesResult) IsSetSuccess 

func (p *InternalStorageServiceChainAddEdgesResult) IsSetSuccess() bool

func (*InternalStorageServiceChainAddEdgesResult) LogValue 

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

func (*InternalStorageServiceChainAddEdgesResult) Read 

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

func (*InternalStorageServiceChainAddEdgesResult) ReadField0 

func (p *InternalStorageServiceChainAddEdgesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*InternalStorageServiceChainAddEdgesResult) String 

func (p *InternalStorageServiceChainAddEdgesResult) String() string

func (*InternalStorageServiceChainAddEdgesResult) Write 

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

type InternalStorageServiceChainDeleteEdgesArgs 

type InternalStorageServiceChainDeleteEdgesArgs struct {
	Req *ChainDeleteEdgesRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewInternalStorageServiceChainDeleteEdgesArgs 

func NewInternalStorageServiceChainDeleteEdgesArgs() *InternalStorageServiceChainDeleteEdgesArgs

func (*InternalStorageServiceChainDeleteEdgesArgs) GetReq 

func (p *InternalStorageServiceChainDeleteEdgesArgs) GetReq() *ChainDeleteEdgesRequest

func (*InternalStorageServiceChainDeleteEdgesArgs) IsSetReq 

func (p *InternalStorageServiceChainDeleteEdgesArgs) IsSetReq() bool

func (*InternalStorageServiceChainDeleteEdgesArgs) LogValue 

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

func (*InternalStorageServiceChainDeleteEdgesArgs) Read 

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

func (*InternalStorageServiceChainDeleteEdgesArgs) ReadField1 

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

func (*InternalStorageServiceChainDeleteEdgesArgs) String 

func (p *InternalStorageServiceChainDeleteEdgesArgs) String() string

func (*InternalStorageServiceChainDeleteEdgesArgs) Write 

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

type InternalStorageServiceChainDeleteEdgesResult 

type InternalStorageServiceChainDeleteEdgesResult struct {
	Success *ExecResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewInternalStorageServiceChainDeleteEdgesResult 

func NewInternalStorageServiceChainDeleteEdgesResult() *InternalStorageServiceChainDeleteEdgesResult

func (*InternalStorageServiceChainDeleteEdgesResult) GetSuccess 

func (p *InternalStorageServiceChainDeleteEdgesResult) GetSuccess() *ExecResponse

func (*InternalStorageServiceChainDeleteEdgesResult) IsSetSuccess 

func (p *InternalStorageServiceChainDeleteEdgesResult) IsSetSuccess() bool

func (*InternalStorageServiceChainDeleteEdgesResult) LogValue 

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

func (*InternalStorageServiceChainDeleteEdgesResult) Read 

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

func (*InternalStorageServiceChainDeleteEdgesResult) ReadField0 

func (p *InternalStorageServiceChainDeleteEdgesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*InternalStorageServiceChainDeleteEdgesResult) String 

func (p *InternalStorageServiceChainDeleteEdgesResult) String() string

func (*InternalStorageServiceChainDeleteEdgesResult) Write 

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

type InternalStorageServiceChainUpdateEdgeArgs 

type InternalStorageServiceChainUpdateEdgeArgs struct {
	Req *ChainUpdateEdgeRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewInternalStorageServiceChainUpdateEdgeArgs 

func NewInternalStorageServiceChainUpdateEdgeArgs() *InternalStorageServiceChainUpdateEdgeArgs

func (*InternalStorageServiceChainUpdateEdgeArgs) GetReq 

func (p *InternalStorageServiceChainUpdateEdgeArgs) GetReq() *ChainUpdateEdgeRequest

func (*InternalStorageServiceChainUpdateEdgeArgs) IsSetReq 

func (p *InternalStorageServiceChainUpdateEdgeArgs) IsSetReq() bool

func (*InternalStorageServiceChainUpdateEdgeArgs) LogValue 

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

func (*InternalStorageServiceChainUpdateEdgeArgs) Read 

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

func (*InternalStorageServiceChainUpdateEdgeArgs) ReadField1 

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

func (*InternalStorageServiceChainUpdateEdgeArgs) String 

func (p *InternalStorageServiceChainUpdateEdgeArgs) String() string

func (*InternalStorageServiceChainUpdateEdgeArgs) Write 

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

type InternalStorageServiceChainUpdateEdgeResult 

type InternalStorageServiceChainUpdateEdgeResult struct {
	Success *UpdateResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewInternalStorageServiceChainUpdateEdgeResult 

func NewInternalStorageServiceChainUpdateEdgeResult() *InternalStorageServiceChainUpdateEdgeResult

func (*InternalStorageServiceChainUpdateEdgeResult) GetSuccess 

func (p *InternalStorageServiceChainUpdateEdgeResult) GetSuccess() *UpdateResponse

func (*InternalStorageServiceChainUpdateEdgeResult) IsSetSuccess 

func (p *InternalStorageServiceChainUpdateEdgeResult) IsSetSuccess() bool

func (*InternalStorageServiceChainUpdateEdgeResult) LogValue 

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

func (*InternalStorageServiceChainUpdateEdgeResult) Read 

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

func (*InternalStorageServiceChainUpdateEdgeResult) ReadField0 

func (p *InternalStorageServiceChainUpdateEdgeResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*InternalStorageServiceChainUpdateEdgeResult) String 

func (p *InternalStorageServiceChainUpdateEdgeResult) String() string

func (*InternalStorageServiceChainUpdateEdgeResult) Write 

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

type InternalStorageServiceClient 

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

func NewInternalStorageServiceClient 

func NewInternalStorageServiceClient(c thrift.TClient) *InternalStorageServiceClient

func NewInternalStorageServiceClientFactory 

func NewInternalStorageServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *InternalStorageServiceClient

func NewInternalStorageServiceClientProtocol 

func NewInternalStorageServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *InternalStorageServiceClient

func (*InternalStorageServiceClient) ChainAddEdges 

func (p *InternalStorageServiceClient) ChainAddEdges(ctx context.Context, req *ChainAddEdgesRequest) (_r *ExecResponse, _err error)

Parameters:

  • Req

func (*InternalStorageServiceClient) ChainDeleteEdges 

func (p *InternalStorageServiceClient) ChainDeleteEdges(ctx context.Context, req *ChainDeleteEdgesRequest) (_r *ExecResponse, _err error)

Parameters:

  • Req

func (*InternalStorageServiceClient) ChainUpdateEdge 

func (p *InternalStorageServiceClient) ChainUpdateEdge(ctx context.Context, req *ChainUpdateEdgeRequest) (_r *UpdateResponse, _err error)

Parameters:

  • Req

func (*InternalStorageServiceClient) Client_ 

func (p *InternalStorageServiceClient) Client_() thrift.TClient

func (*InternalStorageServiceClient) LastResponseMeta_ 

func (p *InternalStorageServiceClient) LastResponseMeta_() thrift.ResponseMeta

func (*InternalStorageServiceClient) SetLastResponseMeta_ 

func (p *InternalStorageServiceClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

type InternalStorageServiceProcessor 

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

func NewInternalStorageServiceProcessor 

func NewInternalStorageServiceProcessor(handler InternalStorageService) *InternalStorageServiceProcessor

func (*InternalStorageServiceProcessor) AddToProcessorMap 

func (p *InternalStorageServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*InternalStorageServiceProcessor) GetProcessorFunction 

func (p *InternalStorageServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*InternalStorageServiceProcessor) Process 

func (p *InternalStorageServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*InternalStorageServiceProcessor) ProcessorMap 

func (p *InternalStorageServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type KVGetRequest 

type KVGetRequest struct {
	SpaceID      nebula.GraphSpaceID             `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts        map[nebula.PartitionID][][]byte `thrift:"parts,2" db:"parts" json:"parts"`
	ReturnPartly bool                            `thrift:"return_partly,3" db:"return_partly" json:"return_partly"`
}

Attributes:

  • SpaceID
  • Parts
  • ReturnPartly
var GraphStorageServiceGetArgs_Req_DEFAULT *KVGetRequest

func NewKVGetRequest 

func NewKVGetRequest() *KVGetRequest

func (*KVGetRequest) Equals 

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

func (*KVGetRequest) GetParts 

func (p *KVGetRequest) GetParts() map[nebula.PartitionID][][]byte

func (*KVGetRequest) GetReturnPartly 

func (p *KVGetRequest) GetReturnPartly() bool

func (*KVGetRequest) GetSpaceID 

func (p *KVGetRequest) GetSpaceID() nebula.GraphSpaceID

func (*KVGetRequest) LogValue 

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

func (*KVGetRequest) Read 

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

func (*KVGetRequest) ReadField1 

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

func (*KVGetRequest) ReadField2 

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

func (*KVGetRequest) ReadField3 

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

func (*KVGetRequest) String 

func (p *KVGetRequest) String() string

func (*KVGetRequest) Validate 

func (p *KVGetRequest) Validate() error

func (*KVGetRequest) Write 

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

type KVGetResponse 

type KVGetResponse struct {
	Result_   *ResponseCommon   `thrift:"result,1,required" db:"result" json:"result"`
	KeyValues map[string][]byte `thrift:"key_values,2" db:"key_values" json:"key_values"`
}

Attributes:

  • Result_
  • KeyValues
var GraphStorageServiceGetResult_Success_DEFAULT *KVGetResponse

func NewKVGetResponse 

func NewKVGetResponse() *KVGetResponse

func (*KVGetResponse) Equals 

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

func (*KVGetResponse) GetKeyValues 

func (p *KVGetResponse) GetKeyValues() map[string][]byte

func (*KVGetResponse) GetResult_ 

func (p *KVGetResponse) GetResult_() *ResponseCommon

func (*KVGetResponse) IsSetResult_ 

func (p *KVGetResponse) IsSetResult_() bool

func (*KVGetResponse) LogValue 

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

func (*KVGetResponse) Read 

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

func (*KVGetResponse) ReadField1 

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

func (*KVGetResponse) ReadField2 

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

func (*KVGetResponse) String 

func (p *KVGetResponse) String() string

func (*KVGetResponse) Validate 

func (p *KVGetResponse) Validate() error

func (*KVGetResponse) Write 

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

type KVPutRequest 

type KVPutRequest struct {
	SpaceID nebula.GraphSpaceID                       `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts   map[nebula.PartitionID][]*nebula.KeyValue `thrift:"parts,2" db:"parts" json:"parts"`
}

Attributes:

  • SpaceID
  • Parts
var GraphStorageServicePutArgs_Req_DEFAULT *KVPutRequest

func NewKVPutRequest 

func NewKVPutRequest() *KVPutRequest

func (*KVPutRequest) Equals 

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

func (*KVPutRequest) GetParts 

func (p *KVPutRequest) GetParts() map[nebula.PartitionID][]*nebula.KeyValue

func (*KVPutRequest) GetSpaceID 

func (p *KVPutRequest) GetSpaceID() nebula.GraphSpaceID

func (*KVPutRequest) LogValue 

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

func (*KVPutRequest) Read 

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

func (*KVPutRequest) ReadField1 

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

func (*KVPutRequest) ReadField2 

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

func (*KVPutRequest) String 

func (p *KVPutRequest) String() string

func (*KVPutRequest) Validate 

func (p *KVPutRequest) Validate() error

func (*KVPutRequest) Write 

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

type KVRemoveRequest 

type KVRemoveRequest struct {
	SpaceID nebula.GraphSpaceID             `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts   map[nebula.PartitionID][][]byte `thrift:"parts,2" db:"parts" json:"parts"`
}

Attributes:

  • SpaceID
  • Parts
var GraphStorageServiceRemoveArgs_Req_DEFAULT *KVRemoveRequest

func NewKVRemoveRequest 

func NewKVRemoveRequest() *KVRemoveRequest

func (*KVRemoveRequest) Equals 

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

func (*KVRemoveRequest) GetParts 

func (p *KVRemoveRequest) GetParts() map[nebula.PartitionID][][]byte

func (*KVRemoveRequest) GetSpaceID 

func (p *KVRemoveRequest) GetSpaceID() nebula.GraphSpaceID

func (*KVRemoveRequest) LogValue 

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

func (*KVRemoveRequest) Read 

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

func (*KVRemoveRequest) ReadField1 

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

func (*KVRemoveRequest) ReadField2 

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

func (*KVRemoveRequest) String 

func (p *KVRemoveRequest) String() string

func (*KVRemoveRequest) Validate 

func (p *KVRemoveRequest) Validate() error

func (*KVRemoveRequest) Write 

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

type ListClusterInfoReq 

type ListClusterInfoReq struct {
}

func NewListClusterInfoReq 

func NewListClusterInfoReq() *ListClusterInfoReq

func (*ListClusterInfoReq) Equals 

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

func (*ListClusterInfoReq) LogValue 

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

func (*ListClusterInfoReq) Read 

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

func (*ListClusterInfoReq) String 

func (p *ListClusterInfoReq) String() string

func (*ListClusterInfoReq) Validate 

func (p *ListClusterInfoReq) Validate() error

func (*ListClusterInfoReq) Write 

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

type ListClusterInfoResp 

type ListClusterInfoResp struct {
	Result_ *ResponseCommon `thrift:"result,1,required" db:"result" json:"result"`
	Dir     *nebula.DirInfo `thrift:"dir,2" db:"dir" json:"dir"`
}

Attributes:

  • Result_
  • Dir

func NewListClusterInfoResp 

func NewListClusterInfoResp() *ListClusterInfoResp

func (*ListClusterInfoResp) Equals 

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

func (*ListClusterInfoResp) GetDir 

func (p *ListClusterInfoResp) GetDir() *nebula.DirInfo

func (*ListClusterInfoResp) GetResult_ 

func (p *ListClusterInfoResp) GetResult_() *ResponseCommon

func (*ListClusterInfoResp) IsSetDir 

func (p *ListClusterInfoResp) IsSetDir() bool

func (*ListClusterInfoResp) IsSetResult_ 

func (p *ListClusterInfoResp) IsSetResult_() bool

func (*ListClusterInfoResp) LogValue 

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

func (*ListClusterInfoResp) Read 

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

func (*ListClusterInfoResp) ReadField1 

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

func (*ListClusterInfoResp) ReadField2 

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

func (*ListClusterInfoResp) String 

func (p *ListClusterInfoResp) String() string

func (*ListClusterInfoResp) Validate 

func (p *ListClusterInfoResp) Validate() error

func (*ListClusterInfoResp) Write 

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

type LookupAndTraverseRequest 

type LookupAndTraverseRequest struct {
	SpaceID      nebula.GraphSpaceID  `thrift:"space_id,1,required" db:"space_id" json:"space_id"`
	Parts        []nebula.PartitionID `thrift:"parts,2,required" db:"parts" json:"parts"`
	Indices      *IndexSpec           `thrift:"indices,3" db:"indices" json:"indices"`
	TraverseSpec *TraverseSpec        `thrift:"traverse_spec,4" db:"traverse_spec" json:"traverse_spec"`
	Common       *RequestCommon       `thrift:"common,5" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • Indices
  • TraverseSpec
  • Common
var GraphStorageServiceLookupAndTraverseArgs_Req_DEFAULT *LookupAndTraverseRequest

func NewLookupAndTraverseRequest 

func NewLookupAndTraverseRequest() *LookupAndTraverseRequest

func (*LookupAndTraverseRequest) Equals 

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

func (*LookupAndTraverseRequest) GetCommon 

func (p *LookupAndTraverseRequest) GetCommon() *RequestCommon

func (*LookupAndTraverseRequest) GetIndices 

func (p *LookupAndTraverseRequest) GetIndices() *IndexSpec

func (*LookupAndTraverseRequest) GetParts 

func (p *LookupAndTraverseRequest) GetParts() []nebula.PartitionID

func (*LookupAndTraverseRequest) GetSpaceID 

func (p *LookupAndTraverseRequest) GetSpaceID() nebula.GraphSpaceID

func (*LookupAndTraverseRequest) GetTraverseSpec 

func (p *LookupAndTraverseRequest) GetTraverseSpec() *TraverseSpec

func (*LookupAndTraverseRequest) IsSetCommon 

func (p *LookupAndTraverseRequest) IsSetCommon() bool

func (*LookupAndTraverseRequest) IsSetIndices 

func (p *LookupAndTraverseRequest) IsSetIndices() bool

func (*LookupAndTraverseRequest) IsSetTraverseSpec 

func (p *LookupAndTraverseRequest) IsSetTraverseSpec() bool

func (*LookupAndTraverseRequest) LogValue 

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

func (*LookupAndTraverseRequest) Read 

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

func (*LookupAndTraverseRequest) ReadField1 

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

func (*LookupAndTraverseRequest) ReadField2 

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

func (*LookupAndTraverseRequest) ReadField3 

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

func (*LookupAndTraverseRequest) ReadField4 

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

func (*LookupAndTraverseRequest) ReadField5 

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

func (*LookupAndTraverseRequest) String 

func (p *LookupAndTraverseRequest) String() string

func (*LookupAndTraverseRequest) Validate 

func (p *LookupAndTraverseRequest) Validate() error

func (*LookupAndTraverseRequest) Write 

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

type LookupIndexRequest 

type LookupIndexRequest struct {
	SpaceID       nebula.GraphSpaceID  `thrift:"space_id,1,required" db:"space_id" json:"space_id"`
	Parts         []nebula.PartitionID `thrift:"parts,2,required" db:"parts" json:"parts"`
	Indices       *IndexSpec           `thrift:"indices,3" db:"indices" json:"indices"`
	ReturnColumns [][]byte             `thrift:"return_columns,4" db:"return_columns" json:"return_columns,omitempty"`
	Common        *RequestCommon       `thrift:"common,5" db:"common" json:"common,omitempty"`
	Limit         *int64               `thrift:"limit,6" db:"limit" json:"limit,omitempty"`
	OrderBy       []*OrderBy           `thrift:"order_by,7" db:"order_by" json:"order_by,omitempty"`
	StatColumns   []*StatProp          `thrift:"stat_columns,8" db:"stat_columns" json:"stat_columns,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • Indices
  • ReturnColumns
  • Common
  • Limit
  • OrderBy
  • StatColumns
var GraphStorageServiceLookupIndexArgs_Req_DEFAULT *LookupIndexRequest

func NewLookupIndexRequest 

func NewLookupIndexRequest() *LookupIndexRequest

func (*LookupIndexRequest) Equals 

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

func (*LookupIndexRequest) GetCommon 

func (p *LookupIndexRequest) GetCommon() *RequestCommon

func (*LookupIndexRequest) GetIndices 

func (p *LookupIndexRequest) GetIndices() *IndexSpec

func (*LookupIndexRequest) GetLimit 

func (p *LookupIndexRequest) GetLimit() int64

func (*LookupIndexRequest) GetOrderBy 

func (p *LookupIndexRequest) GetOrderBy() []*OrderBy

func (*LookupIndexRequest) GetParts 

func (p *LookupIndexRequest) GetParts() []nebula.PartitionID

func (*LookupIndexRequest) GetReturnColumns 

func (p *LookupIndexRequest) GetReturnColumns() [][]byte

func (*LookupIndexRequest) GetSpaceID 

func (p *LookupIndexRequest) GetSpaceID() nebula.GraphSpaceID

func (*LookupIndexRequest) GetStatColumns 

func (p *LookupIndexRequest) GetStatColumns() []*StatProp

func (*LookupIndexRequest) IsSetCommon 

func (p *LookupIndexRequest) IsSetCommon() bool

func (*LookupIndexRequest) IsSetIndices 

func (p *LookupIndexRequest) IsSetIndices() bool

func (*LookupIndexRequest) IsSetLimit 

func (p *LookupIndexRequest) IsSetLimit() bool

func (*LookupIndexRequest) IsSetOrderBy 

func (p *LookupIndexRequest) IsSetOrderBy() bool

func (*LookupIndexRequest) IsSetReturnColumns 

func (p *LookupIndexRequest) IsSetReturnColumns() bool

func (*LookupIndexRequest) IsSetStatColumns 

func (p *LookupIndexRequest) IsSetStatColumns() bool

func (*LookupIndexRequest) LogValue 

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

func (*LookupIndexRequest) Read 

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

func (*LookupIndexRequest) ReadField1 

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

func (*LookupIndexRequest) ReadField2 

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

func (*LookupIndexRequest) ReadField3 

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

func (*LookupIndexRequest) ReadField4 

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

func (*LookupIndexRequest) ReadField5 

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

func (*LookupIndexRequest) ReadField6 

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

func (*LookupIndexRequest) ReadField7 

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

func (*LookupIndexRequest) ReadField8 

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

func (*LookupIndexRequest) String 

func (p *LookupIndexRequest) String() string

func (*LookupIndexRequest) Validate 

func (p *LookupIndexRequest) Validate() error

func (*LookupIndexRequest) Write 

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

type LookupIndexResp 

type LookupIndexResp struct {
	Result_  *ResponseCommon `thrift:"result,1,required" db:"result" json:"result"`
	Data     *nebula.DataSet `thrift:"data,2" db:"data" json:"data,omitempty"`
	StatData *nebula.DataSet `thrift:"stat_data,3" db:"stat_data" json:"stat_data,omitempty"`
}

Attributes:

  • Result_
  • Data
  • StatData
var GraphStorageServiceLookupIndexResult_Success_DEFAULT *LookupIndexResp

func NewLookupIndexResp 

func NewLookupIndexResp() *LookupIndexResp

func (*LookupIndexResp) Equals 

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

func (*LookupIndexResp) GetData 

func (p *LookupIndexResp) GetData() *nebula.DataSet

func (*LookupIndexResp) GetResult_ 

func (p *LookupIndexResp) GetResult_() *ResponseCommon

func (*LookupIndexResp) GetStatData 

func (p *LookupIndexResp) GetStatData() *nebula.DataSet

func (*LookupIndexResp) IsSetData 

func (p *LookupIndexResp) IsSetData() bool

func (*LookupIndexResp) IsSetResult_ 

func (p *LookupIndexResp) IsSetResult_() bool

func (*LookupIndexResp) IsSetStatData 

func (p *LookupIndexResp) IsSetStatData() bool

func (*LookupIndexResp) LogValue 

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

func (*LookupIndexResp) Read 

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

func (*LookupIndexResp) ReadField1 

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

func (*LookupIndexResp) ReadField2 

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

func (*LookupIndexResp) ReadField3 

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

func (*LookupIndexResp) String 

func (p *LookupIndexResp) String() string

func (*LookupIndexResp) Validate 

func (p *LookupIndexResp) Validate() error

func (*LookupIndexResp) Write 

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

type MemberChangeReq 

type MemberChangeReq struct {
	SpaceID nebula.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID  nebula.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	Peer    *nebula.HostAddr    `thrift:"peer,3" db:"peer" json:"peer"`
	Add     bool                `thrift:"add,4" db:"add" json:"add"`
}

Attributes:

  • SpaceID
  • PartID
  • Peer
  • Add
var StorageAdminServiceMemberChangeArgs_Req_DEFAULT *MemberChangeReq

func NewMemberChangeReq 

func NewMemberChangeReq() *MemberChangeReq

func (*MemberChangeReq) Equals 

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

func (*MemberChangeReq) GetAdd 

func (p *MemberChangeReq) GetAdd() bool

func (*MemberChangeReq) GetPartID 

func (p *MemberChangeReq) GetPartID() nebula.PartitionID

func (*MemberChangeReq) GetPeer 

func (p *MemberChangeReq) GetPeer() *nebula.HostAddr

func (*MemberChangeReq) GetSpaceID 

func (p *MemberChangeReq) GetSpaceID() nebula.GraphSpaceID

func (*MemberChangeReq) IsSetPeer 

func (p *MemberChangeReq) IsSetPeer() bool

func (*MemberChangeReq) LogValue 

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

func (*MemberChangeReq) Read 

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

func (*MemberChangeReq) ReadField1 

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

func (*MemberChangeReq) ReadField2 

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

func (*MemberChangeReq) ReadField3 

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

func (*MemberChangeReq) ReadField4 

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

func (*MemberChangeReq) String 

func (p *MemberChangeReq) String() string

func (*MemberChangeReq) Validate 

func (p *MemberChangeReq) Validate() error

func (*MemberChangeReq) Write 

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

type NewEdge_ 

type NewEdge_ struct {
	Key   *EdgeKey        `thrift:"key,1" db:"key" json:"key"`
	Props []*nebula.Value `thrift:"props,2" db:"props" json:"props"`
}

Attributes:

  • Key
  • Props

func NewNewEdge_ 

func NewNewEdge_() *NewEdge_

func (*NewEdge_) Equals 

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

func (*NewEdge_) GetKey 

func (p *NewEdge_) GetKey() *EdgeKey

func (*NewEdge_) GetProps 

func (p *NewEdge_) GetProps() []*nebula.Value

func (*NewEdge_) IsSetKey 

func (p *NewEdge_) IsSetKey() bool

func (*NewEdge_) LogValue 

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

func (*NewEdge_) Read 

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

func (*NewEdge_) ReadField1 

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

func (*NewEdge_) ReadField2 

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

func (*NewEdge_) String 

func (p *NewEdge_) String() string

func (*NewEdge_) Validate 

func (p *NewEdge_) Validate() error

func (*NewEdge_) Write 

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

type NewTag_ 

type NewTag_ struct {
	TagID nebula.TagID    `thrift:"tag_id,1" db:"tag_id" json:"tag_id"`
	Props []*nebula.Value `thrift:"props,2" db:"props" json:"props"`
}

Attributes:

  • TagID
  • Props

func NewNewTag_ 

func NewNewTag_() *NewTag_

func (*NewTag_) Equals 

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

func (*NewTag_) GetProps 

func (p *NewTag_) GetProps() []*nebula.Value

func (*NewTag_) GetTagID 

func (p *NewTag_) GetTagID() nebula.TagID

func (*NewTag_) LogValue 

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

func (*NewTag_) Read 

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

func (*NewTag_) ReadField1 

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

func (*NewTag_) ReadField2 

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

func (*NewTag_) String 

func (p *NewTag_) String() string

func (*NewTag_) Validate 

func (p *NewTag_) Validate() error

func (*NewTag_) Write 

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

type NewVertex_ 

type NewVertex_ struct {
	ID   *nebula.Value `thrift:"id,1" db:"id" json:"id"`
	Tags []*NewTag_    `thrift:"tags,2" db:"tags" json:"tags"`
}

Attributes:

  • ID
  • Tags

func NewNewVertex_ 

func NewNewVertex_() *NewVertex_

func (*NewVertex_) Equals 

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

func (*NewVertex_) GetID 

func (p *NewVertex_) GetID() *nebula.Value

func (*NewVertex_) GetTags 

func (p *NewVertex_) GetTags() []*NewTag_

func (*NewVertex_) IsSetID 

func (p *NewVertex_) IsSetID() bool

func (*NewVertex_) LogValue 

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

func (*NewVertex_) Read 

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

func (*NewVertex_) ReadField1 

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

func (*NewVertex_) ReadField2 

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

func (*NewVertex_) String 

func (p *NewVertex_) String() string

func (*NewVertex_) Validate 

func (p *NewVertex_) Validate() error

func (*NewVertex_) Write 

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

type OrderBy 

type OrderBy struct {
	Prop      []byte         `thrift:"prop,1" db:"prop" json:"prop"`
	Direction OrderDirection `thrift:"direction,2" db:"direction" json:"direction"`
}

Attributes:

  • Prop
  • Direction

func NewOrderBy 

func NewOrderBy() *OrderBy

func (*OrderBy) Equals 

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

func (*OrderBy) GetDirection 

func (p *OrderBy) GetDirection() OrderDirection

func (*OrderBy) GetProp 

func (p *OrderBy) GetProp() []byte

func (*OrderBy) LogValue 

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

func (*OrderBy) Read 

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

func (*OrderBy) ReadField1 

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

func (*OrderBy) ReadField2 

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

func (*OrderBy) String 

func (p *OrderBy) String() string

func (*OrderBy) Validate 

func (p *OrderBy) Validate() error

func (*OrderBy) Write 

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

type OrderDirection 

type OrderDirection int64
const (
	OrderDirection_ASCENDING  OrderDirection = 1
	OrderDirection_DESCENDING OrderDirection = 2
)

func OrderDirectionFromString 

func OrderDirectionFromString(s string) (OrderDirection, error)

func OrderDirectionPtr 

func OrderDirectionPtr(v OrderDirection) *OrderDirection

func (OrderDirection) MarshalText 

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

func (*OrderDirection) Scan 

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

func (OrderDirection) String 

func (p OrderDirection) String() string

func (*OrderDirection) UnmarshalText 

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

func (*OrderDirection) Value 

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

type PartitionResult_ 

type PartitionResult_ struct {
	Code   nebula.ErrorCode   `thrift:"code,1,required" db:"code" json:"code"`
	PartID nebula.PartitionID `thrift:"part_id,2,required" db:"part_id" json:"part_id"`
	Leader *nebula.HostAddr   `thrift:"leader,3" db:"leader" json:"leader,omitempty"`
}

Attributes:

  • Code
  • PartID
  • Leader

func NewPartitionResult_ 

func NewPartitionResult_() *PartitionResult_

func (*PartitionResult_) Equals 

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

func (*PartitionResult_) GetCode 

func (p *PartitionResult_) GetCode() nebula.ErrorCode

func (*PartitionResult_) GetLeader 

func (p *PartitionResult_) GetLeader() *nebula.HostAddr

func (*PartitionResult_) GetPartID 

func (p *PartitionResult_) GetPartID() nebula.PartitionID

func (*PartitionResult_) IsSetLeader 

func (p *PartitionResult_) IsSetLeader() bool

func (*PartitionResult_) LogValue 

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

func (*PartitionResult_) Read 

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

func (*PartitionResult_) ReadField1 

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

func (*PartitionResult_) ReadField2 

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

func (*PartitionResult_) ReadField3 

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

func (*PartitionResult_) String 

func (p *PartitionResult_) String() string

func (*PartitionResult_) Validate 

func (p *PartitionResult_) Validate() error

func (*PartitionResult_) Write 

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

type RebuildIndexRequest 

type RebuildIndexRequest struct {
	SpaceID nebula.GraphSpaceID  `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts   []nebula.PartitionID `thrift:"parts,2" db:"parts" json:"parts"`
	IndexID nebula.IndexID       `thrift:"index_id,3" db:"index_id" json:"index_id"`
}

Attributes:

  • SpaceID
  • Parts
  • IndexID

func NewRebuildIndexRequest 

func NewRebuildIndexRequest() *RebuildIndexRequest

func (*RebuildIndexRequest) Equals 

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

func (*RebuildIndexRequest) GetIndexID 

func (p *RebuildIndexRequest) GetIndexID() nebula.IndexID

func (*RebuildIndexRequest) GetParts 

func (p *RebuildIndexRequest) GetParts() []nebula.PartitionID

func (*RebuildIndexRequest) GetSpaceID 

func (p *RebuildIndexRequest) GetSpaceID() nebula.GraphSpaceID

func (*RebuildIndexRequest) LogValue 

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

func (*RebuildIndexRequest) Read 

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

func (*RebuildIndexRequest) ReadField1 

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

func (*RebuildIndexRequest) ReadField2 

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

func (*RebuildIndexRequest) ReadField3 

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

func (*RebuildIndexRequest) String 

func (p *RebuildIndexRequest) String() string

func (*RebuildIndexRequest) Validate 

func (p *RebuildIndexRequest) Validate() error

func (*RebuildIndexRequest) Write 

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

type RemovePartReq 

type RemovePartReq struct {
	SpaceID nebula.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID  nebula.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
}

Attributes:

  • SpaceID
  • PartID
var StorageAdminServiceRemovePartArgs_Req_DEFAULT *RemovePartReq

func NewRemovePartReq 

func NewRemovePartReq() *RemovePartReq

func (*RemovePartReq) Equals 

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

func (*RemovePartReq) GetPartID 

func (p *RemovePartReq) GetPartID() nebula.PartitionID

func (*RemovePartReq) GetSpaceID 

func (p *RemovePartReq) GetSpaceID() nebula.GraphSpaceID

func (*RemovePartReq) LogValue 

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

func (*RemovePartReq) Read 

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

func (*RemovePartReq) ReadField1 

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

func (*RemovePartReq) ReadField2 

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

func (*RemovePartReq) String 

func (p *RemovePartReq) String() string

func (*RemovePartReq) Validate 

func (p *RemovePartReq) Validate() error

func (*RemovePartReq) Write 

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

type RequestCommon 

type RequestCommon struct {
	SessionID     *nebula.SessionID       `thrift:"session_id,1" db:"session_id" json:"session_id,omitempty"`
	PlanID        *nebula.ExecutionPlanID `thrift:"plan_id,2" db:"plan_id" json:"plan_id,omitempty"`
	ProfileDetail *bool                   `thrift:"profile_detail,3" db:"profile_detail" json:"profile_detail,omitempty"`
}

Attributes:

  • SessionID
  • PlanID
  • ProfileDetail
var AddEdgesRequest_Common_DEFAULT *RequestCommon
var AddVerticesRequest_Common_DEFAULT *RequestCommon
var DeleteEdgesRequest_Common_DEFAULT *RequestCommon
var DeleteTagsRequest_Common_DEFAULT *RequestCommon
var DeleteVerticesRequest_Common_DEFAULT *RequestCommon
var GetDstBySrcRequest_Common_DEFAULT *RequestCommon
var GetNeighborsRequest_Common_DEFAULT *RequestCommon
var GetPropRequest_Common_DEFAULT *RequestCommon
var GetUUIDReq_Common_DEFAULT *RequestCommon
var LookupAndTraverseRequest_Common_DEFAULT *RequestCommon
var LookupIndexRequest_Common_DEFAULT *RequestCommon
var ScanEdgeRequest_Common_DEFAULT *RequestCommon
var ScanVertexRequest_Common_DEFAULT *RequestCommon
var UpdateEdgeRequest_Common_DEFAULT *RequestCommon
var UpdateVertexRequest_Common_DEFAULT *RequestCommon

func NewRequestCommon 

func NewRequestCommon() *RequestCommon

func (*RequestCommon) Equals 

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

func (*RequestCommon) GetPlanID 

func (p *RequestCommon) GetPlanID() nebula.ExecutionPlanID

func (*RequestCommon) GetProfileDetail 

func (p *RequestCommon) GetProfileDetail() bool

func (*RequestCommon) GetSessionID 

func (p *RequestCommon) GetSessionID() nebula.SessionID

func (*RequestCommon) IsSetPlanID 

func (p *RequestCommon) IsSetPlanID() bool

func (*RequestCommon) IsSetProfileDetail 

func (p *RequestCommon) IsSetProfileDetail() bool

func (*RequestCommon) IsSetSessionID 

func (p *RequestCommon) IsSetSessionID() bool

func (*RequestCommon) LogValue 

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

func (*RequestCommon) Read 

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

func (*RequestCommon) ReadField1 

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

func (*RequestCommon) ReadField2 

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

func (*RequestCommon) ReadField3 

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

func (*RequestCommon) String 

func (p *RequestCommon) String() string

func (*RequestCommon) Validate 

func (p *RequestCommon) Validate() error

func (*RequestCommon) Write 

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

type ResponseCommon 

type ResponseCommon struct {
	FailedParts     []*PartitionResult_ `thrift:"failed_parts,1,required" db:"failed_parts" json:"failed_parts"`
	LatencyInUs     int64               `thrift:"latency_in_us,2,required" db:"latency_in_us" json:"latency_in_us"`
	LatencyDetailUs map[string]int32    `thrift:"latency_detail_us,3" db:"latency_detail_us" json:"latency_detail_us,omitempty"`
}

Attributes:

  • FailedParts
  • LatencyInUs
  • LatencyDetailUs
var AdminExecResp_Result__DEFAULT *ResponseCommon
var ExecResponse_Result__DEFAULT *ResponseCommon
var GetDstBySrcResponse_Result__DEFAULT *ResponseCommon
var GetNeighborsResponse_Result__DEFAULT *ResponseCommon
var GetPropResponse_Result__DEFAULT *ResponseCommon
var GetUUIDResp_Result__DEFAULT *ResponseCommon
var KVGetResponse_Result__DEFAULT *ResponseCommon
var ListClusterInfoResp_Result__DEFAULT *ResponseCommon
var LookupIndexResp_Result__DEFAULT *ResponseCommon
var ScanResponse_Result__DEFAULT *ResponseCommon
var UpdateResponse_Result__DEFAULT *ResponseCommon

func NewResponseCommon 

func NewResponseCommon() *ResponseCommon

func (*ResponseCommon) Equals 

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

func (*ResponseCommon) GetFailedParts 

func (p *ResponseCommon) GetFailedParts() []*PartitionResult_

func (*ResponseCommon) GetLatencyDetailUs 

func (p *ResponseCommon) GetLatencyDetailUs() map[string]int32

func (*ResponseCommon) GetLatencyInUs 

func (p *ResponseCommon) GetLatencyInUs() int64

func (*ResponseCommon) IsSetLatencyDetailUs 

func (p *ResponseCommon) IsSetLatencyDetailUs() bool

func (*ResponseCommon) LogValue 

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

func (*ResponseCommon) Read 

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

func (*ResponseCommon) ReadField1 

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

func (*ResponseCommon) ReadField2 

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

func (*ResponseCommon) ReadField3 

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

func (*ResponseCommon) String 

func (p *ResponseCommon) String() string

func (*ResponseCommon) Validate 

func (p *ResponseCommon) Validate() error

func (*ResponseCommon) Write 

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

type ScanCursor 

type ScanCursor struct {
	NextCursor []byte `thrift:"next_cursor,1" db:"next_cursor" json:"next_cursor,omitempty"`
}

Attributes:

  • NextCursor

func NewScanCursor 

func NewScanCursor() *ScanCursor

func (*ScanCursor) Equals 

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

func (*ScanCursor) GetNextCursor 

func (p *ScanCursor) GetNextCursor() []byte

func (*ScanCursor) IsSetNextCursor 

func (p *ScanCursor) IsSetNextCursor() bool

func (*ScanCursor) LogValue 

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

func (*ScanCursor) Read 

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

func (*ScanCursor) ReadField1 

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

func (*ScanCursor) String 

func (p *ScanCursor) String() string

func (*ScanCursor) Validate 

func (p *ScanCursor) Validate() error

func (*ScanCursor) Write 

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

type ScanEdgeRequest 

type ScanEdgeRequest struct {
	SpaceID                nebula.GraphSpaceID                `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts                  map[nebula.PartitionID]*ScanCursor `thrift:"parts,2" db:"parts" json:"parts"`
	ReturnColumns          []*EdgeProp                        `thrift:"return_columns,3" db:"return_columns" json:"return_columns"`
	Limit                  int64                              `thrift:"limit,4" db:"limit" json:"limit"`
	StartTime              *int64                             `thrift:"start_time,5" db:"start_time" json:"start_time,omitempty"`
	EndTime                *int64                             `thrift:"end_time,6" db:"end_time" json:"end_time,omitempty"`
	Filter                 []byte                             `thrift:"filter,7" db:"filter" json:"filter,omitempty"`
	OnlyLatestVersion      bool                               `thrift:"only_latest_version,8" db:"only_latest_version" json:"only_latest_version"`
	EnableReadFromFollower bool                               `thrift:"enable_read_from_follower,9" db:"enable_read_from_follower" json:"enable_read_from_follower"`
	Common                 *RequestCommon                     `thrift:"common,10" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • ReturnColumns
  • Limit
  • StartTime
  • EndTime
  • Filter
  • OnlyLatestVersion
  • EnableReadFromFollower
  • Common
var GraphStorageServiceScanEdgeArgs_Req_DEFAULT *ScanEdgeRequest

func NewScanEdgeRequest 

func NewScanEdgeRequest() *ScanEdgeRequest

func (*ScanEdgeRequest) Equals 

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

func (*ScanEdgeRequest) GetCommon 

func (p *ScanEdgeRequest) GetCommon() *RequestCommon

func (*ScanEdgeRequest) GetEnableReadFromFollower 

func (p *ScanEdgeRequest) GetEnableReadFromFollower() bool

func (*ScanEdgeRequest) GetEndTime 

func (p *ScanEdgeRequest) GetEndTime() int64

func (*ScanEdgeRequest) GetFilter 

func (p *ScanEdgeRequest) GetFilter() []byte

func (*ScanEdgeRequest) GetLimit 

func (p *ScanEdgeRequest) GetLimit() int64

func (*ScanEdgeRequest) GetOnlyLatestVersion 

func (p *ScanEdgeRequest) GetOnlyLatestVersion() bool

func (*ScanEdgeRequest) GetParts 

func (p *ScanEdgeRequest) GetParts() map[nebula.PartitionID]*ScanCursor

func (*ScanEdgeRequest) GetReturnColumns 

func (p *ScanEdgeRequest) GetReturnColumns() []*EdgeProp

func (*ScanEdgeRequest) GetSpaceID 

func (p *ScanEdgeRequest) GetSpaceID() nebula.GraphSpaceID

func (*ScanEdgeRequest) GetStartTime 

func (p *ScanEdgeRequest) GetStartTime() int64

func (*ScanEdgeRequest) IsSetCommon 

func (p *ScanEdgeRequest) IsSetCommon() bool

func (*ScanEdgeRequest) IsSetEndTime 

func (p *ScanEdgeRequest) IsSetEndTime() bool

func (*ScanEdgeRequest) IsSetFilter 

func (p *ScanEdgeRequest) IsSetFilter() bool

func (*ScanEdgeRequest) IsSetStartTime 

func (p *ScanEdgeRequest) IsSetStartTime() bool

func (*ScanEdgeRequest) LogValue 

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

func (*ScanEdgeRequest) Read 

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

func (*ScanEdgeRequest) ReadField1 

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

func (*ScanEdgeRequest) ReadField10 

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

func (*ScanEdgeRequest) ReadField2 

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

func (*ScanEdgeRequest) ReadField3 

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

func (*ScanEdgeRequest) ReadField4 

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

func (*ScanEdgeRequest) ReadField5 

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

func (*ScanEdgeRequest) ReadField6 

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

func (*ScanEdgeRequest) ReadField7 

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

func (*ScanEdgeRequest) ReadField8 

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

func (*ScanEdgeRequest) ReadField9 

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

func (*ScanEdgeRequest) String 

func (p *ScanEdgeRequest) String() string

func (*ScanEdgeRequest) Validate 

func (p *ScanEdgeRequest) Validate() error

func (*ScanEdgeRequest) Write 

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

type ScanResponse 

type ScanResponse struct {
	Result_ *ResponseCommon                    `thrift:"result,1,required" db:"result" json:"result"`
	Props   *nebula.DataSet                    `thrift:"props,2" db:"props" json:"props,omitempty"`
	Cursors map[nebula.PartitionID]*ScanCursor `thrift:"cursors,3" db:"cursors" json:"cursors"`
}

Attributes:

  • Result_
  • Props
  • Cursors
var GraphStorageServiceScanEdgeResult_Success_DEFAULT *ScanResponse
var GraphStorageServiceScanVertexResult_Success_DEFAULT *ScanResponse

func NewScanResponse 

func NewScanResponse() *ScanResponse

func (*ScanResponse) Equals 

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

func (*ScanResponse) GetCursors 

func (p *ScanResponse) GetCursors() map[nebula.PartitionID]*ScanCursor

func (*ScanResponse) GetProps 

func (p *ScanResponse) GetProps() *nebula.DataSet

func (*ScanResponse) GetResult_ 

func (p *ScanResponse) GetResult_() *ResponseCommon

func (*ScanResponse) IsSetProps 

func (p *ScanResponse) IsSetProps() bool

func (*ScanResponse) IsSetResult_ 

func (p *ScanResponse) IsSetResult_() bool

func (*ScanResponse) LogValue 

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

func (*ScanResponse) Read 

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

func (*ScanResponse) ReadField1 

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

func (*ScanResponse) ReadField2 

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

func (*ScanResponse) ReadField3 

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

func (*ScanResponse) String 

func (p *ScanResponse) String() string

func (*ScanResponse) Validate 

func (p *ScanResponse) Validate() error

func (*ScanResponse) Write 

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

type ScanType 

type ScanType int64
const (
	ScanType_PREFIX ScanType = 1
	ScanType_RANGE  ScanType = 2
)

func ScanTypeFromString 

func ScanTypeFromString(s string) (ScanType, error)

func ScanTypePtr 

func ScanTypePtr(v ScanType) *ScanType

func (ScanType) MarshalText 

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

func (*ScanType) Scan 

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

func (ScanType) String 

func (p ScanType) String() string

func (*ScanType) UnmarshalText 

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

func (*ScanType) Value 

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

type ScanVertexRequest 

type ScanVertexRequest struct {
	SpaceID                nebula.GraphSpaceID                `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts                  map[nebula.PartitionID]*ScanCursor `thrift:"parts,2" db:"parts" json:"parts"`
	ReturnColumns          []*VertexProp                      `thrift:"return_columns,3" db:"return_columns" json:"return_columns"`
	Limit                  int64                              `thrift:"limit,4" db:"limit" json:"limit"`
	StartTime              *int64                             `thrift:"start_time,5" db:"start_time" json:"start_time,omitempty"`
	EndTime                *int64                             `thrift:"end_time,6" db:"end_time" json:"end_time,omitempty"`
	Filter                 []byte                             `thrift:"filter,7" db:"filter" json:"filter,omitempty"`
	OnlyLatestVersion      bool                               `thrift:"only_latest_version,8" db:"only_latest_version" json:"only_latest_version"`
	EnableReadFromFollower bool                               `thrift:"enable_read_from_follower,9" db:"enable_read_from_follower" json:"enable_read_from_follower"`
	Common                 *RequestCommon                     `thrift:"common,10" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • ReturnColumns
  • Limit
  • StartTime
  • EndTime
  • Filter
  • OnlyLatestVersion
  • EnableReadFromFollower
  • Common
var GraphStorageServiceScanVertexArgs_Req_DEFAULT *ScanVertexRequest

func NewScanVertexRequest 

func NewScanVertexRequest() *ScanVertexRequest

func (*ScanVertexRequest) Equals 

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

func (*ScanVertexRequest) GetCommon 

func (p *ScanVertexRequest) GetCommon() *RequestCommon

func (*ScanVertexRequest) GetEnableReadFromFollower 

func (p *ScanVertexRequest) GetEnableReadFromFollower() bool

func (*ScanVertexRequest) GetEndTime 

func (p *ScanVertexRequest) GetEndTime() int64

func (*ScanVertexRequest) GetFilter 

func (p *ScanVertexRequest) GetFilter() []byte

func (*ScanVertexRequest) GetLimit 

func (p *ScanVertexRequest) GetLimit() int64

func (*ScanVertexRequest) GetOnlyLatestVersion 

func (p *ScanVertexRequest) GetOnlyLatestVersion() bool

func (*ScanVertexRequest) GetParts 

func (p *ScanVertexRequest) GetParts() map[nebula.PartitionID]*ScanCursor

func (*ScanVertexRequest) GetReturnColumns 

func (p *ScanVertexRequest) GetReturnColumns() []*VertexProp

func (*ScanVertexRequest) GetSpaceID 

func (p *ScanVertexRequest) GetSpaceID() nebula.GraphSpaceID

func (*ScanVertexRequest) GetStartTime 

func (p *ScanVertexRequest) GetStartTime() int64

func (*ScanVertexRequest) IsSetCommon 

func (p *ScanVertexRequest) IsSetCommon() bool

func (*ScanVertexRequest) IsSetEndTime 

func (p *ScanVertexRequest) IsSetEndTime() bool

func (*ScanVertexRequest) IsSetFilter 

func (p *ScanVertexRequest) IsSetFilter() bool

func (*ScanVertexRequest) IsSetStartTime 

func (p *ScanVertexRequest) IsSetStartTime() bool

func (*ScanVertexRequest) LogValue 

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

func (*ScanVertexRequest) Read 

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

func (*ScanVertexRequest) ReadField1 

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

func (*ScanVertexRequest) ReadField10 

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

func (*ScanVertexRequest) ReadField2 

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

func (*ScanVertexRequest) ReadField3 

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

func (*ScanVertexRequest) ReadField4 

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

func (*ScanVertexRequest) ReadField5 

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

func (*ScanVertexRequest) ReadField6 

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

func (*ScanVertexRequest) ReadField7 

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

func (*ScanVertexRequest) ReadField8 

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

func (*ScanVertexRequest) ReadField9 

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

func (*ScanVertexRequest) String 

func (p *ScanVertexRequest) String() string

func (*ScanVertexRequest) Validate 

func (p *ScanVertexRequest) Validate() error

func (*ScanVertexRequest) Write 

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

type StatProp 

type StatProp struct {
	Alias []byte   `thrift:"alias,1" db:"alias" json:"alias"`
	Prop  []byte   `thrift:"prop,2" db:"prop" json:"prop"`
	Stat  StatType `thrift:"stat,3" db:"stat" json:"stat"`
}

Attributes:

  • Alias
  • Prop
  • Stat

func NewStatProp 

func NewStatProp() *StatProp

func (*StatProp) Equals 

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

func (*StatProp) GetAlias 

func (p *StatProp) GetAlias() []byte

func (*StatProp) GetProp 

func (p *StatProp) GetProp() []byte

func (*StatProp) GetStat 

func (p *StatProp) GetStat() StatType

func (*StatProp) LogValue 

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

func (*StatProp) Read 

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

func (*StatProp) ReadField1 

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

func (*StatProp) ReadField2 

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

func (*StatProp) ReadField3 

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

func (*StatProp) String 

func (p *StatProp) String() string

func (*StatProp) Validate 

func (p *StatProp) Validate() error

func (*StatProp) Write 

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

type StatType 

type StatType int64
const (
	StatType_SUM   StatType = 1
	StatType_COUNT StatType = 2
	StatType_AVG   StatType = 3
	StatType_MAX   StatType = 4
	StatType_MIN   StatType = 5
)

func StatTypeFromString 

func StatTypeFromString(s string) (StatType, error)

func StatTypePtr 

func StatTypePtr(v StatType) *StatType

func (StatType) MarshalText 

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

func (*StatType) Scan 

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

func (StatType) String 

func (p StatType) String() string

func (*StatType) UnmarshalText 

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

func (*StatType) Value 

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

type StopTaskRequest 

type StopTaskRequest struct {
	JobID  int32 `thrift:"job_id,1" db:"job_id" json:"job_id"`
	TaskID int32 `thrift:"task_id,2" db:"task_id" json:"task_id"`
}

Attributes:

  • JobID
  • TaskID
var StorageAdminServiceStopAdminTaskArgs_Req_DEFAULT *StopTaskRequest

func NewStopTaskRequest 

func NewStopTaskRequest() *StopTaskRequest

func (*StopTaskRequest) Equals 

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

func (*StopTaskRequest) GetJobID 

func (p *StopTaskRequest) GetJobID() int32

func (*StopTaskRequest) GetTaskID 

func (p *StopTaskRequest) GetTaskID() int32

func (*StopTaskRequest) LogValue 

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

func (*StopTaskRequest) Read 

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

func (*StopTaskRequest) ReadField1 

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

func (*StopTaskRequest) ReadField2 

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

func (*StopTaskRequest) String 

func (p *StopTaskRequest) String() string

func (*StopTaskRequest) Validate 

func (p *StopTaskRequest) Validate() error

func (*StopTaskRequest) Write 

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

type StopTaskResp 

type StopTaskResp struct {
	Code nebula.ErrorCode `thrift:"code,1" db:"code" json:"code"`
}

Attributes:

  • Code
var StorageAdminServiceStopAdminTaskResult_Success_DEFAULT *StopTaskResp

func NewStopTaskResp 

func NewStopTaskResp() *StopTaskResp

func (*StopTaskResp) Equals 

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

func (*StopTaskResp) GetCode 

func (p *StopTaskResp) GetCode() nebula.ErrorCode

func (*StopTaskResp) LogValue 

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

func (*StopTaskResp) Read 

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

func (*StopTaskResp) ReadField1 

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

func (*StopTaskResp) String 

func (p *StopTaskResp) String() string

func (*StopTaskResp) Validate 

func (p *StopTaskResp) Validate() error

func (*StopTaskResp) Write 

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

type StorageAdminService 

type StorageAdminService interface {
	// Parameters:
	//  - Req
	TransLeader(ctx context.Context, req *TransLeaderReq) (_r *AdminExecResp, _err error)
	// Parameters:
	//  - Req
	AddPart(ctx context.Context, req *AddPartReq) (_r *AdminExecResp, _err error)
	// Parameters:
	//  - Req
	AddLearner(ctx context.Context, req *AddLearnerReq) (_r *AdminExecResp, _err error)
	// Parameters:
	//  - Req
	RemovePart(ctx context.Context, req *RemovePartReq) (_r *AdminExecResp, _err error)
	// Parameters:
	//  - Req
	MemberChange(ctx context.Context, req *MemberChangeReq) (_r *AdminExecResp, _err error)
	// Parameters:
	//  - Req
	WaitingForCatchUpData(ctx context.Context, req *CatchUpDataReq) (_r *AdminExecResp, _err error)
	// Parameters:
	//  - Req
	CreateCheckpoint(ctx context.Context, req *CreateCPRequest) (_r *CreateCPResp, _err error)
	// Parameters:
	//  - Req
	DropCheckpoint(ctx context.Context, req *DropCPRequest) (_r *DropCPResp, _err error)
	// Parameters:
	//  - Req
	BlockingWrites(ctx context.Context, req *BlockingSignRequest) (_r *BlockingSignResp, _err error)
	// Parameters:
	//  - Req
	GetLeaderParts(ctx context.Context, req *GetLeaderReq) (_r *GetLeaderPartsResp, _err error)
	// Parameters:
	//  - Req
	CheckPeers(ctx context.Context, req *CheckPeersReq) (_r *AdminExecResp, _err error)
	// Parameters:
	//  - Req
	AddAdminTask(ctx context.Context, req *AddTaskRequest) (_r *AddTaskResp, _err error)
	// Parameters:
	//  - Req
	StopAdminTask(ctx context.Context, req *StopTaskRequest) (_r *StopTaskResp, _err error)
	// Parameters:
	//  - Req
	ClearSpace(ctx context.Context, req *ClearSpaceReq) (_r *ClearSpaceResp, _err error)
}

type StorageAdminServiceAddAdminTaskArgs 

type StorageAdminServiceAddAdminTaskArgs struct {
	Req *AddTaskRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceAddAdminTaskArgs 

func NewStorageAdminServiceAddAdminTaskArgs() *StorageAdminServiceAddAdminTaskArgs

func (*StorageAdminServiceAddAdminTaskArgs) GetReq 

func (p *StorageAdminServiceAddAdminTaskArgs) GetReq() *AddTaskRequest

func (*StorageAdminServiceAddAdminTaskArgs) IsSetReq 

func (p *StorageAdminServiceAddAdminTaskArgs) IsSetReq() bool

func (*StorageAdminServiceAddAdminTaskArgs) LogValue 

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

func (*StorageAdminServiceAddAdminTaskArgs) Read 

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

func (*StorageAdminServiceAddAdminTaskArgs) ReadField1 

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

func (*StorageAdminServiceAddAdminTaskArgs) String 

func (p *StorageAdminServiceAddAdminTaskArgs) String() string

func (*StorageAdminServiceAddAdminTaskArgs) Write 

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

type StorageAdminServiceAddAdminTaskResult 

type StorageAdminServiceAddAdminTaskResult struct {
	Success *AddTaskResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceAddAdminTaskResult 

func NewStorageAdminServiceAddAdminTaskResult() *StorageAdminServiceAddAdminTaskResult

func (*StorageAdminServiceAddAdminTaskResult) GetSuccess 

func (p *StorageAdminServiceAddAdminTaskResult) GetSuccess() *AddTaskResp

func (*StorageAdminServiceAddAdminTaskResult) IsSetSuccess 

func (p *StorageAdminServiceAddAdminTaskResult) IsSetSuccess() bool

func (*StorageAdminServiceAddAdminTaskResult) LogValue 

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

func (*StorageAdminServiceAddAdminTaskResult) Read 

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

func (*StorageAdminServiceAddAdminTaskResult) ReadField0 

func (p *StorageAdminServiceAddAdminTaskResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceAddAdminTaskResult) String 

func (p *StorageAdminServiceAddAdminTaskResult) String() string

func (*StorageAdminServiceAddAdminTaskResult) Write 

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

type StorageAdminServiceAddLearnerArgs 

type StorageAdminServiceAddLearnerArgs struct {
	Req *AddLearnerReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceAddLearnerArgs 

func NewStorageAdminServiceAddLearnerArgs() *StorageAdminServiceAddLearnerArgs

func (*StorageAdminServiceAddLearnerArgs) GetReq 

func (p *StorageAdminServiceAddLearnerArgs) GetReq() *AddLearnerReq

func (*StorageAdminServiceAddLearnerArgs) IsSetReq 

func (p *StorageAdminServiceAddLearnerArgs) IsSetReq() bool

func (*StorageAdminServiceAddLearnerArgs) LogValue 

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

func (*StorageAdminServiceAddLearnerArgs) Read 

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

func (*StorageAdminServiceAddLearnerArgs) ReadField1 

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

func (*StorageAdminServiceAddLearnerArgs) String 

func (p *StorageAdminServiceAddLearnerArgs) String() string

func (*StorageAdminServiceAddLearnerArgs) Write 

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

type StorageAdminServiceAddLearnerResult 

type StorageAdminServiceAddLearnerResult struct {
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceAddLearnerResult 

func NewStorageAdminServiceAddLearnerResult() *StorageAdminServiceAddLearnerResult

func (*StorageAdminServiceAddLearnerResult) GetSuccess 

func (p *StorageAdminServiceAddLearnerResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceAddLearnerResult) IsSetSuccess 

func (p *StorageAdminServiceAddLearnerResult) IsSetSuccess() bool

func (*StorageAdminServiceAddLearnerResult) LogValue 

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

func (*StorageAdminServiceAddLearnerResult) Read 

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

func (*StorageAdminServiceAddLearnerResult) ReadField0 

func (p *StorageAdminServiceAddLearnerResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceAddLearnerResult) String 

func (p *StorageAdminServiceAddLearnerResult) String() string

func (*StorageAdminServiceAddLearnerResult) Write 

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

type StorageAdminServiceAddPartArgs 

type StorageAdminServiceAddPartArgs struct {
	Req *AddPartReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceAddPartArgs 

func NewStorageAdminServiceAddPartArgs() *StorageAdminServiceAddPartArgs

func (*StorageAdminServiceAddPartArgs) GetReq 

func (p *StorageAdminServiceAddPartArgs) GetReq() *AddPartReq

func (*StorageAdminServiceAddPartArgs) IsSetReq 

func (p *StorageAdminServiceAddPartArgs) IsSetReq() bool

func (*StorageAdminServiceAddPartArgs) LogValue 

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

func (*StorageAdminServiceAddPartArgs) Read 

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

func (*StorageAdminServiceAddPartArgs) ReadField1 

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

func (*StorageAdminServiceAddPartArgs) String 

func (p *StorageAdminServiceAddPartArgs) String() string

func (*StorageAdminServiceAddPartArgs) Write 

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

type StorageAdminServiceAddPartResult 

type StorageAdminServiceAddPartResult struct {
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceAddPartResult 

func NewStorageAdminServiceAddPartResult() *StorageAdminServiceAddPartResult

func (*StorageAdminServiceAddPartResult) GetSuccess 

func (p *StorageAdminServiceAddPartResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceAddPartResult) IsSetSuccess 

func (p *StorageAdminServiceAddPartResult) IsSetSuccess() bool

func (*StorageAdminServiceAddPartResult) LogValue 

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

func (*StorageAdminServiceAddPartResult) Read 

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

func (*StorageAdminServiceAddPartResult) ReadField0 

func (p *StorageAdminServiceAddPartResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceAddPartResult) String 

func (p *StorageAdminServiceAddPartResult) String() string

func (*StorageAdminServiceAddPartResult) Write 

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

type StorageAdminServiceBlockingWritesArgs 

type StorageAdminServiceBlockingWritesArgs struct {
	Req *BlockingSignRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceBlockingWritesArgs 

func NewStorageAdminServiceBlockingWritesArgs() *StorageAdminServiceBlockingWritesArgs

func (*StorageAdminServiceBlockingWritesArgs) GetReq 

func (p *StorageAdminServiceBlockingWritesArgs) GetReq() *BlockingSignRequest

func (*StorageAdminServiceBlockingWritesArgs) IsSetReq 

func (p *StorageAdminServiceBlockingWritesArgs) IsSetReq() bool

func (*StorageAdminServiceBlockingWritesArgs) LogValue 

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

func (*StorageAdminServiceBlockingWritesArgs) Read 

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

func (*StorageAdminServiceBlockingWritesArgs) ReadField1 

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

func (*StorageAdminServiceBlockingWritesArgs) String 

func (p *StorageAdminServiceBlockingWritesArgs) String() string

func (*StorageAdminServiceBlockingWritesArgs) Write 

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

type StorageAdminServiceBlockingWritesResult 

type StorageAdminServiceBlockingWritesResult struct {
	Success *BlockingSignResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceBlockingWritesResult 

func NewStorageAdminServiceBlockingWritesResult() *StorageAdminServiceBlockingWritesResult

func (*StorageAdminServiceBlockingWritesResult) GetSuccess 

func (p *StorageAdminServiceBlockingWritesResult) GetSuccess() *BlockingSignResp

func (*StorageAdminServiceBlockingWritesResult) IsSetSuccess 

func (p *StorageAdminServiceBlockingWritesResult) IsSetSuccess() bool

func (*StorageAdminServiceBlockingWritesResult) LogValue 

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

func (*StorageAdminServiceBlockingWritesResult) Read 

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

func (*StorageAdminServiceBlockingWritesResult) ReadField0 

func (p *StorageAdminServiceBlockingWritesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceBlockingWritesResult) String 

func (p *StorageAdminServiceBlockingWritesResult) String() string

func (*StorageAdminServiceBlockingWritesResult) Write 

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

type StorageAdminServiceCheckPeersArgs 

type StorageAdminServiceCheckPeersArgs struct {
	Req *CheckPeersReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceCheckPeersArgs 

func NewStorageAdminServiceCheckPeersArgs() *StorageAdminServiceCheckPeersArgs

func (*StorageAdminServiceCheckPeersArgs) GetReq 

func (p *StorageAdminServiceCheckPeersArgs) GetReq() *CheckPeersReq

func (*StorageAdminServiceCheckPeersArgs) IsSetReq 

func (p *StorageAdminServiceCheckPeersArgs) IsSetReq() bool

func (*StorageAdminServiceCheckPeersArgs) LogValue 

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

func (*StorageAdminServiceCheckPeersArgs) Read 

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

func (*StorageAdminServiceCheckPeersArgs) ReadField1 

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

func (*StorageAdminServiceCheckPeersArgs) String 

func (p *StorageAdminServiceCheckPeersArgs) String() string

func (*StorageAdminServiceCheckPeersArgs) Write 

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

type StorageAdminServiceCheckPeersResult 

type StorageAdminServiceCheckPeersResult struct {
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceCheckPeersResult 

func NewStorageAdminServiceCheckPeersResult() *StorageAdminServiceCheckPeersResult

func (*StorageAdminServiceCheckPeersResult) GetSuccess 

func (p *StorageAdminServiceCheckPeersResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceCheckPeersResult) IsSetSuccess 

func (p *StorageAdminServiceCheckPeersResult) IsSetSuccess() bool

func (*StorageAdminServiceCheckPeersResult) LogValue 

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

func (*StorageAdminServiceCheckPeersResult) Read 

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

func (*StorageAdminServiceCheckPeersResult) ReadField0 

func (p *StorageAdminServiceCheckPeersResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceCheckPeersResult) String 

func (p *StorageAdminServiceCheckPeersResult) String() string

func (*StorageAdminServiceCheckPeersResult) Write 

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

type StorageAdminServiceClearSpaceArgs 

type StorageAdminServiceClearSpaceArgs struct {
	Req *ClearSpaceReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceClearSpaceArgs 

func NewStorageAdminServiceClearSpaceArgs() *StorageAdminServiceClearSpaceArgs

func (*StorageAdminServiceClearSpaceArgs) GetReq 

func (p *StorageAdminServiceClearSpaceArgs) GetReq() *ClearSpaceReq

func (*StorageAdminServiceClearSpaceArgs) IsSetReq 

func (p *StorageAdminServiceClearSpaceArgs) IsSetReq() bool

func (*StorageAdminServiceClearSpaceArgs) LogValue 

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

func (*StorageAdminServiceClearSpaceArgs) Read 

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

func (*StorageAdminServiceClearSpaceArgs) ReadField1 

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

func (*StorageAdminServiceClearSpaceArgs) String 

func (p *StorageAdminServiceClearSpaceArgs) String() string

func (*StorageAdminServiceClearSpaceArgs) Write 

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

type StorageAdminServiceClearSpaceResult 

type StorageAdminServiceClearSpaceResult struct {
	Success *ClearSpaceResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceClearSpaceResult 

func NewStorageAdminServiceClearSpaceResult() *StorageAdminServiceClearSpaceResult

func (*StorageAdminServiceClearSpaceResult) GetSuccess 

func (p *StorageAdminServiceClearSpaceResult) GetSuccess() *ClearSpaceResp

func (*StorageAdminServiceClearSpaceResult) IsSetSuccess 

func (p *StorageAdminServiceClearSpaceResult) IsSetSuccess() bool

func (*StorageAdminServiceClearSpaceResult) LogValue 

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

func (*StorageAdminServiceClearSpaceResult) Read 

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

func (*StorageAdminServiceClearSpaceResult) ReadField0 

func (p *StorageAdminServiceClearSpaceResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceClearSpaceResult) String 

func (p *StorageAdminServiceClearSpaceResult) String() string

func (*StorageAdminServiceClearSpaceResult) Write 

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

type StorageAdminServiceClient 

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

func NewStorageAdminServiceClient 

func NewStorageAdminServiceClient(c thrift.TClient) *StorageAdminServiceClient

func NewStorageAdminServiceClientFactory 

func NewStorageAdminServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *StorageAdminServiceClient

func NewStorageAdminServiceClientProtocol 

func NewStorageAdminServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *StorageAdminServiceClient

func (*StorageAdminServiceClient) AddAdminTask 

func (p *StorageAdminServiceClient) AddAdminTask(ctx context.Context, req *AddTaskRequest) (_r *AddTaskResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) AddLearner 

func (p *StorageAdminServiceClient) AddLearner(ctx context.Context, req *AddLearnerReq) (_r *AdminExecResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) AddPart 

func (p *StorageAdminServiceClient) AddPart(ctx context.Context, req *AddPartReq) (_r *AdminExecResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) BlockingWrites 

func (p *StorageAdminServiceClient) BlockingWrites(ctx context.Context, req *BlockingSignRequest) (_r *BlockingSignResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) CheckPeers 

func (p *StorageAdminServiceClient) CheckPeers(ctx context.Context, req *CheckPeersReq) (_r *AdminExecResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) ClearSpace 

func (p *StorageAdminServiceClient) ClearSpace(ctx context.Context, req *ClearSpaceReq) (_r *ClearSpaceResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) Client_ 

func (p *StorageAdminServiceClient) Client_() thrift.TClient

func (*StorageAdminServiceClient) CreateCheckpoint 

func (p *StorageAdminServiceClient) CreateCheckpoint(ctx context.Context, req *CreateCPRequest) (_r *CreateCPResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) DropCheckpoint 

func (p *StorageAdminServiceClient) DropCheckpoint(ctx context.Context, req *DropCPRequest) (_r *DropCPResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) GetLeaderParts 

func (p *StorageAdminServiceClient) GetLeaderParts(ctx context.Context, req *GetLeaderReq) (_r *GetLeaderPartsResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) LastResponseMeta_ 

func (p *StorageAdminServiceClient) LastResponseMeta_() thrift.ResponseMeta

func (*StorageAdminServiceClient) MemberChange 

func (p *StorageAdminServiceClient) MemberChange(ctx context.Context, req *MemberChangeReq) (_r *AdminExecResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) RemovePart 

func (p *StorageAdminServiceClient) RemovePart(ctx context.Context, req *RemovePartReq) (_r *AdminExecResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) SetLastResponseMeta_ 

func (p *StorageAdminServiceClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

func (*StorageAdminServiceClient) StopAdminTask 

func (p *StorageAdminServiceClient) StopAdminTask(ctx context.Context, req *StopTaskRequest) (_r *StopTaskResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) TransLeader 

func (p *StorageAdminServiceClient) TransLeader(ctx context.Context, req *TransLeaderReq) (_r *AdminExecResp, _err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) WaitingForCatchUpData 

func (p *StorageAdminServiceClient) WaitingForCatchUpData(ctx context.Context, req *CatchUpDataReq) (_r *AdminExecResp, _err error)

Parameters:

  • Req

type StorageAdminServiceCreateCheckpointArgs 

type StorageAdminServiceCreateCheckpointArgs struct {
	Req *CreateCPRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceCreateCheckpointArgs 

func NewStorageAdminServiceCreateCheckpointArgs() *StorageAdminServiceCreateCheckpointArgs

func (*StorageAdminServiceCreateCheckpointArgs) GetReq 

func (p *StorageAdminServiceCreateCheckpointArgs) GetReq() *CreateCPRequest

func (*StorageAdminServiceCreateCheckpointArgs) IsSetReq 

func (p *StorageAdminServiceCreateCheckpointArgs) IsSetReq() bool

func (*StorageAdminServiceCreateCheckpointArgs) LogValue 

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

func (*StorageAdminServiceCreateCheckpointArgs) Read 

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

func (*StorageAdminServiceCreateCheckpointArgs) ReadField1 

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

func (*StorageAdminServiceCreateCheckpointArgs) String 

func (p *StorageAdminServiceCreateCheckpointArgs) String() string

func (*StorageAdminServiceCreateCheckpointArgs) Write 

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

type StorageAdminServiceCreateCheckpointResult 

type StorageAdminServiceCreateCheckpointResult struct {
	Success *CreateCPResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceCreateCheckpointResult 

func NewStorageAdminServiceCreateCheckpointResult() *StorageAdminServiceCreateCheckpointResult

func (*StorageAdminServiceCreateCheckpointResult) GetSuccess 

func (p *StorageAdminServiceCreateCheckpointResult) GetSuccess() *CreateCPResp

func (*StorageAdminServiceCreateCheckpointResult) IsSetSuccess 

func (p *StorageAdminServiceCreateCheckpointResult) IsSetSuccess() bool

func (*StorageAdminServiceCreateCheckpointResult) LogValue 

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

func (*StorageAdminServiceCreateCheckpointResult) Read 

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

func (*StorageAdminServiceCreateCheckpointResult) ReadField0 

func (p *StorageAdminServiceCreateCheckpointResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceCreateCheckpointResult) String 

func (p *StorageAdminServiceCreateCheckpointResult) String() string

func (*StorageAdminServiceCreateCheckpointResult) Write 

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

type StorageAdminServiceDropCheckpointArgs 

type StorageAdminServiceDropCheckpointArgs struct {
	Req *DropCPRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceDropCheckpointArgs 

func NewStorageAdminServiceDropCheckpointArgs() *StorageAdminServiceDropCheckpointArgs

func (*StorageAdminServiceDropCheckpointArgs) GetReq 

func (p *StorageAdminServiceDropCheckpointArgs) GetReq() *DropCPRequest

func (*StorageAdminServiceDropCheckpointArgs) IsSetReq 

func (p *StorageAdminServiceDropCheckpointArgs) IsSetReq() bool

func (*StorageAdminServiceDropCheckpointArgs) LogValue 

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

func (*StorageAdminServiceDropCheckpointArgs) Read 

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

func (*StorageAdminServiceDropCheckpointArgs) ReadField1 

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

func (*StorageAdminServiceDropCheckpointArgs) String 

func (p *StorageAdminServiceDropCheckpointArgs) String() string

func (*StorageAdminServiceDropCheckpointArgs) Write 

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

type StorageAdminServiceDropCheckpointResult 

type StorageAdminServiceDropCheckpointResult struct {
	Success *DropCPResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceDropCheckpointResult 

func NewStorageAdminServiceDropCheckpointResult() *StorageAdminServiceDropCheckpointResult

func (*StorageAdminServiceDropCheckpointResult) GetSuccess 

func (p *StorageAdminServiceDropCheckpointResult) GetSuccess() *DropCPResp

func (*StorageAdminServiceDropCheckpointResult) IsSetSuccess 

func (p *StorageAdminServiceDropCheckpointResult) IsSetSuccess() bool

func (*StorageAdminServiceDropCheckpointResult) LogValue 

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

func (*StorageAdminServiceDropCheckpointResult) Read 

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

func (*StorageAdminServiceDropCheckpointResult) ReadField0 

func (p *StorageAdminServiceDropCheckpointResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceDropCheckpointResult) String 

func (p *StorageAdminServiceDropCheckpointResult) String() string

func (*StorageAdminServiceDropCheckpointResult) Write 

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

type StorageAdminServiceGetLeaderPartsArgs 

type StorageAdminServiceGetLeaderPartsArgs struct {
	Req *GetLeaderReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceGetLeaderPartsArgs 

func NewStorageAdminServiceGetLeaderPartsArgs() *StorageAdminServiceGetLeaderPartsArgs

func (*StorageAdminServiceGetLeaderPartsArgs) GetReq 

func (p *StorageAdminServiceGetLeaderPartsArgs) GetReq() *GetLeaderReq

func (*StorageAdminServiceGetLeaderPartsArgs) IsSetReq 

func (p *StorageAdminServiceGetLeaderPartsArgs) IsSetReq() bool

func (*StorageAdminServiceGetLeaderPartsArgs) LogValue 

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

func (*StorageAdminServiceGetLeaderPartsArgs) Read 

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

func (*StorageAdminServiceGetLeaderPartsArgs) ReadField1 

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

func (*StorageAdminServiceGetLeaderPartsArgs) String 

func (p *StorageAdminServiceGetLeaderPartsArgs) String() string

func (*StorageAdminServiceGetLeaderPartsArgs) Write 

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

type StorageAdminServiceGetLeaderPartsResult 

type StorageAdminServiceGetLeaderPartsResult struct {
	Success *GetLeaderPartsResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceGetLeaderPartsResult 

func NewStorageAdminServiceGetLeaderPartsResult() *StorageAdminServiceGetLeaderPartsResult

func (*StorageAdminServiceGetLeaderPartsResult) GetSuccess 

func (p *StorageAdminServiceGetLeaderPartsResult) GetSuccess() *GetLeaderPartsResp

func (*StorageAdminServiceGetLeaderPartsResult) IsSetSuccess 

func (p *StorageAdminServiceGetLeaderPartsResult) IsSetSuccess() bool

func (*StorageAdminServiceGetLeaderPartsResult) LogValue 

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

func (*StorageAdminServiceGetLeaderPartsResult) Read 

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

func (*StorageAdminServiceGetLeaderPartsResult) ReadField0 

func (p *StorageAdminServiceGetLeaderPartsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceGetLeaderPartsResult) String 

func (p *StorageAdminServiceGetLeaderPartsResult) String() string

func (*StorageAdminServiceGetLeaderPartsResult) Write 

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

type StorageAdminServiceMemberChangeArgs 

type StorageAdminServiceMemberChangeArgs struct {
	Req *MemberChangeReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceMemberChangeArgs 

func NewStorageAdminServiceMemberChangeArgs() *StorageAdminServiceMemberChangeArgs

func (*StorageAdminServiceMemberChangeArgs) GetReq 

func (p *StorageAdminServiceMemberChangeArgs) GetReq() *MemberChangeReq

func (*StorageAdminServiceMemberChangeArgs) IsSetReq 

func (p *StorageAdminServiceMemberChangeArgs) IsSetReq() bool

func (*StorageAdminServiceMemberChangeArgs) LogValue 

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

func (*StorageAdminServiceMemberChangeArgs) Read 

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

func (*StorageAdminServiceMemberChangeArgs) ReadField1 

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

func (*StorageAdminServiceMemberChangeArgs) String 

func (p *StorageAdminServiceMemberChangeArgs) String() string

func (*StorageAdminServiceMemberChangeArgs) Write 

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

type StorageAdminServiceMemberChangeResult 

type StorageAdminServiceMemberChangeResult struct {
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceMemberChangeResult 

func NewStorageAdminServiceMemberChangeResult() *StorageAdminServiceMemberChangeResult

func (*StorageAdminServiceMemberChangeResult) GetSuccess 

func (p *StorageAdminServiceMemberChangeResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceMemberChangeResult) IsSetSuccess 

func (p *StorageAdminServiceMemberChangeResult) IsSetSuccess() bool

func (*StorageAdminServiceMemberChangeResult) LogValue 

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

func (*StorageAdminServiceMemberChangeResult) Read 

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

func (*StorageAdminServiceMemberChangeResult) ReadField0 

func (p *StorageAdminServiceMemberChangeResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceMemberChangeResult) String 

func (p *StorageAdminServiceMemberChangeResult) String() string

func (*StorageAdminServiceMemberChangeResult) Write 

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

type StorageAdminServiceProcessor 

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

func NewStorageAdminServiceProcessor 

func NewStorageAdminServiceProcessor(handler StorageAdminService) *StorageAdminServiceProcessor

func (*StorageAdminServiceProcessor) AddToProcessorMap 

func (p *StorageAdminServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*StorageAdminServiceProcessor) GetProcessorFunction 

func (p *StorageAdminServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*StorageAdminServiceProcessor) Process 

func (p *StorageAdminServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*StorageAdminServiceProcessor) ProcessorMap 

func (p *StorageAdminServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type StorageAdminServiceRemovePartArgs 

type StorageAdminServiceRemovePartArgs struct {
	Req *RemovePartReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceRemovePartArgs 

func NewStorageAdminServiceRemovePartArgs() *StorageAdminServiceRemovePartArgs

func (*StorageAdminServiceRemovePartArgs) GetReq 

func (p *StorageAdminServiceRemovePartArgs) GetReq() *RemovePartReq

func (*StorageAdminServiceRemovePartArgs) IsSetReq 

func (p *StorageAdminServiceRemovePartArgs) IsSetReq() bool

func (*StorageAdminServiceRemovePartArgs) LogValue 

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

func (*StorageAdminServiceRemovePartArgs) Read 

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

func (*StorageAdminServiceRemovePartArgs) ReadField1 

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

func (*StorageAdminServiceRemovePartArgs) String 

func (p *StorageAdminServiceRemovePartArgs) String() string

func (*StorageAdminServiceRemovePartArgs) Write 

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

type StorageAdminServiceRemovePartResult 

type StorageAdminServiceRemovePartResult struct {
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceRemovePartResult 

func NewStorageAdminServiceRemovePartResult() *StorageAdminServiceRemovePartResult

func (*StorageAdminServiceRemovePartResult) GetSuccess 

func (p *StorageAdminServiceRemovePartResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceRemovePartResult) IsSetSuccess 

func (p *StorageAdminServiceRemovePartResult) IsSetSuccess() bool

func (*StorageAdminServiceRemovePartResult) LogValue 

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

func (*StorageAdminServiceRemovePartResult) Read 

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

func (*StorageAdminServiceRemovePartResult) ReadField0 

func (p *StorageAdminServiceRemovePartResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceRemovePartResult) String 

func (p *StorageAdminServiceRemovePartResult) String() string

func (*StorageAdminServiceRemovePartResult) Write 

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

type StorageAdminServiceStopAdminTaskArgs 

type StorageAdminServiceStopAdminTaskArgs struct {
	Req *StopTaskRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceStopAdminTaskArgs 

func NewStorageAdminServiceStopAdminTaskArgs() *StorageAdminServiceStopAdminTaskArgs

func (*StorageAdminServiceStopAdminTaskArgs) GetReq 

func (p *StorageAdminServiceStopAdminTaskArgs) GetReq() *StopTaskRequest

func (*StorageAdminServiceStopAdminTaskArgs) IsSetReq 

func (p *StorageAdminServiceStopAdminTaskArgs) IsSetReq() bool

func (*StorageAdminServiceStopAdminTaskArgs) LogValue 

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

func (*StorageAdminServiceStopAdminTaskArgs) Read 

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

func (*StorageAdminServiceStopAdminTaskArgs) ReadField1 

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

func (*StorageAdminServiceStopAdminTaskArgs) String 

func (p *StorageAdminServiceStopAdminTaskArgs) String() string

func (*StorageAdminServiceStopAdminTaskArgs) Write 

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

type StorageAdminServiceStopAdminTaskResult 

type StorageAdminServiceStopAdminTaskResult struct {
	Success *StopTaskResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceStopAdminTaskResult 

func NewStorageAdminServiceStopAdminTaskResult() *StorageAdminServiceStopAdminTaskResult

func (*StorageAdminServiceStopAdminTaskResult) GetSuccess 

func (p *StorageAdminServiceStopAdminTaskResult) GetSuccess() *StopTaskResp

func (*StorageAdminServiceStopAdminTaskResult) IsSetSuccess 

func (p *StorageAdminServiceStopAdminTaskResult) IsSetSuccess() bool

func (*StorageAdminServiceStopAdminTaskResult) LogValue 

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

func (*StorageAdminServiceStopAdminTaskResult) Read 

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

func (*StorageAdminServiceStopAdminTaskResult) ReadField0 

func (p *StorageAdminServiceStopAdminTaskResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceStopAdminTaskResult) String 

func (p *StorageAdminServiceStopAdminTaskResult) String() string

func (*StorageAdminServiceStopAdminTaskResult) Write 

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

type StorageAdminServiceTransLeaderArgs 

type StorageAdminServiceTransLeaderArgs struct {
	Req *TransLeaderReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceTransLeaderArgs 

func NewStorageAdminServiceTransLeaderArgs() *StorageAdminServiceTransLeaderArgs

func (*StorageAdminServiceTransLeaderArgs) GetReq 

func (p *StorageAdminServiceTransLeaderArgs) GetReq() *TransLeaderReq

func (*StorageAdminServiceTransLeaderArgs) IsSetReq 

func (p *StorageAdminServiceTransLeaderArgs) IsSetReq() bool

func (*StorageAdminServiceTransLeaderArgs) LogValue 

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

func (*StorageAdminServiceTransLeaderArgs) Read 

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

func (*StorageAdminServiceTransLeaderArgs) ReadField1 

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

func (*StorageAdminServiceTransLeaderArgs) String 

func (p *StorageAdminServiceTransLeaderArgs) String() string

func (*StorageAdminServiceTransLeaderArgs) Write 

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

type StorageAdminServiceTransLeaderResult 

type StorageAdminServiceTransLeaderResult struct {
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceTransLeaderResult 

func NewStorageAdminServiceTransLeaderResult() *StorageAdminServiceTransLeaderResult

func (*StorageAdminServiceTransLeaderResult) GetSuccess 

func (p *StorageAdminServiceTransLeaderResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceTransLeaderResult) IsSetSuccess 

func (p *StorageAdminServiceTransLeaderResult) IsSetSuccess() bool

func (*StorageAdminServiceTransLeaderResult) LogValue 

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

func (*StorageAdminServiceTransLeaderResult) Read 

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

func (*StorageAdminServiceTransLeaderResult) ReadField0 

func (p *StorageAdminServiceTransLeaderResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceTransLeaderResult) String 

func (p *StorageAdminServiceTransLeaderResult) String() string

func (*StorageAdminServiceTransLeaderResult) Write 

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

type StorageAdminServiceWaitingForCatchUpDataArgs 

type StorageAdminServiceWaitingForCatchUpDataArgs struct {
	Req *CatchUpDataReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceWaitingForCatchUpDataArgs 

func NewStorageAdminServiceWaitingForCatchUpDataArgs() *StorageAdminServiceWaitingForCatchUpDataArgs

func (*StorageAdminServiceWaitingForCatchUpDataArgs) GetReq 

func (p *StorageAdminServiceWaitingForCatchUpDataArgs) GetReq() *CatchUpDataReq

func (*StorageAdminServiceWaitingForCatchUpDataArgs) IsSetReq 

func (p *StorageAdminServiceWaitingForCatchUpDataArgs) IsSetReq() bool

func (*StorageAdminServiceWaitingForCatchUpDataArgs) LogValue 

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

func (*StorageAdminServiceWaitingForCatchUpDataArgs) Read 

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

func (*StorageAdminServiceWaitingForCatchUpDataArgs) ReadField1 

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

func (*StorageAdminServiceWaitingForCatchUpDataArgs) String 

func (p *StorageAdminServiceWaitingForCatchUpDataArgs) String() string

func (*StorageAdminServiceWaitingForCatchUpDataArgs) Write 

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

type StorageAdminServiceWaitingForCatchUpDataResult 

type StorageAdminServiceWaitingForCatchUpDataResult struct {
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceWaitingForCatchUpDataResult 

func NewStorageAdminServiceWaitingForCatchUpDataResult() *StorageAdminServiceWaitingForCatchUpDataResult

func (*StorageAdminServiceWaitingForCatchUpDataResult) GetSuccess 

func (p *StorageAdminServiceWaitingForCatchUpDataResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceWaitingForCatchUpDataResult) IsSetSuccess 

func (p *StorageAdminServiceWaitingForCatchUpDataResult) IsSetSuccess() bool

func (*StorageAdminServiceWaitingForCatchUpDataResult) LogValue 

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

func (*StorageAdminServiceWaitingForCatchUpDataResult) Read 

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

func (*StorageAdminServiceWaitingForCatchUpDataResult) ReadField0 

func (p *StorageAdminServiceWaitingForCatchUpDataResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*StorageAdminServiceWaitingForCatchUpDataResult) String 

func (p *StorageAdminServiceWaitingForCatchUpDataResult) String() string

func (*StorageAdminServiceWaitingForCatchUpDataResult) Write 

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

type TaskPara 

type TaskPara struct {
	SpaceID           nebula.GraphSpaceID  `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts             []nebula.PartitionID `thrift:"parts,2" db:"parts" json:"parts,omitempty"`
	TaskSpecificParas [][]byte             `thrift:"task_specific_paras,3" db:"task_specific_paras" json:"task_specific_paras,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • TaskSpecificParas
var AddTaskRequest_Para_DEFAULT *TaskPara

func NewTaskPara 

func NewTaskPara() *TaskPara

func (*TaskPara) Equals 

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

func (*TaskPara) GetParts 

func (p *TaskPara) GetParts() []nebula.PartitionID

func (*TaskPara) GetSpaceID 

func (p *TaskPara) GetSpaceID() nebula.GraphSpaceID

func (*TaskPara) GetTaskSpecificParas 

func (p *TaskPara) GetTaskSpecificParas() [][]byte

func (*TaskPara) IsSetParts 

func (p *TaskPara) IsSetParts() bool

func (*TaskPara) IsSetTaskSpecificParas 

func (p *TaskPara) IsSetTaskSpecificParas() bool

func (*TaskPara) LogValue 

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

func (*TaskPara) Read 

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

func (*TaskPara) ReadField1 

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

func (*TaskPara) ReadField2 

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

func (*TaskPara) ReadField3 

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

func (*TaskPara) String 

func (p *TaskPara) String() string

func (*TaskPara) Validate 

func (p *TaskPara) Validate() error

func (*TaskPara) Write 

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

type TransLeaderReq 

type TransLeaderReq struct {
	SpaceID    nebula.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID     nebula.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	NewLeader_ *nebula.HostAddr    `thrift:"new_leader,3" db:"new_leader" json:"new_leader"`
}

Attributes:

  • SpaceID
  • PartID
  • NewLeader_
var StorageAdminServiceTransLeaderArgs_Req_DEFAULT *TransLeaderReq

func NewTransLeaderReq 

func NewTransLeaderReq() *TransLeaderReq

func (*TransLeaderReq) Equals 

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

func (*TransLeaderReq) GetNewLeader_ 

func (p *TransLeaderReq) GetNewLeader_() *nebula.HostAddr

func (*TransLeaderReq) GetPartID 

func (p *TransLeaderReq) GetPartID() nebula.PartitionID

func (*TransLeaderReq) GetSpaceID 

func (p *TransLeaderReq) GetSpaceID() nebula.GraphSpaceID

func (*TransLeaderReq) IsSetNewLeader_ 

func (p *TransLeaderReq) IsSetNewLeader_() bool

func (*TransLeaderReq) LogValue 

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

func (*TransLeaderReq) Read 

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

func (*TransLeaderReq) ReadField1 

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

func (*TransLeaderReq) ReadField2 

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

func (*TransLeaderReq) ReadField3 

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

func (*TransLeaderReq) String 

func (p *TransLeaderReq) String() string

func (*TransLeaderReq) Validate 

func (p *TransLeaderReq) Validate() error

func (*TransLeaderReq) Write 

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

type TraverseSpec 

type TraverseSpec struct {
	EdgeTypes     []nebula.EdgeType `thrift:"edge_types,1" db:"edge_types" json:"edge_types"`
	EdgeDirection EdgeDirection     `thrift:"edge_direction,2" db:"edge_direction" json:"edge_direction"`
	Dedup         bool              `thrift:"dedup,3" db:"dedup" json:"dedup"`
	StatProps     []*StatProp       `thrift:"stat_props,4" db:"stat_props" json:"stat_props,omitempty"`
	VertexProps   []*VertexProp     `thrift:"vertex_props,5" db:"vertex_props" json:"vertex_props,omitempty"`
	EdgeProps     []*EdgeProp       `thrift:"edge_props,6" db:"edge_props" json:"edge_props,omitempty"`
	Expressions   []*Expr           `thrift:"expressions,7" db:"expressions" json:"expressions,omitempty"`
	OrderBy       []*OrderBy        `thrift:"order_by,8" db:"order_by" json:"order_by,omitempty"`
	Random        *bool             `thrift:"random,9" db:"random" json:"random,omitempty"`
	Limit         *int64            `thrift:"limit,10" db:"limit" json:"limit,omitempty"`
	Filter        []byte            `thrift:"filter,11" db:"filter" json:"filter,omitempty"`
	TagFilter     []byte            `thrift:"tag_filter,12" db:"tag_filter" json:"tag_filter,omitempty"`
}

Attributes:

  • EdgeTypes
  • EdgeDirection
  • Dedup
  • StatProps
  • VertexProps
  • EdgeProps
  • Expressions
  • OrderBy
  • Random
  • Limit
  • Filter
  • TagFilter
var GetNeighborsRequest_TraverseSpec_DEFAULT *TraverseSpec
var LookupAndTraverseRequest_TraverseSpec_DEFAULT *TraverseSpec

func NewTraverseSpec 

func NewTraverseSpec() *TraverseSpec

func (*TraverseSpec) Equals 

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

func (*TraverseSpec) GetDedup 

func (p *TraverseSpec) GetDedup() bool

func (*TraverseSpec) GetEdgeDirection 

func (p *TraverseSpec) GetEdgeDirection() EdgeDirection

func (*TraverseSpec) GetEdgeProps 

func (p *TraverseSpec) GetEdgeProps() []*EdgeProp

func (*TraverseSpec) GetEdgeTypes 

func (p *TraverseSpec) GetEdgeTypes() []nebula.EdgeType

func (*TraverseSpec) GetExpressions 

func (p *TraverseSpec) GetExpressions() []*Expr

func (*TraverseSpec) GetFilter 

func (p *TraverseSpec) GetFilter() []byte

func (*TraverseSpec) GetLimit 

func (p *TraverseSpec) GetLimit() int64

func (*TraverseSpec) GetOrderBy 

func (p *TraverseSpec) GetOrderBy() []*OrderBy

func (*TraverseSpec) GetRandom 

func (p *TraverseSpec) GetRandom() bool

func (*TraverseSpec) GetStatProps 

func (p *TraverseSpec) GetStatProps() []*StatProp

func (*TraverseSpec) GetTagFilter 

func (p *TraverseSpec) GetTagFilter() []byte

func (*TraverseSpec) GetVertexProps 

func (p *TraverseSpec) GetVertexProps() []*VertexProp

func (*TraverseSpec) IsSetEdgeProps 

func (p *TraverseSpec) IsSetEdgeProps() bool

func (*TraverseSpec) IsSetExpressions 

func (p *TraverseSpec) IsSetExpressions() bool

func (*TraverseSpec) IsSetFilter 

func (p *TraverseSpec) IsSetFilter() bool

func (*TraverseSpec) IsSetLimit 

func (p *TraverseSpec) IsSetLimit() bool

func (*TraverseSpec) IsSetOrderBy 

func (p *TraverseSpec) IsSetOrderBy() bool

func (*TraverseSpec) IsSetRandom 

func (p *TraverseSpec) IsSetRandom() bool

func (*TraverseSpec) IsSetStatProps 

func (p *TraverseSpec) IsSetStatProps() bool

func (*TraverseSpec) IsSetTagFilter 

func (p *TraverseSpec) IsSetTagFilter() bool

func (*TraverseSpec) IsSetVertexProps 

func (p *TraverseSpec) IsSetVertexProps() bool

func (*TraverseSpec) LogValue 

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

func (*TraverseSpec) Read 

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

func (*TraverseSpec) ReadField1 

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

func (*TraverseSpec) ReadField10 

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

func (*TraverseSpec) ReadField11 

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

func (*TraverseSpec) ReadField12 

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

func (*TraverseSpec) ReadField2 

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

func (*TraverseSpec) ReadField3 

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

func (*TraverseSpec) ReadField4 

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

func (*TraverseSpec) ReadField5 

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

func (*TraverseSpec) ReadField6 

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

func (*TraverseSpec) ReadField7 

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

func (*TraverseSpec) ReadField8 

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

func (*TraverseSpec) ReadField9 

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

func (*TraverseSpec) String 

func (p *TraverseSpec) String() string

func (*TraverseSpec) Validate 

func (p *TraverseSpec) Validate() error

func (*TraverseSpec) Write 

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

type UpdateEdgeRequest 

type UpdateEdgeRequest struct {
	SpaceID      nebula.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID       nebula.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	EdgeKey      *EdgeKey            `thrift:"edge_key,3" db:"edge_key" json:"edge_key"`
	UpdatedProps []*UpdatedProp      `thrift:"updated_props,4" db:"updated_props" json:"updated_props"`
	Insertable   bool                `thrift:"insertable,5" db:"insertable" json:"insertable"`
	ReturnProps  [][]byte            `thrift:"return_props,6" db:"return_props" json:"return_props,omitempty"`
	Condition    []byte              `thrift:"condition,7" db:"condition" json:"condition,omitempty"`
	Common       *RequestCommon      `thrift:"common,8" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • PartID
  • EdgeKey
  • UpdatedProps
  • Insertable
  • ReturnProps
  • Condition
  • Common
var ChainUpdateEdgeRequest_UpdateEdgeRequest_DEFAULT *UpdateEdgeRequest
var GraphStorageServiceChainUpdateEdgeArgs_Req_DEFAULT *UpdateEdgeRequest
var GraphStorageServiceUpdateEdgeArgs_Req_DEFAULT *UpdateEdgeRequest

func NewUpdateEdgeRequest 

func NewUpdateEdgeRequest() *UpdateEdgeRequest

func (*UpdateEdgeRequest) Equals 

func (p *UpdateEdgeRequest) Equals(other *UpdateEdgeRequest) bool

func (*UpdateEdgeRequest) GetCommon 

func (p *UpdateEdgeRequest) GetCommon() *RequestCommon

func (*UpdateEdgeRequest) GetCondition 

func (p *UpdateEdgeRequest) GetCondition() []byte

func (*UpdateEdgeRequest) GetEdgeKey 

func (p *UpdateEdgeRequest) GetEdgeKey() *EdgeKey

func (*UpdateEdgeRequest) GetInsertable 

func (p *UpdateEdgeRequest) GetInsertable() bool

func (*UpdateEdgeRequest) GetPartID 

func (p *UpdateEdgeRequest) GetPartID() nebula.PartitionID

func (*UpdateEdgeRequest) GetReturnProps 

func (p *UpdateEdgeRequest) GetReturnProps() [][]byte

func (*UpdateEdgeRequest) GetSpaceID 

func (p *UpdateEdgeRequest) GetSpaceID() nebula.GraphSpaceID

func (*UpdateEdgeRequest) GetUpdatedProps 

func (p *UpdateEdgeRequest) GetUpdatedProps() []*UpdatedProp

func (*UpdateEdgeRequest) IsSetCommon 

func (p *UpdateEdgeRequest) IsSetCommon() bool

func (*UpdateEdgeRequest) IsSetCondition 

func (p *UpdateEdgeRequest) IsSetCondition() bool

func (*UpdateEdgeRequest) IsSetEdgeKey 

func (p *UpdateEdgeRequest) IsSetEdgeKey() bool

func (*UpdateEdgeRequest) IsSetInsertable 

func (p *UpdateEdgeRequest) IsSetInsertable() bool

func (*UpdateEdgeRequest) IsSetReturnProps 

func (p *UpdateEdgeRequest) IsSetReturnProps() bool

func (*UpdateEdgeRequest) LogValue 

func (p *UpdateEdgeRequest) LogValue() slog.Value

func (*UpdateEdgeRequest) Read 

func (p *UpdateEdgeRequest) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateEdgeRequest) ReadField1 

func (p *UpdateEdgeRequest) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateEdgeRequest) ReadField2 

func (p *UpdateEdgeRequest) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateEdgeRequest) ReadField3 

func (p *UpdateEdgeRequest) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateEdgeRequest) ReadField4 

func (p *UpdateEdgeRequest) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateEdgeRequest) ReadField5 

func (p *UpdateEdgeRequest) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateEdgeRequest) ReadField6 

func (p *UpdateEdgeRequest) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateEdgeRequest) ReadField7 

func (p *UpdateEdgeRequest) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateEdgeRequest) ReadField8 

func (p *UpdateEdgeRequest) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateEdgeRequest) String 

func (p *UpdateEdgeRequest) String() string

func (*UpdateEdgeRequest) Validate 

func (p *UpdateEdgeRequest) Validate() error

func (*UpdateEdgeRequest) Write 

func (p *UpdateEdgeRequest) Write(ctx context.Context, oprot thrift.TProtocol) error

type UpdateResponse 

type UpdateResponse struct {
	Result_ *ResponseCommon `thrift:"result,1,required" db:"result" json:"result"`
	Props   *nebula.DataSet `thrift:"props,2" db:"props" json:"props,omitempty"`
}

Attributes:

  • Result_
  • Props
var GraphStorageServiceChainUpdateEdgeResult_Success_DEFAULT *UpdateResponse
var GraphStorageServiceUpdateEdgeResult_Success_DEFAULT *UpdateResponse
var GraphStorageServiceUpdateVertexResult_Success_DEFAULT *UpdateResponse
var InternalStorageServiceChainUpdateEdgeResult_Success_DEFAULT *UpdateResponse

func NewUpdateResponse 

func NewUpdateResponse() *UpdateResponse

func (*UpdateResponse) Equals 

func (p *UpdateResponse) Equals(other *UpdateResponse) bool

func (*UpdateResponse) GetProps 

func (p *UpdateResponse) GetProps() *nebula.DataSet

func (*UpdateResponse) GetResult_ 

func (p *UpdateResponse) GetResult_() *ResponseCommon

func (*UpdateResponse) IsSetProps 

func (p *UpdateResponse) IsSetProps() bool

func (*UpdateResponse) IsSetResult_ 

func (p *UpdateResponse) IsSetResult_() bool

func (*UpdateResponse) LogValue 

func (p *UpdateResponse) LogValue() slog.Value

func (*UpdateResponse) Read 

func (p *UpdateResponse) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateResponse) ReadField1 

func (p *UpdateResponse) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateResponse) ReadField2 

func (p *UpdateResponse) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateResponse) String 

func (p *UpdateResponse) String() string

func (*UpdateResponse) Validate 

func (p *UpdateResponse) Validate() error

func (*UpdateResponse) Write 

func (p *UpdateResponse) Write(ctx context.Context, oprot thrift.TProtocol) error

type UpdateVertexRequest 

type UpdateVertexRequest struct {
	SpaceID      nebula.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID       nebula.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	VertexID     *nebula.Value       `thrift:"vertex_id,3" db:"vertex_id" json:"vertex_id"`
	TagID        nebula.TagID        `thrift:"tag_id,4,required" db:"tag_id" json:"tag_id"`
	UpdatedProps []*UpdatedProp      `thrift:"updated_props,5" db:"updated_props" json:"updated_props"`
	Insertable   bool                `thrift:"insertable,6" db:"insertable" json:"insertable"`
	ReturnProps  [][]byte            `thrift:"return_props,7" db:"return_props" json:"return_props,omitempty"`
	Condition    []byte              `thrift:"condition,8" db:"condition" json:"condition,omitempty"`
	Common       *RequestCommon      `thrift:"common,9" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • PartID
  • VertexID
  • TagID
  • UpdatedProps
  • Insertable
  • ReturnProps
  • Condition
  • Common
var GraphStorageServiceUpdateVertexArgs_Req_DEFAULT *UpdateVertexRequest

func NewUpdateVertexRequest 

func NewUpdateVertexRequest() *UpdateVertexRequest

func (*UpdateVertexRequest) Equals 

func (p *UpdateVertexRequest) Equals(other *UpdateVertexRequest) bool

func (*UpdateVertexRequest) GetCommon 

func (p *UpdateVertexRequest) GetCommon() *RequestCommon

func (*UpdateVertexRequest) GetCondition 

func (p *UpdateVertexRequest) GetCondition() []byte

func (*UpdateVertexRequest) GetInsertable 

func (p *UpdateVertexRequest) GetInsertable() bool

func (*UpdateVertexRequest) GetPartID 

func (p *UpdateVertexRequest) GetPartID() nebula.PartitionID

func (*UpdateVertexRequest) GetReturnProps 

func (p *UpdateVertexRequest) GetReturnProps() [][]byte

func (*UpdateVertexRequest) GetSpaceID 

func (p *UpdateVertexRequest) GetSpaceID() nebula.GraphSpaceID

func (*UpdateVertexRequest) GetTagID 

func (p *UpdateVertexRequest) GetTagID() nebula.TagID

func (*UpdateVertexRequest) GetUpdatedProps 

func (p *UpdateVertexRequest) GetUpdatedProps() []*UpdatedProp

func (*UpdateVertexRequest) GetVertexID 

func (p *UpdateVertexRequest) GetVertexID() *nebula.Value

func (*UpdateVertexRequest) IsSetCommon 

func (p *UpdateVertexRequest) IsSetCommon() bool

func (*UpdateVertexRequest) IsSetCondition 

func (p *UpdateVertexRequest) IsSetCondition() bool

func (*UpdateVertexRequest) IsSetInsertable 

func (p *UpdateVertexRequest) IsSetInsertable() bool

func (*UpdateVertexRequest) IsSetReturnProps 

func (p *UpdateVertexRequest) IsSetReturnProps() bool

func (*UpdateVertexRequest) IsSetVertexID 

func (p *UpdateVertexRequest) IsSetVertexID() bool

func (*UpdateVertexRequest) LogValue 

func (p *UpdateVertexRequest) LogValue() slog.Value

func (*UpdateVertexRequest) Read 

func (p *UpdateVertexRequest) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateVertexRequest) ReadField1 

func (p *UpdateVertexRequest) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateVertexRequest) ReadField2 

func (p *UpdateVertexRequest) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateVertexRequest) ReadField3 

func (p *UpdateVertexRequest) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateVertexRequest) ReadField4 

func (p *UpdateVertexRequest) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateVertexRequest) ReadField5 

func (p *UpdateVertexRequest) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateVertexRequest) ReadField6 

func (p *UpdateVertexRequest) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateVertexRequest) ReadField7 

func (p *UpdateVertexRequest) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateVertexRequest) ReadField8 

func (p *UpdateVertexRequest) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateVertexRequest) ReadField9 

func (p *UpdateVertexRequest) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdateVertexRequest) String 

func (p *UpdateVertexRequest) String() string

func (*UpdateVertexRequest) Validate 

func (p *UpdateVertexRequest) Validate() error

func (*UpdateVertexRequest) Write 

func (p *UpdateVertexRequest) Write(ctx context.Context, oprot thrift.TProtocol) error

type UpdatedProp 

type UpdatedProp struct {
	Name  []byte `thrift:"name,1,required" db:"name" json:"name"`
	Value []byte `thrift:"value,2,required" db:"value" json:"value"`
}

Attributes:

  • Name
  • Value

func NewUpdatedProp 

func NewUpdatedProp() *UpdatedProp

func (*UpdatedProp) Equals 

func (p *UpdatedProp) Equals(other *UpdatedProp) bool

func (*UpdatedProp) GetName 

func (p *UpdatedProp) GetName() []byte

func (*UpdatedProp) GetValue 

func (p *UpdatedProp) GetValue() []byte

func (*UpdatedProp) LogValue 

func (p *UpdatedProp) LogValue() slog.Value

func (*UpdatedProp) Read 

func (p *UpdatedProp) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdatedProp) ReadField1 

func (p *UpdatedProp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdatedProp) ReadField2 

func (p *UpdatedProp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*UpdatedProp) String 

func (p *UpdatedProp) String() string

func (*UpdatedProp) Validate 

func (p *UpdatedProp) Validate() error

func (*UpdatedProp) Write 

func (p *UpdatedProp) Write(ctx context.Context, oprot thrift.TProtocol) error

type VertexProp 

type VertexProp struct {
	Tag   nebula.TagID `thrift:"tag,1" db:"tag" json:"tag"`
	Props [][]byte     `thrift:"props,2" db:"props" json:"props"`
}

Attributes:

  • Tag
  • Props

func NewVertexProp 

func NewVertexProp() *VertexProp

func (*VertexProp) Equals 

func (p *VertexProp) Equals(other *VertexProp) bool

func (*VertexProp) GetProps 

func (p *VertexProp) GetProps() [][]byte

func (*VertexProp) GetTag 

func (p *VertexProp) GetTag() nebula.TagID

func (*VertexProp) LogValue 

func (p *VertexProp) LogValue() slog.Value

func (*VertexProp) Read 

func (p *VertexProp) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*VertexProp) ReadField1 

func (p *VertexProp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*VertexProp) ReadField2 

func (p *VertexProp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*VertexProp) String 

func (p *VertexProp) String() string

func (*VertexProp) Validate 

func (p *VertexProp) Validate() error

func (*VertexProp) Write 

func (p *VertexProp) Write(ctx context.Context, oprot thrift.TProtocol) error

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.