storage

package
v2.6.0 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2021 License: Apache-2.0 Imports: 7 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AddAdminTaskRequest_Concurrency_DEFAULT int32
View Source 
var AddLearnerReq_Learner_DEFAULT *nebula0.HostAddr
View Source 
var AdminExecResp_Stats_DEFAULT *meta1.StatsItem
View Source 
var CatchUpDataReq_Target_DEFAULT *nebula0.HostAddr
View Source 
var ChainAddEdgesRequest_EdgeVersion_DEFAULT int64
View Source 
var ChainUpdateEdgeRequest_EdgeVersion_DEFAULT int64
View Source 
var DelTags_Id_DEFAULT *nebula0.Value
View Source 
var EdgeDirectionNames = []string{
	"BOTH",
	"IN_EDGE",
	"OUT_EDGE",
}
View Source 
var EdgeDirectionToName = map[EdgeDirection]string{
	EdgeDirection_BOTH:     "BOTH",
	EdgeDirection_IN_EDGE:  "IN_EDGE",
	EdgeDirection_OUT_EDGE: "OUT_EDGE",
}
View Source 
var EdgeDirectionToValue = map[string]EdgeDirection{
	"BOTH":     EdgeDirection_BOTH,
	"IN_EDGE":  EdgeDirection_IN_EDGE,
	"OUT_EDGE": EdgeDirection_OUT_EDGE,
}
View Source 
var EdgeDirectionValues = []EdgeDirection{
	EdgeDirection_BOTH,
	EdgeDirection_IN_EDGE,
	EdgeDirection_OUT_EDGE,
}
View Source 
var EdgeKey_Dst_DEFAULT *nebula0.Value
View Source 
var EdgeKey_Src_DEFAULT *nebula0.Value
View Source 
var EngineSignTypeNames = []string{
	"BLOCK_ON",
	"BLOCK_OFF",
}
View Source 
var EngineSignTypeToName = map[EngineSignType]string{
	EngineSignType_BLOCK_ON:  "BLOCK_ON",
	EngineSignType_BLOCK_OFF: "BLOCK_OFF",
}
View Source 
var EngineSignTypeToValue = map[string]EngineSignType{
	"BLOCK_ON":  EngineSignType_BLOCK_ON,
	"BLOCK_OFF": EngineSignType_BLOCK_OFF,
}
View Source 
var EngineSignTypeValues = []EngineSignType{
	EngineSignType_BLOCK_ON,
	EngineSignType_BLOCK_OFF,
}
View Source 
var GetNeighborsResponse_Vertices_DEFAULT *nebula0.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 *nebula0.DataSet
View Source 
var GetUUIDResp_Id_DEFAULT *nebula0.Value
View Source 
var GoUnusedProtection__ int
View Source 
var IndexColumnHint_BeginValue_DEFAULT *nebula0.Value
View Source 
var IndexColumnHint_EndValue_DEFAULT *nebula0.Value
View Source 
var IndexSpec_SchemaID_DEFAULT *nebula0.SchemaID
View Source 
var InternalTxnRequest_EdgeVer_DEFAULT map[nebula0.PartitionID][]int64
View Source 
var ListClusterInfoResp_Dir_DEFAULT *nebula0.DirInfo
View Source 
var LookupIndexRequest_Limit_DEFAULT int64
View Source 
var LookupIndexRequest_ReturnColumns_DEFAULT [][]byte
View Source 
var LookupIndexResp_Data_DEFAULT *nebula0.DataSet
View Source 
var MemberChangeReq_Peer_DEFAULT *nebula0.HostAddr
View Source 
var NewVertex__Id_DEFAULT *nebula0.Value
View Source 
var OrderDirectionNames = []string{
	"ASCENDING",
	"DESCENDING",
}
View Source 
var OrderDirectionToName = map[OrderDirection]string{
	OrderDirection_ASCENDING:  "ASCENDING",
	OrderDirection_DESCENDING: "DESCENDING",
}
View Source 
var OrderDirectionToValue = map[string]OrderDirection{
	"ASCENDING":  OrderDirection_ASCENDING,
	"DESCENDING": OrderDirection_DESCENDING,
}
View Source 
var OrderDirectionValues = []OrderDirection{
	OrderDirection_ASCENDING,
	OrderDirection_DESCENDING,
}
View Source 
var PartitionResult__Leader_DEFAULT *nebula0.HostAddr
View Source 
var RequestCommon_PlanID_DEFAULT nebula0.ExecutionPlanID
View Source 
var RequestCommon_ProfileDetail_DEFAULT bool
View Source 
var RequestCommon_SessionID_DEFAULT nebula0.SessionID
View Source 
var ResponseCommon_LatencyDetailUs_DEFAULT map[string]int32
View Source 
var ScanEdgeRequest_Cursor_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 ScanEdgeResponse_EdgeData_DEFAULT *nebula0.DataSet
View Source 
var ScanEdgeResponse_NextCursor_DEFAULT []byte
View Source 
var ScanTypeNames = []string{
	"PREFIX",
	"RANGE",
}
View Source 
var ScanTypeToName = map[ScanType]string{
	ScanType_PREFIX: "PREFIX",
	ScanType_RANGE:  "RANGE",
}
View Source 
var ScanTypeToValue = map[string]ScanType{
	"PREFIX": ScanType_PREFIX,
	"RANGE":  ScanType_RANGE,
}
View Source 
var ScanTypeValues = []ScanType{
	ScanType_PREFIX,
	ScanType_RANGE,
}
View Source 
var ScanVertexRequest_Cursor_DEFAULT []byte
View Source 
var ScanVertexRequest_EndTime_DEFAULT int64
View Source 
var ScanVertexRequest_Filter_DEFAULT []byte
View Source 
var ScanVertexRequest_StartTime_DEFAULT int64
View Source 
var ScanVertexResponse_NextCursor_DEFAULT []byte
View Source 
var ScanVertexResponse_VertexData_DEFAULT *nebula0.DataSet
View Source 
var StatTypeNames = []string{
	"SUM",
	"COUNT",
	"AVG",
	"MAX",
	"MIN",
}
View Source 
var StatTypeToName = map[StatType]string{
	StatType_SUM:   "SUM",
	StatType_COUNT: "COUNT",
	StatType_AVG:   "AVG",
	StatType_MAX:   "MAX",
	StatType_MIN:   "MIN",
}
View Source 
var StatTypeToValue = map[string]StatType{
	"SUM":   StatType_SUM,
	"COUNT": StatType_COUNT,
	"AVG":   StatType_AVG,
	"MAX":   StatType_MAX,
	"MIN":   StatType_MIN,
}
View Source 
var StatTypeValues = []StatType{
	StatType_SUM,
	StatType_COUNT,
	StatType_AVG,
	StatType_MAX,
	StatType_MIN,
}
View Source 
var TaskPara_Parts_DEFAULT []nebula0.PartitionID
View Source 
var TaskPara_TaskSpecficParas_DEFAULT [][]byte
View Source 
var TransLeaderReq_NewLeader__DEFAULT *nebula0.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_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 *nebula0.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 *nebula0.Value

Functions

This section is empty.

Types

type AddAdminTaskRequest 

type AddAdminTaskRequest struct {
	Cmd         meta1.AdminCmd `thrift:"cmd,1" db:"cmd" json:"cmd"`
	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"`
	Concurrency *int32         `thrift:"concurrency,5" db:"concurrency" json:"concurrency,omitempty"`
}

Attributes:

  • Cmd
  • JobID
  • TaskID
  • Para
  • Concurrency
var StorageAdminServiceAddAdminTaskArgs_Req_DEFAULT *AddAdminTaskRequest

func NewAddAdminTaskRequest 

func NewAddAdminTaskRequest() *AddAdminTaskRequest

func (*AddAdminTaskRequest) GetCmd 

func (p *AddAdminTaskRequest) GetCmd() meta1.AdminCmd

func (*AddAdminTaskRequest) GetConcurrency 

func (p *AddAdminTaskRequest) GetConcurrency() int32

func (*AddAdminTaskRequest) GetJobID 

func (p *AddAdminTaskRequest) GetJobID() int32

func (*AddAdminTaskRequest) GetPara 

func (p *AddAdminTaskRequest) GetPara() *TaskPara

func (*AddAdminTaskRequest) GetTaskID 

func (p *AddAdminTaskRequest) GetTaskID() int32

func (*AddAdminTaskRequest) IsSetConcurrency 

func (p *AddAdminTaskRequest) IsSetConcurrency() bool

func (*AddAdminTaskRequest) IsSetPara 

func (p *AddAdminTaskRequest) IsSetPara() bool

func (*AddAdminTaskRequest) Read 

func (p *AddAdminTaskRequest) Read(iprot thrift.Protocol) error

func (*AddAdminTaskRequest) ReadField1 

func (p *AddAdminTaskRequest) ReadField1(iprot thrift.Protocol) error

func (*AddAdminTaskRequest) ReadField2 

func (p *AddAdminTaskRequest) ReadField2(iprot thrift.Protocol) error

func (*AddAdminTaskRequest) ReadField3 

func (p *AddAdminTaskRequest) ReadField3(iprot thrift.Protocol) error

func (*AddAdminTaskRequest) ReadField4 

func (p *AddAdminTaskRequest) ReadField4(iprot thrift.Protocol) error

func (*AddAdminTaskRequest) ReadField5 

func (p *AddAdminTaskRequest) ReadField5(iprot thrift.Protocol) error

func (*AddAdminTaskRequest) String 

func (p *AddAdminTaskRequest) String() string

func (*AddAdminTaskRequest) Write 

func (p *AddAdminTaskRequest) Write(oprot thrift.Protocol) error

type AddEdgesRequest 

type AddEdgesRequest struct {
	SpaceID     nebula0.GraphSpaceID                `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts       map[nebula0.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"`
	Common      *RequestCommon                      `thrift:"common,5" db:"common" json:"common,omitempty"`
}

Attributes:

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

func NewAddEdgesRequest 

func NewAddEdgesRequest() *AddEdgesRequest

func (*AddEdgesRequest) GetCommon added in v2.6.0 

func (p *AddEdgesRequest) GetCommon() *RequestCommon

func (*AddEdgesRequest) GetIfNotExists 

func (p *AddEdgesRequest) GetIfNotExists() bool

func (*AddEdgesRequest) GetParts 

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

func (*AddEdgesRequest) GetPropNames 

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

func (*AddEdgesRequest) GetSpaceID 

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

func (*AddEdgesRequest) IsSetCommon added in v2.6.0 

func (p *AddEdgesRequest) IsSetCommon() bool

func (*AddEdgesRequest) Read 

func (p *AddEdgesRequest) Read(iprot thrift.Protocol) error

func (*AddEdgesRequest) ReadField1 

func (p *AddEdgesRequest) ReadField1(iprot thrift.Protocol) error

func (*AddEdgesRequest) ReadField2 

func (p *AddEdgesRequest) ReadField2(iprot thrift.Protocol) error

func (*AddEdgesRequest) ReadField3 

func (p *AddEdgesRequest) ReadField3(iprot thrift.Protocol) error

func (*AddEdgesRequest) ReadField4 

func (p *AddEdgesRequest) ReadField4(iprot thrift.Protocol) error

func (*AddEdgesRequest) ReadField5 added in v2.6.0 

func (p *AddEdgesRequest) ReadField5(iprot thrift.Protocol) error

func (*AddEdgesRequest) String 

func (p *AddEdgesRequest) String() string

func (*AddEdgesRequest) Write 

func (p *AddEdgesRequest) Write(oprot thrift.Protocol) error

type AddLearnerReq 

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

Attributes:

  • SpaceID
  • PartID
  • Learner
var StorageAdminServiceAddLearnerArgs_Req_DEFAULT *AddLearnerReq

func NewAddLearnerReq 

func NewAddLearnerReq() *AddLearnerReq

func (*AddLearnerReq) GetLearner 

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

func (*AddLearnerReq) GetPartID 

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

func (*AddLearnerReq) GetSpaceID 

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

func (*AddLearnerReq) IsSetLearner 

func (p *AddLearnerReq) IsSetLearner() bool

func (*AddLearnerReq) Read 

func (p *AddLearnerReq) Read(iprot thrift.Protocol) error

func (*AddLearnerReq) ReadField1 

func (p *AddLearnerReq) ReadField1(iprot thrift.Protocol) error

func (*AddLearnerReq) ReadField2 

func (p *AddLearnerReq) ReadField2(iprot thrift.Protocol) error

func (*AddLearnerReq) ReadField3 

func (p *AddLearnerReq) ReadField3(iprot thrift.Protocol) error

func (*AddLearnerReq) String 

func (p *AddLearnerReq) String() string

func (*AddLearnerReq) Write 

func (p *AddLearnerReq) Write(oprot thrift.Protocol) error

type AddPartReq 

type AddPartReq struct {
	SpaceID   nebula0.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID    nebula0.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	AsLearner bool                 `thrift:"as_learner,3" db:"as_learner" json:"as_learner"`
	Peers     []*nebula0.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) GetAsLearner 

func (p *AddPartReq) GetAsLearner() bool

func (*AddPartReq) GetPartID 

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

func (*AddPartReq) GetPeers 

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

func (*AddPartReq) GetSpaceID 

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

func (*AddPartReq) Read 

func (p *AddPartReq) Read(iprot thrift.Protocol) error

func (*AddPartReq) ReadField1 

func (p *AddPartReq) ReadField1(iprot thrift.Protocol) error

func (*AddPartReq) ReadField2 

func (p *AddPartReq) ReadField2(iprot thrift.Protocol) error

func (*AddPartReq) ReadField3 

func (p *AddPartReq) ReadField3(iprot thrift.Protocol) error

func (*AddPartReq) ReadField4 

func (p *AddPartReq) ReadField4(iprot thrift.Protocol) error

func (*AddPartReq) String 

func (p *AddPartReq) String() string

func (*AddPartReq) Write 

func (p *AddPartReq) Write(oprot thrift.Protocol) error

type AddVerticesRequest 

type AddVerticesRequest struct {
	SpaceID     nebula0.GraphSpaceID                  `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts       map[nebula0.PartitionID][]*NewVertex_ `thrift:"parts,2" db:"parts" json:"parts"`
	PropNames   map[nebula0.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"`
	Common      *RequestCommon                        `thrift:"common,5" db:"common" json:"common,omitempty"`
}

Attributes:

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

func NewAddVerticesRequest 

func NewAddVerticesRequest() *AddVerticesRequest

func (*AddVerticesRequest) GetCommon added in v2.6.0 

func (p *AddVerticesRequest) GetCommon() *RequestCommon

func (*AddVerticesRequest) GetIfNotExists 

func (p *AddVerticesRequest) GetIfNotExists() bool

func (*AddVerticesRequest) GetParts 

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

func (*AddVerticesRequest) GetPropNames 

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

func (*AddVerticesRequest) GetSpaceID 

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

func (*AddVerticesRequest) IsSetCommon added in v2.6.0 

func (p *AddVerticesRequest) IsSetCommon() bool

func (*AddVerticesRequest) Read 

func (p *AddVerticesRequest) Read(iprot thrift.Protocol) error

func (*AddVerticesRequest) ReadField1 

func (p *AddVerticesRequest) ReadField1(iprot thrift.Protocol) error

func (*AddVerticesRequest) ReadField2 

func (p *AddVerticesRequest) ReadField2(iprot thrift.Protocol) error

func (*AddVerticesRequest) ReadField3 

func (p *AddVerticesRequest) ReadField3(iprot thrift.Protocol) error

func (*AddVerticesRequest) ReadField4 

func (p *AddVerticesRequest) ReadField4(iprot thrift.Protocol) error

func (*AddVerticesRequest) ReadField5 added in v2.6.0 

func (p *AddVerticesRequest) ReadField5(iprot thrift.Protocol) error

func (*AddVerticesRequest) String 

func (p *AddVerticesRequest) String() string

func (*AddVerticesRequest) Write 

func (p *AddVerticesRequest) Write(oprot thrift.Protocol) error

type AdminExecResp 

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

Attributes:

  • Result_
  • Stats
var StorageAdminServiceAddAdminTaskResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceAddLearnerResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceAddPartResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceBlockingWritesResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceCheckPeersResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceDropCheckpointResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceMemberChangeResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceRebuildEdgeIndexResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceRebuildTagIndexResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceRemovePartResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceStopAdminTaskResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceTransLeaderResult_Success_DEFAULT *AdminExecResp
var StorageAdminServiceWaitingForCatchUpDataResult_Success_DEFAULT *AdminExecResp

func NewAdminExecResp 

func NewAdminExecResp() *AdminExecResp

func (*AdminExecResp) GetResult_ 

func (p *AdminExecResp) GetResult_() *ResponseCommon

func (*AdminExecResp) GetStats added in v2.6.0 

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

func (*AdminExecResp) IsSetResult_ 

func (p *AdminExecResp) IsSetResult_() bool

func (*AdminExecResp) IsSetStats added in v2.6.0 

func (p *AdminExecResp) IsSetStats() bool

func (*AdminExecResp) Read 

func (p *AdminExecResp) Read(iprot thrift.Protocol) error

func (*AdminExecResp) ReadField1 

func (p *AdminExecResp) ReadField1(iprot thrift.Protocol) error

func (*AdminExecResp) ReadField2 

func (p *AdminExecResp) ReadField2(iprot thrift.Protocol) error

func (*AdminExecResp) String 

func (p *AdminExecResp) String() string

func (*AdminExecResp) Write 

func (p *AdminExecResp) Write(oprot thrift.Protocol) error

type BlockingSignRequest 

type BlockingSignRequest struct {
	SpaceID nebula0.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Sign    EngineSignType       `thrift:"sign,2,required" db:"sign" json:"sign"`
}

Attributes:

  • SpaceID
  • Sign
var StorageAdminServiceBlockingWritesArgs_Req_DEFAULT *BlockingSignRequest

func NewBlockingSignRequest 

func NewBlockingSignRequest() *BlockingSignRequest

func (*BlockingSignRequest) GetSign 

func (p *BlockingSignRequest) GetSign() EngineSignType

func (*BlockingSignRequest) GetSpaceID 

func (p *BlockingSignRequest) GetSpaceID() nebula0.GraphSpaceID

func (*BlockingSignRequest) Read 

func (p *BlockingSignRequest) Read(iprot thrift.Protocol) error

func (*BlockingSignRequest) ReadField1 

func (p *BlockingSignRequest) ReadField1(iprot thrift.Protocol) error

func (*BlockingSignRequest) ReadField2 

func (p *BlockingSignRequest) ReadField2(iprot thrift.Protocol) error

func (*BlockingSignRequest) String 

func (p *BlockingSignRequest) String() string

func (*BlockingSignRequest) Write 

func (p *BlockingSignRequest) Write(oprot thrift.Protocol) error

type CatchUpDataReq 

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

Attributes:

  • SpaceID
  • PartID
  • Target
var StorageAdminServiceWaitingForCatchUpDataArgs_Req_DEFAULT *CatchUpDataReq

func NewCatchUpDataReq 

func NewCatchUpDataReq() *CatchUpDataReq

func (*CatchUpDataReq) GetPartID 

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

func (*CatchUpDataReq) GetSpaceID 

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

func (*CatchUpDataReq) GetTarget 

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

func (*CatchUpDataReq) IsSetTarget 

func (p *CatchUpDataReq) IsSetTarget() bool

func (*CatchUpDataReq) Read 

func (p *CatchUpDataReq) Read(iprot thrift.Protocol) error

func (*CatchUpDataReq) ReadField1 

func (p *CatchUpDataReq) ReadField1(iprot thrift.Protocol) error

func (*CatchUpDataReq) ReadField2 

func (p *CatchUpDataReq) ReadField2(iprot thrift.Protocol) error

func (*CatchUpDataReq) ReadField3 

func (p *CatchUpDataReq) ReadField3(iprot thrift.Protocol) error

func (*CatchUpDataReq) String 

func (p *CatchUpDataReq) String() string

func (*CatchUpDataReq) Write 

func (p *CatchUpDataReq) Write(oprot thrift.Protocol) error

type ChainAddEdgesRequest added in v2.6.0 

type ChainAddEdgesRequest struct {
	SpaceID     nebula0.GraphSpaceID                `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts       map[nebula0.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

func NewChainAddEdgesRequest added in v2.6.0 

func NewChainAddEdgesRequest() *ChainAddEdgesRequest

func (*ChainAddEdgesRequest) GetEdgeVersion added in v2.6.0 

func (p *ChainAddEdgesRequest) GetEdgeVersion() int64

func (*ChainAddEdgesRequest) GetIfNotExists added in v2.6.0 

func (p *ChainAddEdgesRequest) GetIfNotExists() bool

func (*ChainAddEdgesRequest) GetParts added in v2.6.0 

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

func (*ChainAddEdgesRequest) GetPropNames added in v2.6.0 

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

func (*ChainAddEdgesRequest) GetSpaceID added in v2.6.0 

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

func (*ChainAddEdgesRequest) GetTerm added in v2.6.0 

func (p *ChainAddEdgesRequest) GetTerm() int64

func (*ChainAddEdgesRequest) IsSetEdgeVersion added in v2.6.0 

func (p *ChainAddEdgesRequest) IsSetEdgeVersion() bool

func (*ChainAddEdgesRequest) Read added in v2.6.0 

func (p *ChainAddEdgesRequest) Read(iprot thrift.Protocol) error

func (*ChainAddEdgesRequest) ReadField1 added in v2.6.0 

func (p *ChainAddEdgesRequest) ReadField1(iprot thrift.Protocol) error

func (*ChainAddEdgesRequest) ReadField2 added in v2.6.0 

func (p *ChainAddEdgesRequest) ReadField2(iprot thrift.Protocol) error

func (*ChainAddEdgesRequest) ReadField3 added in v2.6.0 

func (p *ChainAddEdgesRequest) ReadField3(iprot thrift.Protocol) error

func (*ChainAddEdgesRequest) ReadField4 added in v2.6.0 

func (p *ChainAddEdgesRequest) ReadField4(iprot thrift.Protocol) error

func (*ChainAddEdgesRequest) ReadField5 added in v2.6.0 

func (p *ChainAddEdgesRequest) ReadField5(iprot thrift.Protocol) error

func (*ChainAddEdgesRequest) ReadField6 added in v2.6.0 

func (p *ChainAddEdgesRequest) ReadField6(iprot thrift.Protocol) error

func (*ChainAddEdgesRequest) String added in v2.6.0 

func (p *ChainAddEdgesRequest) String() string

func (*ChainAddEdgesRequest) Write added in v2.6.0 

func (p *ChainAddEdgesRequest) Write(oprot thrift.Protocol) error

type ChainUpdateEdgeRequest added in v2.6.0 

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           nebula0.GraphSpaceID  `thrift:"space_id,4" db:"space_id" json:"space_id"`
	Parts             []nebula0.PartitionID `thrift:"parts,5,required" db:"parts" json:"parts"`
}

Attributes:

  • UpdateEdgeRequest
  • Term
  • EdgeVersion
  • SpaceID
  • Parts

func NewChainUpdateEdgeRequest added in v2.6.0 

func NewChainUpdateEdgeRequest() *ChainUpdateEdgeRequest

func (*ChainUpdateEdgeRequest) GetEdgeVersion added in v2.6.0 

func (p *ChainUpdateEdgeRequest) GetEdgeVersion() int64

func (*ChainUpdateEdgeRequest) GetParts added in v2.6.0 

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

func (*ChainUpdateEdgeRequest) GetSpaceID added in v2.6.0 

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

func (*ChainUpdateEdgeRequest) GetTerm added in v2.6.0 

func (p *ChainUpdateEdgeRequest) GetTerm() int64

func (*ChainUpdateEdgeRequest) GetUpdateEdgeRequest added in v2.6.0 

func (p *ChainUpdateEdgeRequest) GetUpdateEdgeRequest() *UpdateEdgeRequest

func (*ChainUpdateEdgeRequest) IsSetEdgeVersion added in v2.6.0 

func (p *ChainUpdateEdgeRequest) IsSetEdgeVersion() bool

func (*ChainUpdateEdgeRequest) IsSetUpdateEdgeRequest added in v2.6.0 

func (p *ChainUpdateEdgeRequest) IsSetUpdateEdgeRequest() bool

func (*ChainUpdateEdgeRequest) Read added in v2.6.0 

func (p *ChainUpdateEdgeRequest) Read(iprot thrift.Protocol) error

func (*ChainUpdateEdgeRequest) ReadField1 added in v2.6.0 

func (p *ChainUpdateEdgeRequest) ReadField1(iprot thrift.Protocol) error

func (*ChainUpdateEdgeRequest) ReadField2 added in v2.6.0 

func (p *ChainUpdateEdgeRequest) ReadField2(iprot thrift.Protocol) error

func (*ChainUpdateEdgeRequest) ReadField3 added in v2.6.0 

func (p *ChainUpdateEdgeRequest) ReadField3(iprot thrift.Protocol) error

func (*ChainUpdateEdgeRequest) ReadField4 added in v2.6.0 

func (p *ChainUpdateEdgeRequest) ReadField4(iprot thrift.Protocol) error

func (*ChainUpdateEdgeRequest) ReadField5 added in v2.6.0 

func (p *ChainUpdateEdgeRequest) ReadField5(iprot thrift.Protocol) error

func (*ChainUpdateEdgeRequest) String added in v2.6.0 

func (p *ChainUpdateEdgeRequest) String() string

func (*ChainUpdateEdgeRequest) Write added in v2.6.0 

func (p *ChainUpdateEdgeRequest) Write(oprot thrift.Protocol) error

type CheckPeersReq 

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

Attributes:

  • SpaceID
  • PartID
  • Peers
var StorageAdminServiceCheckPeersArgs_Req_DEFAULT *CheckPeersReq

func NewCheckPeersReq 

func NewCheckPeersReq() *CheckPeersReq

func (*CheckPeersReq) GetPartID 

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

func (*CheckPeersReq) GetPeers 

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

func (*CheckPeersReq) GetSpaceID 

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

func (*CheckPeersReq) Read 

func (p *CheckPeersReq) Read(iprot thrift.Protocol) error

func (*CheckPeersReq) ReadField1 

func (p *CheckPeersReq) ReadField1(iprot thrift.Protocol) error

func (*CheckPeersReq) ReadField2 

func (p *CheckPeersReq) ReadField2(iprot thrift.Protocol) error

func (*CheckPeersReq) ReadField3 

func (p *CheckPeersReq) ReadField3(iprot thrift.Protocol) error

func (*CheckPeersReq) String 

func (p *CheckPeersReq) String() string

func (*CheckPeersReq) Write 

func (p *CheckPeersReq) Write(oprot thrift.Protocol) error

type CreateCPRequest 

type CreateCPRequest struct {
	SpaceID nebula0.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Name    []byte               `thrift:"name,2" db:"name" json:"name"`
}

Attributes:

  • SpaceID
  • Name
var StorageAdminServiceCreateCheckpointArgs_Req_DEFAULT *CreateCPRequest

func NewCreateCPRequest 

func NewCreateCPRequest() *CreateCPRequest

func (*CreateCPRequest) GetName 

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

func (*CreateCPRequest) GetSpaceID 

func (p *CreateCPRequest) GetSpaceID() nebula0.GraphSpaceID

func (*CreateCPRequest) Read 

func (p *CreateCPRequest) Read(iprot thrift.Protocol) error

func (*CreateCPRequest) ReadField1 

func (p *CreateCPRequest) ReadField1(iprot thrift.Protocol) error

func (*CreateCPRequest) ReadField2 

func (p *CreateCPRequest) ReadField2(iprot thrift.Protocol) error

func (*CreateCPRequest) String 

func (p *CreateCPRequest) String() string

func (*CreateCPRequest) Write 

func (p *CreateCPRequest) Write(oprot thrift.Protocol) error

type CreateCPResp 

type CreateCPResp struct {
	Result_ *ResponseCommon           `thrift:"result,1,required" db:"result" json:"result"`
	Info    []*nebula0.CheckpointInfo `thrift:"info,2" db:"info" json:"info"`
}

Attributes:

  • Result_
  • Info
var StorageAdminServiceCreateCheckpointResult_Success_DEFAULT *CreateCPResp

func NewCreateCPResp 

func NewCreateCPResp() *CreateCPResp

func (*CreateCPResp) GetInfo 

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

func (*CreateCPResp) GetResult_ 

func (p *CreateCPResp) GetResult_() *ResponseCommon

func (*CreateCPResp) IsSetResult_ 

func (p *CreateCPResp) IsSetResult_() bool

func (*CreateCPResp) Read 

func (p *CreateCPResp) Read(iprot thrift.Protocol) error

func (*CreateCPResp) ReadField1 

func (p *CreateCPResp) ReadField1(iprot thrift.Protocol) error

func (*CreateCPResp) ReadField2 

func (p *CreateCPResp) ReadField2(iprot thrift.Protocol) error

func (*CreateCPResp) String 

func (p *CreateCPResp) String() string

func (*CreateCPResp) Write 

func (p *CreateCPResp) Write(oprot thrift.Protocol) error

type DelTags added in v2.6.0 

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

Attributes:

  • Id
  • Tags

func NewDelTags added in v2.6.0 

func NewDelTags() *DelTags

func (*DelTags) GetId added in v2.6.0 

func (p *DelTags) GetId() *nebula0.Value

func (*DelTags) GetTags added in v2.6.0 

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

func (*DelTags) IsSetId added in v2.6.0 

func (p *DelTags) IsSetId() bool

func (*DelTags) Read added in v2.6.0 

func (p *DelTags) Read(iprot thrift.Protocol) error

func (*DelTags) ReadField1 added in v2.6.0 

func (p *DelTags) ReadField1(iprot thrift.Protocol) error

func (*DelTags) ReadField2 added in v2.6.0 

func (p *DelTags) ReadField2(iprot thrift.Protocol) error

func (*DelTags) String added in v2.6.0 

func (p *DelTags) String() string

func (*DelTags) Write added in v2.6.0 

func (p *DelTags) Write(oprot thrift.Protocol) error

type DeleteEdgesRequest 

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

Attributes:

  • SpaceID
  • Parts
  • Common
var GraphStorageServiceDeleteEdgesArgs_Req_DEFAULT *DeleteEdgesRequest

func NewDeleteEdgesRequest 

func NewDeleteEdgesRequest() *DeleteEdgesRequest

func (*DeleteEdgesRequest) GetCommon added in v2.6.0 

func (p *DeleteEdgesRequest) GetCommon() *RequestCommon

func (*DeleteEdgesRequest) GetParts 

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

func (*DeleteEdgesRequest) GetSpaceID 

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

func (*DeleteEdgesRequest) IsSetCommon added in v2.6.0 

func (p *DeleteEdgesRequest) IsSetCommon() bool

func (*DeleteEdgesRequest) Read 

func (p *DeleteEdgesRequest) Read(iprot thrift.Protocol) error

func (*DeleteEdgesRequest) ReadField1 

func (p *DeleteEdgesRequest) ReadField1(iprot thrift.Protocol) error

func (*DeleteEdgesRequest) ReadField2 

func (p *DeleteEdgesRequest) ReadField2(iprot thrift.Protocol) error

func (*DeleteEdgesRequest) ReadField3 added in v2.6.0 

func (p *DeleteEdgesRequest) ReadField3(iprot thrift.Protocol) error

func (*DeleteEdgesRequest) String 

func (p *DeleteEdgesRequest) String() string

func (*DeleteEdgesRequest) Write 

func (p *DeleteEdgesRequest) Write(oprot thrift.Protocol) error

type DeleteTagsRequest added in v2.6.0 

type DeleteTagsRequest struct {
	SpaceID nebula0.GraphSpaceID               `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts   map[nebula0.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 added in v2.6.0 

func NewDeleteTagsRequest() *DeleteTagsRequest

func (*DeleteTagsRequest) GetCommon added in v2.6.0 

func (p *DeleteTagsRequest) GetCommon() *RequestCommon

func (*DeleteTagsRequest) GetParts added in v2.6.0 

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

func (*DeleteTagsRequest) GetSpaceID added in v2.6.0 

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

func (*DeleteTagsRequest) IsSetCommon added in v2.6.0 

func (p *DeleteTagsRequest) IsSetCommon() bool

func (*DeleteTagsRequest) Read added in v2.6.0 

func (p *DeleteTagsRequest) Read(iprot thrift.Protocol) error

func (*DeleteTagsRequest) ReadField1 added in v2.6.0 

func (p *DeleteTagsRequest) ReadField1(iprot thrift.Protocol) error

func (*DeleteTagsRequest) ReadField2 added in v2.6.0 

func (p *DeleteTagsRequest) ReadField2(iprot thrift.Protocol) error

func (*DeleteTagsRequest) ReadField3 added in v2.6.0 

func (p *DeleteTagsRequest) ReadField3(iprot thrift.Protocol) error

func (*DeleteTagsRequest) String added in v2.6.0 

func (p *DeleteTagsRequest) String() string

func (*DeleteTagsRequest) Write added in v2.6.0 

func (p *DeleteTagsRequest) Write(oprot thrift.Protocol) error

type DeleteVerticesRequest 

type DeleteVerticesRequest struct {
	SpaceID nebula0.GraphSpaceID                     `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts   map[nebula0.PartitionID][]*nebula0.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) GetCommon added in v2.6.0 

func (p *DeleteVerticesRequest) GetCommon() *RequestCommon

func (*DeleteVerticesRequest) GetParts 

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

func (*DeleteVerticesRequest) GetSpaceID 

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

func (*DeleteVerticesRequest) IsSetCommon added in v2.6.0 

func (p *DeleteVerticesRequest) IsSetCommon() bool

func (*DeleteVerticesRequest) Read 

func (p *DeleteVerticesRequest) Read(iprot thrift.Protocol) error

func (*DeleteVerticesRequest) ReadField1 

func (p *DeleteVerticesRequest) ReadField1(iprot thrift.Protocol) error

func (*DeleteVerticesRequest) ReadField2 

func (p *DeleteVerticesRequest) ReadField2(iprot thrift.Protocol) error

func (*DeleteVerticesRequest) ReadField3 added in v2.6.0 

func (p *DeleteVerticesRequest) ReadField3(iprot thrift.Protocol) error

func (*DeleteVerticesRequest) String 

func (p *DeleteVerticesRequest) String() string

func (*DeleteVerticesRequest) Write 

func (p *DeleteVerticesRequest) Write(oprot thrift.Protocol) error

type DropCPRequest 

type DropCPRequest struct {
	SpaceID nebula0.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Name    []byte               `thrift:"name,2" db:"name" json:"name"`
}

Attributes:

  • SpaceID
  • Name
var StorageAdminServiceDropCheckpointArgs_Req_DEFAULT *DropCPRequest

func NewDropCPRequest 

func NewDropCPRequest() *DropCPRequest

func (*DropCPRequest) GetName 

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

func (*DropCPRequest) GetSpaceID 

func (p *DropCPRequest) GetSpaceID() nebula0.GraphSpaceID

func (*DropCPRequest) Read 

func (p *DropCPRequest) Read(iprot thrift.Protocol) error

func (*DropCPRequest) ReadField1 

func (p *DropCPRequest) ReadField1(iprot thrift.Protocol) error

func (*DropCPRequest) ReadField2 

func (p *DropCPRequest) ReadField2(iprot thrift.Protocol) error

func (*DropCPRequest) String 

func (p *DropCPRequest) String() string

func (*DropCPRequest) Write 

func (p *DropCPRequest) Write(oprot thrift.Protocol) 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) String 

func (p EdgeDirection) String() string

type EdgeKey 

type EdgeKey struct {
	Src      *nebula0.Value      `thrift:"src,1" db:"src" json:"src"`
	EdgeType nebula0.EdgeType    `thrift:"edge_type,2" db:"edge_type" json:"edge_type"`
	Ranking  nebula0.EdgeRanking `thrift:"ranking,3" db:"ranking" json:"ranking"`
	Dst      *nebula0.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) GetDst 

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

func (*EdgeKey) GetEdgeType 

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

func (*EdgeKey) GetRanking 

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

func (*EdgeKey) GetSrc 

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

func (*EdgeKey) IsSetDst 

func (p *EdgeKey) IsSetDst() bool

func (*EdgeKey) IsSetSrc 

func (p *EdgeKey) IsSetSrc() bool

func (*EdgeKey) Read 

func (p *EdgeKey) Read(iprot thrift.Protocol) error

func (*EdgeKey) ReadField1 

func (p *EdgeKey) ReadField1(iprot thrift.Protocol) error

func (*EdgeKey) ReadField2 

func (p *EdgeKey) ReadField2(iprot thrift.Protocol) error

func (*EdgeKey) ReadField3 

func (p *EdgeKey) ReadField3(iprot thrift.Protocol) error

func (*EdgeKey) ReadField4 

func (p *EdgeKey) ReadField4(iprot thrift.Protocol) error

func (*EdgeKey) String 

func (p *EdgeKey) String() string

func (*EdgeKey) Write 

func (p *EdgeKey) Write(oprot thrift.Protocol) error

type EdgeProp 

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

Attributes:

  • Type
  • Props
var ScanEdgeRequest_ReturnColumns_DEFAULT *EdgeProp

func NewEdgeProp 

func NewEdgeProp() *EdgeProp

func (*EdgeProp) GetProps 

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

func (*EdgeProp) GetType 

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

func (*EdgeProp) Read 

func (p *EdgeProp) Read(iprot thrift.Protocol) error

func (*EdgeProp) ReadField1 

func (p *EdgeProp) ReadField1(iprot thrift.Protocol) error

func (*EdgeProp) ReadField2 

func (p *EdgeProp) ReadField2(iprot thrift.Protocol) error

func (*EdgeProp) String 

func (p *EdgeProp) String() string

func (*EdgeProp) Write 

func (p *EdgeProp) Write(oprot thrift.Protocol) 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) String 

func (p EngineSignType) String() string

type ExecResponse 

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

Attributes:

  • Result_
var GeneralStorageServicePutResult_Success_DEFAULT *ExecResponse
var GeneralStorageServiceRemoveResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceAddEdgesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceAddVerticesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceChainAddEdgesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceDeleteEdgesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceDeleteTagsResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceDeleteVerticesResult_Success_DEFAULT *ExecResponse

func NewExecResponse 

func NewExecResponse() *ExecResponse

func (*ExecResponse) GetResult_ 

func (p *ExecResponse) GetResult_() *ResponseCommon

func (*ExecResponse) IsSetResult_ 

func (p *ExecResponse) IsSetResult_() bool

func (*ExecResponse) Read 

func (p *ExecResponse) Read(iprot thrift.Protocol) error

func (*ExecResponse) ReadField1 

func (p *ExecResponse) ReadField1(iprot thrift.Protocol) error

func (*ExecResponse) String 

func (p *ExecResponse) String() string

func (*ExecResponse) Write 

func (p *ExecResponse) Write(oprot thrift.Protocol) 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) GetAlias 

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

func (*Expr) GetExpr 

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

func (*Expr) Read 

func (p *Expr) Read(iprot thrift.Protocol) error

func (*Expr) ReadField1 

func (p *Expr) ReadField1(iprot thrift.Protocol) error

func (*Expr) ReadField2 

func (p *Expr) ReadField2(iprot thrift.Protocol) error

func (*Expr) String 

func (p *Expr) String() string

func (*Expr) Write 

func (p *Expr) Write(oprot thrift.Protocol) error

type GeneralStorageService 

type GeneralStorageService interface {
	// 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 GeneralStorageServiceChannelClient 

type GeneralStorageServiceChannelClient struct {
	RequestChannel thrift.RequestChannel
}

func NewGeneralStorageServiceChannelClient 

func NewGeneralStorageServiceChannelClient(channel thrift.RequestChannel) *GeneralStorageServiceChannelClient

func (*GeneralStorageServiceChannelClient) Close 

func (c *GeneralStorageServiceChannelClient) Close() error

func (*GeneralStorageServiceChannelClient) Get 

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

Parameters:

  • Req

func (*GeneralStorageServiceChannelClient) IsOpen 

func (c *GeneralStorageServiceChannelClient) IsOpen() bool

func (*GeneralStorageServiceChannelClient) Open 

func (c *GeneralStorageServiceChannelClient) Open() error

func (*GeneralStorageServiceChannelClient) Put 

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

Parameters:

  • Req

func (*GeneralStorageServiceChannelClient) Remove 

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

Parameters:

  • Req

type GeneralStorageServiceClient 

type GeneralStorageServiceClient struct {
	GeneralStorageServiceClientInterface
	CC thrift.ClientConn
}

func NewGeneralStorageServiceClient 

func NewGeneralStorageServiceClient(t thrift.Transport, iprot thrift.Protocol, oprot thrift.Protocol) *GeneralStorageServiceClient

func NewGeneralStorageServiceClientFactory 

func NewGeneralStorageServiceClientFactory(t thrift.Transport, f thrift.ProtocolFactory) *GeneralStorageServiceClient

func NewGeneralStorageServiceClientProtocol 

func NewGeneralStorageServiceClientProtocol(prot thrift.Protocol) *GeneralStorageServiceClient

func (*GeneralStorageServiceClient) Close 

func (client *GeneralStorageServiceClient) Close() error

func (*GeneralStorageServiceClient) Get 

func (p *GeneralStorageServiceClient) Get(req *KVGetRequest) (_r *KVGetResponse, err error)

Parameters:

  • Req

func (*GeneralStorageServiceClient) IsOpen 

func (client *GeneralStorageServiceClient) IsOpen() bool

func (*GeneralStorageServiceClient) Open 

func (client *GeneralStorageServiceClient) Open() error

func (*GeneralStorageServiceClient) Put 

func (p *GeneralStorageServiceClient) Put(req *KVPutRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GeneralStorageServiceClient) Remove 

func (p *GeneralStorageServiceClient) Remove(req *KVRemoveRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

type GeneralStorageServiceClientInterface 

type GeneralStorageServiceClientInterface interface {
	thrift.ClientInterface
	// Parameters:
	//  - Req
	Get(req *KVGetRequest) (_r *KVGetResponse, err error)
	// Parameters:
	//  - Req
	Put(req *KVPutRequest) (_r *ExecResponse, err error)
	// Parameters:
	//  - Req
	Remove(req *KVRemoveRequest) (_r *ExecResponse, err error)
}

type GeneralStorageServiceGetArgs 

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

Attributes:

  • Req

func NewGeneralStorageServiceGetArgs 

func NewGeneralStorageServiceGetArgs() *GeneralStorageServiceGetArgs

func (*GeneralStorageServiceGetArgs) GetReq 

func (p *GeneralStorageServiceGetArgs) GetReq() *KVGetRequest

func (*GeneralStorageServiceGetArgs) IsSetReq 

func (p *GeneralStorageServiceGetArgs) IsSetReq() bool

func (*GeneralStorageServiceGetArgs) Read 

func (p *GeneralStorageServiceGetArgs) Read(iprot thrift.Protocol) error

func (*GeneralStorageServiceGetArgs) ReadField1 

func (p *GeneralStorageServiceGetArgs) ReadField1(iprot thrift.Protocol) error

func (*GeneralStorageServiceGetArgs) String 

func (p *GeneralStorageServiceGetArgs) String() string

func (*GeneralStorageServiceGetArgs) Write 

func (p *GeneralStorageServiceGetArgs) Write(oprot thrift.Protocol) error

type GeneralStorageServiceGetResult 

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

Attributes:

  • Success

func NewGeneralStorageServiceGetResult 

func NewGeneralStorageServiceGetResult() *GeneralStorageServiceGetResult

func (*GeneralStorageServiceGetResult) GetSuccess 

func (p *GeneralStorageServiceGetResult) GetSuccess() *KVGetResponse

func (*GeneralStorageServiceGetResult) IsSetSuccess 

func (p *GeneralStorageServiceGetResult) IsSetSuccess() bool

func (*GeneralStorageServiceGetResult) Read 

func (p *GeneralStorageServiceGetResult) Read(iprot thrift.Protocol) error

func (*GeneralStorageServiceGetResult) ReadField0 

func (p *GeneralStorageServiceGetResult) ReadField0(iprot thrift.Protocol) error

func (*GeneralStorageServiceGetResult) String 

func (p *GeneralStorageServiceGetResult) String() string

func (*GeneralStorageServiceGetResult) Write 

func (p *GeneralStorageServiceGetResult) Write(oprot thrift.Protocol) error

type GeneralStorageServiceProcessor 

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

func NewGeneralStorageServiceProcessor 

func NewGeneralStorageServiceProcessor(handler GeneralStorageService) *GeneralStorageServiceProcessor

func (*GeneralStorageServiceProcessor) AddToProcessorMap 

func (p *GeneralStorageServiceProcessor) AddToProcessorMap(key string, processor thrift.ProcessorFunctionContext)

func (*GeneralStorageServiceProcessor) GetProcessorFunctionContext 

func (p *GeneralStorageServiceProcessor) GetProcessorFunctionContext(key string) (processor thrift.ProcessorFunctionContext, err error)

func (*GeneralStorageServiceProcessor) ProcessorMap 

func (p *GeneralStorageServiceProcessor) ProcessorMap() map[string]thrift.ProcessorFunctionContext

type GeneralStorageServicePutArgs 

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

Attributes:

  • Req

func NewGeneralStorageServicePutArgs 

func NewGeneralStorageServicePutArgs() *GeneralStorageServicePutArgs

func (*GeneralStorageServicePutArgs) GetReq 

func (p *GeneralStorageServicePutArgs) GetReq() *KVPutRequest

func (*GeneralStorageServicePutArgs) IsSetReq 

func (p *GeneralStorageServicePutArgs) IsSetReq() bool

func (*GeneralStorageServicePutArgs) Read 

func (p *GeneralStorageServicePutArgs) Read(iprot thrift.Protocol) error

func (*GeneralStorageServicePutArgs) ReadField1 

func (p *GeneralStorageServicePutArgs) ReadField1(iprot thrift.Protocol) error

func (*GeneralStorageServicePutArgs) String 

func (p *GeneralStorageServicePutArgs) String() string

func (*GeneralStorageServicePutArgs) Write 

func (p *GeneralStorageServicePutArgs) Write(oprot thrift.Protocol) error

type GeneralStorageServicePutResult 

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

Attributes:

  • Success

func NewGeneralStorageServicePutResult 

func NewGeneralStorageServicePutResult() *GeneralStorageServicePutResult

func (*GeneralStorageServicePutResult) GetSuccess 

func (p *GeneralStorageServicePutResult) GetSuccess() *ExecResponse

func (*GeneralStorageServicePutResult) IsSetSuccess 

func (p *GeneralStorageServicePutResult) IsSetSuccess() bool

func (*GeneralStorageServicePutResult) Read 

func (p *GeneralStorageServicePutResult) Read(iprot thrift.Protocol) error

func (*GeneralStorageServicePutResult) ReadField0 

func (p *GeneralStorageServicePutResult) ReadField0(iprot thrift.Protocol) error

func (*GeneralStorageServicePutResult) String 

func (p *GeneralStorageServicePutResult) String() string

func (*GeneralStorageServicePutResult) Write 

func (p *GeneralStorageServicePutResult) Write(oprot thrift.Protocol) error

type GeneralStorageServiceRemoveArgs 

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

Attributes:

  • Req

func NewGeneralStorageServiceRemoveArgs 

func NewGeneralStorageServiceRemoveArgs() *GeneralStorageServiceRemoveArgs

func (*GeneralStorageServiceRemoveArgs) GetReq 

func (p *GeneralStorageServiceRemoveArgs) GetReq() *KVRemoveRequest

func (*GeneralStorageServiceRemoveArgs) IsSetReq 

func (p *GeneralStorageServiceRemoveArgs) IsSetReq() bool

func (*GeneralStorageServiceRemoveArgs) Read 

func (p *GeneralStorageServiceRemoveArgs) Read(iprot thrift.Protocol) error

func (*GeneralStorageServiceRemoveArgs) ReadField1 

func (p *GeneralStorageServiceRemoveArgs) ReadField1(iprot thrift.Protocol) error

func (*GeneralStorageServiceRemoveArgs) String 

func (p *GeneralStorageServiceRemoveArgs) String() string

func (*GeneralStorageServiceRemoveArgs) Write 

func (p *GeneralStorageServiceRemoveArgs) Write(oprot thrift.Protocol) error

type GeneralStorageServiceRemoveResult 

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

Attributes:

  • Success

func NewGeneralStorageServiceRemoveResult 

func NewGeneralStorageServiceRemoveResult() *GeneralStorageServiceRemoveResult

func (*GeneralStorageServiceRemoveResult) GetSuccess 

func (p *GeneralStorageServiceRemoveResult) GetSuccess() *ExecResponse

func (*GeneralStorageServiceRemoveResult) IsSetSuccess 

func (p *GeneralStorageServiceRemoveResult) IsSetSuccess() bool

func (*GeneralStorageServiceRemoveResult) Read 

func (p *GeneralStorageServiceRemoveResult) Read(iprot thrift.Protocol) error

func (*GeneralStorageServiceRemoveResult) ReadField0 

func (p *GeneralStorageServiceRemoveResult) ReadField0(iprot thrift.Protocol) error

func (*GeneralStorageServiceRemoveResult) String 

func (p *GeneralStorageServiceRemoveResult) String() string

func (*GeneralStorageServiceRemoveResult) Write 

func (p *GeneralStorageServiceRemoveResult) Write(oprot thrift.Protocol) error

type GeneralStorageServiceThreadsafeClient 

type GeneralStorageServiceThreadsafeClient struct {
	GeneralStorageServiceClientInterface
	CC thrift.ClientConn
	Mu sync.Mutex
}

func NewGeneralStorageServiceThreadsafeClient 

func NewGeneralStorageServiceThreadsafeClient(t thrift.Transport, iprot thrift.Protocol, oprot thrift.Protocol) *GeneralStorageServiceThreadsafeClient

func NewGeneralStorageServiceThreadsafeClientFactory 

func NewGeneralStorageServiceThreadsafeClientFactory(t thrift.Transport, f thrift.ProtocolFactory) *GeneralStorageServiceThreadsafeClient

func NewGeneralStorageServiceThreadsafeClientProtocol 

func NewGeneralStorageServiceThreadsafeClientProtocol(prot thrift.Protocol) *GeneralStorageServiceThreadsafeClient

func (*GeneralStorageServiceThreadsafeClient) Close 

func (client *GeneralStorageServiceThreadsafeClient) Close() error

func (*GeneralStorageServiceThreadsafeClient) Get 

func (p *GeneralStorageServiceThreadsafeClient) Get(req *KVGetRequest) (_r *KVGetResponse, err error)

Parameters:

  • Req

func (*GeneralStorageServiceThreadsafeClient) IsOpen 

func (client *GeneralStorageServiceThreadsafeClient) IsOpen() bool

func (*GeneralStorageServiceThreadsafeClient) Open 

func (client *GeneralStorageServiceThreadsafeClient) Open() error

func (*GeneralStorageServiceThreadsafeClient) Put 

func (p *GeneralStorageServiceThreadsafeClient) Put(req *KVPutRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GeneralStorageServiceThreadsafeClient) Remove 

func (p *GeneralStorageServiceThreadsafeClient) Remove(req *KVRemoveRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

type GetLeaderPartsResp 

type GetLeaderPartsResp struct {
	Result_     *ResponseCommon                                `thrift:"result,1,required" db:"result" json:"result"`
	LeaderParts map[nebula0.GraphSpaceID][]nebula0.PartitionID `thrift:"leader_parts,2" db:"leader_parts" json:"leader_parts"`
}

Attributes:

  • Result_
  • LeaderParts
var StorageAdminServiceGetLeaderPartsResult_Success_DEFAULT *GetLeaderPartsResp

func NewGetLeaderPartsResp 

func NewGetLeaderPartsResp() *GetLeaderPartsResp

func (*GetLeaderPartsResp) GetLeaderParts 

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

func (*GetLeaderPartsResp) GetResult_ 

func (p *GetLeaderPartsResp) GetResult_() *ResponseCommon

func (*GetLeaderPartsResp) IsSetResult_ 

func (p *GetLeaderPartsResp) IsSetResult_() bool

func (*GetLeaderPartsResp) Read 

func (p *GetLeaderPartsResp) Read(iprot thrift.Protocol) error

func (*GetLeaderPartsResp) ReadField1 

func (p *GetLeaderPartsResp) ReadField1(iprot thrift.Protocol) error

func (*GetLeaderPartsResp) ReadField2 

func (p *GetLeaderPartsResp) ReadField2(iprot thrift.Protocol) error

func (*GetLeaderPartsResp) String 

func (p *GetLeaderPartsResp) String() string

func (*GetLeaderPartsResp) Write 

func (p *GetLeaderPartsResp) Write(oprot thrift.Protocol) error

type GetLeaderReq 

type GetLeaderReq struct {
}
var StorageAdminServiceGetLeaderPartsArgs_Req_DEFAULT *GetLeaderReq

func NewGetLeaderReq 

func NewGetLeaderReq() *GetLeaderReq

func (*GetLeaderReq) Read 

func (p *GetLeaderReq) Read(iprot thrift.Protocol) error

func (*GetLeaderReq) String 

func (p *GetLeaderReq) String() string

func (*GetLeaderReq) Write 

func (p *GetLeaderReq) Write(oprot thrift.Protocol) error

type GetNeighborsRequest 

type GetNeighborsRequest struct {
	SpaceID      nebula0.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[nebula0.PartitionID][]*nebula0.Row `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) GetColumnNames 

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

func (*GetNeighborsRequest) GetCommon added in v2.6.0 

func (p *GetNeighborsRequest) GetCommon() *RequestCommon

func (*GetNeighborsRequest) GetParts 

func (p *GetNeighborsRequest) GetParts() map[nebula0.PartitionID][]*nebula0.Row

func (*GetNeighborsRequest) GetSpaceID 

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

func (*GetNeighborsRequest) GetTraverseSpec 

func (p *GetNeighborsRequest) GetTraverseSpec() *TraverseSpec

func (*GetNeighborsRequest) IsSetCommon added in v2.6.0 

func (p *GetNeighborsRequest) IsSetCommon() bool

func (*GetNeighborsRequest) IsSetTraverseSpec 

func (p *GetNeighborsRequest) IsSetTraverseSpec() bool

func (*GetNeighborsRequest) Read 

func (p *GetNeighborsRequest) Read(iprot thrift.Protocol) error

func (*GetNeighborsRequest) ReadField1 

func (p *GetNeighborsRequest) ReadField1(iprot thrift.Protocol) error

func (*GetNeighborsRequest) ReadField2 

func (p *GetNeighborsRequest) ReadField2(iprot thrift.Protocol) error

func (*GetNeighborsRequest) ReadField3 

func (p *GetNeighborsRequest) ReadField3(iprot thrift.Protocol) error

func (*GetNeighborsRequest) ReadField4 

func (p *GetNeighborsRequest) ReadField4(iprot thrift.Protocol) error

func (*GetNeighborsRequest) ReadField5 added in v2.6.0 

func (p *GetNeighborsRequest) ReadField5(iprot thrift.Protocol) error

func (*GetNeighborsRequest) String 

func (p *GetNeighborsRequest) String() string

func (*GetNeighborsRequest) Write 

func (p *GetNeighborsRequest) Write(oprot thrift.Protocol) error

type GetNeighborsResponse 

type GetNeighborsResponse struct {
	Result_  *ResponseCommon  `thrift:"result,1,required" db:"result" json:"result"`
	Vertices *nebula0.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) GetResult_ 

func (p *GetNeighborsResponse) GetResult_() *ResponseCommon

func (*GetNeighborsResponse) GetVertices 

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

func (*GetNeighborsResponse) IsSetResult_ 

func (p *GetNeighborsResponse) IsSetResult_() bool

func (*GetNeighborsResponse) IsSetVertices 

func (p *GetNeighborsResponse) IsSetVertices() bool

func (*GetNeighborsResponse) Read 

func (p *GetNeighborsResponse) Read(iprot thrift.Protocol) error

func (*GetNeighborsResponse) ReadField1 

func (p *GetNeighborsResponse) ReadField1(iprot thrift.Protocol) error

func (*GetNeighborsResponse) ReadField2 

func (p *GetNeighborsResponse) ReadField2(iprot thrift.Protocol) error

func (*GetNeighborsResponse) String 

func (p *GetNeighborsResponse) String() string

func (*GetNeighborsResponse) Write 

func (p *GetNeighborsResponse) Write(oprot thrift.Protocol) error

type GetPropRequest 

type GetPropRequest struct {
	SpaceID     nebula0.GraphSpaceID                   `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts       map[nebula0.PartitionID][]*nebula0.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) GetCommon added in v2.6.0 

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[nebula0.PartitionID][]*nebula0.Row

func (*GetPropRequest) GetSpaceID 

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

func (*GetPropRequest) GetVertexProps 

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

func (*GetPropRequest) IsSetCommon added in v2.6.0 

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

func (p *GetPropRequest) Read(iprot thrift.Protocol) error

func (*GetPropRequest) ReadField1 

func (p *GetPropRequest) ReadField1(iprot thrift.Protocol) error

func (*GetPropRequest) ReadField10 added in v2.6.0 

func (p *GetPropRequest) ReadField10(iprot thrift.Protocol) error

func (*GetPropRequest) ReadField2 

func (p *GetPropRequest) ReadField2(iprot thrift.Protocol) error

func (*GetPropRequest) ReadField3 

func (p *GetPropRequest) ReadField3(iprot thrift.Protocol) error

func (*GetPropRequest) ReadField4 

func (p *GetPropRequest) ReadField4(iprot thrift.Protocol) error

func (*GetPropRequest) ReadField5 

func (p *GetPropRequest) ReadField5(iprot thrift.Protocol) error

func (*GetPropRequest) ReadField6 

func (p *GetPropRequest) ReadField6(iprot thrift.Protocol) error

func (*GetPropRequest) ReadField7 

func (p *GetPropRequest) ReadField7(iprot thrift.Protocol) error

func (*GetPropRequest) ReadField8 

func (p *GetPropRequest) ReadField8(iprot thrift.Protocol) error

func (*GetPropRequest) ReadField9 

func (p *GetPropRequest) ReadField9(iprot thrift.Protocol) error

func (*GetPropRequest) String 

func (p *GetPropRequest) String() string

func (*GetPropRequest) Write 

func (p *GetPropRequest) Write(oprot thrift.Protocol) error

type GetPropResponse 

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

Attributes:

  • Result_
  • Props
var GraphStorageServiceGetPropsResult_Success_DEFAULT *GetPropResponse

func NewGetPropResponse 

func NewGetPropResponse() *GetPropResponse

func (*GetPropResponse) GetProps 

func (p *GetPropResponse) GetProps() *nebula0.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) Read 

func (p *GetPropResponse) Read(iprot thrift.Protocol) error

func (*GetPropResponse) ReadField1 

func (p *GetPropResponse) ReadField1(iprot thrift.Protocol) error

func (*GetPropResponse) ReadField2 

func (p *GetPropResponse) ReadField2(iprot thrift.Protocol) error

func (*GetPropResponse) String 

func (p *GetPropResponse) String() string

func (*GetPropResponse) Write 

func (p *GetPropResponse) Write(oprot thrift.Protocol) error

type GetUUIDReq 

type GetUUIDReq struct {
	SpaceID nebula0.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID  nebula0.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) GetCommon added in v2.6.0 

func (p *GetUUIDReq) GetCommon() *RequestCommon

func (*GetUUIDReq) GetName 

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

func (*GetUUIDReq) GetPartID 

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

func (*GetUUIDReq) GetSpaceID 

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

func (*GetUUIDReq) IsSetCommon added in v2.6.0 

func (p *GetUUIDReq) IsSetCommon() bool

func (*GetUUIDReq) Read 

func (p *GetUUIDReq) Read(iprot thrift.Protocol) error

func (*GetUUIDReq) ReadField1 

func (p *GetUUIDReq) ReadField1(iprot thrift.Protocol) error

func (*GetUUIDReq) ReadField2 

func (p *GetUUIDReq) ReadField2(iprot thrift.Protocol) error

func (*GetUUIDReq) ReadField3 

func (p *GetUUIDReq) ReadField3(iprot thrift.Protocol) error

func (*GetUUIDReq) ReadField4 added in v2.6.0 

func (p *GetUUIDReq) ReadField4(iprot thrift.Protocol) error

func (*GetUUIDReq) String 

func (p *GetUUIDReq) String() string

func (*GetUUIDReq) Write 

func (p *GetUUIDReq) Write(oprot thrift.Protocol) error

type GetUUIDResp 

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

Attributes:

  • Result_
  • Id
var GraphStorageServiceGetUUIDResult_Success_DEFAULT *GetUUIDResp

func NewGetUUIDResp 

func NewGetUUIDResp() *GetUUIDResp

func (*GetUUIDResp) GetId 

func (p *GetUUIDResp) GetId() *nebula0.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) Read 

func (p *GetUUIDResp) Read(iprot thrift.Protocol) error

func (*GetUUIDResp) ReadField1 

func (p *GetUUIDResp) ReadField1(iprot thrift.Protocol) error

func (*GetUUIDResp) ReadField2 

func (p *GetUUIDResp) ReadField2(iprot thrift.Protocol) error

func (*GetUUIDResp) String 

func (p *GetUUIDResp) String() string

func (*GetUUIDResp) Write 

func (p *GetUUIDResp) Write(oprot thrift.Protocol) error

type GraphStorageService 

type GraphStorageService interface {
	// Parameters:
	//  - Req
	GetNeighbors(ctx context.Context, req *GetNeighborsRequest) (_r *GetNeighborsResponse, 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 *ScanVertexResponse, err error)
	// Parameters:
	//  - Req
	ScanEdge(ctx context.Context, req *ScanEdgeRequest) (_r *ScanEdgeResponse, 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)
}

type GraphStorageServiceAddEdgesArgs 

type GraphStorageServiceAddEdgesArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceAddEdgesArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceAddEdgesArgs) ReadField1 

func (p *GraphStorageServiceAddEdgesArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceAddEdgesArgs) String 

func (p *GraphStorageServiceAddEdgesArgs) String() string

func (*GraphStorageServiceAddEdgesArgs) Write 

func (p *GraphStorageServiceAddEdgesArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceAddEdgesResult 

type GraphStorageServiceAddEdgesResult struct {
	thrift.IResponse
	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) Read 

func (p *GraphStorageServiceAddEdgesResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceAddEdgesResult) ReadField0 

func (p *GraphStorageServiceAddEdgesResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceAddEdgesResult) String 

func (p *GraphStorageServiceAddEdgesResult) String() string

func (*GraphStorageServiceAddEdgesResult) Write 

func (p *GraphStorageServiceAddEdgesResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceAddVerticesArgs 

type GraphStorageServiceAddVerticesArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceAddVerticesArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceAddVerticesArgs) ReadField1 

func (p *GraphStorageServiceAddVerticesArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceAddVerticesArgs) String 

func (p *GraphStorageServiceAddVerticesArgs) String() string

func (*GraphStorageServiceAddVerticesArgs) Write 

func (p *GraphStorageServiceAddVerticesArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceAddVerticesResult 

type GraphStorageServiceAddVerticesResult struct {
	thrift.IResponse
	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) Read 

func (p *GraphStorageServiceAddVerticesResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceAddVerticesResult) ReadField0 

func (p *GraphStorageServiceAddVerticesResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceAddVerticesResult) String 

func (p *GraphStorageServiceAddVerticesResult) String() string

func (*GraphStorageServiceAddVerticesResult) Write 

func (p *GraphStorageServiceAddVerticesResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceChainAddEdgesArgs added in v2.6.0 

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

Attributes:

  • Req

func NewGraphStorageServiceChainAddEdgesArgs added in v2.6.0 

func NewGraphStorageServiceChainAddEdgesArgs() *GraphStorageServiceChainAddEdgesArgs

func (*GraphStorageServiceChainAddEdgesArgs) GetReq added in v2.6.0 

func (p *GraphStorageServiceChainAddEdgesArgs) GetReq() *AddEdgesRequest

func (*GraphStorageServiceChainAddEdgesArgs) IsSetReq added in v2.6.0 

func (p *GraphStorageServiceChainAddEdgesArgs) IsSetReq() bool

func (*GraphStorageServiceChainAddEdgesArgs) Read added in v2.6.0 

func (p *GraphStorageServiceChainAddEdgesArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceChainAddEdgesArgs) ReadField1 added in v2.6.0 

func (p *GraphStorageServiceChainAddEdgesArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceChainAddEdgesArgs) String added in v2.6.0 

func (p *GraphStorageServiceChainAddEdgesArgs) String() string

func (*GraphStorageServiceChainAddEdgesArgs) Write added in v2.6.0 

func (p *GraphStorageServiceChainAddEdgesArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceChainAddEdgesResult added in v2.6.0 

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

Attributes:

  • Success

func NewGraphStorageServiceChainAddEdgesResult added in v2.6.0 

func NewGraphStorageServiceChainAddEdgesResult() *GraphStorageServiceChainAddEdgesResult

func (*GraphStorageServiceChainAddEdgesResult) GetSuccess added in v2.6.0 

func (p *GraphStorageServiceChainAddEdgesResult) GetSuccess() *ExecResponse

func (*GraphStorageServiceChainAddEdgesResult) IsSetSuccess added in v2.6.0 

func (p *GraphStorageServiceChainAddEdgesResult) IsSetSuccess() bool

func (*GraphStorageServiceChainAddEdgesResult) Read added in v2.6.0 

func (p *GraphStorageServiceChainAddEdgesResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceChainAddEdgesResult) ReadField0 added in v2.6.0 

func (p *GraphStorageServiceChainAddEdgesResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceChainAddEdgesResult) String added in v2.6.0 

func (p *GraphStorageServiceChainAddEdgesResult) String() string

func (*GraphStorageServiceChainAddEdgesResult) Write added in v2.6.0 

func (p *GraphStorageServiceChainAddEdgesResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceChainUpdateEdgeArgs added in v2.6.0 

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

Attributes:

  • Req

func NewGraphStorageServiceChainUpdateEdgeArgs added in v2.6.0 

func NewGraphStorageServiceChainUpdateEdgeArgs() *GraphStorageServiceChainUpdateEdgeArgs

func (*GraphStorageServiceChainUpdateEdgeArgs) GetReq added in v2.6.0 

func (p *GraphStorageServiceChainUpdateEdgeArgs) GetReq() *UpdateEdgeRequest

func (*GraphStorageServiceChainUpdateEdgeArgs) IsSetReq added in v2.6.0 

func (p *GraphStorageServiceChainUpdateEdgeArgs) IsSetReq() bool

func (*GraphStorageServiceChainUpdateEdgeArgs) Read added in v2.6.0 

func (p *GraphStorageServiceChainUpdateEdgeArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceChainUpdateEdgeArgs) ReadField1 added in v2.6.0 

func (p *GraphStorageServiceChainUpdateEdgeArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceChainUpdateEdgeArgs) String added in v2.6.0 

func (p *GraphStorageServiceChainUpdateEdgeArgs) String() string

func (*GraphStorageServiceChainUpdateEdgeArgs) Write added in v2.6.0 

func (p *GraphStorageServiceChainUpdateEdgeArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceChainUpdateEdgeResult added in v2.6.0 

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

Attributes:

  • Success

func NewGraphStorageServiceChainUpdateEdgeResult added in v2.6.0 

func NewGraphStorageServiceChainUpdateEdgeResult() *GraphStorageServiceChainUpdateEdgeResult

func (*GraphStorageServiceChainUpdateEdgeResult) GetSuccess added in v2.6.0 

func (p *GraphStorageServiceChainUpdateEdgeResult) GetSuccess() *UpdateResponse

func (*GraphStorageServiceChainUpdateEdgeResult) IsSetSuccess added in v2.6.0 

func (p *GraphStorageServiceChainUpdateEdgeResult) IsSetSuccess() bool

func (*GraphStorageServiceChainUpdateEdgeResult) Read added in v2.6.0 

func (p *GraphStorageServiceChainUpdateEdgeResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceChainUpdateEdgeResult) ReadField0 added in v2.6.0 

func (p *GraphStorageServiceChainUpdateEdgeResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceChainUpdateEdgeResult) String added in v2.6.0 

func (p *GraphStorageServiceChainUpdateEdgeResult) String() string

func (*GraphStorageServiceChainUpdateEdgeResult) Write added in v2.6.0 

func (p *GraphStorageServiceChainUpdateEdgeResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceChannelClient 

type GraphStorageServiceChannelClient struct {
	RequestChannel thrift.RequestChannel
}

func NewGraphStorageServiceChannelClient 

func NewGraphStorageServiceChannelClient(channel thrift.RequestChannel) *GraphStorageServiceChannelClient

func (*GraphStorageServiceChannelClient) AddEdges 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) AddVertices 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) ChainAddEdges added in v2.6.0 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) ChainUpdateEdge added in v2.6.0 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) Close 

func (c *GraphStorageServiceChannelClient) Close() error

func (*GraphStorageServiceChannelClient) DeleteEdges 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) DeleteTags added in v2.6.0 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) DeleteVertices 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) GetNeighbors 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) GetProps 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) GetUUID 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) IsOpen 

func (c *GraphStorageServiceChannelClient) IsOpen() bool

func (*GraphStorageServiceChannelClient) LookupAndTraverse 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) LookupIndex 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) Open 

func (c *GraphStorageServiceChannelClient) Open() error

func (*GraphStorageServiceChannelClient) ScanEdge 

func (p *GraphStorageServiceChannelClient) ScanEdge(ctx context.Context, req *ScanEdgeRequest) (_r *ScanEdgeResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) ScanVertex 

func (p *GraphStorageServiceChannelClient) ScanVertex(ctx context.Context, req *ScanVertexRequest) (_r *ScanVertexResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) UpdateEdge 

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) UpdateVertex 

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

Parameters:

  • Req

type GraphStorageServiceClient 

type GraphStorageServiceClient struct {
	GraphStorageServiceClientInterface
	CC thrift.ClientConn
}

func NewGraphStorageServiceClient 

func NewGraphStorageServiceClient(t thrift.Transport, iprot thrift.Protocol, oprot thrift.Protocol) *GraphStorageServiceClient

func NewGraphStorageServiceClientFactory 

func NewGraphStorageServiceClientFactory(t thrift.Transport, f thrift.ProtocolFactory) *GraphStorageServiceClient

func NewGraphStorageServiceClientProtocol 

func NewGraphStorageServiceClientProtocol(prot thrift.Protocol) *GraphStorageServiceClient

func (*GraphStorageServiceClient) AddEdges 

func (p *GraphStorageServiceClient) AddEdges(req *AddEdgesRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) AddVertices 

func (p *GraphStorageServiceClient) AddVertices(req *AddVerticesRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) ChainAddEdges added in v2.6.0 

func (p *GraphStorageServiceClient) ChainAddEdges(req *AddEdgesRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) ChainUpdateEdge added in v2.6.0 

func (p *GraphStorageServiceClient) ChainUpdateEdge(req *UpdateEdgeRequest) (_r *UpdateResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) Close 

func (client *GraphStorageServiceClient) Close() error

func (*GraphStorageServiceClient) DeleteEdges 

func (p *GraphStorageServiceClient) DeleteEdges(req *DeleteEdgesRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) DeleteTags added in v2.6.0 

func (p *GraphStorageServiceClient) DeleteTags(req *DeleteTagsRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) DeleteVertices 

func (p *GraphStorageServiceClient) DeleteVertices(req *DeleteVerticesRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) GetNeighbors 

func (p *GraphStorageServiceClient) GetNeighbors(req *GetNeighborsRequest) (_r *GetNeighborsResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) GetProps 

func (p *GraphStorageServiceClient) GetProps(req *GetPropRequest) (_r *GetPropResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) GetUUID 

func (p *GraphStorageServiceClient) GetUUID(req *GetUUIDReq) (_r *GetUUIDResp, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) IsOpen 

func (client *GraphStorageServiceClient) IsOpen() bool

func (*GraphStorageServiceClient) LookupAndTraverse 

func (p *GraphStorageServiceClient) LookupAndTraverse(req *LookupAndTraverseRequest) (_r *GetNeighborsResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) LookupIndex 

func (p *GraphStorageServiceClient) LookupIndex(req *LookupIndexRequest) (_r *LookupIndexResp, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) Open 

func (client *GraphStorageServiceClient) Open() error

func (*GraphStorageServiceClient) ScanEdge 

func (p *GraphStorageServiceClient) ScanEdge(req *ScanEdgeRequest) (_r *ScanEdgeResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) ScanVertex 

func (p *GraphStorageServiceClient) ScanVertex(req *ScanVertexRequest) (_r *ScanVertexResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) UpdateEdge 

func (p *GraphStorageServiceClient) UpdateEdge(req *UpdateEdgeRequest) (_r *UpdateResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceClient) UpdateVertex 

func (p *GraphStorageServiceClient) UpdateVertex(req *UpdateVertexRequest) (_r *UpdateResponse, err error)

Parameters:

  • Req

type GraphStorageServiceClientInterface 

type GraphStorageServiceClientInterface interface {
	thrift.ClientInterface
	// Parameters:
	//  - Req
	GetNeighbors(req *GetNeighborsRequest) (_r *GetNeighborsResponse, err error)
	// Parameters:
	//  - Req
	GetProps(req *GetPropRequest) (_r *GetPropResponse, err error)
	// Parameters:
	//  - Req
	AddVertices(req *AddVerticesRequest) (_r *ExecResponse, err error)
	// Parameters:
	//  - Req
	AddEdges(req *AddEdgesRequest) (_r *ExecResponse, err error)
	// Parameters:
	//  - Req
	DeleteEdges(req *DeleteEdgesRequest) (_r *ExecResponse, err error)
	// Parameters:
	//  - Req
	DeleteVertices(req *DeleteVerticesRequest) (_r *ExecResponse, err error)
	// Parameters:
	//  - Req
	DeleteTags(req *DeleteTagsRequest) (_r *ExecResponse, err error)
	// Parameters:
	//  - Req
	UpdateVertex(req *UpdateVertexRequest) (_r *UpdateResponse, err error)
	// Parameters:
	//  - Req
	UpdateEdge(req *UpdateEdgeRequest) (_r *UpdateResponse, err error)
	// Parameters:
	//  - Req
	ScanVertex(req *ScanVertexRequest) (_r *ScanVertexResponse, err error)
	// Parameters:
	//  - Req
	ScanEdge(req *ScanEdgeRequest) (_r *ScanEdgeResponse, err error)
	// Parameters:
	//  - Req
	GetUUID(req *GetUUIDReq) (_r *GetUUIDResp, err error)
	// Parameters:
	//  - Req
	LookupIndex(req *LookupIndexRequest) (_r *LookupIndexResp, err error)
	// Parameters:
	//  - Req
	LookupAndTraverse(req *LookupAndTraverseRequest) (_r *GetNeighborsResponse, err error)
	// Parameters:
	//  - Req
	ChainUpdateEdge(req *UpdateEdgeRequest) (_r *UpdateResponse, err error)
	// Parameters:
	//  - Req
	ChainAddEdges(req *AddEdgesRequest) (_r *ExecResponse, err error)
}

type GraphStorageServiceDeleteEdgesArgs 

type GraphStorageServiceDeleteEdgesArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceDeleteEdgesArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceDeleteEdgesArgs) ReadField1 

func (p *GraphStorageServiceDeleteEdgesArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceDeleteEdgesArgs) String 

func (p *GraphStorageServiceDeleteEdgesArgs) String() string

func (*GraphStorageServiceDeleteEdgesArgs) Write 

func (p *GraphStorageServiceDeleteEdgesArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceDeleteEdgesResult 

type GraphStorageServiceDeleteEdgesResult struct {
	thrift.IResponse
	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) Read 

func (p *GraphStorageServiceDeleteEdgesResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceDeleteEdgesResult) ReadField0 

func (p *GraphStorageServiceDeleteEdgesResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceDeleteEdgesResult) String 

func (p *GraphStorageServiceDeleteEdgesResult) String() string

func (*GraphStorageServiceDeleteEdgesResult) Write 

func (p *GraphStorageServiceDeleteEdgesResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceDeleteTagsArgs added in v2.6.0 

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

Attributes:

  • Req

func NewGraphStorageServiceDeleteTagsArgs added in v2.6.0 

func NewGraphStorageServiceDeleteTagsArgs() *GraphStorageServiceDeleteTagsArgs

func (*GraphStorageServiceDeleteTagsArgs) GetReq added in v2.6.0 

func (p *GraphStorageServiceDeleteTagsArgs) GetReq() *DeleteTagsRequest

func (*GraphStorageServiceDeleteTagsArgs) IsSetReq added in v2.6.0 

func (p *GraphStorageServiceDeleteTagsArgs) IsSetReq() bool

func (*GraphStorageServiceDeleteTagsArgs) Read added in v2.6.0 

func (p *GraphStorageServiceDeleteTagsArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceDeleteTagsArgs) ReadField1 added in v2.6.0 

func (p *GraphStorageServiceDeleteTagsArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceDeleteTagsArgs) String added in v2.6.0 

func (p *GraphStorageServiceDeleteTagsArgs) String() string

func (*GraphStorageServiceDeleteTagsArgs) Write added in v2.6.0 

func (p *GraphStorageServiceDeleteTagsArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceDeleteTagsResult added in v2.6.0 

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

Attributes:

  • Success

func NewGraphStorageServiceDeleteTagsResult added in v2.6.0 

func NewGraphStorageServiceDeleteTagsResult() *GraphStorageServiceDeleteTagsResult

func (*GraphStorageServiceDeleteTagsResult) GetSuccess added in v2.6.0 

func (p *GraphStorageServiceDeleteTagsResult) GetSuccess() *ExecResponse

func (*GraphStorageServiceDeleteTagsResult) IsSetSuccess added in v2.6.0 

func (p *GraphStorageServiceDeleteTagsResult) IsSetSuccess() bool

func (*GraphStorageServiceDeleteTagsResult) Read added in v2.6.0 

func (p *GraphStorageServiceDeleteTagsResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceDeleteTagsResult) ReadField0 added in v2.6.0 

func (p *GraphStorageServiceDeleteTagsResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceDeleteTagsResult) String added in v2.6.0 

func (p *GraphStorageServiceDeleteTagsResult) String() string

func (*GraphStorageServiceDeleteTagsResult) Write added in v2.6.0 

func (p *GraphStorageServiceDeleteTagsResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceDeleteVerticesArgs 

type GraphStorageServiceDeleteVerticesArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceDeleteVerticesArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceDeleteVerticesArgs) ReadField1 

func (p *GraphStorageServiceDeleteVerticesArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceDeleteVerticesArgs) String 

func (p *GraphStorageServiceDeleteVerticesArgs) String() string

func (*GraphStorageServiceDeleteVerticesArgs) Write 

func (p *GraphStorageServiceDeleteVerticesArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceDeleteVerticesResult 

type GraphStorageServiceDeleteVerticesResult struct {
	thrift.IResponse
	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) Read 

func (p *GraphStorageServiceDeleteVerticesResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceDeleteVerticesResult) ReadField0 

func (p *GraphStorageServiceDeleteVerticesResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceDeleteVerticesResult) String 

func (p *GraphStorageServiceDeleteVerticesResult) String() string

func (*GraphStorageServiceDeleteVerticesResult) Write 

func (p *GraphStorageServiceDeleteVerticesResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceGetNeighborsArgs 

type GraphStorageServiceGetNeighborsArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceGetNeighborsArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceGetNeighborsArgs) ReadField1 

func (p *GraphStorageServiceGetNeighborsArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceGetNeighborsArgs) String 

func (p *GraphStorageServiceGetNeighborsArgs) String() string

func (*GraphStorageServiceGetNeighborsArgs) Write 

func (p *GraphStorageServiceGetNeighborsArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceGetNeighborsResult 

type GraphStorageServiceGetNeighborsResult struct {
	thrift.IResponse
	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) Read 

func (p *GraphStorageServiceGetNeighborsResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceGetNeighborsResult) ReadField0 

func (p *GraphStorageServiceGetNeighborsResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceGetNeighborsResult) String 

func (p *GraphStorageServiceGetNeighborsResult) String() string

func (*GraphStorageServiceGetNeighborsResult) Write 

func (p *GraphStorageServiceGetNeighborsResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceGetPropsArgs 

type GraphStorageServiceGetPropsArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceGetPropsArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceGetPropsArgs) ReadField1 

func (p *GraphStorageServiceGetPropsArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceGetPropsArgs) String 

func (p *GraphStorageServiceGetPropsArgs) String() string

func (*GraphStorageServiceGetPropsArgs) Write 

func (p *GraphStorageServiceGetPropsArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceGetPropsResult 

type GraphStorageServiceGetPropsResult struct {
	thrift.IResponse
	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) Read 

func (p *GraphStorageServiceGetPropsResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceGetPropsResult) ReadField0 

func (p *GraphStorageServiceGetPropsResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceGetPropsResult) String 

func (p *GraphStorageServiceGetPropsResult) String() string

func (*GraphStorageServiceGetPropsResult) Write 

func (p *GraphStorageServiceGetPropsResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceGetUUIDArgs 

type GraphStorageServiceGetUUIDArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceGetUUIDArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceGetUUIDArgs) ReadField1 

func (p *GraphStorageServiceGetUUIDArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceGetUUIDArgs) String 

func (p *GraphStorageServiceGetUUIDArgs) String() string

func (*GraphStorageServiceGetUUIDArgs) Write 

func (p *GraphStorageServiceGetUUIDArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceGetUUIDResult 

type GraphStorageServiceGetUUIDResult struct {
	thrift.IResponse
	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) Read 

func (p *GraphStorageServiceGetUUIDResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceGetUUIDResult) ReadField0 

func (p *GraphStorageServiceGetUUIDResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceGetUUIDResult) String 

func (p *GraphStorageServiceGetUUIDResult) String() string

func (*GraphStorageServiceGetUUIDResult) Write 

func (p *GraphStorageServiceGetUUIDResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceLookupAndTraverseArgs 

type GraphStorageServiceLookupAndTraverseArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceLookupAndTraverseArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceLookupAndTraverseArgs) ReadField1 

func (p *GraphStorageServiceLookupAndTraverseArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceLookupAndTraverseArgs) String 

func (p *GraphStorageServiceLookupAndTraverseArgs) String() string

func (*GraphStorageServiceLookupAndTraverseArgs) Write 

func (p *GraphStorageServiceLookupAndTraverseArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceLookupAndTraverseResult 

type GraphStorageServiceLookupAndTraverseResult struct {
	thrift.IResponse
	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) Read 

func (p *GraphStorageServiceLookupAndTraverseResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceLookupAndTraverseResult) ReadField0 

func (p *GraphStorageServiceLookupAndTraverseResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceLookupAndTraverseResult) String 

func (p *GraphStorageServiceLookupAndTraverseResult) String() string

func (*GraphStorageServiceLookupAndTraverseResult) Write 

func (p *GraphStorageServiceLookupAndTraverseResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceLookupIndexArgs 

type GraphStorageServiceLookupIndexArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceLookupIndexArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceLookupIndexArgs) ReadField1 

func (p *GraphStorageServiceLookupIndexArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceLookupIndexArgs) String 

func (p *GraphStorageServiceLookupIndexArgs) String() string

func (*GraphStorageServiceLookupIndexArgs) Write 

func (p *GraphStorageServiceLookupIndexArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceLookupIndexResult 

type GraphStorageServiceLookupIndexResult struct {
	thrift.IResponse
	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) Read 

func (p *GraphStorageServiceLookupIndexResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceLookupIndexResult) ReadField0 

func (p *GraphStorageServiceLookupIndexResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceLookupIndexResult) String 

func (p *GraphStorageServiceLookupIndexResult) String() string

func (*GraphStorageServiceLookupIndexResult) Write 

func (p *GraphStorageServiceLookupIndexResult) Write(oprot thrift.Protocol) 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.ProcessorFunctionContext)

func (*GraphStorageServiceProcessor) GetProcessorFunctionContext 

func (p *GraphStorageServiceProcessor) GetProcessorFunctionContext(key string) (processor thrift.ProcessorFunctionContext, err error)

func (*GraphStorageServiceProcessor) ProcessorMap 

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

type GraphStorageServiceScanEdgeArgs 

type GraphStorageServiceScanEdgeArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceScanEdgeArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceScanEdgeArgs) ReadField1 

func (p *GraphStorageServiceScanEdgeArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceScanEdgeArgs) String 

func (p *GraphStorageServiceScanEdgeArgs) String() string

func (*GraphStorageServiceScanEdgeArgs) Write 

func (p *GraphStorageServiceScanEdgeArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceScanEdgeResult 

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

Attributes:

  • Success

func NewGraphStorageServiceScanEdgeResult 

func NewGraphStorageServiceScanEdgeResult() *GraphStorageServiceScanEdgeResult

func (*GraphStorageServiceScanEdgeResult) GetSuccess 

func (p *GraphStorageServiceScanEdgeResult) GetSuccess() *ScanEdgeResponse

func (*GraphStorageServiceScanEdgeResult) IsSetSuccess 

func (p *GraphStorageServiceScanEdgeResult) IsSetSuccess() bool

func (*GraphStorageServiceScanEdgeResult) Read 

func (p *GraphStorageServiceScanEdgeResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceScanEdgeResult) ReadField0 

func (p *GraphStorageServiceScanEdgeResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceScanEdgeResult) String 

func (p *GraphStorageServiceScanEdgeResult) String() string

func (*GraphStorageServiceScanEdgeResult) Write 

func (p *GraphStorageServiceScanEdgeResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceScanVertexArgs 

type GraphStorageServiceScanVertexArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceScanVertexArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceScanVertexArgs) ReadField1 

func (p *GraphStorageServiceScanVertexArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceScanVertexArgs) String 

func (p *GraphStorageServiceScanVertexArgs) String() string

func (*GraphStorageServiceScanVertexArgs) Write 

func (p *GraphStorageServiceScanVertexArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceScanVertexResult 

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

Attributes:

  • Success

func NewGraphStorageServiceScanVertexResult 

func NewGraphStorageServiceScanVertexResult() *GraphStorageServiceScanVertexResult

func (*GraphStorageServiceScanVertexResult) GetSuccess 

func (p *GraphStorageServiceScanVertexResult) GetSuccess() *ScanVertexResponse

func (*GraphStorageServiceScanVertexResult) IsSetSuccess 

func (p *GraphStorageServiceScanVertexResult) IsSetSuccess() bool

func (*GraphStorageServiceScanVertexResult) Read 

func (p *GraphStorageServiceScanVertexResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceScanVertexResult) ReadField0 

func (p *GraphStorageServiceScanVertexResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceScanVertexResult) String 

func (p *GraphStorageServiceScanVertexResult) String() string

func (*GraphStorageServiceScanVertexResult) Write 

func (p *GraphStorageServiceScanVertexResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceThreadsafeClient 

type GraphStorageServiceThreadsafeClient struct {
	GraphStorageServiceClientInterface
	CC thrift.ClientConn
	Mu sync.Mutex
}

func NewGraphStorageServiceThreadsafeClient 

func NewGraphStorageServiceThreadsafeClient(t thrift.Transport, iprot thrift.Protocol, oprot thrift.Protocol) *GraphStorageServiceThreadsafeClient

func NewGraphStorageServiceThreadsafeClientFactory 

func NewGraphStorageServiceThreadsafeClientFactory(t thrift.Transport, f thrift.ProtocolFactory) *GraphStorageServiceThreadsafeClient

func NewGraphStorageServiceThreadsafeClientProtocol 

func NewGraphStorageServiceThreadsafeClientProtocol(prot thrift.Protocol) *GraphStorageServiceThreadsafeClient

func (*GraphStorageServiceThreadsafeClient) AddEdges 

func (p *GraphStorageServiceThreadsafeClient) AddEdges(req *AddEdgesRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) AddVertices 

func (p *GraphStorageServiceThreadsafeClient) AddVertices(req *AddVerticesRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) ChainAddEdges added in v2.6.0 

func (p *GraphStorageServiceThreadsafeClient) ChainAddEdges(req *AddEdgesRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) ChainUpdateEdge added in v2.6.0 

func (p *GraphStorageServiceThreadsafeClient) ChainUpdateEdge(req *UpdateEdgeRequest) (_r *UpdateResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) Close 

func (client *GraphStorageServiceThreadsafeClient) Close() error

func (*GraphStorageServiceThreadsafeClient) DeleteEdges 

func (p *GraphStorageServiceThreadsafeClient) DeleteEdges(req *DeleteEdgesRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) DeleteTags added in v2.6.0 

func (p *GraphStorageServiceThreadsafeClient) DeleteTags(req *DeleteTagsRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) DeleteVertices 

func (p *GraphStorageServiceThreadsafeClient) DeleteVertices(req *DeleteVerticesRequest) (_r *ExecResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) GetNeighbors 

func (p *GraphStorageServiceThreadsafeClient) GetNeighbors(req *GetNeighborsRequest) (_r *GetNeighborsResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) GetProps 

func (p *GraphStorageServiceThreadsafeClient) GetProps(req *GetPropRequest) (_r *GetPropResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) GetUUID 

func (p *GraphStorageServiceThreadsafeClient) GetUUID(req *GetUUIDReq) (_r *GetUUIDResp, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) IsOpen 

func (client *GraphStorageServiceThreadsafeClient) IsOpen() bool

func (*GraphStorageServiceThreadsafeClient) LookupAndTraverse 

func (p *GraphStorageServiceThreadsafeClient) LookupAndTraverse(req *LookupAndTraverseRequest) (_r *GetNeighborsResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) LookupIndex 

func (p *GraphStorageServiceThreadsafeClient) LookupIndex(req *LookupIndexRequest) (_r *LookupIndexResp, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) Open 

func (client *GraphStorageServiceThreadsafeClient) Open() error

func (*GraphStorageServiceThreadsafeClient) ScanEdge 

func (p *GraphStorageServiceThreadsafeClient) ScanEdge(req *ScanEdgeRequest) (_r *ScanEdgeResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) ScanVertex 

func (p *GraphStorageServiceThreadsafeClient) ScanVertex(req *ScanVertexRequest) (_r *ScanVertexResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) UpdateEdge 

func (p *GraphStorageServiceThreadsafeClient) UpdateEdge(req *UpdateEdgeRequest) (_r *UpdateResponse, err error)

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) UpdateVertex 

func (p *GraphStorageServiceThreadsafeClient) UpdateVertex(req *UpdateVertexRequest) (_r *UpdateResponse, err error)

Parameters:

  • Req

type GraphStorageServiceUpdateEdgeArgs 

type GraphStorageServiceUpdateEdgeArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceUpdateEdgeArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceUpdateEdgeArgs) ReadField1 

func (p *GraphStorageServiceUpdateEdgeArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceUpdateEdgeArgs) String 

func (p *GraphStorageServiceUpdateEdgeArgs) String() string

func (*GraphStorageServiceUpdateEdgeArgs) Write 

func (p *GraphStorageServiceUpdateEdgeArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceUpdateEdgeResult 

type GraphStorageServiceUpdateEdgeResult struct {
	thrift.IResponse
	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) Read 

func (p *GraphStorageServiceUpdateEdgeResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceUpdateEdgeResult) ReadField0 

func (p *GraphStorageServiceUpdateEdgeResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceUpdateEdgeResult) String 

func (p *GraphStorageServiceUpdateEdgeResult) String() string

func (*GraphStorageServiceUpdateEdgeResult) Write 

func (p *GraphStorageServiceUpdateEdgeResult) Write(oprot thrift.Protocol) error

type GraphStorageServiceUpdateVertexArgs 

type GraphStorageServiceUpdateVertexArgs struct {
	thrift.IRequest
	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) Read 

func (p *GraphStorageServiceUpdateVertexArgs) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceUpdateVertexArgs) ReadField1 

func (p *GraphStorageServiceUpdateVertexArgs) ReadField1(iprot thrift.Protocol) error

func (*GraphStorageServiceUpdateVertexArgs) String 

func (p *GraphStorageServiceUpdateVertexArgs) String() string

func (*GraphStorageServiceUpdateVertexArgs) Write 

func (p *GraphStorageServiceUpdateVertexArgs) Write(oprot thrift.Protocol) error

type GraphStorageServiceUpdateVertexResult 

type GraphStorageServiceUpdateVertexResult struct {
	thrift.IResponse
	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) Read 

func (p *GraphStorageServiceUpdateVertexResult) Read(iprot thrift.Protocol) error

func (*GraphStorageServiceUpdateVertexResult) ReadField0 

func (p *GraphStorageServiceUpdateVertexResult) ReadField0(iprot thrift.Protocol) error

func (*GraphStorageServiceUpdateVertexResult) String 

func (p *GraphStorageServiceUpdateVertexResult) String() string

func (*GraphStorageServiceUpdateVertexResult) Write 

func (p *GraphStorageServiceUpdateVertexResult) Write(oprot thrift.Protocol) 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 *nebula0.Value `thrift:"begin_value,3" db:"begin_value" json:"begin_value"`
	EndValue   *nebula0.Value `thrift:"end_value,4" db:"end_value" json:"end_value"`
}

Attributes:

  • ColumnName
  • ScanType
  • BeginValue
  • EndValue

func NewIndexColumnHint 

func NewIndexColumnHint() *IndexColumnHint

func (*IndexColumnHint) GetBeginValue 

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

func (*IndexColumnHint) GetColumnName 

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

func (*IndexColumnHint) GetEndValue 

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

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

func (p *IndexColumnHint) Read(iprot thrift.Protocol) error

func (*IndexColumnHint) ReadField1 

func (p *IndexColumnHint) ReadField1(iprot thrift.Protocol) error

func (*IndexColumnHint) ReadField2 

func (p *IndexColumnHint) ReadField2(iprot thrift.Protocol) error

func (*IndexColumnHint) ReadField3 

func (p *IndexColumnHint) ReadField3(iprot thrift.Protocol) error

func (*IndexColumnHint) ReadField4 

func (p *IndexColumnHint) ReadField4(iprot thrift.Protocol) error

func (*IndexColumnHint) String 

func (p *IndexColumnHint) String() string

func (*IndexColumnHint) Write 

func (p *IndexColumnHint) Write(oprot thrift.Protocol) error

type IndexQueryContext 

type IndexQueryContext struct {
	IndexID     nebula0.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) GetColumnHints 

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

func (*IndexQueryContext) GetFilter 

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

func (*IndexQueryContext) GetIndexID 

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

func (*IndexQueryContext) Read 

func (p *IndexQueryContext) Read(iprot thrift.Protocol) error

func (*IndexQueryContext) ReadField1 

func (p *IndexQueryContext) ReadField1(iprot thrift.Protocol) error

func (*IndexQueryContext) ReadField2 

func (p *IndexQueryContext) ReadField2(iprot thrift.Protocol) error

func (*IndexQueryContext) ReadField3 

func (p *IndexQueryContext) ReadField3(iprot thrift.Protocol) error

func (*IndexQueryContext) String 

func (p *IndexQueryContext) String() string

func (*IndexQueryContext) Write 

func (p *IndexQueryContext) Write(oprot thrift.Protocol) error

type IndexSpec 

type IndexSpec struct {
	Contexts []*IndexQueryContext `thrift:"contexts,1,required" db:"contexts" json:"contexts"`
	SchemaID *nebula0.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) GetContexts 

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

func (*IndexSpec) GetSchemaID added in v2.6.0 

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

func (*IndexSpec) IsSetSchemaID added in v2.6.0 

func (p *IndexSpec) IsSetSchemaID() bool

func (*IndexSpec) Read 

func (p *IndexSpec) Read(iprot thrift.Protocol) error

func (*IndexSpec) ReadField1 

func (p *IndexSpec) ReadField1(iprot thrift.Protocol) error

func (*IndexSpec) ReadField2 

func (p *IndexSpec) ReadField2(iprot thrift.Protocol) error

func (*IndexSpec) String 

func (p *IndexSpec) String() string

func (*IndexSpec) Write 

func (p *IndexSpec) Write(oprot thrift.Protocol) error

type InternalTxnRequest 

type InternalTxnRequest struct {
	TxnID       int64                           `thrift:"txn_id,1" db:"txn_id" json:"txn_id"`
	TermOfParts map[nebula0.PartitionID]int64   `thrift:"term_of_parts,2" db:"term_of_parts" json:"term_of_parts"`
	AddEdgeReq  *AddEdgesRequest                `thrift:"add_edge_req,3" db:"add_edge_req" json:"add_edge_req,omitempty"`
	UpdEdgeReq  *UpdateEdgeRequest              `thrift:"upd_edge_req,4" db:"upd_edge_req" json:"upd_edge_req,omitempty"`
	EdgeVer     map[nebula0.PartitionID][]int64 `thrift:"edge_ver,5" db:"edge_ver" json:"edge_ver,omitempty"`
}

Attributes:

  • TxnID
  • TermOfParts
  • AddEdgeReq
  • UpdEdgeReq
  • EdgeVer

func NewInternalTxnRequest 

func NewInternalTxnRequest() *InternalTxnRequest

func (*InternalTxnRequest) GetAddEdgeReq added in v2.6.0 

func (p *InternalTxnRequest) GetAddEdgeReq() *AddEdgesRequest

func (*InternalTxnRequest) GetEdgeVer added in v2.6.0 

func (p *InternalTxnRequest) GetEdgeVer() map[nebula0.PartitionID][]int64

func (*InternalTxnRequest) GetTermOfParts added in v2.6.0 

func (p *InternalTxnRequest) GetTermOfParts() map[nebula0.PartitionID]int64

func (*InternalTxnRequest) GetTxnID 

func (p *InternalTxnRequest) GetTxnID() int64

func (*InternalTxnRequest) GetUpdEdgeReq added in v2.6.0 

func (p *InternalTxnRequest) GetUpdEdgeReq() *UpdateEdgeRequest

func (*InternalTxnRequest) IsSetAddEdgeReq added in v2.6.0 

func (p *InternalTxnRequest) IsSetAddEdgeReq() bool

func (*InternalTxnRequest) IsSetEdgeVer added in v2.6.0 

func (p *InternalTxnRequest) IsSetEdgeVer() bool

func (*InternalTxnRequest) IsSetUpdEdgeReq added in v2.6.0 

func (p *InternalTxnRequest) IsSetUpdEdgeReq() bool

func (*InternalTxnRequest) Read 

func (p *InternalTxnRequest) Read(iprot thrift.Protocol) error

func (*InternalTxnRequest) ReadField1 

func (p *InternalTxnRequest) ReadField1(iprot thrift.Protocol) error

func (*InternalTxnRequest) ReadField2 

func (p *InternalTxnRequest) ReadField2(iprot thrift.Protocol) error

func (*InternalTxnRequest) ReadField3 

func (p *InternalTxnRequest) ReadField3(iprot thrift.Protocol) error

func (*InternalTxnRequest) ReadField4 

func (p *InternalTxnRequest) ReadField4(iprot thrift.Protocol) error

func (*InternalTxnRequest) ReadField5 

func (p *InternalTxnRequest) ReadField5(iprot thrift.Protocol) error

func (*InternalTxnRequest) String 

func (p *InternalTxnRequest) String() string

func (*InternalTxnRequest) Write 

func (p *InternalTxnRequest) Write(oprot thrift.Protocol) error

type KVGetRequest 

type KVGetRequest struct {
	SpaceID      nebula0.GraphSpaceID             `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts        map[nebula0.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 GeneralStorageServiceGetArgs_Req_DEFAULT *KVGetRequest

func NewKVGetRequest 

func NewKVGetRequest() *KVGetRequest

func (*KVGetRequest) GetParts 

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

func (*KVGetRequest) GetReturnPartly 

func (p *KVGetRequest) GetReturnPartly() bool

func (*KVGetRequest) GetSpaceID 

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

func (*KVGetRequest) Read 

func (p *KVGetRequest) Read(iprot thrift.Protocol) error

func (*KVGetRequest) ReadField1 

func (p *KVGetRequest) ReadField1(iprot thrift.Protocol) error

func (*KVGetRequest) ReadField2 

func (p *KVGetRequest) ReadField2(iprot thrift.Protocol) error

func (*KVGetRequest) ReadField3 

func (p *KVGetRequest) ReadField3(iprot thrift.Protocol) error

func (*KVGetRequest) String 

func (p *KVGetRequest) String() string

func (*KVGetRequest) Write 

func (p *KVGetRequest) Write(oprot thrift.Protocol) 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 GeneralStorageServiceGetResult_Success_DEFAULT *KVGetResponse

func NewKVGetResponse 

func NewKVGetResponse() *KVGetResponse

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

func (p *KVGetResponse) Read(iprot thrift.Protocol) error

func (*KVGetResponse) ReadField1 

func (p *KVGetResponse) ReadField1(iprot thrift.Protocol) error

func (*KVGetResponse) ReadField2 

func (p *KVGetResponse) ReadField2(iprot thrift.Protocol) error

func (*KVGetResponse) String 

func (p *KVGetResponse) String() string

func (*KVGetResponse) Write 

func (p *KVGetResponse) Write(oprot thrift.Protocol) error

type KVPutRequest 

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

Attributes:

  • SpaceID
  • Parts
var GeneralStorageServicePutArgs_Req_DEFAULT *KVPutRequest

func NewKVPutRequest 

func NewKVPutRequest() *KVPutRequest

func (*KVPutRequest) GetParts 

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

func (*KVPutRequest) GetSpaceID 

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

func (*KVPutRequest) Read 

func (p *KVPutRequest) Read(iprot thrift.Protocol) error

func (*KVPutRequest) ReadField1 

func (p *KVPutRequest) ReadField1(iprot thrift.Protocol) error

func (*KVPutRequest) ReadField2 

func (p *KVPutRequest) ReadField2(iprot thrift.Protocol) error

func (*KVPutRequest) String 

func (p *KVPutRequest) String() string

func (*KVPutRequest) Write 

func (p *KVPutRequest) Write(oprot thrift.Protocol) error

type KVRemoveRequest 

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

Attributes:

  • SpaceID
  • Parts
var GeneralStorageServiceRemoveArgs_Req_DEFAULT *KVRemoveRequest

func NewKVRemoveRequest 

func NewKVRemoveRequest() *KVRemoveRequest

func (*KVRemoveRequest) GetParts 

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

func (*KVRemoveRequest) GetSpaceID 

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

func (*KVRemoveRequest) Read 

func (p *KVRemoveRequest) Read(iprot thrift.Protocol) error

func (*KVRemoveRequest) ReadField1 

func (p *KVRemoveRequest) ReadField1(iprot thrift.Protocol) error

func (*KVRemoveRequest) ReadField2 

func (p *KVRemoveRequest) ReadField2(iprot thrift.Protocol) error

func (*KVRemoveRequest) String 

func (p *KVRemoveRequest) String() string

func (*KVRemoveRequest) Write 

func (p *KVRemoveRequest) Write(oprot thrift.Protocol) error

type ListClusterInfoReq 

type ListClusterInfoReq struct {
}
var StorageAdminServiceListClusterInfoArgs_Req_DEFAULT *ListClusterInfoReq

func NewListClusterInfoReq 

func NewListClusterInfoReq() *ListClusterInfoReq

func (*ListClusterInfoReq) Read 

func (p *ListClusterInfoReq) Read(iprot thrift.Protocol) error

func (*ListClusterInfoReq) String 

func (p *ListClusterInfoReq) String() string

func (*ListClusterInfoReq) Write 

func (p *ListClusterInfoReq) Write(oprot thrift.Protocol) error

type ListClusterInfoResp 

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

Attributes:

  • Result_
  • Dir
var StorageAdminServiceListClusterInfoResult_Success_DEFAULT *ListClusterInfoResp

func NewListClusterInfoResp 

func NewListClusterInfoResp() *ListClusterInfoResp

func (*ListClusterInfoResp) GetDir 

func (p *ListClusterInfoResp) GetDir() *nebula0.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) Read 

func (p *ListClusterInfoResp) Read(iprot thrift.Protocol) error

func (*ListClusterInfoResp) ReadField1 

func (p *ListClusterInfoResp) ReadField1(iprot thrift.Protocol) error

func (*ListClusterInfoResp) ReadField2 

func (p *ListClusterInfoResp) ReadField2(iprot thrift.Protocol) error

func (*ListClusterInfoResp) String 

func (p *ListClusterInfoResp) String() string

func (*ListClusterInfoResp) Write 

func (p *ListClusterInfoResp) Write(oprot thrift.Protocol) error

type LookupAndTraverseRequest 

type LookupAndTraverseRequest struct {
	SpaceID      nebula0.GraphSpaceID  `thrift:"space_id,1,required" db:"space_id" json:"space_id"`
	Parts        []nebula0.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) GetCommon added in v2.6.0 

func (p *LookupAndTraverseRequest) GetCommon() *RequestCommon

func (*LookupAndTraverseRequest) GetIndices 

func (p *LookupAndTraverseRequest) GetIndices() *IndexSpec

func (*LookupAndTraverseRequest) GetParts 

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

func (*LookupAndTraverseRequest) GetSpaceID 

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

func (*LookupAndTraverseRequest) GetTraverseSpec 

func (p *LookupAndTraverseRequest) GetTraverseSpec() *TraverseSpec

func (*LookupAndTraverseRequest) IsSetCommon added in v2.6.0 

func (p *LookupAndTraverseRequest) IsSetCommon() bool

func (*LookupAndTraverseRequest) IsSetIndices 

func (p *LookupAndTraverseRequest) IsSetIndices() bool

func (*LookupAndTraverseRequest) IsSetTraverseSpec 

func (p *LookupAndTraverseRequest) IsSetTraverseSpec() bool

func (*LookupAndTraverseRequest) Read 

func (p *LookupAndTraverseRequest) Read(iprot thrift.Protocol) error

func (*LookupAndTraverseRequest) ReadField1 

func (p *LookupAndTraverseRequest) ReadField1(iprot thrift.Protocol) error

func (*LookupAndTraverseRequest) ReadField2 

func (p *LookupAndTraverseRequest) ReadField2(iprot thrift.Protocol) error

func (*LookupAndTraverseRequest) ReadField3 

func (p *LookupAndTraverseRequest) ReadField3(iprot thrift.Protocol) error

func (*LookupAndTraverseRequest) ReadField4 

func (p *LookupAndTraverseRequest) ReadField4(iprot thrift.Protocol) error

func (*LookupAndTraverseRequest) ReadField5 added in v2.6.0 

func (p *LookupAndTraverseRequest) ReadField5(iprot thrift.Protocol) error

func (*LookupAndTraverseRequest) String 

func (p *LookupAndTraverseRequest) String() string

func (*LookupAndTraverseRequest) Write 

func (p *LookupAndTraverseRequest) Write(oprot thrift.Protocol) error

type LookupIndexRequest 

type LookupIndexRequest struct {
	SpaceID       nebula0.GraphSpaceID  `thrift:"space_id,1,required" db:"space_id" json:"space_id"`
	Parts         []nebula0.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"`
}

Attributes:

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

func NewLookupIndexRequest 

func NewLookupIndexRequest() *LookupIndexRequest

func (*LookupIndexRequest) GetCommon added in v2.6.0 

func (p *LookupIndexRequest) GetCommon() *RequestCommon

func (*LookupIndexRequest) GetIndices 

func (p *LookupIndexRequest) GetIndices() *IndexSpec

func (*LookupIndexRequest) GetLimit added in v2.6.0 

func (p *LookupIndexRequest) GetLimit() int64

func (*LookupIndexRequest) GetParts 

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

func (*LookupIndexRequest) GetReturnColumns 

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

func (*LookupIndexRequest) GetSpaceID 

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

func (*LookupIndexRequest) IsSetCommon added in v2.6.0 

func (p *LookupIndexRequest) IsSetCommon() bool

func (*LookupIndexRequest) IsSetIndices 

func (p *LookupIndexRequest) IsSetIndices() bool

func (*LookupIndexRequest) IsSetLimit added in v2.6.0 

func (p *LookupIndexRequest) IsSetLimit() bool

func (*LookupIndexRequest) IsSetReturnColumns 

func (p *LookupIndexRequest) IsSetReturnColumns() bool

func (*LookupIndexRequest) Read 

func (p *LookupIndexRequest) Read(iprot thrift.Protocol) error

func (*LookupIndexRequest) ReadField1 

func (p *LookupIndexRequest) ReadField1(iprot thrift.Protocol) error

func (*LookupIndexRequest) ReadField2 

func (p *LookupIndexRequest) ReadField2(iprot thrift.Protocol) error

func (*LookupIndexRequest) ReadField3 

func (p *LookupIndexRequest) ReadField3(iprot thrift.Protocol) error

func (*LookupIndexRequest) ReadField4 

func (p *LookupIndexRequest) ReadField4(iprot thrift.Protocol) error

func (*LookupIndexRequest) ReadField5 added in v2.6.0 

func (p *LookupIndexRequest) ReadField5(iprot thrift.Protocol) error

func (*LookupIndexRequest) ReadField6 added in v2.6.0 

func (p *LookupIndexRequest) ReadField6(iprot thrift.Protocol) error

func (*LookupIndexRequest) String 

func (p *LookupIndexRequest) String() string

func (*LookupIndexRequest) Write 

func (p *LookupIndexRequest) Write(oprot thrift.Protocol) error

type LookupIndexResp 

type LookupIndexResp struct {
	Result_ *ResponseCommon  `thrift:"result,1,required" db:"result" json:"result"`
	Data    *nebula0.DataSet `thrift:"data,2" db:"data" json:"data,omitempty"`
}

Attributes:

  • Result_
  • Data
var GraphStorageServiceLookupIndexResult_Success_DEFAULT *LookupIndexResp

func NewLookupIndexResp 

func NewLookupIndexResp() *LookupIndexResp

func (*LookupIndexResp) GetData 

func (p *LookupIndexResp) GetData() *nebula0.DataSet

func (*LookupIndexResp) GetResult_ 

func (p *LookupIndexResp) GetResult_() *ResponseCommon

func (*LookupIndexResp) IsSetData 

func (p *LookupIndexResp) IsSetData() bool

func (*LookupIndexResp) IsSetResult_ 

func (p *LookupIndexResp) IsSetResult_() bool

func (*LookupIndexResp) Read 

func (p *LookupIndexResp) Read(iprot thrift.Protocol) error

func (*LookupIndexResp) ReadField1 

func (p *LookupIndexResp) ReadField1(iprot thrift.Protocol) error

func (*LookupIndexResp) ReadField2 

func (p *LookupIndexResp) ReadField2(iprot thrift.Protocol) error

func (*LookupIndexResp) String 

func (p *LookupIndexResp) String() string

func (*LookupIndexResp) Write 

func (p *LookupIndexResp) Write(oprot thrift.Protocol) error

type MemberChangeReq 

type MemberChangeReq struct {
	SpaceID nebula0.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID  nebula0.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	Peer    *nebula0.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) GetAdd 

func (p *MemberChangeReq) GetAdd() bool

func (*MemberChangeReq) GetPartID 

func (p *MemberChangeReq) GetPartID() nebula0.PartitionID

func (*MemberChangeReq) GetPeer 

func (p *MemberChangeReq) GetPeer() *nebula0.HostAddr

func (*MemberChangeReq) GetSpaceID 

func (p *MemberChangeReq) GetSpaceID() nebula0.GraphSpaceID

func (*MemberChangeReq) IsSetPeer 

func (p *MemberChangeReq) IsSetPeer() bool

func (*MemberChangeReq) Read 

func (p *MemberChangeReq) Read(iprot thrift.Protocol) error

func (*MemberChangeReq) ReadField1 

func (p *MemberChangeReq) ReadField1(iprot thrift.Protocol) error

func (*MemberChangeReq) ReadField2 

func (p *MemberChangeReq) ReadField2(iprot thrift.Protocol) error

func (*MemberChangeReq) ReadField3 

func (p *MemberChangeReq) ReadField3(iprot thrift.Protocol) error

func (*MemberChangeReq) ReadField4 

func (p *MemberChangeReq) ReadField4(iprot thrift.Protocol) error

func (*MemberChangeReq) String 

func (p *MemberChangeReq) String() string

func (*MemberChangeReq) Write 

func (p *MemberChangeReq) Write(oprot thrift.Protocol) error

type NewEdge_ 

type NewEdge_ struct {
	Key   *EdgeKey         `thrift:"key,1" db:"key" json:"key"`
	Props []*nebula0.Value `thrift:"props,2" db:"props" json:"props"`
}

Attributes:

  • Key
  • Props

func NewNewEdge_ 

func NewNewEdge_() *NewEdge_

func (*NewEdge_) GetKey 

func (p *NewEdge_) GetKey() *EdgeKey

func (*NewEdge_) GetProps 

func (p *NewEdge_) GetProps() []*nebula0.Value

func (*NewEdge_) IsSetKey 

func (p *NewEdge_) IsSetKey() bool

func (*NewEdge_) Read 

func (p *NewEdge_) Read(iprot thrift.Protocol) error

func (*NewEdge_) ReadField1 

func (p *NewEdge_) ReadField1(iprot thrift.Protocol) error

func (*NewEdge_) ReadField2 

func (p *NewEdge_) ReadField2(iprot thrift.Protocol) error

func (*NewEdge_) String 

func (p *NewEdge_) String() string

func (*NewEdge_) Write 

func (p *NewEdge_) Write(oprot thrift.Protocol) error

type NewTag_ 

type NewTag_ struct {
	TagID nebula0.TagID    `thrift:"tag_id,1" db:"tag_id" json:"tag_id"`
	Props []*nebula0.Value `thrift:"props,2" db:"props" json:"props"`
}

Attributes:

  • TagID
  • Props

func NewNewTag_ 

func NewNewTag_() *NewTag_

func (*NewTag_) GetProps 

func (p *NewTag_) GetProps() []*nebula0.Value

func (*NewTag_) GetTagID 

func (p *NewTag_) GetTagID() nebula0.TagID

func (*NewTag_) Read 

func (p *NewTag_) Read(iprot thrift.Protocol) error

func (*NewTag_) ReadField1 

func (p *NewTag_) ReadField1(iprot thrift.Protocol) error

func (*NewTag_) ReadField2 

func (p *NewTag_) ReadField2(iprot thrift.Protocol) error

func (*NewTag_) String 

func (p *NewTag_) String() string

func (*NewTag_) Write 

func (p *NewTag_) Write(oprot thrift.Protocol) error

type NewVertex_ 

type NewVertex_ struct {
	Id   *nebula0.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_) GetId 

func (p *NewVertex_) GetId() *nebula0.Value

func (*NewVertex_) GetTags 

func (p *NewVertex_) GetTags() []*NewTag_

func (*NewVertex_) IsSetId 

func (p *NewVertex_) IsSetId() bool

func (*NewVertex_) Read 

func (p *NewVertex_) Read(iprot thrift.Protocol) error

func (*NewVertex_) ReadField1 

func (p *NewVertex_) ReadField1(iprot thrift.Protocol) error

func (*NewVertex_) ReadField2 

func (p *NewVertex_) ReadField2(iprot thrift.Protocol) error

func (*NewVertex_) String 

func (p *NewVertex_) String() string

func (*NewVertex_) Write 

func (p *NewVertex_) Write(oprot thrift.Protocol) 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) GetDirection 

func (p *OrderBy) GetDirection() OrderDirection

func (*OrderBy) GetProp 

func (p *OrderBy) GetProp() []byte

func (*OrderBy) Read 

func (p *OrderBy) Read(iprot thrift.Protocol) error

func (*OrderBy) ReadField1 

func (p *OrderBy) ReadField1(iprot thrift.Protocol) error

func (*OrderBy) ReadField2 

func (p *OrderBy) ReadField2(iprot thrift.Protocol) error

func (*OrderBy) String 

func (p *OrderBy) String() string

func (*OrderBy) Write 

func (p *OrderBy) Write(oprot thrift.Protocol) 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) String 

func (p OrderDirection) String() string

type PartitionResult_ 

type PartitionResult_ struct {
	Code   nebula0.ErrorCode   `thrift:"code,1,required" db:"code" json:"code"`
	PartID nebula0.PartitionID `thrift:"part_id,2,required" db:"part_id" json:"part_id"`
	Leader *nebula0.HostAddr   `thrift:"leader,3" db:"leader" json:"leader,omitempty"`
}

Attributes:

  • Code
  • PartID
  • Leader

func NewPartitionResult_ 

func NewPartitionResult_() *PartitionResult_

func (*PartitionResult_) GetCode 

func (p *PartitionResult_) GetCode() nebula0.ErrorCode

func (*PartitionResult_) GetLeader 

func (p *PartitionResult_) GetLeader() *nebula0.HostAddr

func (*PartitionResult_) GetPartID 

func (p *PartitionResult_) GetPartID() nebula0.PartitionID

func (*PartitionResult_) IsSetLeader 

func (p *PartitionResult_) IsSetLeader() bool

func (*PartitionResult_) Read 

func (p *PartitionResult_) Read(iprot thrift.Protocol) error

func (*PartitionResult_) ReadField1 

func (p *PartitionResult_) ReadField1(iprot thrift.Protocol) error

func (*PartitionResult_) ReadField2 

func (p *PartitionResult_) ReadField2(iprot thrift.Protocol) error

func (*PartitionResult_) ReadField3 

func (p *PartitionResult_) ReadField3(iprot thrift.Protocol) error

func (*PartitionResult_) String 

func (p *PartitionResult_) String() string

func (*PartitionResult_) Write 

func (p *PartitionResult_) Write(oprot thrift.Protocol) error

type RebuildIndexRequest 

type RebuildIndexRequest struct {
	SpaceID nebula0.GraphSpaceID  `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts   []nebula0.PartitionID `thrift:"parts,2" db:"parts" json:"parts"`
	IndexID nebula0.IndexID       `thrift:"index_id,3" db:"index_id" json:"index_id"`
}

Attributes:

  • SpaceID
  • Parts
  • IndexID
var StorageAdminServiceRebuildEdgeIndexArgs_Req_DEFAULT *RebuildIndexRequest
var StorageAdminServiceRebuildTagIndexArgs_Req_DEFAULT *RebuildIndexRequest

func NewRebuildIndexRequest 

func NewRebuildIndexRequest() *RebuildIndexRequest

func (*RebuildIndexRequest) GetIndexID 

func (p *RebuildIndexRequest) GetIndexID() nebula0.IndexID

func (*RebuildIndexRequest) GetParts 

func (p *RebuildIndexRequest) GetParts() []nebula0.PartitionID

func (*RebuildIndexRequest) GetSpaceID 

func (p *RebuildIndexRequest) GetSpaceID() nebula0.GraphSpaceID

func (*RebuildIndexRequest) Read 

func (p *RebuildIndexRequest) Read(iprot thrift.Protocol) error

func (*RebuildIndexRequest) ReadField1 

func (p *RebuildIndexRequest) ReadField1(iprot thrift.Protocol) error

func (*RebuildIndexRequest) ReadField2 

func (p *RebuildIndexRequest) ReadField2(iprot thrift.Protocol) error

func (*RebuildIndexRequest) ReadField3 

func (p *RebuildIndexRequest) ReadField3(iprot thrift.Protocol) error

func (*RebuildIndexRequest) String 

func (p *RebuildIndexRequest) String() string

func (*RebuildIndexRequest) Write 

func (p *RebuildIndexRequest) Write(oprot thrift.Protocol) error

type RemovePartReq 

type RemovePartReq struct {
	SpaceID nebula0.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID  nebula0.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) GetPartID 

func (p *RemovePartReq) GetPartID() nebula0.PartitionID

func (*RemovePartReq) GetSpaceID 

func (p *RemovePartReq) GetSpaceID() nebula0.GraphSpaceID

func (*RemovePartReq) Read 

func (p *RemovePartReq) Read(iprot thrift.Protocol) error

func (*RemovePartReq) ReadField1 

func (p *RemovePartReq) ReadField1(iprot thrift.Protocol) error

func (*RemovePartReq) ReadField2 

func (p *RemovePartReq) ReadField2(iprot thrift.Protocol) error

func (*RemovePartReq) String 

func (p *RemovePartReq) String() string

func (*RemovePartReq) Write 

func (p *RemovePartReq) Write(oprot thrift.Protocol) error

type RequestCommon added in v2.6.0 

type RequestCommon struct {
	SessionID     *nebula0.SessionID       `thrift:"session_id,1" db:"session_id" json:"session_id,omitempty"`
	PlanID        *nebula0.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 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 added in v2.6.0 

func NewRequestCommon() *RequestCommon

func (*RequestCommon) GetPlanID added in v2.6.0 

func (p *RequestCommon) GetPlanID() nebula0.ExecutionPlanID

func (*RequestCommon) GetProfileDetail added in v2.6.0 

func (p *RequestCommon) GetProfileDetail() bool

func (*RequestCommon) GetSessionID added in v2.6.0 

func (p *RequestCommon) GetSessionID() nebula0.SessionID

func (*RequestCommon) IsSetPlanID added in v2.6.0 

func (p *RequestCommon) IsSetPlanID() bool

func (*RequestCommon) IsSetProfileDetail added in v2.6.0 

func (p *RequestCommon) IsSetProfileDetail() bool

func (*RequestCommon) IsSetSessionID added in v2.6.0 

func (p *RequestCommon) IsSetSessionID() bool

func (*RequestCommon) Read added in v2.6.0 

func (p *RequestCommon) Read(iprot thrift.Protocol) error

func (*RequestCommon) ReadField1 added in v2.6.0 

func (p *RequestCommon) ReadField1(iprot thrift.Protocol) error

func (*RequestCommon) ReadField2 added in v2.6.0 

func (p *RequestCommon) ReadField2(iprot thrift.Protocol) error

func (*RequestCommon) ReadField3 added in v2.6.0 

func (p *RequestCommon) ReadField3(iprot thrift.Protocol) error

func (*RequestCommon) String added in v2.6.0 

func (p *RequestCommon) String() string

func (*RequestCommon) Write added in v2.6.0 

func (p *RequestCommon) Write(oprot thrift.Protocol) error

type ResponseCommon 

type ResponseCommon struct {
	FailedParts     []*PartitionResult_ `thrift:"failed_parts,1,required" db:"failed_parts" json:"failed_parts"`
	LatencyInUs     int32               `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 CreateCPResp_Result__DEFAULT *ResponseCommon
var ExecResponse_Result__DEFAULT *ResponseCommon
var GetLeaderPartsResp_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 ScanEdgeResponse_Result__DEFAULT *ResponseCommon
var ScanVertexResponse_Result__DEFAULT *ResponseCommon
var UpdateResponse_Result__DEFAULT *ResponseCommon

func NewResponseCommon 

func NewResponseCommon() *ResponseCommon

func (*ResponseCommon) GetFailedParts 

func (p *ResponseCommon) GetFailedParts() []*PartitionResult_

func (*ResponseCommon) GetLatencyDetailUs added in v2.6.0 

func (p *ResponseCommon) GetLatencyDetailUs() map[string]int32

func (*ResponseCommon) GetLatencyInUs 

func (p *ResponseCommon) GetLatencyInUs() int32

func (*ResponseCommon) IsSetLatencyDetailUs added in v2.6.0 

func (p *ResponseCommon) IsSetLatencyDetailUs() bool

func (*ResponseCommon) Read 

func (p *ResponseCommon) Read(iprot thrift.Protocol) error

func (*ResponseCommon) ReadField1 

func (p *ResponseCommon) ReadField1(iprot thrift.Protocol) error

func (*ResponseCommon) ReadField2 

func (p *ResponseCommon) ReadField2(iprot thrift.Protocol) error

func (*ResponseCommon) ReadField3 added in v2.6.0 

func (p *ResponseCommon) ReadField3(iprot thrift.Protocol) error

func (*ResponseCommon) String 

func (p *ResponseCommon) String() string

func (*ResponseCommon) Write 

func (p *ResponseCommon) Write(oprot thrift.Protocol) error

type ScanEdgeRequest 

type ScanEdgeRequest struct {
	SpaceID                nebula0.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID                 nebula0.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	Cursor                 []byte               `thrift:"cursor,3" db:"cursor" json:"cursor,omitempty"`
	ReturnColumns          *EdgeProp            `thrift:"return_columns,4" db:"return_columns" json:"return_columns"`
	Limit                  int64                `thrift:"limit,5" db:"limit" json:"limit"`
	StartTime              *int64               `thrift:"start_time,6" db:"start_time" json:"start_time,omitempty"`
	EndTime                *int64               `thrift:"end_time,7" db:"end_time" json:"end_time,omitempty"`
	Filter                 []byte               `thrift:"filter,8" db:"filter" json:"filter,omitempty"`
	OnlyLatestVersion      bool                 `thrift:"only_latest_version,9" db:"only_latest_version" json:"only_latest_version"`
	EnableReadFromFollower bool                 `thrift:"enable_read_from_follower,10" db:"enable_read_from_follower" json:"enable_read_from_follower"`
	Common                 *RequestCommon       `thrift:"common,11" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • PartID
  • Cursor
  • ReturnColumns
  • Limit
  • StartTime
  • EndTime
  • Filter
  • OnlyLatestVersion
  • EnableReadFromFollower
  • Common
var GraphStorageServiceScanEdgeArgs_Req_DEFAULT *ScanEdgeRequest

func NewScanEdgeRequest 

func NewScanEdgeRequest() *ScanEdgeRequest

func (*ScanEdgeRequest) GetCommon added in v2.6.0 

func (p *ScanEdgeRequest) GetCommon() *RequestCommon

func (*ScanEdgeRequest) GetCursor 

func (p *ScanEdgeRequest) GetCursor() []byte

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

func (p *ScanEdgeRequest) GetPartID() nebula0.PartitionID

func (*ScanEdgeRequest) GetReturnColumns 

func (p *ScanEdgeRequest) GetReturnColumns() *EdgeProp

func (*ScanEdgeRequest) GetSpaceID 

func (p *ScanEdgeRequest) GetSpaceID() nebula0.GraphSpaceID

func (*ScanEdgeRequest) GetStartTime 

func (p *ScanEdgeRequest) GetStartTime() int64

func (*ScanEdgeRequest) IsSetCommon added in v2.6.0 

func (p *ScanEdgeRequest) IsSetCommon() bool

func (*ScanEdgeRequest) IsSetCursor 

func (p *ScanEdgeRequest) IsSetCursor() bool

func (*ScanEdgeRequest) IsSetEndTime 

func (p *ScanEdgeRequest) IsSetEndTime() bool

func (*ScanEdgeRequest) IsSetFilter 

func (p *ScanEdgeRequest) IsSetFilter() bool

func (*ScanEdgeRequest) IsSetReturnColumns 

func (p *ScanEdgeRequest) IsSetReturnColumns() bool

func (*ScanEdgeRequest) IsSetStartTime 

func (p *ScanEdgeRequest) IsSetStartTime() bool

func (*ScanEdgeRequest) Read 

func (p *ScanEdgeRequest) Read(iprot thrift.Protocol) error

func (*ScanEdgeRequest) ReadField1 

func (p *ScanEdgeRequest) ReadField1(iprot thrift.Protocol) error

func (*ScanEdgeRequest) ReadField10 

func (p *ScanEdgeRequest) ReadField10(iprot thrift.Protocol) error

func (*ScanEdgeRequest) ReadField11 added in v2.6.0 

func (p *ScanEdgeRequest) ReadField11(iprot thrift.Protocol) error

func (*ScanEdgeRequest) ReadField2 

func (p *ScanEdgeRequest) ReadField2(iprot thrift.Protocol) error

func (*ScanEdgeRequest) ReadField3 

func (p *ScanEdgeRequest) ReadField3(iprot thrift.Protocol) error

func (*ScanEdgeRequest) ReadField4 

func (p *ScanEdgeRequest) ReadField4(iprot thrift.Protocol) error

func (*ScanEdgeRequest) ReadField5 

func (p *ScanEdgeRequest) ReadField5(iprot thrift.Protocol) error

func (*ScanEdgeRequest) ReadField6 

func (p *ScanEdgeRequest) ReadField6(iprot thrift.Protocol) error

func (*ScanEdgeRequest) ReadField7 

func (p *ScanEdgeRequest) ReadField7(iprot thrift.Protocol) error

func (*ScanEdgeRequest) ReadField8 

func (p *ScanEdgeRequest) ReadField8(iprot thrift.Protocol) error

func (*ScanEdgeRequest) ReadField9 

func (p *ScanEdgeRequest) ReadField9(iprot thrift.Protocol) error

func (*ScanEdgeRequest) String 

func (p *ScanEdgeRequest) String() string

func (*ScanEdgeRequest) Write 

func (p *ScanEdgeRequest) Write(oprot thrift.Protocol) error

type ScanEdgeResponse 

type ScanEdgeResponse struct {
	Result_    *ResponseCommon  `thrift:"result,1,required" db:"result" json:"result"`
	EdgeData   *nebula0.DataSet `thrift:"edge_data,2" db:"edge_data" json:"edge_data"`
	HasNext    bool             `thrift:"has_next,3" db:"has_next" json:"has_next"`
	NextCursor []byte           `thrift:"next_cursor,4" db:"next_cursor" json:"next_cursor,omitempty"`
}

Attributes:

  • Result_
  • EdgeData
  • HasNext
  • NextCursor
var GraphStorageServiceScanEdgeResult_Success_DEFAULT *ScanEdgeResponse

func NewScanEdgeResponse 

func NewScanEdgeResponse() *ScanEdgeResponse

func (*ScanEdgeResponse) GetEdgeData 

func (p *ScanEdgeResponse) GetEdgeData() *nebula0.DataSet

func (*ScanEdgeResponse) GetHasNext 

func (p *ScanEdgeResponse) GetHasNext() bool

func (*ScanEdgeResponse) GetNextCursor 

func (p *ScanEdgeResponse) GetNextCursor() []byte

func (*ScanEdgeResponse) GetResult_ 

func (p *ScanEdgeResponse) GetResult_() *ResponseCommon

func (*ScanEdgeResponse) IsSetEdgeData 

func (p *ScanEdgeResponse) IsSetEdgeData() bool

func (*ScanEdgeResponse) IsSetNextCursor 

func (p *ScanEdgeResponse) IsSetNextCursor() bool

func (*ScanEdgeResponse) IsSetResult_ 

func (p *ScanEdgeResponse) IsSetResult_() bool

func (*ScanEdgeResponse) Read 

func (p *ScanEdgeResponse) Read(iprot thrift.Protocol) error

func (*ScanEdgeResponse) ReadField1 

func (p *ScanEdgeResponse) ReadField1(iprot thrift.Protocol) error

func (*ScanEdgeResponse) ReadField2 

func (p *ScanEdgeResponse) ReadField2(iprot thrift.Protocol) error

func (*ScanEdgeResponse) ReadField3 

func (p *ScanEdgeResponse) ReadField3(iprot thrift.Protocol) error

func (*ScanEdgeResponse) ReadField4 

func (p *ScanEdgeResponse) ReadField4(iprot thrift.Protocol) error

func (*ScanEdgeResponse) String 

func (p *ScanEdgeResponse) String() string

func (*ScanEdgeResponse) Write 

func (p *ScanEdgeResponse) Write(oprot thrift.Protocol) 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) String 

func (p ScanType) String() string

type ScanVertexRequest 

type ScanVertexRequest struct {
	SpaceID                nebula0.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID                 nebula0.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	Cursor                 []byte               `thrift:"cursor,3" db:"cursor" json:"cursor,omitempty"`
	ReturnColumns          *VertexProp          `thrift:"return_columns,4" db:"return_columns" json:"return_columns"`
	Limit                  int64                `thrift:"limit,5" db:"limit" json:"limit"`
	StartTime              *int64               `thrift:"start_time,6" db:"start_time" json:"start_time,omitempty"`
	EndTime                *int64               `thrift:"end_time,7" db:"end_time" json:"end_time,omitempty"`
	Filter                 []byte               `thrift:"filter,8" db:"filter" json:"filter,omitempty"`
	OnlyLatestVersion      bool                 `thrift:"only_latest_version,9" db:"only_latest_version" json:"only_latest_version"`
	EnableReadFromFollower bool                 `thrift:"enable_read_from_follower,10" db:"enable_read_from_follower" json:"enable_read_from_follower"`
	Common                 *RequestCommon       `thrift:"common,11" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • PartID
  • Cursor
  • ReturnColumns
  • Limit
  • StartTime
  • EndTime
  • Filter
  • OnlyLatestVersion
  • EnableReadFromFollower
  • Common
var GraphStorageServiceScanVertexArgs_Req_DEFAULT *ScanVertexRequest

func NewScanVertexRequest 

func NewScanVertexRequest() *ScanVertexRequest

func (*ScanVertexRequest) GetCommon added in v2.6.0 

func (p *ScanVertexRequest) GetCommon() *RequestCommon

func (*ScanVertexRequest) GetCursor 

func (p *ScanVertexRequest) GetCursor() []byte

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

func (p *ScanVertexRequest) GetPartID() nebula0.PartitionID

func (*ScanVertexRequest) GetReturnColumns 

func (p *ScanVertexRequest) GetReturnColumns() *VertexProp

func (*ScanVertexRequest) GetSpaceID 

func (p *ScanVertexRequest) GetSpaceID() nebula0.GraphSpaceID

func (*ScanVertexRequest) GetStartTime 

func (p *ScanVertexRequest) GetStartTime() int64

func (*ScanVertexRequest) IsSetCommon added in v2.6.0 

func (p *ScanVertexRequest) IsSetCommon() bool

func (*ScanVertexRequest) IsSetCursor 

func (p *ScanVertexRequest) IsSetCursor() bool

func (*ScanVertexRequest) IsSetEndTime 

func (p *ScanVertexRequest) IsSetEndTime() bool

func (*ScanVertexRequest) IsSetFilter 

func (p *ScanVertexRequest) IsSetFilter() bool

func (*ScanVertexRequest) IsSetReturnColumns 

func (p *ScanVertexRequest) IsSetReturnColumns() bool

func (*ScanVertexRequest) IsSetStartTime 

func (p *ScanVertexRequest) IsSetStartTime() bool

func (*ScanVertexRequest) Read 

func (p *ScanVertexRequest) Read(iprot thrift.Protocol) error

func (*ScanVertexRequest) ReadField1 

func (p *ScanVertexRequest) ReadField1(iprot thrift.Protocol) error

func (*ScanVertexRequest) ReadField10 

func (p *ScanVertexRequest) ReadField10(iprot thrift.Protocol) error

func (*ScanVertexRequest) ReadField11 added in v2.6.0 

func (p *ScanVertexRequest) ReadField11(iprot thrift.Protocol) error

func (*ScanVertexRequest) ReadField2 

func (p *ScanVertexRequest) ReadField2(iprot thrift.Protocol) error

func (*ScanVertexRequest) ReadField3 

func (p *ScanVertexRequest) ReadField3(iprot thrift.Protocol) error

func (*ScanVertexRequest) ReadField4 

func (p *ScanVertexRequest) ReadField4(iprot thrift.Protocol) error

func (*ScanVertexRequest) ReadField5 

func (p *ScanVertexRequest) ReadField5(iprot thrift.Protocol) error

func (*ScanVertexRequest) ReadField6 

func (p *ScanVertexRequest) ReadField6(iprot thrift.Protocol) error

func (*ScanVertexRequest) ReadField7 

func (p *ScanVertexRequest) ReadField7(iprot thrift.Protocol) error

func (*ScanVertexRequest) ReadField8 

func (p *ScanVertexRequest) ReadField8(iprot thrift.Protocol) error

func (*ScanVertexRequest) ReadField9 

func (p *ScanVertexRequest) ReadField9(iprot thrift.Protocol) error

func (*ScanVertexRequest) String 

func (p *ScanVertexRequest) String() string

func (*ScanVertexRequest) Write 

func (p *ScanVertexRequest) Write(oprot thrift.Protocol) error

type ScanVertexResponse 

type ScanVertexResponse struct {
	Result_    *ResponseCommon  `thrift:"result,1,required" db:"result" json:"result"`
	VertexData *nebula0.DataSet `thrift:"vertex_data,2" db:"vertex_data" json:"vertex_data"`
	HasNext    bool             `thrift:"has_next,3" db:"has_next" json:"has_next"`
	NextCursor []byte           `thrift:"next_cursor,4" db:"next_cursor" json:"next_cursor,omitempty"`
}

Attributes:

  • Result_
  • VertexData
  • HasNext
  • NextCursor
var GraphStorageServiceScanVertexResult_Success_DEFAULT *ScanVertexResponse

func NewScanVertexResponse 

func NewScanVertexResponse() *ScanVertexResponse

func (*ScanVertexResponse) GetHasNext 

func (p *ScanVertexResponse) GetHasNext() bool

func (*ScanVertexResponse) GetNextCursor 

func (p *ScanVertexResponse) GetNextCursor() []byte

func (*ScanVertexResponse) GetResult_ 

func (p *ScanVertexResponse) GetResult_() *ResponseCommon

func (*ScanVertexResponse) GetVertexData 

func (p *ScanVertexResponse) GetVertexData() *nebula0.DataSet

func (*ScanVertexResponse) IsSetNextCursor 

func (p *ScanVertexResponse) IsSetNextCursor() bool

func (*ScanVertexResponse) IsSetResult_ 

func (p *ScanVertexResponse) IsSetResult_() bool

func (*ScanVertexResponse) IsSetVertexData 

func (p *ScanVertexResponse) IsSetVertexData() bool

func (*ScanVertexResponse) Read 

func (p *ScanVertexResponse) Read(iprot thrift.Protocol) error

func (*ScanVertexResponse) ReadField1 

func (p *ScanVertexResponse) ReadField1(iprot thrift.Protocol) error

func (*ScanVertexResponse) ReadField2 

func (p *ScanVertexResponse) ReadField2(iprot thrift.Protocol) error

func (*ScanVertexResponse) ReadField3 

func (p *ScanVertexResponse) ReadField3(iprot thrift.Protocol) error

func (*ScanVertexResponse) ReadField4 

func (p *ScanVertexResponse) ReadField4(iprot thrift.Protocol) error

func (*ScanVertexResponse) String 

func (p *ScanVertexResponse) String() string

func (*ScanVertexResponse) Write 

func (p *ScanVertexResponse) Write(oprot thrift.Protocol) 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) GetAlias 

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

func (*StatProp) GetProp 

func (p *StatProp) GetProp() []byte

func (*StatProp) GetStat 

func (p *StatProp) GetStat() StatType

func (*StatProp) Read 

func (p *StatProp) Read(iprot thrift.Protocol) error

func (*StatProp) ReadField1 

func (p *StatProp) ReadField1(iprot thrift.Protocol) error

func (*StatProp) ReadField2 

func (p *StatProp) ReadField2(iprot thrift.Protocol) error

func (*StatProp) ReadField3 

func (p *StatProp) ReadField3(iprot thrift.Protocol) error

func (*StatProp) String 

func (p *StatProp) String() string

func (*StatProp) Write 

func (p *StatProp) Write(oprot thrift.Protocol) 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) String 

func (p StatType) String() string

type StopAdminTaskRequest 

type StopAdminTaskRequest 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 *StopAdminTaskRequest

func NewStopAdminTaskRequest 

func NewStopAdminTaskRequest() *StopAdminTaskRequest

func (*StopAdminTaskRequest) GetJobID 

func (p *StopAdminTaskRequest) GetJobID() int32

func (*StopAdminTaskRequest) GetTaskID 

func (p *StopAdminTaskRequest) GetTaskID() int32

func (*StopAdminTaskRequest) Read 

func (p *StopAdminTaskRequest) Read(iprot thrift.Protocol) error

func (*StopAdminTaskRequest) ReadField1 

func (p *StopAdminTaskRequest) ReadField1(iprot thrift.Protocol) error

func (*StopAdminTaskRequest) ReadField2 

func (p *StopAdminTaskRequest) ReadField2(iprot thrift.Protocol) error

func (*StopAdminTaskRequest) String 

func (p *StopAdminTaskRequest) String() string

func (*StopAdminTaskRequest) Write 

func (p *StopAdminTaskRequest) Write(oprot thrift.Protocol) 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 *AdminExecResp, err error)
	// Parameters:
	//  - Req
	BlockingWrites(ctx context.Context, req *BlockingSignRequest) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	RebuildTagIndex(ctx context.Context, req *RebuildIndexRequest) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	RebuildEdgeIndex(ctx context.Context, req *RebuildIndexRequest) (_r *AdminExecResp, 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 *AddAdminTaskRequest) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	StopAdminTask(ctx context.Context, req *StopAdminTaskRequest) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	ListClusterInfo(ctx context.Context, req *ListClusterInfoReq) (_r *ListClusterInfoResp, err error)
}

type StorageAdminServiceAddAdminTaskArgs 

type StorageAdminServiceAddAdminTaskArgs struct {
	thrift.IRequest
	Req *AddAdminTaskRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceAddAdminTaskArgs 

func NewStorageAdminServiceAddAdminTaskArgs() *StorageAdminServiceAddAdminTaskArgs

func (*StorageAdminServiceAddAdminTaskArgs) GetReq 

func (p *StorageAdminServiceAddAdminTaskArgs) GetReq() *AddAdminTaskRequest

func (*StorageAdminServiceAddAdminTaskArgs) IsSetReq 

func (p *StorageAdminServiceAddAdminTaskArgs) IsSetReq() bool

func (*StorageAdminServiceAddAdminTaskArgs) Read 

func (p *StorageAdminServiceAddAdminTaskArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceAddAdminTaskArgs) ReadField1 

func (p *StorageAdminServiceAddAdminTaskArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceAddAdminTaskArgs) String 

func (p *StorageAdminServiceAddAdminTaskArgs) String() string

func (*StorageAdminServiceAddAdminTaskArgs) Write 

func (p *StorageAdminServiceAddAdminTaskArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceAddAdminTaskResult 

type StorageAdminServiceAddAdminTaskResult struct {
	thrift.IResponse
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceAddAdminTaskResult 

func NewStorageAdminServiceAddAdminTaskResult() *StorageAdminServiceAddAdminTaskResult

func (*StorageAdminServiceAddAdminTaskResult) GetSuccess 

func (p *StorageAdminServiceAddAdminTaskResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceAddAdminTaskResult) IsSetSuccess 

func (p *StorageAdminServiceAddAdminTaskResult) IsSetSuccess() bool

func (*StorageAdminServiceAddAdminTaskResult) Read 

func (p *StorageAdminServiceAddAdminTaskResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceAddAdminTaskResult) ReadField0 

func (p *StorageAdminServiceAddAdminTaskResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceAddAdminTaskResult) String 

func (p *StorageAdminServiceAddAdminTaskResult) String() string

func (*StorageAdminServiceAddAdminTaskResult) Write 

func (p *StorageAdminServiceAddAdminTaskResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceAddLearnerArgs 

type StorageAdminServiceAddLearnerArgs struct {
	thrift.IRequest
	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) Read 

func (p *StorageAdminServiceAddLearnerArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceAddLearnerArgs) ReadField1 

func (p *StorageAdminServiceAddLearnerArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceAddLearnerArgs) String 

func (p *StorageAdminServiceAddLearnerArgs) String() string

func (*StorageAdminServiceAddLearnerArgs) Write 

func (p *StorageAdminServiceAddLearnerArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceAddLearnerResult 

type StorageAdminServiceAddLearnerResult struct {
	thrift.IResponse
	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) Read 

func (p *StorageAdminServiceAddLearnerResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceAddLearnerResult) ReadField0 

func (p *StorageAdminServiceAddLearnerResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceAddLearnerResult) String 

func (p *StorageAdminServiceAddLearnerResult) String() string

func (*StorageAdminServiceAddLearnerResult) Write 

func (p *StorageAdminServiceAddLearnerResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceAddPartArgs 

type StorageAdminServiceAddPartArgs struct {
	thrift.IRequest
	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) Read 

func (p *StorageAdminServiceAddPartArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceAddPartArgs) ReadField1 

func (p *StorageAdminServiceAddPartArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceAddPartArgs) String 

func (p *StorageAdminServiceAddPartArgs) String() string

func (*StorageAdminServiceAddPartArgs) Write 

func (p *StorageAdminServiceAddPartArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceAddPartResult 

type StorageAdminServiceAddPartResult struct {
	thrift.IResponse
	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) Read 

func (p *StorageAdminServiceAddPartResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceAddPartResult) ReadField0 

func (p *StorageAdminServiceAddPartResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceAddPartResult) String 

func (p *StorageAdminServiceAddPartResult) String() string

func (*StorageAdminServiceAddPartResult) Write 

func (p *StorageAdminServiceAddPartResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceBlockingWritesArgs 

type StorageAdminServiceBlockingWritesArgs struct {
	thrift.IRequest
	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) Read 

func (p *StorageAdminServiceBlockingWritesArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceBlockingWritesArgs) ReadField1 

func (p *StorageAdminServiceBlockingWritesArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceBlockingWritesArgs) String 

func (p *StorageAdminServiceBlockingWritesArgs) String() string

func (*StorageAdminServiceBlockingWritesArgs) Write 

func (p *StorageAdminServiceBlockingWritesArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceBlockingWritesResult 

type StorageAdminServiceBlockingWritesResult struct {
	thrift.IResponse
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceBlockingWritesResult 

func NewStorageAdminServiceBlockingWritesResult() *StorageAdminServiceBlockingWritesResult

func (*StorageAdminServiceBlockingWritesResult) GetSuccess 

func (p *StorageAdminServiceBlockingWritesResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceBlockingWritesResult) IsSetSuccess 

func (p *StorageAdminServiceBlockingWritesResult) IsSetSuccess() bool

func (*StorageAdminServiceBlockingWritesResult) Read 

func (p *StorageAdminServiceBlockingWritesResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceBlockingWritesResult) ReadField0 

func (p *StorageAdminServiceBlockingWritesResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceBlockingWritesResult) String 

func (p *StorageAdminServiceBlockingWritesResult) String() string

func (*StorageAdminServiceBlockingWritesResult) Write 

func (p *StorageAdminServiceBlockingWritesResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceChannelClient 

type StorageAdminServiceChannelClient struct {
	RequestChannel thrift.RequestChannel
}

func NewStorageAdminServiceChannelClient 

func NewStorageAdminServiceChannelClient(channel thrift.RequestChannel) *StorageAdminServiceChannelClient

func (*StorageAdminServiceChannelClient) AddAdminTask 

func (p *StorageAdminServiceChannelClient) AddAdminTask(ctx context.Context, req *AddAdminTaskRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) AddLearner 

func (p *StorageAdminServiceChannelClient) AddLearner(ctx context.Context, req *AddLearnerReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) AddPart 

func (p *StorageAdminServiceChannelClient) AddPart(ctx context.Context, req *AddPartReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) BlockingWrites 

func (p *StorageAdminServiceChannelClient) BlockingWrites(ctx context.Context, req *BlockingSignRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) CheckPeers 

func (p *StorageAdminServiceChannelClient) CheckPeers(ctx context.Context, req *CheckPeersReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) Close 

func (c *StorageAdminServiceChannelClient) Close() error

func (*StorageAdminServiceChannelClient) CreateCheckpoint 

func (p *StorageAdminServiceChannelClient) CreateCheckpoint(ctx context.Context, req *CreateCPRequest) (_r *CreateCPResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) DropCheckpoint 

func (p *StorageAdminServiceChannelClient) DropCheckpoint(ctx context.Context, req *DropCPRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) GetLeaderParts 

func (p *StorageAdminServiceChannelClient) GetLeaderParts(ctx context.Context, req *GetLeaderReq) (_r *GetLeaderPartsResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) IsOpen 

func (c *StorageAdminServiceChannelClient) IsOpen() bool

func (*StorageAdminServiceChannelClient) ListClusterInfo 

func (p *StorageAdminServiceChannelClient) ListClusterInfo(ctx context.Context, req *ListClusterInfoReq) (_r *ListClusterInfoResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) MemberChange 

func (p *StorageAdminServiceChannelClient) MemberChange(ctx context.Context, req *MemberChangeReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) Open 

func (c *StorageAdminServiceChannelClient) Open() error

func (*StorageAdminServiceChannelClient) RebuildEdgeIndex 

func (p *StorageAdminServiceChannelClient) RebuildEdgeIndex(ctx context.Context, req *RebuildIndexRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) RebuildTagIndex 

func (p *StorageAdminServiceChannelClient) RebuildTagIndex(ctx context.Context, req *RebuildIndexRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) RemovePart 

func (p *StorageAdminServiceChannelClient) RemovePart(ctx context.Context, req *RemovePartReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) StopAdminTask 

func (p *StorageAdminServiceChannelClient) StopAdminTask(ctx context.Context, req *StopAdminTaskRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) TransLeader 

func (p *StorageAdminServiceChannelClient) TransLeader(ctx context.Context, req *TransLeaderReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) WaitingForCatchUpData 

func (p *StorageAdminServiceChannelClient) WaitingForCatchUpData(ctx context.Context, req *CatchUpDataReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

type StorageAdminServiceCheckPeersArgs 

type StorageAdminServiceCheckPeersArgs struct {
	thrift.IRequest
	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) Read 

func (p *StorageAdminServiceCheckPeersArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceCheckPeersArgs) ReadField1 

func (p *StorageAdminServiceCheckPeersArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceCheckPeersArgs) String 

func (p *StorageAdminServiceCheckPeersArgs) String() string

func (*StorageAdminServiceCheckPeersArgs) Write 

func (p *StorageAdminServiceCheckPeersArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceCheckPeersResult 

type StorageAdminServiceCheckPeersResult struct {
	thrift.IResponse
	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) Read 

func (p *StorageAdminServiceCheckPeersResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceCheckPeersResult) ReadField0 

func (p *StorageAdminServiceCheckPeersResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceCheckPeersResult) String 

func (p *StorageAdminServiceCheckPeersResult) String() string

func (*StorageAdminServiceCheckPeersResult) Write 

func (p *StorageAdminServiceCheckPeersResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceClient 

type StorageAdminServiceClient struct {
	StorageAdminServiceClientInterface
	CC thrift.ClientConn
}

func NewStorageAdminServiceClient 

func NewStorageAdminServiceClient(t thrift.Transport, iprot thrift.Protocol, oprot thrift.Protocol) *StorageAdminServiceClient

func NewStorageAdminServiceClientFactory 

func NewStorageAdminServiceClientFactory(t thrift.Transport, f thrift.ProtocolFactory) *StorageAdminServiceClient

func NewStorageAdminServiceClientProtocol 

func NewStorageAdminServiceClientProtocol(prot thrift.Protocol) *StorageAdminServiceClient

func (*StorageAdminServiceClient) AddAdminTask 

func (p *StorageAdminServiceClient) AddAdminTask(req *AddAdminTaskRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) AddLearner 

func (p *StorageAdminServiceClient) AddLearner(req *AddLearnerReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) AddPart 

func (p *StorageAdminServiceClient) AddPart(req *AddPartReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) BlockingWrites 

func (p *StorageAdminServiceClient) BlockingWrites(req *BlockingSignRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) CheckPeers 

func (p *StorageAdminServiceClient) CheckPeers(req *CheckPeersReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) Close 

func (client *StorageAdminServiceClient) Close() error

func (*StorageAdminServiceClient) CreateCheckpoint 

func (p *StorageAdminServiceClient) CreateCheckpoint(req *CreateCPRequest) (_r *CreateCPResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) DropCheckpoint 

func (p *StorageAdminServiceClient) DropCheckpoint(req *DropCPRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) GetLeaderParts 

func (p *StorageAdminServiceClient) GetLeaderParts(req *GetLeaderReq) (_r *GetLeaderPartsResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) IsOpen 

func (client *StorageAdminServiceClient) IsOpen() bool

func (*StorageAdminServiceClient) ListClusterInfo 

func (p *StorageAdminServiceClient) ListClusterInfo(req *ListClusterInfoReq) (_r *ListClusterInfoResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) MemberChange 

func (p *StorageAdminServiceClient) MemberChange(req *MemberChangeReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) Open 

func (client *StorageAdminServiceClient) Open() error

func (*StorageAdminServiceClient) RebuildEdgeIndex 

func (p *StorageAdminServiceClient) RebuildEdgeIndex(req *RebuildIndexRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) RebuildTagIndex 

func (p *StorageAdminServiceClient) RebuildTagIndex(req *RebuildIndexRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) RemovePart 

func (p *StorageAdminServiceClient) RemovePart(req *RemovePartReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) StopAdminTask 

func (p *StorageAdminServiceClient) StopAdminTask(req *StopAdminTaskRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) TransLeader 

func (p *StorageAdminServiceClient) TransLeader(req *TransLeaderReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) WaitingForCatchUpData 

func (p *StorageAdminServiceClient) WaitingForCatchUpData(req *CatchUpDataReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

type StorageAdminServiceClientInterface 

type StorageAdminServiceClientInterface interface {
	thrift.ClientInterface
	// Parameters:
	//  - Req
	TransLeader(req *TransLeaderReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	AddPart(req *AddPartReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	AddLearner(req *AddLearnerReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	RemovePart(req *RemovePartReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	MemberChange(req *MemberChangeReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	WaitingForCatchUpData(req *CatchUpDataReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	CreateCheckpoint(req *CreateCPRequest) (_r *CreateCPResp, err error)
	// Parameters:
	//  - Req
	DropCheckpoint(req *DropCPRequest) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	BlockingWrites(req *BlockingSignRequest) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	RebuildTagIndex(req *RebuildIndexRequest) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	RebuildEdgeIndex(req *RebuildIndexRequest) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	GetLeaderParts(req *GetLeaderReq) (_r *GetLeaderPartsResp, err error)
	// Parameters:
	//  - Req
	CheckPeers(req *CheckPeersReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	AddAdminTask(req *AddAdminTaskRequest) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	StopAdminTask(req *StopAdminTaskRequest) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	ListClusterInfo(req *ListClusterInfoReq) (_r *ListClusterInfoResp, err error)
}

type StorageAdminServiceCreateCheckpointArgs 

type StorageAdminServiceCreateCheckpointArgs struct {
	thrift.IRequest
	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) Read 

func (p *StorageAdminServiceCreateCheckpointArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceCreateCheckpointArgs) ReadField1 

func (p *StorageAdminServiceCreateCheckpointArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceCreateCheckpointArgs) String 

func (p *StorageAdminServiceCreateCheckpointArgs) String() string

func (*StorageAdminServiceCreateCheckpointArgs) Write 

func (p *StorageAdminServiceCreateCheckpointArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceCreateCheckpointResult 

type StorageAdminServiceCreateCheckpointResult struct {
	thrift.IResponse
	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) Read 

func (p *StorageAdminServiceCreateCheckpointResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceCreateCheckpointResult) ReadField0 

func (p *StorageAdminServiceCreateCheckpointResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceCreateCheckpointResult) String 

func (p *StorageAdminServiceCreateCheckpointResult) String() string

func (*StorageAdminServiceCreateCheckpointResult) Write 

func (p *StorageAdminServiceCreateCheckpointResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceDropCheckpointArgs 

type StorageAdminServiceDropCheckpointArgs struct {
	thrift.IRequest
	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) Read 

func (p *StorageAdminServiceDropCheckpointArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceDropCheckpointArgs) ReadField1 

func (p *StorageAdminServiceDropCheckpointArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceDropCheckpointArgs) String 

func (p *StorageAdminServiceDropCheckpointArgs) String() string

func (*StorageAdminServiceDropCheckpointArgs) Write 

func (p *StorageAdminServiceDropCheckpointArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceDropCheckpointResult 

type StorageAdminServiceDropCheckpointResult struct {
	thrift.IResponse
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceDropCheckpointResult 

func NewStorageAdminServiceDropCheckpointResult() *StorageAdminServiceDropCheckpointResult

func (*StorageAdminServiceDropCheckpointResult) GetSuccess 

func (p *StorageAdminServiceDropCheckpointResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceDropCheckpointResult) IsSetSuccess 

func (p *StorageAdminServiceDropCheckpointResult) IsSetSuccess() bool

func (*StorageAdminServiceDropCheckpointResult) Read 

func (p *StorageAdminServiceDropCheckpointResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceDropCheckpointResult) ReadField0 

func (p *StorageAdminServiceDropCheckpointResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceDropCheckpointResult) String 

func (p *StorageAdminServiceDropCheckpointResult) String() string

func (*StorageAdminServiceDropCheckpointResult) Write 

func (p *StorageAdminServiceDropCheckpointResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceGetLeaderPartsArgs 

type StorageAdminServiceGetLeaderPartsArgs struct {
	thrift.IRequest
	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) Read 

func (p *StorageAdminServiceGetLeaderPartsArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceGetLeaderPartsArgs) ReadField1 

func (p *StorageAdminServiceGetLeaderPartsArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceGetLeaderPartsArgs) String 

func (p *StorageAdminServiceGetLeaderPartsArgs) String() string

func (*StorageAdminServiceGetLeaderPartsArgs) Write 

func (p *StorageAdminServiceGetLeaderPartsArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceGetLeaderPartsResult 

type StorageAdminServiceGetLeaderPartsResult struct {
	thrift.IResponse
	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) Read 

func (p *StorageAdminServiceGetLeaderPartsResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceGetLeaderPartsResult) ReadField0 

func (p *StorageAdminServiceGetLeaderPartsResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceGetLeaderPartsResult) String 

func (p *StorageAdminServiceGetLeaderPartsResult) String() string

func (*StorageAdminServiceGetLeaderPartsResult) Write 

func (p *StorageAdminServiceGetLeaderPartsResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceListClusterInfoArgs 

type StorageAdminServiceListClusterInfoArgs struct {
	thrift.IRequest
	Req *ListClusterInfoReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceListClusterInfoArgs 

func NewStorageAdminServiceListClusterInfoArgs() *StorageAdminServiceListClusterInfoArgs

func (*StorageAdminServiceListClusterInfoArgs) GetReq 

func (p *StorageAdminServiceListClusterInfoArgs) GetReq() *ListClusterInfoReq

func (*StorageAdminServiceListClusterInfoArgs) IsSetReq 

func (p *StorageAdminServiceListClusterInfoArgs) IsSetReq() bool

func (*StorageAdminServiceListClusterInfoArgs) Read 

func (p *StorageAdminServiceListClusterInfoArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceListClusterInfoArgs) ReadField1 

func (p *StorageAdminServiceListClusterInfoArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceListClusterInfoArgs) String 

func (p *StorageAdminServiceListClusterInfoArgs) String() string

func (*StorageAdminServiceListClusterInfoArgs) Write 

func (p *StorageAdminServiceListClusterInfoArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceListClusterInfoResult 

type StorageAdminServiceListClusterInfoResult struct {
	thrift.IResponse
	Success *ListClusterInfoResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceListClusterInfoResult 

func NewStorageAdminServiceListClusterInfoResult() *StorageAdminServiceListClusterInfoResult

func (*StorageAdminServiceListClusterInfoResult) GetSuccess 

func (p *StorageAdminServiceListClusterInfoResult) GetSuccess() *ListClusterInfoResp

func (*StorageAdminServiceListClusterInfoResult) IsSetSuccess 

func (p *StorageAdminServiceListClusterInfoResult) IsSetSuccess() bool

func (*StorageAdminServiceListClusterInfoResult) Read 

func (p *StorageAdminServiceListClusterInfoResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceListClusterInfoResult) ReadField0 

func (p *StorageAdminServiceListClusterInfoResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceListClusterInfoResult) String 

func (p *StorageAdminServiceListClusterInfoResult) String() string

func (*StorageAdminServiceListClusterInfoResult) Write 

func (p *StorageAdminServiceListClusterInfoResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceMemberChangeArgs 

type StorageAdminServiceMemberChangeArgs struct {
	thrift.IRequest
	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) Read 

func (p *StorageAdminServiceMemberChangeArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceMemberChangeArgs) ReadField1 

func (p *StorageAdminServiceMemberChangeArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceMemberChangeArgs) String 

func (p *StorageAdminServiceMemberChangeArgs) String() string

func (*StorageAdminServiceMemberChangeArgs) Write 

func (p *StorageAdminServiceMemberChangeArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceMemberChangeResult 

type StorageAdminServiceMemberChangeResult struct {
	thrift.IResponse
	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) Read 

func (p *StorageAdminServiceMemberChangeResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceMemberChangeResult) ReadField0 

func (p *StorageAdminServiceMemberChangeResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceMemberChangeResult) String 

func (p *StorageAdminServiceMemberChangeResult) String() string

func (*StorageAdminServiceMemberChangeResult) Write 

func (p *StorageAdminServiceMemberChangeResult) Write(oprot thrift.Protocol) 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.ProcessorFunctionContext)

func (*StorageAdminServiceProcessor) GetProcessorFunctionContext 

func (p *StorageAdminServiceProcessor) GetProcessorFunctionContext(key string) (processor thrift.ProcessorFunctionContext, err error)

func (*StorageAdminServiceProcessor) ProcessorMap 

func (p *StorageAdminServiceProcessor) ProcessorMap() map[string]thrift.ProcessorFunctionContext

type StorageAdminServiceRebuildEdgeIndexArgs 

type StorageAdminServiceRebuildEdgeIndexArgs struct {
	thrift.IRequest
	Req *RebuildIndexRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceRebuildEdgeIndexArgs 

func NewStorageAdminServiceRebuildEdgeIndexArgs() *StorageAdminServiceRebuildEdgeIndexArgs

func (*StorageAdminServiceRebuildEdgeIndexArgs) GetReq 

func (p *StorageAdminServiceRebuildEdgeIndexArgs) GetReq() *RebuildIndexRequest

func (*StorageAdminServiceRebuildEdgeIndexArgs) IsSetReq 

func (p *StorageAdminServiceRebuildEdgeIndexArgs) IsSetReq() bool

func (*StorageAdminServiceRebuildEdgeIndexArgs) Read 

func (p *StorageAdminServiceRebuildEdgeIndexArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceRebuildEdgeIndexArgs) ReadField1 

func (p *StorageAdminServiceRebuildEdgeIndexArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceRebuildEdgeIndexArgs) String 

func (p *StorageAdminServiceRebuildEdgeIndexArgs) String() string

func (*StorageAdminServiceRebuildEdgeIndexArgs) Write 

func (p *StorageAdminServiceRebuildEdgeIndexArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceRebuildEdgeIndexResult 

type StorageAdminServiceRebuildEdgeIndexResult struct {
	thrift.IResponse
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceRebuildEdgeIndexResult 

func NewStorageAdminServiceRebuildEdgeIndexResult() *StorageAdminServiceRebuildEdgeIndexResult

func (*StorageAdminServiceRebuildEdgeIndexResult) GetSuccess 

func (p *StorageAdminServiceRebuildEdgeIndexResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceRebuildEdgeIndexResult) IsSetSuccess 

func (p *StorageAdminServiceRebuildEdgeIndexResult) IsSetSuccess() bool

func (*StorageAdminServiceRebuildEdgeIndexResult) Read 

func (p *StorageAdminServiceRebuildEdgeIndexResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceRebuildEdgeIndexResult) ReadField0 

func (p *StorageAdminServiceRebuildEdgeIndexResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceRebuildEdgeIndexResult) String 

func (p *StorageAdminServiceRebuildEdgeIndexResult) String() string

func (*StorageAdminServiceRebuildEdgeIndexResult) Write 

func (p *StorageAdminServiceRebuildEdgeIndexResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceRebuildTagIndexArgs 

type StorageAdminServiceRebuildTagIndexArgs struct {
	thrift.IRequest
	Req *RebuildIndexRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceRebuildTagIndexArgs 

func NewStorageAdminServiceRebuildTagIndexArgs() *StorageAdminServiceRebuildTagIndexArgs

func (*StorageAdminServiceRebuildTagIndexArgs) GetReq 

func (p *StorageAdminServiceRebuildTagIndexArgs) GetReq() *RebuildIndexRequest

func (*StorageAdminServiceRebuildTagIndexArgs) IsSetReq 

func (p *StorageAdminServiceRebuildTagIndexArgs) IsSetReq() bool

func (*StorageAdminServiceRebuildTagIndexArgs) Read 

func (p *StorageAdminServiceRebuildTagIndexArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceRebuildTagIndexArgs) ReadField1 

func (p *StorageAdminServiceRebuildTagIndexArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceRebuildTagIndexArgs) String 

func (p *StorageAdminServiceRebuildTagIndexArgs) String() string

func (*StorageAdminServiceRebuildTagIndexArgs) Write 

func (p *StorageAdminServiceRebuildTagIndexArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceRebuildTagIndexResult 

type StorageAdminServiceRebuildTagIndexResult struct {
	thrift.IResponse
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceRebuildTagIndexResult 

func NewStorageAdminServiceRebuildTagIndexResult() *StorageAdminServiceRebuildTagIndexResult

func (*StorageAdminServiceRebuildTagIndexResult) GetSuccess 

func (p *StorageAdminServiceRebuildTagIndexResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceRebuildTagIndexResult) IsSetSuccess 

func (p *StorageAdminServiceRebuildTagIndexResult) IsSetSuccess() bool

func (*StorageAdminServiceRebuildTagIndexResult) Read 

func (p *StorageAdminServiceRebuildTagIndexResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceRebuildTagIndexResult) ReadField0 

func (p *StorageAdminServiceRebuildTagIndexResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceRebuildTagIndexResult) String 

func (p *StorageAdminServiceRebuildTagIndexResult) String() string

func (*StorageAdminServiceRebuildTagIndexResult) Write 

func (p *StorageAdminServiceRebuildTagIndexResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceRemovePartArgs 

type StorageAdminServiceRemovePartArgs struct {
	thrift.IRequest
	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) Read 

func (p *StorageAdminServiceRemovePartArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceRemovePartArgs) ReadField1 

func (p *StorageAdminServiceRemovePartArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceRemovePartArgs) String 

func (p *StorageAdminServiceRemovePartArgs) String() string

func (*StorageAdminServiceRemovePartArgs) Write 

func (p *StorageAdminServiceRemovePartArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceRemovePartResult 

type StorageAdminServiceRemovePartResult struct {
	thrift.IResponse
	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) Read 

func (p *StorageAdminServiceRemovePartResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceRemovePartResult) ReadField0 

func (p *StorageAdminServiceRemovePartResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceRemovePartResult) String 

func (p *StorageAdminServiceRemovePartResult) String() string

func (*StorageAdminServiceRemovePartResult) Write 

func (p *StorageAdminServiceRemovePartResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceStopAdminTaskArgs 

type StorageAdminServiceStopAdminTaskArgs struct {
	thrift.IRequest
	Req *StopAdminTaskRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewStorageAdminServiceStopAdminTaskArgs 

func NewStorageAdminServiceStopAdminTaskArgs() *StorageAdminServiceStopAdminTaskArgs

func (*StorageAdminServiceStopAdminTaskArgs) GetReq 

func (p *StorageAdminServiceStopAdminTaskArgs) GetReq() *StopAdminTaskRequest

func (*StorageAdminServiceStopAdminTaskArgs) IsSetReq 

func (p *StorageAdminServiceStopAdminTaskArgs) IsSetReq() bool

func (*StorageAdminServiceStopAdminTaskArgs) Read 

func (p *StorageAdminServiceStopAdminTaskArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceStopAdminTaskArgs) ReadField1 

func (p *StorageAdminServiceStopAdminTaskArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceStopAdminTaskArgs) String 

func (p *StorageAdminServiceStopAdminTaskArgs) String() string

func (*StorageAdminServiceStopAdminTaskArgs) Write 

func (p *StorageAdminServiceStopAdminTaskArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceStopAdminTaskResult 

type StorageAdminServiceStopAdminTaskResult struct {
	thrift.IResponse
	Success *AdminExecResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceStopAdminTaskResult 

func NewStorageAdminServiceStopAdminTaskResult() *StorageAdminServiceStopAdminTaskResult

func (*StorageAdminServiceStopAdminTaskResult) GetSuccess 

func (p *StorageAdminServiceStopAdminTaskResult) GetSuccess() *AdminExecResp

func (*StorageAdminServiceStopAdminTaskResult) IsSetSuccess 

func (p *StorageAdminServiceStopAdminTaskResult) IsSetSuccess() bool

func (*StorageAdminServiceStopAdminTaskResult) Read 

func (p *StorageAdminServiceStopAdminTaskResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceStopAdminTaskResult) ReadField0 

func (p *StorageAdminServiceStopAdminTaskResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceStopAdminTaskResult) String 

func (p *StorageAdminServiceStopAdminTaskResult) String() string

func (*StorageAdminServiceStopAdminTaskResult) Write 

func (p *StorageAdminServiceStopAdminTaskResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceThreadsafeClient 

type StorageAdminServiceThreadsafeClient struct {
	StorageAdminServiceClientInterface
	CC thrift.ClientConn
	Mu sync.Mutex
}

func NewStorageAdminServiceThreadsafeClient 

func NewStorageAdminServiceThreadsafeClient(t thrift.Transport, iprot thrift.Protocol, oprot thrift.Protocol) *StorageAdminServiceThreadsafeClient

func NewStorageAdminServiceThreadsafeClientFactory 

func NewStorageAdminServiceThreadsafeClientFactory(t thrift.Transport, f thrift.ProtocolFactory) *StorageAdminServiceThreadsafeClient

func NewStorageAdminServiceThreadsafeClientProtocol 

func NewStorageAdminServiceThreadsafeClientProtocol(prot thrift.Protocol) *StorageAdminServiceThreadsafeClient

func (*StorageAdminServiceThreadsafeClient) AddAdminTask 

func (p *StorageAdminServiceThreadsafeClient) AddAdminTask(req *AddAdminTaskRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) AddLearner 

func (p *StorageAdminServiceThreadsafeClient) AddLearner(req *AddLearnerReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) AddPart 

func (p *StorageAdminServiceThreadsafeClient) AddPart(req *AddPartReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) BlockingWrites 

func (p *StorageAdminServiceThreadsafeClient) BlockingWrites(req *BlockingSignRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) CheckPeers 

func (p *StorageAdminServiceThreadsafeClient) CheckPeers(req *CheckPeersReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) Close 

func (client *StorageAdminServiceThreadsafeClient) Close() error

func (*StorageAdminServiceThreadsafeClient) CreateCheckpoint 

func (p *StorageAdminServiceThreadsafeClient) CreateCheckpoint(req *CreateCPRequest) (_r *CreateCPResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) DropCheckpoint 

func (p *StorageAdminServiceThreadsafeClient) DropCheckpoint(req *DropCPRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) GetLeaderParts 

func (p *StorageAdminServiceThreadsafeClient) GetLeaderParts(req *GetLeaderReq) (_r *GetLeaderPartsResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) IsOpen 

func (client *StorageAdminServiceThreadsafeClient) IsOpen() bool

func (*StorageAdminServiceThreadsafeClient) ListClusterInfo 

func (p *StorageAdminServiceThreadsafeClient) ListClusterInfo(req *ListClusterInfoReq) (_r *ListClusterInfoResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) MemberChange 

func (p *StorageAdminServiceThreadsafeClient) MemberChange(req *MemberChangeReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) Open 

func (client *StorageAdminServiceThreadsafeClient) Open() error

func (*StorageAdminServiceThreadsafeClient) RebuildEdgeIndex 

func (p *StorageAdminServiceThreadsafeClient) RebuildEdgeIndex(req *RebuildIndexRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) RebuildTagIndex 

func (p *StorageAdminServiceThreadsafeClient) RebuildTagIndex(req *RebuildIndexRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) RemovePart 

func (p *StorageAdminServiceThreadsafeClient) RemovePart(req *RemovePartReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) StopAdminTask 

func (p *StorageAdminServiceThreadsafeClient) StopAdminTask(req *StopAdminTaskRequest) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) TransLeader 

func (p *StorageAdminServiceThreadsafeClient) TransLeader(req *TransLeaderReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) WaitingForCatchUpData 

func (p *StorageAdminServiceThreadsafeClient) WaitingForCatchUpData(req *CatchUpDataReq) (_r *AdminExecResp, err error)

Parameters:

  • Req

type StorageAdminServiceTransLeaderArgs 

type StorageAdminServiceTransLeaderArgs struct {
	thrift.IRequest
	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) Read 

func (p *StorageAdminServiceTransLeaderArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceTransLeaderArgs) ReadField1 

func (p *StorageAdminServiceTransLeaderArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceTransLeaderArgs) String 

func (p *StorageAdminServiceTransLeaderArgs) String() string

func (*StorageAdminServiceTransLeaderArgs) Write 

func (p *StorageAdminServiceTransLeaderArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceTransLeaderResult 

type StorageAdminServiceTransLeaderResult struct {
	thrift.IResponse
	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) Read 

func (p *StorageAdminServiceTransLeaderResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceTransLeaderResult) ReadField0 

func (p *StorageAdminServiceTransLeaderResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceTransLeaderResult) String 

func (p *StorageAdminServiceTransLeaderResult) String() string

func (*StorageAdminServiceTransLeaderResult) Write 

func (p *StorageAdminServiceTransLeaderResult) Write(oprot thrift.Protocol) error

type StorageAdminServiceWaitingForCatchUpDataArgs 

type StorageAdminServiceWaitingForCatchUpDataArgs struct {
	thrift.IRequest
	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) Read 

func (p *StorageAdminServiceWaitingForCatchUpDataArgs) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceWaitingForCatchUpDataArgs) ReadField1 

func (p *StorageAdminServiceWaitingForCatchUpDataArgs) ReadField1(iprot thrift.Protocol) error

func (*StorageAdminServiceWaitingForCatchUpDataArgs) String 

func (p *StorageAdminServiceWaitingForCatchUpDataArgs) String() string

func (*StorageAdminServiceWaitingForCatchUpDataArgs) Write 

func (p *StorageAdminServiceWaitingForCatchUpDataArgs) Write(oprot thrift.Protocol) error

type StorageAdminServiceWaitingForCatchUpDataResult 

type StorageAdminServiceWaitingForCatchUpDataResult struct {
	thrift.IResponse
	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) Read 

func (p *StorageAdminServiceWaitingForCatchUpDataResult) Read(iprot thrift.Protocol) error

func (*StorageAdminServiceWaitingForCatchUpDataResult) ReadField0 

func (p *StorageAdminServiceWaitingForCatchUpDataResult) ReadField0(iprot thrift.Protocol) error

func (*StorageAdminServiceWaitingForCatchUpDataResult) String 

func (p *StorageAdminServiceWaitingForCatchUpDataResult) String() string

func (*StorageAdminServiceWaitingForCatchUpDataResult) Write 

func (p *StorageAdminServiceWaitingForCatchUpDataResult) Write(oprot thrift.Protocol) error

type TaskPara 

type TaskPara struct {
	SpaceID          nebula0.GraphSpaceID  `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts            []nebula0.PartitionID `thrift:"parts,2" db:"parts" json:"parts,omitempty"`
	TaskSpecficParas [][]byte              `thrift:"task_specfic_paras,3" db:"task_specfic_paras" json:"task_specfic_paras,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • TaskSpecficParas
var AddAdminTaskRequest_Para_DEFAULT *TaskPara

func NewTaskPara 

func NewTaskPara() *TaskPara

func (*TaskPara) GetParts 

func (p *TaskPara) GetParts() []nebula0.PartitionID

func (*TaskPara) GetSpaceID 

func (p *TaskPara) GetSpaceID() nebula0.GraphSpaceID

func (*TaskPara) GetTaskSpecficParas 

func (p *TaskPara) GetTaskSpecficParas() [][]byte

func (*TaskPara) IsSetParts 

func (p *TaskPara) IsSetParts() bool

func (*TaskPara) IsSetTaskSpecficParas 

func (p *TaskPara) IsSetTaskSpecficParas() bool

func (*TaskPara) Read 

func (p *TaskPara) Read(iprot thrift.Protocol) error

func (*TaskPara) ReadField1 

func (p *TaskPara) ReadField1(iprot thrift.Protocol) error

func (*TaskPara) ReadField2 

func (p *TaskPara) ReadField2(iprot thrift.Protocol) error

func (*TaskPara) ReadField3 

func (p *TaskPara) ReadField3(iprot thrift.Protocol) error

func (*TaskPara) String 

func (p *TaskPara) String() string

func (*TaskPara) Write 

func (p *TaskPara) Write(oprot thrift.Protocol) error

type TransLeaderReq 

type TransLeaderReq struct {
	SpaceID    nebula0.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID     nebula0.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	NewLeader_ *nebula0.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) GetNewLeader_ 

func (p *TransLeaderReq) GetNewLeader_() *nebula0.HostAddr

func (*TransLeaderReq) GetPartID 

func (p *TransLeaderReq) GetPartID() nebula0.PartitionID

func (*TransLeaderReq) GetSpaceID 

func (p *TransLeaderReq) GetSpaceID() nebula0.GraphSpaceID

func (*TransLeaderReq) IsSetNewLeader_ 

func (p *TransLeaderReq) IsSetNewLeader_() bool

func (*TransLeaderReq) Read 

func (p *TransLeaderReq) Read(iprot thrift.Protocol) error

func (*TransLeaderReq) ReadField1 

func (p *TransLeaderReq) ReadField1(iprot thrift.Protocol) error

func (*TransLeaderReq) ReadField2 

func (p *TransLeaderReq) ReadField2(iprot thrift.Protocol) error

func (*TransLeaderReq) ReadField3 

func (p *TransLeaderReq) ReadField3(iprot thrift.Protocol) error

func (*TransLeaderReq) String 

func (p *TransLeaderReq) String() string

func (*TransLeaderReq) Write 

func (p *TransLeaderReq) Write(oprot thrift.Protocol) error

type TraverseSpec 

type TraverseSpec struct {
	EdgeTypes     []nebula0.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"`
}

Attributes:

  • EdgeTypes
  • EdgeDirection
  • Dedup
  • StatProps
  • VertexProps
  • EdgeProps
  • Expressions
  • OrderBy
  • Random
  • Limit
  • Filter
var GetNeighborsRequest_TraverseSpec_DEFAULT *TraverseSpec
var LookupAndTraverseRequest_TraverseSpec_DEFAULT *TraverseSpec

func NewTraverseSpec 

func NewTraverseSpec() *TraverseSpec

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() []nebula0.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) 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) IsSetVertexProps 

func (p *TraverseSpec) IsSetVertexProps() bool

func (*TraverseSpec) Read 

func (p *TraverseSpec) Read(iprot thrift.Protocol) error

func (*TraverseSpec) ReadField1 

func (p *TraverseSpec) ReadField1(iprot thrift.Protocol) error

func (*TraverseSpec) ReadField10 

func (p *TraverseSpec) ReadField10(iprot thrift.Protocol) error

func (*TraverseSpec) ReadField11 

func (p *TraverseSpec) ReadField11(iprot thrift.Protocol) error

func (*TraverseSpec) ReadField2 

func (p *TraverseSpec) ReadField2(iprot thrift.Protocol) error

func (*TraverseSpec) ReadField3 

func (p *TraverseSpec) ReadField3(iprot thrift.Protocol) error

func (*TraverseSpec) ReadField4 

func (p *TraverseSpec) ReadField4(iprot thrift.Protocol) error

func (*TraverseSpec) ReadField5 

func (p *TraverseSpec) ReadField5(iprot thrift.Protocol) error

func (*TraverseSpec) ReadField6 

func (p *TraverseSpec) ReadField6(iprot thrift.Protocol) error

func (*TraverseSpec) ReadField7 

func (p *TraverseSpec) ReadField7(iprot thrift.Protocol) error

func (*TraverseSpec) ReadField8 

func (p *TraverseSpec) ReadField8(iprot thrift.Protocol) error

func (*TraverseSpec) ReadField9 

func (p *TraverseSpec) ReadField9(iprot thrift.Protocol) error

func (*TraverseSpec) String 

func (p *TraverseSpec) String() string

func (*TraverseSpec) Write 

func (p *TraverseSpec) Write(oprot thrift.Protocol) error

type UpdateEdgeRequest 

type UpdateEdgeRequest struct {
	SpaceID      nebula0.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID       nebula0.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,omitempty"`
	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
var InternalTxnRequest_UpdEdgeReq_DEFAULT *UpdateEdgeRequest

func NewUpdateEdgeRequest 

func NewUpdateEdgeRequest() *UpdateEdgeRequest

func (*UpdateEdgeRequest) GetCommon added in v2.6.0 

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() nebula0.PartitionID

func (*UpdateEdgeRequest) GetReturnProps 

func (p *UpdateEdgeRequest) GetReturnProps() [][]byte

func (*UpdateEdgeRequest) GetSpaceID 

func (p *UpdateEdgeRequest) GetSpaceID() nebula0.GraphSpaceID

func (*UpdateEdgeRequest) GetUpdatedProps 

func (p *UpdateEdgeRequest) GetUpdatedProps() []*UpdatedProp

func (*UpdateEdgeRequest) IsSetCommon added in v2.6.0 

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

func (p *UpdateEdgeRequest) Read(iprot thrift.Protocol) error

func (*UpdateEdgeRequest) ReadField1 

func (p *UpdateEdgeRequest) ReadField1(iprot thrift.Protocol) error

func (*UpdateEdgeRequest) ReadField2 

func (p *UpdateEdgeRequest) ReadField2(iprot thrift.Protocol) error

func (*UpdateEdgeRequest) ReadField3 

func (p *UpdateEdgeRequest) ReadField3(iprot thrift.Protocol) error

func (*UpdateEdgeRequest) ReadField4 

func (p *UpdateEdgeRequest) ReadField4(iprot thrift.Protocol) error

func (*UpdateEdgeRequest) ReadField5 

func (p *UpdateEdgeRequest) ReadField5(iprot thrift.Protocol) error

func (*UpdateEdgeRequest) ReadField6 

func (p *UpdateEdgeRequest) ReadField6(iprot thrift.Protocol) error

func (*UpdateEdgeRequest) ReadField7 

func (p *UpdateEdgeRequest) ReadField7(iprot thrift.Protocol) error

func (*UpdateEdgeRequest) ReadField8 added in v2.6.0 

func (p *UpdateEdgeRequest) ReadField8(iprot thrift.Protocol) error

func (*UpdateEdgeRequest) String 

func (p *UpdateEdgeRequest) String() string

func (*UpdateEdgeRequest) Write 

func (p *UpdateEdgeRequest) Write(oprot thrift.Protocol) error

type UpdateResponse 

type UpdateResponse struct {
	Result_ *ResponseCommon  `thrift:"result,1,required" db:"result" json:"result"`
	Props   *nebula0.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

func NewUpdateResponse 

func NewUpdateResponse() *UpdateResponse

func (*UpdateResponse) GetProps 

func (p *UpdateResponse) GetProps() *nebula0.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) Read 

func (p *UpdateResponse) Read(iprot thrift.Protocol) error

func (*UpdateResponse) ReadField1 

func (p *UpdateResponse) ReadField1(iprot thrift.Protocol) error

func (*UpdateResponse) ReadField2 

func (p *UpdateResponse) ReadField2(iprot thrift.Protocol) error

func (*UpdateResponse) String 

func (p *UpdateResponse) String() string

func (*UpdateResponse) Write 

func (p *UpdateResponse) Write(oprot thrift.Protocol) error

type UpdateVertexRequest 

type UpdateVertexRequest struct {
	SpaceID      nebula0.GraphSpaceID `thrift:"space_id,1" db:"space_id" json:"space_id"`
	PartID       nebula0.PartitionID  `thrift:"part_id,2" db:"part_id" json:"part_id"`
	VertexID     *nebula0.Value       `thrift:"vertex_id,3" db:"vertex_id" json:"vertex_id"`
	TagID        nebula0.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,omitempty"`
	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) GetCommon added in v2.6.0 

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() nebula0.PartitionID

func (*UpdateVertexRequest) GetReturnProps 

func (p *UpdateVertexRequest) GetReturnProps() [][]byte

func (*UpdateVertexRequest) GetSpaceID 

func (p *UpdateVertexRequest) GetSpaceID() nebula0.GraphSpaceID

func (*UpdateVertexRequest) GetTagID 

func (p *UpdateVertexRequest) GetTagID() nebula0.TagID

func (*UpdateVertexRequest) GetUpdatedProps 

func (p *UpdateVertexRequest) GetUpdatedProps() []*UpdatedProp

func (*UpdateVertexRequest) GetVertexID 

func (p *UpdateVertexRequest) GetVertexID() *nebula0.Value

func (*UpdateVertexRequest) IsSetCommon added in v2.6.0 

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

func (p *UpdateVertexRequest) Read(iprot thrift.Protocol) error

func (*UpdateVertexRequest) ReadField1 

func (p *UpdateVertexRequest) ReadField1(iprot thrift.Protocol) error

func (*UpdateVertexRequest) ReadField2 

func (p *UpdateVertexRequest) ReadField2(iprot thrift.Protocol) error

func (*UpdateVertexRequest) ReadField3 

func (p *UpdateVertexRequest) ReadField3(iprot thrift.Protocol) error

func (*UpdateVertexRequest) ReadField4 

func (p *UpdateVertexRequest) ReadField4(iprot thrift.Protocol) error

func (*UpdateVertexRequest) ReadField5 

func (p *UpdateVertexRequest) ReadField5(iprot thrift.Protocol) error

func (*UpdateVertexRequest) ReadField6 

func (p *UpdateVertexRequest) ReadField6(iprot thrift.Protocol) error

func (*UpdateVertexRequest) ReadField7 

func (p *UpdateVertexRequest) ReadField7(iprot thrift.Protocol) error

func (*UpdateVertexRequest) ReadField8 

func (p *UpdateVertexRequest) ReadField8(iprot thrift.Protocol) error

func (*UpdateVertexRequest) ReadField9 added in v2.6.0 

func (p *UpdateVertexRequest) ReadField9(iprot thrift.Protocol) error

func (*UpdateVertexRequest) String 

func (p *UpdateVertexRequest) String() string

func (*UpdateVertexRequest) Write 

func (p *UpdateVertexRequest) Write(oprot thrift.Protocol) 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) GetName 

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

func (*UpdatedProp) GetValue 

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

func (*UpdatedProp) Read 

func (p *UpdatedProp) Read(iprot thrift.Protocol) error

func (*UpdatedProp) ReadField1 

func (p *UpdatedProp) ReadField1(iprot thrift.Protocol) error

func (*UpdatedProp) ReadField2 

func (p *UpdatedProp) ReadField2(iprot thrift.Protocol) error

func (*UpdatedProp) String 

func (p *UpdatedProp) String() string

func (*UpdatedProp) Write 

func (p *UpdatedProp) Write(oprot thrift.Protocol) error

type VertexProp 

type VertexProp struct {
	Tag   nebula0.TagID `thrift:"tag,1" db:"tag" json:"tag"`
	Props [][]byte      `thrift:"props,2" db:"props" json:"props"`
}

Attributes:

  • Tag
  • Props
var ScanVertexRequest_ReturnColumns_DEFAULT *VertexProp

func NewVertexProp 

func NewVertexProp() *VertexProp

func (*VertexProp) GetProps 

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

func (*VertexProp) GetTag 

func (p *VertexProp) GetTag() nebula0.TagID

func (*VertexProp) Read 

func (p *VertexProp) Read(iprot thrift.Protocol) error

func (*VertexProp) ReadField1 

func (p *VertexProp) ReadField1(iprot thrift.Protocol) error

func (*VertexProp) ReadField2 

func (p *VertexProp) ReadField2(iprot thrift.Protocol) error

func (*VertexProp) String 

func (p *VertexProp) String() string

func (*VertexProp) Write 

func (p *VertexProp) Write(oprot thrift.Protocol) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.