storage

package
v3.8.0 Latest Latest
Warning

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

Go to latest
Published: Apr 8, 2024 License: Apache-2.0 Imports: 7 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

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 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 GetDstBySrcResponse_Dsts_DEFAULT *nebula0.DataSet
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 ListClusterInfoResp_Dir_DEFAULT *nebula0.DirInfo
View Source
var LookupIndexRequest_Limit_DEFAULT int64
View Source
var LookupIndexRequest_OrderBy_DEFAULT []*OrderBy
View Source
var LookupIndexRequest_ReturnColumns_DEFAULT [][]byte
View Source
var LookupIndexRequest_StatColumns_DEFAULT []*StatProp
View Source
var LookupIndexResp_Data_DEFAULT *nebula0.DataSet
View Source
var LookupIndexResp_StatData_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 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 ScanCursor_NextCursor_DEFAULT []byte
View Source
var ScanEdgeRequest_EndTime_DEFAULT int64
View Source
var ScanEdgeRequest_Filter_DEFAULT []byte
View Source
var ScanEdgeRequest_StartTime_DEFAULT int64
View Source
var ScanResponse_Props_DEFAULT *nebula0.DataSet
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_EndTime_DEFAULT int64
View Source
var ScanVertexRequest_Filter_DEFAULT []byte
View Source
var ScanVertexRequest_StartTime_DEFAULT int64
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 TaskPara_Parts_DEFAULT []nebula0.PartitionID
View Source
var TaskPara_TaskSpecificParas_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_TagFilter_DEFAULT []byte
View Source
var TraverseSpec_VertexProps_DEFAULT []*VertexProp
View Source
var UpdateEdgeRequest_Condition_DEFAULT []byte
View Source
var UpdateEdgeRequest_Insertable_DEFAULT bool = false
View Source
var UpdateEdgeRequest_ReturnProps_DEFAULT [][]byte
View Source
var UpdateResponse_Props_DEFAULT *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 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"`
	IgnoreExistedIndex bool                                `thrift:"ignore_existed_index,5" db:"ignore_existed_index" json:"ignore_existed_index"`
	Common             *RequestCommon                      `thrift:"common,6,optional" db:"common" json:"common,omitempty"`
}

Attributes:

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

func NewAddEdgesRequest

func NewAddEdgesRequest() *AddEdgesRequest

func (*AddEdgesRequest) GetCommon

func (p *AddEdgesRequest) GetCommon() *RequestCommon

func (*AddEdgesRequest) GetIfNotExists

func (p *AddEdgesRequest) GetIfNotExists() bool

func (*AddEdgesRequest) GetIgnoreExistedIndex

func (p *AddEdgesRequest) GetIgnoreExistedIndex() bool

func (*AddEdgesRequest) GetParts

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

func (*AddEdgesRequest) GetPropNames

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

func (*AddEdgesRequest) GetSpaceID

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

func (*AddEdgesRequest) IsSetCommon

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

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

func (*AddEdgesRequest) ReadField6

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

func (*AddEdgesRequest) SetCommon

func (a *AddEdgesRequest) SetCommon(common *RequestCommon) *AddEdgesRequest

func (*AddEdgesRequest) SetIfNotExists

func (a *AddEdgesRequest) SetIfNotExists(ifNotExists bool) *AddEdgesRequest

func (*AddEdgesRequest) SetIgnoreExistedIndex

func (a *AddEdgesRequest) SetIgnoreExistedIndex(ignoreExistedIndex bool) *AddEdgesRequest

func (*AddEdgesRequest) SetParts

func (a *AddEdgesRequest) SetParts(parts map[nebula0.PartitionID][]*NewEdge_) *AddEdgesRequest

func (*AddEdgesRequest) SetPropNames

func (a *AddEdgesRequest) SetPropNames(propNames [][]byte) *AddEdgesRequest

func (*AddEdgesRequest) SetSpaceID

func (a *AddEdgesRequest) SetSpaceID(spaceID nebula0.GraphSpaceID) *AddEdgesRequest

func (*AddEdgesRequest) String

func (p *AddEdgesRequest) String() string

func (*AddEdgesRequest) Write

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

type AddEdgesRequestBuilder

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

func NewAddEdgesRequestBuilder

func NewAddEdgesRequestBuilder() *AddEdgesRequestBuilder

func (*AddEdgesRequestBuilder) Common

func (AddEdgesRequestBuilder) Emit

func (*AddEdgesRequestBuilder) IfNotExists

func (a *AddEdgesRequestBuilder) IfNotExists(ifNotExists bool) *AddEdgesRequestBuilder

func (*AddEdgesRequestBuilder) IgnoreExistedIndex

func (a *AddEdgesRequestBuilder) IgnoreExistedIndex(ignoreExistedIndex bool) *AddEdgesRequestBuilder

func (*AddEdgesRequestBuilder) Parts

func (*AddEdgesRequestBuilder) PropNames

func (a *AddEdgesRequestBuilder) PropNames(propNames [][]byte) *AddEdgesRequestBuilder

func (*AddEdgesRequestBuilder) SpaceID

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

func (a *AddLearnerReq) SetLearner(learner *nebula0.HostAddr) *AddLearnerReq

func (*AddLearnerReq) SetPartID

func (a *AddLearnerReq) SetPartID(partID nebula0.PartitionID) *AddLearnerReq

func (*AddLearnerReq) SetSpaceID

func (a *AddLearnerReq) SetSpaceID(spaceID nebula0.GraphSpaceID) *AddLearnerReq

func (*AddLearnerReq) String

func (p *AddLearnerReq) String() string

func (*AddLearnerReq) Write

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

type AddLearnerReqBuilder

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

func NewAddLearnerReqBuilder

func NewAddLearnerReqBuilder() *AddLearnerReqBuilder

func (AddLearnerReqBuilder) Emit

func (*AddLearnerReqBuilder) Learner

func (*AddLearnerReqBuilder) PartID

func (*AddLearnerReqBuilder) SpaceID

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

func (a *AddPartReq) SetAsLearner(asLearner bool) *AddPartReq

func (*AddPartReq) SetPartID

func (a *AddPartReq) SetPartID(partID nebula0.PartitionID) *AddPartReq

func (*AddPartReq) SetPeers

func (a *AddPartReq) SetPeers(peers []*nebula0.HostAddr) *AddPartReq

func (*AddPartReq) SetSpaceID

func (a *AddPartReq) SetSpaceID(spaceID nebula0.GraphSpaceID) *AddPartReq

func (*AddPartReq) String

func (p *AddPartReq) String() string

func (*AddPartReq) Write

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

type AddPartReqBuilder

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

func NewAddPartReqBuilder

func NewAddPartReqBuilder() *AddPartReqBuilder

func (*AddPartReqBuilder) AsLearner

func (a *AddPartReqBuilder) AsLearner(asLearner bool) *AddPartReqBuilder

func (AddPartReqBuilder) Emit

func (p AddPartReqBuilder) Emit() *AddPartReq

func (*AddPartReqBuilder) PartID

func (*AddPartReqBuilder) Peers

func (*AddPartReqBuilder) SpaceID

type AddTaskRequest added in v3.1.0

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

Attributes:

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

func NewAddTaskRequest added in v3.1.0

func NewAddTaskRequest() *AddTaskRequest

func (*AddTaskRequest) GetJobID added in v3.1.0

func (p *AddTaskRequest) GetJobID() int32

func (*AddTaskRequest) GetJobType added in v3.1.0

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

func (*AddTaskRequest) GetPara added in v3.1.0

func (p *AddTaskRequest) GetPara() *TaskPara

func (*AddTaskRequest) GetTaskID added in v3.1.0

func (p *AddTaskRequest) GetTaskID() int32

func (*AddTaskRequest) IsSetPara added in v3.1.0

func (p *AddTaskRequest) IsSetPara() bool

func (*AddTaskRequest) Read added in v3.1.0

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

func (*AddTaskRequest) ReadField1 added in v3.1.0

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

func (*AddTaskRequest) ReadField2 added in v3.1.0

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

func (*AddTaskRequest) ReadField3 added in v3.1.0

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

func (*AddTaskRequest) ReadField4 added in v3.1.0

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

func (*AddTaskRequest) SetJobID added in v3.1.0

func (a *AddTaskRequest) SetJobID(jobID int32) *AddTaskRequest

func (*AddTaskRequest) SetJobType added in v3.1.0

func (a *AddTaskRequest) SetJobType(jobType meta1.JobType) *AddTaskRequest

func (*AddTaskRequest) SetPara added in v3.1.0

func (a *AddTaskRequest) SetPara(para *TaskPara) *AddTaskRequest

func (*AddTaskRequest) SetTaskID added in v3.1.0

func (a *AddTaskRequest) SetTaskID(taskID int32) *AddTaskRequest

func (*AddTaskRequest) String added in v3.1.0

func (p *AddTaskRequest) String() string

func (*AddTaskRequest) Write added in v3.1.0

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

type AddTaskRequestBuilder added in v3.1.0

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

func NewAddTaskRequestBuilder added in v3.1.0

func NewAddTaskRequestBuilder() *AddTaskRequestBuilder

func (AddTaskRequestBuilder) Emit added in v3.1.0

func (*AddTaskRequestBuilder) JobID added in v3.1.0

func (*AddTaskRequestBuilder) JobType added in v3.1.0

func (*AddTaskRequestBuilder) Para added in v3.1.0

func (*AddTaskRequestBuilder) TaskID added in v3.1.0

type AddTaskResp added in v3.1.0

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

Attributes:

  • Code
var StorageAdminServiceAddAdminTaskResult_Success_DEFAULT *AddTaskResp

func NewAddTaskResp added in v3.1.0

func NewAddTaskResp() *AddTaskResp

func (*AddTaskResp) GetCode added in v3.1.0

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

func (*AddTaskResp) Read added in v3.1.0

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

func (*AddTaskResp) ReadField1 added in v3.1.0

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

func (*AddTaskResp) SetCode added in v3.1.0

func (a *AddTaskResp) SetCode(code nebula0.ErrorCode) *AddTaskResp

func (*AddTaskResp) String added in v3.1.0

func (p *AddTaskResp) String() string

func (*AddTaskResp) Write added in v3.1.0

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

type AddTaskRespBuilder added in v3.1.0

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

func NewAddTaskRespBuilder added in v3.1.0

func NewAddTaskRespBuilder() *AddTaskRespBuilder

func (*AddTaskRespBuilder) Code added in v3.1.0

func (AddTaskRespBuilder) Emit added in v3.1.0

func (p AddTaskRespBuilder) Emit() *AddTaskResp

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"`
	IgnoreExistedIndex bool                                  `thrift:"ignore_existed_index,5" db:"ignore_existed_index" json:"ignore_existed_index"`
	Common             *RequestCommon                        `thrift:"common,6,optional" db:"common" json:"common,omitempty"`
}

Attributes:

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

func NewAddVerticesRequest

func NewAddVerticesRequest() *AddVerticesRequest

func (*AddVerticesRequest) GetCommon

func (p *AddVerticesRequest) GetCommon() *RequestCommon

func (*AddVerticesRequest) GetIfNotExists

func (p *AddVerticesRequest) GetIfNotExists() bool

func (*AddVerticesRequest) GetIgnoreExistedIndex

func (p *AddVerticesRequest) GetIgnoreExistedIndex() bool

func (*AddVerticesRequest) GetParts

func (p *AddVerticesRequest) GetParts() map[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

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

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

func (*AddVerticesRequest) ReadField6

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

func (*AddVerticesRequest) SetCommon

func (a *AddVerticesRequest) SetCommon(common *RequestCommon) *AddVerticesRequest

func (*AddVerticesRequest) SetIfNotExists

func (a *AddVerticesRequest) SetIfNotExists(ifNotExists bool) *AddVerticesRequest

func (*AddVerticesRequest) SetIgnoreExistedIndex

func (a *AddVerticesRequest) SetIgnoreExistedIndex(ignoreExistedIndex bool) *AddVerticesRequest

func (*AddVerticesRequest) SetParts

func (*AddVerticesRequest) SetPropNames

func (a *AddVerticesRequest) SetPropNames(propNames map[nebula0.TagID][][]byte) *AddVerticesRequest

func (*AddVerticesRequest) SetSpaceID

func (*AddVerticesRequest) String

func (p *AddVerticesRequest) String() string

func (*AddVerticesRequest) Write

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

type AddVerticesRequestBuilder

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

func NewAddVerticesRequestBuilder

func NewAddVerticesRequestBuilder() *AddVerticesRequestBuilder

func (*AddVerticesRequestBuilder) Common

func (AddVerticesRequestBuilder) Emit

func (*AddVerticesRequestBuilder) IfNotExists

func (a *AddVerticesRequestBuilder) IfNotExists(ifNotExists bool) *AddVerticesRequestBuilder

func (*AddVerticesRequestBuilder) IgnoreExistedIndex

func (a *AddVerticesRequestBuilder) IgnoreExistedIndex(ignoreExistedIndex bool) *AddVerticesRequestBuilder

func (*AddVerticesRequestBuilder) Parts

func (*AddVerticesRequestBuilder) PropNames

func (a *AddVerticesRequestBuilder) PropNames(propNames map[nebula0.TagID][][]byte) *AddVerticesRequestBuilder

func (*AddVerticesRequestBuilder) SpaceID

type AdminExecResp

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

Attributes:

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

func NewAdminExecResp

func NewAdminExecResp() *AdminExecResp

func (*AdminExecResp) GetResult_

func (p *AdminExecResp) GetResult_() *ResponseCommon

func (*AdminExecResp) GetStats

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

func (*AdminExecResp) IsSetResult_

func (p *AdminExecResp) IsSetResult_() bool

func (*AdminExecResp) IsSetStats

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

func (a *AdminExecResp) SetResult_(result *ResponseCommon) *AdminExecResp

func (*AdminExecResp) SetStats

func (a *AdminExecResp) SetStats(stats *meta1.StatsItem) *AdminExecResp

func (*AdminExecResp) String

func (p *AdminExecResp) String() string

func (*AdminExecResp) Write

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

type AdminExecRespBuilder

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

func NewAdminExecRespBuilder

func NewAdminExecRespBuilder() *AdminExecRespBuilder

func (AdminExecRespBuilder) Emit

func (*AdminExecRespBuilder) Result_

func (*AdminExecRespBuilder) Stats

type BlockingSignRequest

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

Attributes:

  • SpaceIds
  • Sign
var StorageAdminServiceBlockingWritesArgs_Req_DEFAULT *BlockingSignRequest

func NewBlockingSignRequest

func NewBlockingSignRequest() *BlockingSignRequest

func (*BlockingSignRequest) GetSign

func (p *BlockingSignRequest) GetSign() EngineSignType

func (*BlockingSignRequest) GetSpaceIds

func (p *BlockingSignRequest) GetSpaceIds() []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) SetSign

func (*BlockingSignRequest) SetSpaceIds

func (b *BlockingSignRequest) SetSpaceIds(spaceIds []nebula0.GraphSpaceID) *BlockingSignRequest

func (*BlockingSignRequest) String

func (p *BlockingSignRequest) String() string

func (*BlockingSignRequest) Write

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

type BlockingSignRequestBuilder

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

func NewBlockingSignRequestBuilder

func NewBlockingSignRequestBuilder() *BlockingSignRequestBuilder

func (BlockingSignRequestBuilder) Emit

func (*BlockingSignRequestBuilder) Sign

func (*BlockingSignRequestBuilder) SpaceIds

type BlockingSignResp added in v3.1.0

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

Attributes:

  • Code
var StorageAdminServiceBlockingWritesResult_Success_DEFAULT *BlockingSignResp

func NewBlockingSignResp added in v3.1.0

func NewBlockingSignResp() *BlockingSignResp

func (*BlockingSignResp) GetCode added in v3.1.0

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

func (*BlockingSignResp) Read added in v3.1.0

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

func (*BlockingSignResp) ReadField1 added in v3.1.0

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

func (*BlockingSignResp) SetCode added in v3.1.0

func (*BlockingSignResp) String added in v3.1.0

func (p *BlockingSignResp) String() string

func (*BlockingSignResp) Write added in v3.1.0

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

type BlockingSignRespBuilder added in v3.1.0

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

func NewBlockingSignRespBuilder added in v3.1.0

func NewBlockingSignRespBuilder() *BlockingSignRespBuilder

func (*BlockingSignRespBuilder) Code added in v3.1.0

func (BlockingSignRespBuilder) Emit added in v3.1.0

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

func (c *CatchUpDataReq) SetPartID(partID nebula0.PartitionID) *CatchUpDataReq

func (*CatchUpDataReq) SetSpaceID

func (c *CatchUpDataReq) SetSpaceID(spaceID nebula0.GraphSpaceID) *CatchUpDataReq

func (*CatchUpDataReq) SetTarget

func (c *CatchUpDataReq) SetTarget(target *nebula0.HostAddr) *CatchUpDataReq

func (*CatchUpDataReq) String

func (p *CatchUpDataReq) String() string

func (*CatchUpDataReq) Write

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

type CatchUpDataReqBuilder

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

func NewCatchUpDataReqBuilder

func NewCatchUpDataReqBuilder() *CatchUpDataReqBuilder

func (CatchUpDataReqBuilder) Emit

func (*CatchUpDataReqBuilder) PartID

func (*CatchUpDataReqBuilder) SpaceID

func (*CatchUpDataReqBuilder) Target

type ChainAddEdgesRequest

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,optional" db:"edge_version" json:"edge_version,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • PropNames
  • IfNotExists
  • Term
  • EdgeVersion

func NewChainAddEdgesRequest

func NewChainAddEdgesRequest() *ChainAddEdgesRequest

func (*ChainAddEdgesRequest) GetEdgeVersion

func (p *ChainAddEdgesRequest) GetEdgeVersion() int64

func (*ChainAddEdgesRequest) GetIfNotExists

func (p *ChainAddEdgesRequest) GetIfNotExists() bool

func (*ChainAddEdgesRequest) GetParts

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

func (*ChainAddEdgesRequest) GetPropNames

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

func (*ChainAddEdgesRequest) GetSpaceID

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

func (*ChainAddEdgesRequest) GetTerm

func (p *ChainAddEdgesRequest) GetTerm() int64

func (*ChainAddEdgesRequest) IsSetEdgeVersion

func (p *ChainAddEdgesRequest) IsSetEdgeVersion() bool

func (*ChainAddEdgesRequest) Read

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

func (*ChainAddEdgesRequest) ReadField1

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

func (*ChainAddEdgesRequest) ReadField2

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

func (*ChainAddEdgesRequest) ReadField3

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

func (*ChainAddEdgesRequest) ReadField4

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

func (*ChainAddEdgesRequest) ReadField5

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

func (*ChainAddEdgesRequest) ReadField6

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

func (*ChainAddEdgesRequest) SetEdgeVersion

func (c *ChainAddEdgesRequest) SetEdgeVersion(edgeVersion *int64) *ChainAddEdgesRequest

func (*ChainAddEdgesRequest) SetIfNotExists

func (c *ChainAddEdgesRequest) SetIfNotExists(ifNotExists bool) *ChainAddEdgesRequest

func (*ChainAddEdgesRequest) SetParts

func (*ChainAddEdgesRequest) SetPropNames

func (c *ChainAddEdgesRequest) SetPropNames(propNames [][]byte) *ChainAddEdgesRequest

func (*ChainAddEdgesRequest) SetSpaceID

func (*ChainAddEdgesRequest) SetTerm

func (*ChainAddEdgesRequest) String

func (p *ChainAddEdgesRequest) String() string

func (*ChainAddEdgesRequest) Write

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

type ChainAddEdgesRequestBuilder

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

func NewChainAddEdgesRequestBuilder

func NewChainAddEdgesRequestBuilder() *ChainAddEdgesRequestBuilder

func (*ChainAddEdgesRequestBuilder) EdgeVersion

func (c *ChainAddEdgesRequestBuilder) EdgeVersion(edgeVersion *int64) *ChainAddEdgesRequestBuilder

func (ChainAddEdgesRequestBuilder) Emit

func (*ChainAddEdgesRequestBuilder) IfNotExists

func (c *ChainAddEdgesRequestBuilder) IfNotExists(ifNotExists bool) *ChainAddEdgesRequestBuilder

func (*ChainAddEdgesRequestBuilder) Parts

func (*ChainAddEdgesRequestBuilder) PropNames

func (c *ChainAddEdgesRequestBuilder) PropNames(propNames [][]byte) *ChainAddEdgesRequestBuilder

func (*ChainAddEdgesRequestBuilder) SpaceID

func (*ChainAddEdgesRequestBuilder) Term

type ChainDeleteEdgesRequest

type ChainDeleteEdgesRequest 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"`
	TxnID   []byte                             `thrift:"txn_id,3" db:"txn_id" json:"txn_id"`
	Term    int64                              `thrift:"term,4" db:"term" json:"term"`
}

Attributes:

  • SpaceID
  • Parts
  • TxnID
  • Term

func NewChainDeleteEdgesRequest

func NewChainDeleteEdgesRequest() *ChainDeleteEdgesRequest

func (*ChainDeleteEdgesRequest) GetParts

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

func (*ChainDeleteEdgesRequest) GetSpaceID

func (*ChainDeleteEdgesRequest) GetTerm

func (p *ChainDeleteEdgesRequest) GetTerm() int64

func (*ChainDeleteEdgesRequest) GetTxnID

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

func (*ChainDeleteEdgesRequest) Read

func (*ChainDeleteEdgesRequest) ReadField1

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

func (*ChainDeleteEdgesRequest) ReadField2

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

func (*ChainDeleteEdgesRequest) ReadField3

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

func (*ChainDeleteEdgesRequest) ReadField4

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

func (*ChainDeleteEdgesRequest) SetParts

func (*ChainDeleteEdgesRequest) SetSpaceID

func (*ChainDeleteEdgesRequest) SetTerm

func (*ChainDeleteEdgesRequest) SetTxnID

func (*ChainDeleteEdgesRequest) String

func (p *ChainDeleteEdgesRequest) String() string

func (*ChainDeleteEdgesRequest) Write

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

type ChainDeleteEdgesRequestBuilder

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

func NewChainDeleteEdgesRequestBuilder

func NewChainDeleteEdgesRequestBuilder() *ChainDeleteEdgesRequestBuilder

func (ChainDeleteEdgesRequestBuilder) Emit

func (*ChainDeleteEdgesRequestBuilder) Parts

func (*ChainDeleteEdgesRequestBuilder) SpaceID

func (*ChainDeleteEdgesRequestBuilder) Term

func (*ChainDeleteEdgesRequestBuilder) TxnID

type ChainUpdateEdgeRequest

type ChainUpdateEdgeRequest struct {
	UpdateEdgeRequest *UpdateEdgeRequest    `thrift:"update_edge_request,1" db:"update_edge_request" json:"update_edge_request"`
	Term              int64                 `thrift:"term,2" db:"term" json:"term"`
	EdgeVersion       *int64                `thrift:"edge_version,3,optional" 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

func NewChainUpdateEdgeRequest() *ChainUpdateEdgeRequest

func (*ChainUpdateEdgeRequest) GetEdgeVersion

func (p *ChainUpdateEdgeRequest) GetEdgeVersion() int64

func (*ChainUpdateEdgeRequest) GetParts

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

func (*ChainUpdateEdgeRequest) GetSpaceID

func (*ChainUpdateEdgeRequest) GetTerm

func (p *ChainUpdateEdgeRequest) GetTerm() int64

func (*ChainUpdateEdgeRequest) GetUpdateEdgeRequest

func (p *ChainUpdateEdgeRequest) GetUpdateEdgeRequest() *UpdateEdgeRequest

func (*ChainUpdateEdgeRequest) IsSetEdgeVersion

func (p *ChainUpdateEdgeRequest) IsSetEdgeVersion() bool

func (*ChainUpdateEdgeRequest) IsSetUpdateEdgeRequest

func (p *ChainUpdateEdgeRequest) IsSetUpdateEdgeRequest() bool

func (*ChainUpdateEdgeRequest) Read

func (*ChainUpdateEdgeRequest) ReadField1

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

func (*ChainUpdateEdgeRequest) ReadField2

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

func (*ChainUpdateEdgeRequest) ReadField3

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

func (*ChainUpdateEdgeRequest) ReadField4

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

func (*ChainUpdateEdgeRequest) ReadField5

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

func (*ChainUpdateEdgeRequest) SetEdgeVersion

func (c *ChainUpdateEdgeRequest) SetEdgeVersion(edgeVersion *int64) *ChainUpdateEdgeRequest

func (*ChainUpdateEdgeRequest) SetParts

func (*ChainUpdateEdgeRequest) SetSpaceID

func (*ChainUpdateEdgeRequest) SetTerm

func (*ChainUpdateEdgeRequest) SetUpdateEdgeRequest

func (c *ChainUpdateEdgeRequest) SetUpdateEdgeRequest(updateEdgeRequest *UpdateEdgeRequest) *ChainUpdateEdgeRequest

func (*ChainUpdateEdgeRequest) String

func (p *ChainUpdateEdgeRequest) String() string

func (*ChainUpdateEdgeRequest) Write

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

type ChainUpdateEdgeRequestBuilder

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

func NewChainUpdateEdgeRequestBuilder

func NewChainUpdateEdgeRequestBuilder() *ChainUpdateEdgeRequestBuilder

func (*ChainUpdateEdgeRequestBuilder) EdgeVersion

func (ChainUpdateEdgeRequestBuilder) Emit

func (*ChainUpdateEdgeRequestBuilder) Parts

func (*ChainUpdateEdgeRequestBuilder) SpaceID

func (*ChainUpdateEdgeRequestBuilder) Term

func (*ChainUpdateEdgeRequestBuilder) UpdateEdgeRequest

func (c *ChainUpdateEdgeRequestBuilder) UpdateEdgeRequest(updateEdgeRequest *UpdateEdgeRequest) *ChainUpdateEdgeRequestBuilder

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

func (c *CheckPeersReq) SetPartID(partID nebula0.PartitionID) *CheckPeersReq

func (*CheckPeersReq) SetPeers

func (c *CheckPeersReq) SetPeers(peers []*nebula0.HostAddr) *CheckPeersReq

func (*CheckPeersReq) SetSpaceID

func (c *CheckPeersReq) SetSpaceID(spaceID nebula0.GraphSpaceID) *CheckPeersReq

func (*CheckPeersReq) String

func (p *CheckPeersReq) String() string

func (*CheckPeersReq) Write

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

type CheckPeersReqBuilder

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

func NewCheckPeersReqBuilder

func NewCheckPeersReqBuilder() *CheckPeersReqBuilder

func (CheckPeersReqBuilder) Emit

func (*CheckPeersReqBuilder) PartID

func (*CheckPeersReqBuilder) Peers

func (*CheckPeersReqBuilder) SpaceID

type ClearSpaceReq added in v3.1.0

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

Attributes:

  • SpaceID
var StorageAdminServiceClearSpaceArgs_Req_DEFAULT *ClearSpaceReq

func NewClearSpaceReq added in v3.1.0

func NewClearSpaceReq() *ClearSpaceReq

func (*ClearSpaceReq) GetSpaceID added in v3.1.0

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

func (*ClearSpaceReq) Read added in v3.1.0

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

func (*ClearSpaceReq) ReadField1 added in v3.1.0

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

func (*ClearSpaceReq) SetSpaceID added in v3.1.0

func (c *ClearSpaceReq) SetSpaceID(spaceID nebula0.GraphSpaceID) *ClearSpaceReq

func (*ClearSpaceReq) String added in v3.1.0

func (p *ClearSpaceReq) String() string

func (*ClearSpaceReq) Write added in v3.1.0

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

type ClearSpaceReqBuilder added in v3.1.0

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

func NewClearSpaceReqBuilder added in v3.1.0

func NewClearSpaceReqBuilder() *ClearSpaceReqBuilder

func (ClearSpaceReqBuilder) Emit added in v3.1.0

func (*ClearSpaceReqBuilder) SpaceID added in v3.1.0

type ClearSpaceResp added in v3.1.0

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

Attributes:

  • Code
var StorageAdminServiceClearSpaceResult_Success_DEFAULT *ClearSpaceResp

func NewClearSpaceResp added in v3.1.0

func NewClearSpaceResp() *ClearSpaceResp

func (*ClearSpaceResp) GetCode added in v3.1.0

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

func (*ClearSpaceResp) Read added in v3.1.0

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

func (*ClearSpaceResp) ReadField1 added in v3.1.0

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

func (*ClearSpaceResp) SetCode added in v3.1.0

func (c *ClearSpaceResp) SetCode(code nebula0.ErrorCode) *ClearSpaceResp

func (*ClearSpaceResp) String added in v3.1.0

func (p *ClearSpaceResp) String() string

func (*ClearSpaceResp) Write added in v3.1.0

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

type ClearSpaceRespBuilder added in v3.1.0

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

func NewClearSpaceRespBuilder added in v3.1.0

func NewClearSpaceRespBuilder() *ClearSpaceRespBuilder

func (*ClearSpaceRespBuilder) Code added in v3.1.0

func (ClearSpaceRespBuilder) Emit added in v3.1.0

type CreateCPRequest

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

Attributes:

  • SpaceIds
  • Name
var StorageAdminServiceCreateCheckpointArgs_Req_DEFAULT *CreateCPRequest

func NewCreateCPRequest

func NewCreateCPRequest() *CreateCPRequest

func (*CreateCPRequest) GetName

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

func (*CreateCPRequest) GetSpaceIds

func (p *CreateCPRequest) GetSpaceIds() []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) SetName

func (c *CreateCPRequest) SetName(name []byte) *CreateCPRequest

func (*CreateCPRequest) SetSpaceIds

func (c *CreateCPRequest) SetSpaceIds(spaceIds []nebula0.GraphSpaceID) *CreateCPRequest

func (*CreateCPRequest) String

func (p *CreateCPRequest) String() string

func (*CreateCPRequest) Write

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

type CreateCPRequestBuilder

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

func NewCreateCPRequestBuilder

func NewCreateCPRequestBuilder() *CreateCPRequestBuilder

func (CreateCPRequestBuilder) Emit

func (*CreateCPRequestBuilder) Name

func (*CreateCPRequestBuilder) SpaceIds

type CreateCPResp

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

Attributes:

  • Code
  • Info
var StorageAdminServiceCreateCheckpointResult_Success_DEFAULT *CreateCPResp

func NewCreateCPResp

func NewCreateCPResp() *CreateCPResp

func (*CreateCPResp) GetCode added in v3.1.0

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

func (*CreateCPResp) GetInfo

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

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) SetCode added in v3.1.0

func (c *CreateCPResp) SetCode(code nebula0.ErrorCode) *CreateCPResp

func (*CreateCPResp) SetInfo

func (c *CreateCPResp) SetInfo(info []*nebula0.CheckpointInfo) *CreateCPResp

func (*CreateCPResp) String

func (p *CreateCPResp) String() string

func (*CreateCPResp) Write

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

type CreateCPRespBuilder

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

func NewCreateCPRespBuilder

func NewCreateCPRespBuilder() *CreateCPRespBuilder

func (*CreateCPRespBuilder) Code added in v3.1.0

func (CreateCPRespBuilder) Emit

func (*CreateCPRespBuilder) Info

type DelTags

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

func NewDelTags() *DelTags

func (*DelTags) GetId

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

func (*DelTags) GetTags

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

func (*DelTags) IsSetId

func (p *DelTags) IsSetId() bool

func (*DelTags) Read

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

func (*DelTags) ReadField1

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

func (*DelTags) ReadField2

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

func (*DelTags) SetId

func (d *DelTags) SetId(id *nebula0.Value) *DelTags

func (*DelTags) SetTags

func (d *DelTags) SetTags(tags []nebula0.TagID) *DelTags

func (*DelTags) String

func (p *DelTags) String() string

func (*DelTags) Write

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

type DelTagsBuilder

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

func NewDelTagsBuilder

func NewDelTagsBuilder() *DelTagsBuilder

func (DelTagsBuilder) Emit

func (p DelTagsBuilder) Emit() *DelTags

func (*DelTagsBuilder) Id

func (*DelTagsBuilder) Tags

func (d *DelTagsBuilder) Tags(tags []nebula0.TagID) *DelTagsBuilder

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,optional" db:"common" json:"common,omitempty"`
}

Attributes:

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

func NewDeleteEdgesRequest

func NewDeleteEdgesRequest() *DeleteEdgesRequest

func (*DeleteEdgesRequest) GetCommon

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

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

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

func (*DeleteEdgesRequest) SetCommon

func (d *DeleteEdgesRequest) SetCommon(common *RequestCommon) *DeleteEdgesRequest

func (*DeleteEdgesRequest) SetParts

func (*DeleteEdgesRequest) SetSpaceID

func (*DeleteEdgesRequest) String

func (p *DeleteEdgesRequest) String() string

func (*DeleteEdgesRequest) Write

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

type DeleteEdgesRequestBuilder

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

func NewDeleteEdgesRequestBuilder

func NewDeleteEdgesRequestBuilder() *DeleteEdgesRequestBuilder

func (*DeleteEdgesRequestBuilder) Common

func (DeleteEdgesRequestBuilder) Emit

func (*DeleteEdgesRequestBuilder) Parts

func (*DeleteEdgesRequestBuilder) SpaceID

type DeleteTagsRequest

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,optional" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • Common
var GraphStorageServiceDeleteTagsArgs_Req_DEFAULT *DeleteTagsRequest

func NewDeleteTagsRequest

func NewDeleteTagsRequest() *DeleteTagsRequest

func (*DeleteTagsRequest) GetCommon

func (p *DeleteTagsRequest) GetCommon() *RequestCommon

func (*DeleteTagsRequest) GetParts

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

func (*DeleteTagsRequest) GetSpaceID

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

func (*DeleteTagsRequest) IsSetCommon

func (p *DeleteTagsRequest) IsSetCommon() bool

func (*DeleteTagsRequest) Read

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

func (*DeleteTagsRequest) ReadField1

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

func (*DeleteTagsRequest) ReadField2

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

func (*DeleteTagsRequest) ReadField3

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

func (*DeleteTagsRequest) SetCommon

func (d *DeleteTagsRequest) SetCommon(common *RequestCommon) *DeleteTagsRequest

func (*DeleteTagsRequest) SetParts

func (d *DeleteTagsRequest) SetParts(parts map[nebula0.PartitionID][]*DelTags) *DeleteTagsRequest

func (*DeleteTagsRequest) SetSpaceID

func (d *DeleteTagsRequest) SetSpaceID(spaceID nebula0.GraphSpaceID) *DeleteTagsRequest

func (*DeleteTagsRequest) String

func (p *DeleteTagsRequest) String() string

func (*DeleteTagsRequest) Write

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

type DeleteTagsRequestBuilder

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

func NewDeleteTagsRequestBuilder

func NewDeleteTagsRequestBuilder() *DeleteTagsRequestBuilder

func (*DeleteTagsRequestBuilder) Common

func (DeleteTagsRequestBuilder) Emit

func (*DeleteTagsRequestBuilder) Parts

func (*DeleteTagsRequestBuilder) SpaceID

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,optional" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • Common
var GraphStorageServiceDeleteVerticesArgs_Req_DEFAULT *DeleteVerticesRequest

func NewDeleteVerticesRequest

func NewDeleteVerticesRequest() *DeleteVerticesRequest

func (*DeleteVerticesRequest) GetCommon

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

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

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

func (*DeleteVerticesRequest) SetCommon

func (*DeleteVerticesRequest) SetParts

func (*DeleteVerticesRequest) SetSpaceID

func (*DeleteVerticesRequest) String

func (p *DeleteVerticesRequest) String() string

func (*DeleteVerticesRequest) Write

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

type DeleteVerticesRequestBuilder

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

func NewDeleteVerticesRequestBuilder

func NewDeleteVerticesRequestBuilder() *DeleteVerticesRequestBuilder

func (*DeleteVerticesRequestBuilder) Common

func (DeleteVerticesRequestBuilder) Emit

func (*DeleteVerticesRequestBuilder) Parts

func (*DeleteVerticesRequestBuilder) SpaceID

type DropCPRequest

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

Attributes:

  • SpaceIds
  • Name
var StorageAdminServiceDropCheckpointArgs_Req_DEFAULT *DropCPRequest

func NewDropCPRequest

func NewDropCPRequest() *DropCPRequest

func (*DropCPRequest) GetName

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

func (*DropCPRequest) GetSpaceIds

func (p *DropCPRequest) GetSpaceIds() []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) SetName

func (d *DropCPRequest) SetName(name []byte) *DropCPRequest

func (*DropCPRequest) SetSpaceIds

func (d *DropCPRequest) SetSpaceIds(spaceIds []nebula0.GraphSpaceID) *DropCPRequest

func (*DropCPRequest) String

func (p *DropCPRequest) String() string

func (*DropCPRequest) Write

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

type DropCPRequestBuilder

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

func NewDropCPRequestBuilder

func NewDropCPRequestBuilder() *DropCPRequestBuilder

func (DropCPRequestBuilder) Emit

func (*DropCPRequestBuilder) Name

func (*DropCPRequestBuilder) SpaceIds

type DropCPResp added in v3.1.0

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

Attributes:

  • Code
var StorageAdminServiceDropCheckpointResult_Success_DEFAULT *DropCPResp

func NewDropCPResp added in v3.1.0

func NewDropCPResp() *DropCPResp

func (*DropCPResp) GetCode added in v3.1.0

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

func (*DropCPResp) Read added in v3.1.0

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

func (*DropCPResp) ReadField1 added in v3.1.0

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

func (*DropCPResp) SetCode added in v3.1.0

func (d *DropCPResp) SetCode(code nebula0.ErrorCode) *DropCPResp

func (*DropCPResp) String added in v3.1.0

func (p *DropCPResp) String() string

func (*DropCPResp) Write added in v3.1.0

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

type DropCPRespBuilder added in v3.1.0

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

func NewDropCPRespBuilder added in v3.1.0

func NewDropCPRespBuilder() *DropCPRespBuilder

func (*DropCPRespBuilder) Code added in v3.1.0

func (DropCPRespBuilder) Emit added in v3.1.0

func (p DropCPRespBuilder) Emit() *DropCPResp

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

func (e *EdgeKey) SetDst(dst *nebula0.Value) *EdgeKey

func (*EdgeKey) SetEdgeType

func (e *EdgeKey) SetEdgeType(edgeType nebula0.EdgeType) *EdgeKey

func (*EdgeKey) SetRanking

func (e *EdgeKey) SetRanking(ranking nebula0.EdgeRanking) *EdgeKey

func (*EdgeKey) SetSrc

func (e *EdgeKey) SetSrc(src *nebula0.Value) *EdgeKey

func (*EdgeKey) String

func (p *EdgeKey) String() string

func (*EdgeKey) Write

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

type EdgeKeyBuilder

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

func NewEdgeKeyBuilder

func NewEdgeKeyBuilder() *EdgeKeyBuilder

func (*EdgeKeyBuilder) Dst

func (*EdgeKeyBuilder) EdgeType

func (e *EdgeKeyBuilder) EdgeType(edgeType nebula0.EdgeType) *EdgeKeyBuilder

func (EdgeKeyBuilder) Emit

func (p EdgeKeyBuilder) Emit() *EdgeKey

func (*EdgeKeyBuilder) Ranking

func (e *EdgeKeyBuilder) Ranking(ranking nebula0.EdgeRanking) *EdgeKeyBuilder

func (*EdgeKeyBuilder) Src

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

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

func (e *EdgeProp) SetProps(props [][]byte) *EdgeProp

func (*EdgeProp) SetType

func (e *EdgeProp) SetType(type_a1 nebula0.EdgeType) *EdgeProp

func (*EdgeProp) String

func (p *EdgeProp) String() string

func (*EdgeProp) Write

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

type EdgePropBuilder

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

func NewEdgePropBuilder

func NewEdgePropBuilder() *EdgePropBuilder

func (EdgePropBuilder) Emit

func (p EdgePropBuilder) Emit() *EdgeProp

func (*EdgePropBuilder) Props

func (e *EdgePropBuilder) Props(props [][]byte) *EdgePropBuilder

func (*EdgePropBuilder) Type

func (e *EdgePropBuilder) Type(type_a1 nebula0.EdgeType) *EdgePropBuilder

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 GraphStorageServiceAddEdgesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceAddVerticesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceChainAddEdgesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceChainDeleteEdgesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceDeleteEdgesResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceDeleteTagsResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceDeleteVerticesResult_Success_DEFAULT *ExecResponse
var GraphStorageServicePutResult_Success_DEFAULT *ExecResponse
var GraphStorageServiceRemoveResult_Success_DEFAULT *ExecResponse

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

func (e *ExecResponse) SetResult_(result *ResponseCommon) *ExecResponse

func (*ExecResponse) String

func (p *ExecResponse) String() string

func (*ExecResponse) Write

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

type ExecResponseBuilder

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

func NewExecResponseBuilder

func NewExecResponseBuilder() *ExecResponseBuilder

func (ExecResponseBuilder) Emit

func (*ExecResponseBuilder) Result_

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

func (e *Expr) SetAlias(alias []byte) *Expr

func (*Expr) SetExpr

func (e *Expr) SetExpr(expr []byte) *Expr

func (*Expr) String

func (p *Expr) String() string

func (*Expr) Write

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

type ExprBuilder

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

func NewExprBuilder

func NewExprBuilder() *ExprBuilder

func (*ExprBuilder) Alias

func (e *ExprBuilder) Alias(alias []byte) *ExprBuilder

func (ExprBuilder) Emit

func (p ExprBuilder) Emit() *Expr

func (*ExprBuilder) Expr

func (e *ExprBuilder) Expr(expr []byte) *ExprBuilder

type GetDstBySrcRequest added in v3.3.1

type GetDstBySrcRequest 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"`
	EdgeTypes []nebula0.EdgeType                       `thrift:"edge_types,3" db:"edge_types" json:"edge_types"`
	Common    *RequestCommon                           `thrift:"common,4,optional" db:"common" json:"common,omitempty"`
}

Attributes:

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

func NewGetDstBySrcRequest added in v3.3.1

func NewGetDstBySrcRequest() *GetDstBySrcRequest

func (*GetDstBySrcRequest) GetCommon added in v3.3.1

func (p *GetDstBySrcRequest) GetCommon() *RequestCommon

func (*GetDstBySrcRequest) GetEdgeTypes added in v3.3.1

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

func (*GetDstBySrcRequest) GetParts added in v3.3.1

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

func (*GetDstBySrcRequest) GetSpaceID added in v3.3.1

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

func (*GetDstBySrcRequest) IsSetCommon added in v3.3.1

func (p *GetDstBySrcRequest) IsSetCommon() bool

func (*GetDstBySrcRequest) Read added in v3.3.1

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

func (*GetDstBySrcRequest) ReadField1 added in v3.3.1

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

func (*GetDstBySrcRequest) ReadField2 added in v3.3.1

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

func (*GetDstBySrcRequest) ReadField3 added in v3.3.1

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

func (*GetDstBySrcRequest) ReadField4 added in v3.3.1

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

func (*GetDstBySrcRequest) SetCommon added in v3.3.1

func (g *GetDstBySrcRequest) SetCommon(common *RequestCommon) *GetDstBySrcRequest

func (*GetDstBySrcRequest) SetEdgeTypes added in v3.3.1

func (g *GetDstBySrcRequest) SetEdgeTypes(edgeTypes []nebula0.EdgeType) *GetDstBySrcRequest

func (*GetDstBySrcRequest) SetParts added in v3.3.1

func (*GetDstBySrcRequest) SetSpaceID added in v3.3.1

func (*GetDstBySrcRequest) String added in v3.3.1

func (p *GetDstBySrcRequest) String() string

func (*GetDstBySrcRequest) Write added in v3.3.1

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

type GetDstBySrcRequestBuilder added in v3.3.1

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

func NewGetDstBySrcRequestBuilder added in v3.3.1

func NewGetDstBySrcRequestBuilder() *GetDstBySrcRequestBuilder

func (*GetDstBySrcRequestBuilder) Common added in v3.3.1

func (*GetDstBySrcRequestBuilder) EdgeTypes added in v3.3.1

func (GetDstBySrcRequestBuilder) Emit added in v3.3.1

func (*GetDstBySrcRequestBuilder) Parts added in v3.3.1

func (*GetDstBySrcRequestBuilder) SpaceID added in v3.3.1

type GetDstBySrcResponse added in v3.3.1

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

Attributes:

  • Result_
  • Dsts
var GraphStorageServiceGetDstBySrcResult_Success_DEFAULT *GetDstBySrcResponse

func NewGetDstBySrcResponse added in v3.3.1

func NewGetDstBySrcResponse() *GetDstBySrcResponse

func (*GetDstBySrcResponse) GetDsts added in v3.3.1

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

func (*GetDstBySrcResponse) GetResult_ added in v3.3.1

func (p *GetDstBySrcResponse) GetResult_() *ResponseCommon

func (*GetDstBySrcResponse) IsSetDsts added in v3.3.1

func (p *GetDstBySrcResponse) IsSetDsts() bool

func (*GetDstBySrcResponse) IsSetResult_ added in v3.3.1

func (p *GetDstBySrcResponse) IsSetResult_() bool

func (*GetDstBySrcResponse) Read added in v3.3.1

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

func (*GetDstBySrcResponse) ReadField1 added in v3.3.1

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

func (*GetDstBySrcResponse) ReadField2 added in v3.3.1

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

func (*GetDstBySrcResponse) SetDsts added in v3.3.1

func (*GetDstBySrcResponse) SetResult_ added in v3.3.1

func (g *GetDstBySrcResponse) SetResult_(result *ResponseCommon) *GetDstBySrcResponse

func (*GetDstBySrcResponse) String added in v3.3.1

func (p *GetDstBySrcResponse) String() string

func (*GetDstBySrcResponse) Write added in v3.3.1

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

type GetDstBySrcResponseBuilder added in v3.3.1

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

func NewGetDstBySrcResponseBuilder added in v3.3.1

func NewGetDstBySrcResponseBuilder() *GetDstBySrcResponseBuilder

func (*GetDstBySrcResponseBuilder) Dsts added in v3.3.1

func (GetDstBySrcResponseBuilder) Emit added in v3.3.1

func (*GetDstBySrcResponseBuilder) Result_ added in v3.3.1

type GetLeaderPartsResp

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

Attributes:

  • Code
  • LeaderParts
var StorageAdminServiceGetLeaderPartsResult_Success_DEFAULT *GetLeaderPartsResp

func NewGetLeaderPartsResp

func NewGetLeaderPartsResp() *GetLeaderPartsResp

func (*GetLeaderPartsResp) GetCode added in v3.1.0

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

func (*GetLeaderPartsResp) GetLeaderParts

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

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) SetCode added in v3.1.0

func (*GetLeaderPartsResp) SetLeaderParts

func (g *GetLeaderPartsResp) SetLeaderParts(leaderParts map[nebula0.GraphSpaceID][]nebula0.PartitionID) *GetLeaderPartsResp

func (*GetLeaderPartsResp) String

func (p *GetLeaderPartsResp) String() string

func (*GetLeaderPartsResp) Write

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

type GetLeaderPartsRespBuilder

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

func NewGetLeaderPartsRespBuilder

func NewGetLeaderPartsRespBuilder() *GetLeaderPartsRespBuilder

func (*GetLeaderPartsRespBuilder) Code added in v3.1.0

func (GetLeaderPartsRespBuilder) Emit

func (*GetLeaderPartsRespBuilder) LeaderParts

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 GetLeaderReqBuilder

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

func NewGetLeaderReqBuilder

func NewGetLeaderReqBuilder() *GetLeaderReqBuilder

func (GetLeaderReqBuilder) Emit

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.Value `thrift:"parts,3" db:"parts" json:"parts"`
	TraverseSpec *TraverseSpec                            `thrift:"traverse_spec,4" db:"traverse_spec" json:"traverse_spec"`
	Common       *RequestCommon                           `thrift:"common,5,optional" 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

func (p *GetNeighborsRequest) GetCommon() *RequestCommon

func (*GetNeighborsRequest) GetParts

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

func (*GetNeighborsRequest) GetSpaceID

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

func (*GetNeighborsRequest) GetTraverseSpec

func (p *GetNeighborsRequest) GetTraverseSpec() *TraverseSpec

func (*GetNeighborsRequest) IsSetCommon

func (p *GetNeighborsRequest) IsSetCommon() bool

func (*GetNeighborsRequest) IsSetTraverseSpec

func (p *GetNeighborsRequest) IsSetTraverseSpec() bool

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

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

func (*GetNeighborsRequest) SetColumnNames

func (g *GetNeighborsRequest) SetColumnNames(columnNames [][]byte) *GetNeighborsRequest

func (*GetNeighborsRequest) SetCommon

func (g *GetNeighborsRequest) SetCommon(common *RequestCommon) *GetNeighborsRequest

func (*GetNeighborsRequest) SetParts

func (*GetNeighborsRequest) SetSpaceID

func (*GetNeighborsRequest) SetTraverseSpec

func (g *GetNeighborsRequest) SetTraverseSpec(traverseSpec *TraverseSpec) *GetNeighborsRequest

func (*GetNeighborsRequest) String

func (p *GetNeighborsRequest) String() string

func (*GetNeighborsRequest) Write

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

type GetNeighborsRequestBuilder

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

func NewGetNeighborsRequestBuilder

func NewGetNeighborsRequestBuilder() *GetNeighborsRequestBuilder

func (*GetNeighborsRequestBuilder) ColumnNames

func (g *GetNeighborsRequestBuilder) ColumnNames(columnNames [][]byte) *GetNeighborsRequestBuilder

func (*GetNeighborsRequestBuilder) Common

func (GetNeighborsRequestBuilder) Emit

func (*GetNeighborsRequestBuilder) Parts

func (*GetNeighborsRequestBuilder) SpaceID

func (*GetNeighborsRequestBuilder) TraverseSpec

func (g *GetNeighborsRequestBuilder) TraverseSpec(traverseSpec *TraverseSpec) *GetNeighborsRequestBuilder

type GetNeighborsResponse

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

func (*GetNeighborsResponse) SetVertices

func (g *GetNeighborsResponse) SetVertices(vertices *nebula0.DataSet) *GetNeighborsResponse

func (*GetNeighborsResponse) String

func (p *GetNeighborsResponse) String() string

func (*GetNeighborsResponse) Write

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

type GetNeighborsResponseBuilder

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

func NewGetNeighborsResponseBuilder

func NewGetNeighborsResponseBuilder() *GetNeighborsResponseBuilder

func (GetNeighborsResponseBuilder) Emit

func (*GetNeighborsResponseBuilder) Result_

func (*GetNeighborsResponseBuilder) Vertices

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,optional" db:"vertex_props" json:"vertex_props,omitempty"`
	EdgeProps   []*EdgeProp                            `thrift:"edge_props,4,optional" db:"edge_props" json:"edge_props,omitempty"`
	Expressions []*Expr                                `thrift:"expressions,5,optional" db:"expressions" json:"expressions,omitempty"`
	Dedup       bool                                   `thrift:"dedup,6" db:"dedup" json:"dedup"`
	OrderBy     []*OrderBy                             `thrift:"order_by,7,optional" db:"order_by" json:"order_by,omitempty"`
	Limit       *int64                                 `thrift:"limit,8,optional" db:"limit" json:"limit,omitempty"`
	Filter      []byte                                 `thrift:"filter,9,optional" db:"filter" json:"filter,omitempty"`
	Common      *RequestCommon                         `thrift:"common,10,optional" 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

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

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

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

func (g *GetPropRequest) SetCommon(common *RequestCommon) *GetPropRequest

func (*GetPropRequest) SetDedup

func (g *GetPropRequest) SetDedup(dedup bool) *GetPropRequest

func (*GetPropRequest) SetEdgeProps

func (g *GetPropRequest) SetEdgeProps(edgeProps []*EdgeProp) *GetPropRequest

func (*GetPropRequest) SetExpressions

func (g *GetPropRequest) SetExpressions(expressions []*Expr) *GetPropRequest

func (*GetPropRequest) SetFilter

func (g *GetPropRequest) SetFilter(filter []byte) *GetPropRequest

func (*GetPropRequest) SetLimit

func (g *GetPropRequest) SetLimit(limit *int64) *GetPropRequest

func (*GetPropRequest) SetOrderBy

func (g *GetPropRequest) SetOrderBy(orderBy []*OrderBy) *GetPropRequest

func (*GetPropRequest) SetParts

func (g *GetPropRequest) SetParts(parts map[nebula0.PartitionID][]*nebula0.Row) *GetPropRequest

func (*GetPropRequest) SetSpaceID

func (g *GetPropRequest) SetSpaceID(spaceID nebula0.GraphSpaceID) *GetPropRequest

func (*GetPropRequest) SetVertexProps

func (g *GetPropRequest) SetVertexProps(vertexProps []*VertexProp) *GetPropRequest

func (*GetPropRequest) String

func (p *GetPropRequest) String() string

func (*GetPropRequest) Write

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

type GetPropRequestBuilder

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

func NewGetPropRequestBuilder

func NewGetPropRequestBuilder() *GetPropRequestBuilder

func (*GetPropRequestBuilder) Common

func (*GetPropRequestBuilder) Dedup

func (*GetPropRequestBuilder) EdgeProps

func (g *GetPropRequestBuilder) EdgeProps(edgeProps []*EdgeProp) *GetPropRequestBuilder

func (GetPropRequestBuilder) Emit

func (*GetPropRequestBuilder) Expressions

func (g *GetPropRequestBuilder) Expressions(expressions []*Expr) *GetPropRequestBuilder

func (*GetPropRequestBuilder) Filter

func (g *GetPropRequestBuilder) Filter(filter []byte) *GetPropRequestBuilder

func (*GetPropRequestBuilder) Limit

func (*GetPropRequestBuilder) OrderBy

func (g *GetPropRequestBuilder) OrderBy(orderBy []*OrderBy) *GetPropRequestBuilder

func (*GetPropRequestBuilder) Parts

func (*GetPropRequestBuilder) SpaceID

func (*GetPropRequestBuilder) VertexProps

func (g *GetPropRequestBuilder) VertexProps(vertexProps []*VertexProp) *GetPropRequestBuilder

type GetPropResponse

type GetPropResponse struct {
	Result_ *ResponseCommon  `thrift:"result,1" db:"result" json:"result"`
	Props   *nebula0.DataSet `thrift:"props,2,optional" 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) SetProps

func (g *GetPropResponse) SetProps(props *nebula0.DataSet) *GetPropResponse

func (*GetPropResponse) SetResult_

func (g *GetPropResponse) SetResult_(result *ResponseCommon) *GetPropResponse

func (*GetPropResponse) String

func (p *GetPropResponse) String() string

func (*GetPropResponse) Write

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

type GetPropResponseBuilder

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

func NewGetPropResponseBuilder

func NewGetPropResponseBuilder() *GetPropResponseBuilder

func (GetPropResponseBuilder) Emit

func (*GetPropResponseBuilder) Props

func (*GetPropResponseBuilder) Result_

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,optional" db:"common" json:"common,omitempty"`
}

Attributes:

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

func NewGetUUIDReq

func NewGetUUIDReq() *GetUUIDReq

func (*GetUUIDReq) GetCommon

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

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

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

func (*GetUUIDReq) SetCommon

func (g *GetUUIDReq) SetCommon(common *RequestCommon) *GetUUIDReq

func (*GetUUIDReq) SetName

func (g *GetUUIDReq) SetName(name []byte) *GetUUIDReq

func (*GetUUIDReq) SetPartID

func (g *GetUUIDReq) SetPartID(partID nebula0.PartitionID) *GetUUIDReq

func (*GetUUIDReq) SetSpaceID

func (g *GetUUIDReq) SetSpaceID(spaceID nebula0.GraphSpaceID) *GetUUIDReq

func (*GetUUIDReq) String

func (p *GetUUIDReq) String() string

func (*GetUUIDReq) Write

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

type GetUUIDReqBuilder

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

func NewGetUUIDReqBuilder

func NewGetUUIDReqBuilder() *GetUUIDReqBuilder

func (*GetUUIDReqBuilder) Common

func (GetUUIDReqBuilder) Emit

func (p GetUUIDReqBuilder) Emit() *GetUUIDReq

func (*GetUUIDReqBuilder) Name

func (g *GetUUIDReqBuilder) Name(name []byte) *GetUUIDReqBuilder

func (*GetUUIDReqBuilder) PartID

func (*GetUUIDReqBuilder) SpaceID

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

func (g *GetUUIDResp) SetId(id *nebula0.Value) *GetUUIDResp

func (*GetUUIDResp) SetResult_

func (g *GetUUIDResp) SetResult_(result *ResponseCommon) *GetUUIDResp

func (*GetUUIDResp) String

func (p *GetUUIDResp) String() string

func (*GetUUIDResp) Write

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

type GetUUIDRespBuilder

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

func NewGetUUIDRespBuilder

func NewGetUUIDRespBuilder() *GetUUIDRespBuilder

func (GetUUIDRespBuilder) Emit

func (p GetUUIDRespBuilder) Emit() *GetUUIDResp

func (*GetUUIDRespBuilder) Id

func (*GetUUIDRespBuilder) Result_

type GraphStorageService

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

type GraphStorageServiceAddEdgesArgs

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

Attributes:

  • Req

func NewGraphStorageServiceAddEdgesArgs

func NewGraphStorageServiceAddEdgesArgs() *GraphStorageServiceAddEdgesArgs

func (*GraphStorageServiceAddEdgesArgs) GetReq

func (*GraphStorageServiceAddEdgesArgs) IsSetReq

func (p *GraphStorageServiceAddEdgesArgs) IsSetReq() bool

func (*GraphStorageServiceAddEdgesArgs) Read

func (*GraphStorageServiceAddEdgesArgs) ReadField1

func (*GraphStorageServiceAddEdgesArgs) SetReq

func (*GraphStorageServiceAddEdgesArgs) String

func (*GraphStorageServiceAddEdgesArgs) Write

type GraphStorageServiceAddEdgesArgsBuilder

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

func NewGraphStorageServiceAddEdgesArgsBuilder

func NewGraphStorageServiceAddEdgesArgsBuilder() *GraphStorageServiceAddEdgesArgsBuilder

func (GraphStorageServiceAddEdgesArgsBuilder) Emit

func (*GraphStorageServiceAddEdgesArgsBuilder) Req

type GraphStorageServiceAddEdgesResult

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

Attributes:

  • Success

func NewGraphStorageServiceAddEdgesResult

func NewGraphStorageServiceAddEdgesResult() *GraphStorageServiceAddEdgesResult

func (*GraphStorageServiceAddEdgesResult) Exception

func (*GraphStorageServiceAddEdgesResult) GetSuccess

func (*GraphStorageServiceAddEdgesResult) IsSetSuccess

func (p *GraphStorageServiceAddEdgesResult) IsSetSuccess() bool

func (*GraphStorageServiceAddEdgesResult) Read

func (*GraphStorageServiceAddEdgesResult) ReadField0

func (*GraphStorageServiceAddEdgesResult) SetSuccess

func (*GraphStorageServiceAddEdgesResult) String

func (*GraphStorageServiceAddEdgesResult) Write

type GraphStorageServiceAddEdgesResultBuilder

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

func NewGraphStorageServiceAddEdgesResultBuilder

func NewGraphStorageServiceAddEdgesResultBuilder() *GraphStorageServiceAddEdgesResultBuilder

func (GraphStorageServiceAddEdgesResultBuilder) Emit

func (*GraphStorageServiceAddEdgesResultBuilder) Success

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 (*GraphStorageServiceAddVerticesArgs) IsSetReq

func (*GraphStorageServiceAddVerticesArgs) Read

func (*GraphStorageServiceAddVerticesArgs) ReadField1

func (*GraphStorageServiceAddVerticesArgs) SetReq

func (*GraphStorageServiceAddVerticesArgs) String

func (*GraphStorageServiceAddVerticesArgs) Write

type GraphStorageServiceAddVerticesArgsBuilder

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

func NewGraphStorageServiceAddVerticesArgsBuilder

func NewGraphStorageServiceAddVerticesArgsBuilder() *GraphStorageServiceAddVerticesArgsBuilder

func (GraphStorageServiceAddVerticesArgsBuilder) Emit

func (*GraphStorageServiceAddVerticesArgsBuilder) Req

type GraphStorageServiceAddVerticesResult

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

Attributes:

  • Success

func NewGraphStorageServiceAddVerticesResult

func NewGraphStorageServiceAddVerticesResult() *GraphStorageServiceAddVerticesResult

func (*GraphStorageServiceAddVerticesResult) Exception

func (*GraphStorageServiceAddVerticesResult) GetSuccess

func (*GraphStorageServiceAddVerticesResult) IsSetSuccess

func (p *GraphStorageServiceAddVerticesResult) IsSetSuccess() bool

func (*GraphStorageServiceAddVerticesResult) Read

func (*GraphStorageServiceAddVerticesResult) ReadField0

func (*GraphStorageServiceAddVerticesResult) SetSuccess

func (*GraphStorageServiceAddVerticesResult) String

func (*GraphStorageServiceAddVerticesResult) Write

type GraphStorageServiceAddVerticesResultBuilder

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

func NewGraphStorageServiceAddVerticesResultBuilder

func NewGraphStorageServiceAddVerticesResultBuilder() *GraphStorageServiceAddVerticesResultBuilder

func (GraphStorageServiceAddVerticesResultBuilder) Emit

func (*GraphStorageServiceAddVerticesResultBuilder) Success

type GraphStorageServiceChainAddEdgesArgs

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

Attributes:

  • Req

func NewGraphStorageServiceChainAddEdgesArgs

func NewGraphStorageServiceChainAddEdgesArgs() *GraphStorageServiceChainAddEdgesArgs

func (*GraphStorageServiceChainAddEdgesArgs) GetReq

func (*GraphStorageServiceChainAddEdgesArgs) IsSetReq

func (*GraphStorageServiceChainAddEdgesArgs) Read

func (*GraphStorageServiceChainAddEdgesArgs) ReadField1

func (*GraphStorageServiceChainAddEdgesArgs) SetReq

func (*GraphStorageServiceChainAddEdgesArgs) String

func (*GraphStorageServiceChainAddEdgesArgs) Write

type GraphStorageServiceChainAddEdgesArgsBuilder

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

func NewGraphStorageServiceChainAddEdgesArgsBuilder

func NewGraphStorageServiceChainAddEdgesArgsBuilder() *GraphStorageServiceChainAddEdgesArgsBuilder

func (GraphStorageServiceChainAddEdgesArgsBuilder) Emit

func (*GraphStorageServiceChainAddEdgesArgsBuilder) Req

type GraphStorageServiceChainAddEdgesResult

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

Attributes:

  • Success

func NewGraphStorageServiceChainAddEdgesResult

func NewGraphStorageServiceChainAddEdgesResult() *GraphStorageServiceChainAddEdgesResult

func (*GraphStorageServiceChainAddEdgesResult) Exception

func (*GraphStorageServiceChainAddEdgesResult) GetSuccess

func (*GraphStorageServiceChainAddEdgesResult) IsSetSuccess

func (p *GraphStorageServiceChainAddEdgesResult) IsSetSuccess() bool

func (*GraphStorageServiceChainAddEdgesResult) Read

func (*GraphStorageServiceChainAddEdgesResult) ReadField0

func (*GraphStorageServiceChainAddEdgesResult) SetSuccess

func (*GraphStorageServiceChainAddEdgesResult) String

func (*GraphStorageServiceChainAddEdgesResult) Write

type GraphStorageServiceChainAddEdgesResultBuilder

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

func NewGraphStorageServiceChainAddEdgesResultBuilder

func NewGraphStorageServiceChainAddEdgesResultBuilder() *GraphStorageServiceChainAddEdgesResultBuilder

func (GraphStorageServiceChainAddEdgesResultBuilder) Emit

func (*GraphStorageServiceChainAddEdgesResultBuilder) Success

type GraphStorageServiceChainDeleteEdgesArgs

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

Attributes:

  • Req

func NewGraphStorageServiceChainDeleteEdgesArgs

func NewGraphStorageServiceChainDeleteEdgesArgs() *GraphStorageServiceChainDeleteEdgesArgs

func (*GraphStorageServiceChainDeleteEdgesArgs) GetReq

func (*GraphStorageServiceChainDeleteEdgesArgs) IsSetReq

func (*GraphStorageServiceChainDeleteEdgesArgs) Read

func (*GraphStorageServiceChainDeleteEdgesArgs) ReadField1

func (*GraphStorageServiceChainDeleteEdgesArgs) SetReq

func (*GraphStorageServiceChainDeleteEdgesArgs) String

func (*GraphStorageServiceChainDeleteEdgesArgs) Write

type GraphStorageServiceChainDeleteEdgesArgsBuilder

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

func NewGraphStorageServiceChainDeleteEdgesArgsBuilder

func NewGraphStorageServiceChainDeleteEdgesArgsBuilder() *GraphStorageServiceChainDeleteEdgesArgsBuilder

func (GraphStorageServiceChainDeleteEdgesArgsBuilder) Emit

func (*GraphStorageServiceChainDeleteEdgesArgsBuilder) Req

type GraphStorageServiceChainDeleteEdgesResult

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

Attributes:

  • Success

func NewGraphStorageServiceChainDeleteEdgesResult

func NewGraphStorageServiceChainDeleteEdgesResult() *GraphStorageServiceChainDeleteEdgesResult

func (*GraphStorageServiceChainDeleteEdgesResult) Exception

func (*GraphStorageServiceChainDeleteEdgesResult) GetSuccess

func (*GraphStorageServiceChainDeleteEdgesResult) IsSetSuccess

func (*GraphStorageServiceChainDeleteEdgesResult) Read

func (*GraphStorageServiceChainDeleteEdgesResult) ReadField0

func (*GraphStorageServiceChainDeleteEdgesResult) SetSuccess

func (*GraphStorageServiceChainDeleteEdgesResult) String

func (*GraphStorageServiceChainDeleteEdgesResult) Write

type GraphStorageServiceChainDeleteEdgesResultBuilder

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

func NewGraphStorageServiceChainDeleteEdgesResultBuilder

func NewGraphStorageServiceChainDeleteEdgesResultBuilder() *GraphStorageServiceChainDeleteEdgesResultBuilder

func (GraphStorageServiceChainDeleteEdgesResultBuilder) Emit

func (*GraphStorageServiceChainDeleteEdgesResultBuilder) Success

type GraphStorageServiceChainUpdateEdgeArgs

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

Attributes:

  • Req

func NewGraphStorageServiceChainUpdateEdgeArgs

func NewGraphStorageServiceChainUpdateEdgeArgs() *GraphStorageServiceChainUpdateEdgeArgs

func (*GraphStorageServiceChainUpdateEdgeArgs) GetReq

func (*GraphStorageServiceChainUpdateEdgeArgs) IsSetReq

func (*GraphStorageServiceChainUpdateEdgeArgs) Read

func (*GraphStorageServiceChainUpdateEdgeArgs) ReadField1

func (*GraphStorageServiceChainUpdateEdgeArgs) SetReq

func (*GraphStorageServiceChainUpdateEdgeArgs) String

func (*GraphStorageServiceChainUpdateEdgeArgs) Write

type GraphStorageServiceChainUpdateEdgeArgsBuilder

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

func NewGraphStorageServiceChainUpdateEdgeArgsBuilder

func NewGraphStorageServiceChainUpdateEdgeArgsBuilder() *GraphStorageServiceChainUpdateEdgeArgsBuilder

func (GraphStorageServiceChainUpdateEdgeArgsBuilder) Emit

func (*GraphStorageServiceChainUpdateEdgeArgsBuilder) Req

type GraphStorageServiceChainUpdateEdgeResult

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

Attributes:

  • Success

func NewGraphStorageServiceChainUpdateEdgeResult

func NewGraphStorageServiceChainUpdateEdgeResult() *GraphStorageServiceChainUpdateEdgeResult

func (*GraphStorageServiceChainUpdateEdgeResult) Exception

func (*GraphStorageServiceChainUpdateEdgeResult) GetSuccess

func (*GraphStorageServiceChainUpdateEdgeResult) IsSetSuccess

func (*GraphStorageServiceChainUpdateEdgeResult) Read

func (*GraphStorageServiceChainUpdateEdgeResult) ReadField0

func (*GraphStorageServiceChainUpdateEdgeResult) SetSuccess

func (*GraphStorageServiceChainUpdateEdgeResult) String

func (*GraphStorageServiceChainUpdateEdgeResult) Write

type GraphStorageServiceChainUpdateEdgeResultBuilder

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

func NewGraphStorageServiceChainUpdateEdgeResultBuilder

func NewGraphStorageServiceChainUpdateEdgeResultBuilder() *GraphStorageServiceChainUpdateEdgeResultBuilder

func (GraphStorageServiceChainUpdateEdgeResultBuilder) Emit

func (*GraphStorageServiceChainUpdateEdgeResultBuilder) Success

type GraphStorageServiceChannelClient

type GraphStorageServiceChannelClient struct {
	RequestChannel thrift.RequestChannel
}

func NewGraphStorageServiceChannelClient

func NewGraphStorageServiceChannelClient(channel thrift.RequestChannel) *GraphStorageServiceChannelClient

func (*GraphStorageServiceChannelClient) AddEdges

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) AddVertices

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) ChainAddEdges

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) ChainDeleteEdges

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) ChainUpdateEdge

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

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) Close

func (*GraphStorageServiceChannelClient) DeleteEdges

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) DeleteTags

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) DeleteVertices

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) Get

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) GetDstBySrc added in v3.3.1

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) GetNeighbors

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) GetProps

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) GetUUID

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) IsOpen

func (*GraphStorageServiceChannelClient) LookupAndTraverse

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) LookupIndex

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) Open

func (*GraphStorageServiceChannelClient) Put

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) Remove

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) ScanEdge

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) ScanVertex

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) UpdateEdge

Parameters:

  • Req

func (*GraphStorageServiceChannelClient) UpdateVertex

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

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

Parameters:

  • Req

func (*GraphStorageServiceClient) ChainDeleteEdges

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

Parameters:

  • Req

func (*GraphStorageServiceClient) ChainUpdateEdge

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

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

Parameters:

  • Req

func (*GraphStorageServiceClient) GetDstBySrc added in v3.3.1

Parameters:

  • Req

func (*GraphStorageServiceClient) GetNeighbors

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

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

Parameters:

  • Req

func (*GraphStorageServiceClient) Remove

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

Parameters:

  • Req

func (*GraphStorageServiceClient) ScanEdge

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

Parameters:

  • Req

func (*GraphStorageServiceClient) ScanVertex

func (p *GraphStorageServiceClient) ScanVertex(req *ScanVertexRequest) (_r *ScanResponse, 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
	GetDstBySrc(req *GetDstBySrcRequest) (_r *GetDstBySrcResponse, 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 *ScanResponse, err error)
	// Parameters:
	//  - Req
	ScanEdge(req *ScanEdgeRequest) (_r *ScanResponse, 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)
	// Parameters:
	//  - Req
	ChainDeleteEdges(req *DeleteEdgesRequest) (_r *ExecResponse, err error)
	// 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 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 (*GraphStorageServiceDeleteEdgesArgs) IsSetReq

func (*GraphStorageServiceDeleteEdgesArgs) Read

func (*GraphStorageServiceDeleteEdgesArgs) ReadField1

func (*GraphStorageServiceDeleteEdgesArgs) SetReq

func (*GraphStorageServiceDeleteEdgesArgs) String

func (*GraphStorageServiceDeleteEdgesArgs) Write

type GraphStorageServiceDeleteEdgesArgsBuilder

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

func NewGraphStorageServiceDeleteEdgesArgsBuilder

func NewGraphStorageServiceDeleteEdgesArgsBuilder() *GraphStorageServiceDeleteEdgesArgsBuilder

func (GraphStorageServiceDeleteEdgesArgsBuilder) Emit

func (*GraphStorageServiceDeleteEdgesArgsBuilder) Req

type GraphStorageServiceDeleteEdgesResult

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

Attributes:

  • Success

func NewGraphStorageServiceDeleteEdgesResult

func NewGraphStorageServiceDeleteEdgesResult() *GraphStorageServiceDeleteEdgesResult

func (*GraphStorageServiceDeleteEdgesResult) Exception

func (*GraphStorageServiceDeleteEdgesResult) GetSuccess

func (*GraphStorageServiceDeleteEdgesResult) IsSetSuccess

func (p *GraphStorageServiceDeleteEdgesResult) IsSetSuccess() bool

func (*GraphStorageServiceDeleteEdgesResult) Read

func (*GraphStorageServiceDeleteEdgesResult) ReadField0

func (*GraphStorageServiceDeleteEdgesResult) SetSuccess

func (*GraphStorageServiceDeleteEdgesResult) String

func (*GraphStorageServiceDeleteEdgesResult) Write

type GraphStorageServiceDeleteEdgesResultBuilder

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

func NewGraphStorageServiceDeleteEdgesResultBuilder

func NewGraphStorageServiceDeleteEdgesResultBuilder() *GraphStorageServiceDeleteEdgesResultBuilder

func (GraphStorageServiceDeleteEdgesResultBuilder) Emit

func (*GraphStorageServiceDeleteEdgesResultBuilder) Success

type GraphStorageServiceDeleteTagsArgs

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

Attributes:

  • Req

func NewGraphStorageServiceDeleteTagsArgs

func NewGraphStorageServiceDeleteTagsArgs() *GraphStorageServiceDeleteTagsArgs

func (*GraphStorageServiceDeleteTagsArgs) GetReq

func (*GraphStorageServiceDeleteTagsArgs) IsSetReq

func (*GraphStorageServiceDeleteTagsArgs) Read

func (*GraphStorageServiceDeleteTagsArgs) ReadField1

func (*GraphStorageServiceDeleteTagsArgs) SetReq

func (*GraphStorageServiceDeleteTagsArgs) String

func (*GraphStorageServiceDeleteTagsArgs) Write

type GraphStorageServiceDeleteTagsArgsBuilder

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

func NewGraphStorageServiceDeleteTagsArgsBuilder

func NewGraphStorageServiceDeleteTagsArgsBuilder() *GraphStorageServiceDeleteTagsArgsBuilder

func (GraphStorageServiceDeleteTagsArgsBuilder) Emit

func (*GraphStorageServiceDeleteTagsArgsBuilder) Req

type GraphStorageServiceDeleteTagsResult

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

Attributes:

  • Success

func NewGraphStorageServiceDeleteTagsResult

func NewGraphStorageServiceDeleteTagsResult() *GraphStorageServiceDeleteTagsResult

func (*GraphStorageServiceDeleteTagsResult) Exception

func (*GraphStorageServiceDeleteTagsResult) GetSuccess

func (*GraphStorageServiceDeleteTagsResult) IsSetSuccess

func (p *GraphStorageServiceDeleteTagsResult) IsSetSuccess() bool

func (*GraphStorageServiceDeleteTagsResult) Read

func (*GraphStorageServiceDeleteTagsResult) ReadField0

func (*GraphStorageServiceDeleteTagsResult) SetSuccess

func (*GraphStorageServiceDeleteTagsResult) String

func (*GraphStorageServiceDeleteTagsResult) Write

type GraphStorageServiceDeleteTagsResultBuilder

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

func NewGraphStorageServiceDeleteTagsResultBuilder

func NewGraphStorageServiceDeleteTagsResultBuilder() *GraphStorageServiceDeleteTagsResultBuilder

func (GraphStorageServiceDeleteTagsResultBuilder) Emit

func (*GraphStorageServiceDeleteTagsResultBuilder) Success

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 (*GraphStorageServiceDeleteVerticesArgs) IsSetReq

func (*GraphStorageServiceDeleteVerticesArgs) Read

func (*GraphStorageServiceDeleteVerticesArgs) ReadField1

func (*GraphStorageServiceDeleteVerticesArgs) SetReq

func (*GraphStorageServiceDeleteVerticesArgs) String

func (*GraphStorageServiceDeleteVerticesArgs) Write

type GraphStorageServiceDeleteVerticesArgsBuilder

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

func NewGraphStorageServiceDeleteVerticesArgsBuilder

func NewGraphStorageServiceDeleteVerticesArgsBuilder() *GraphStorageServiceDeleteVerticesArgsBuilder

func (GraphStorageServiceDeleteVerticesArgsBuilder) Emit

func (*GraphStorageServiceDeleteVerticesArgsBuilder) Req

type GraphStorageServiceDeleteVerticesResult

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

Attributes:

  • Success

func NewGraphStorageServiceDeleteVerticesResult

func NewGraphStorageServiceDeleteVerticesResult() *GraphStorageServiceDeleteVerticesResult

func (*GraphStorageServiceDeleteVerticesResult) Exception

func (*GraphStorageServiceDeleteVerticesResult) GetSuccess

func (*GraphStorageServiceDeleteVerticesResult) IsSetSuccess

func (*GraphStorageServiceDeleteVerticesResult) Read

func (*GraphStorageServiceDeleteVerticesResult) ReadField0

func (*GraphStorageServiceDeleteVerticesResult) SetSuccess

func (*GraphStorageServiceDeleteVerticesResult) String

func (*GraphStorageServiceDeleteVerticesResult) Write

type GraphStorageServiceDeleteVerticesResultBuilder

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

func NewGraphStorageServiceDeleteVerticesResultBuilder

func NewGraphStorageServiceDeleteVerticesResultBuilder() *GraphStorageServiceDeleteVerticesResultBuilder

func (GraphStorageServiceDeleteVerticesResultBuilder) Emit

func (*GraphStorageServiceDeleteVerticesResultBuilder) Success

type GraphStorageServiceGetArgs

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

Attributes:

  • Req

func NewGraphStorageServiceGetArgs

func NewGraphStorageServiceGetArgs() *GraphStorageServiceGetArgs

func (*GraphStorageServiceGetArgs) GetReq

func (*GraphStorageServiceGetArgs) IsSetReq

func (p *GraphStorageServiceGetArgs) IsSetReq() bool

func (*GraphStorageServiceGetArgs) Read

func (*GraphStorageServiceGetArgs) ReadField1

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

func (*GraphStorageServiceGetArgs) SetReq

func (*GraphStorageServiceGetArgs) String

func (p *GraphStorageServiceGetArgs) String() string

func (*GraphStorageServiceGetArgs) Write

type GraphStorageServiceGetArgsBuilder

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

func NewGraphStorageServiceGetArgsBuilder

func NewGraphStorageServiceGetArgsBuilder() *GraphStorageServiceGetArgsBuilder

func (GraphStorageServiceGetArgsBuilder) Emit

func (*GraphStorageServiceGetArgsBuilder) Req

type GraphStorageServiceGetDstBySrcArgs added in v3.3.1

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

Attributes:

  • Req

func NewGraphStorageServiceGetDstBySrcArgs added in v3.3.1

func NewGraphStorageServiceGetDstBySrcArgs() *GraphStorageServiceGetDstBySrcArgs

func (*GraphStorageServiceGetDstBySrcArgs) GetReq added in v3.3.1

func (*GraphStorageServiceGetDstBySrcArgs) IsSetReq added in v3.3.1

func (*GraphStorageServiceGetDstBySrcArgs) Read added in v3.3.1

func (*GraphStorageServiceGetDstBySrcArgs) ReadField1 added in v3.3.1

func (*GraphStorageServiceGetDstBySrcArgs) SetReq added in v3.3.1

func (*GraphStorageServiceGetDstBySrcArgs) String added in v3.3.1

func (*GraphStorageServiceGetDstBySrcArgs) Write added in v3.3.1

type GraphStorageServiceGetDstBySrcArgsBuilder added in v3.3.1

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

func NewGraphStorageServiceGetDstBySrcArgsBuilder added in v3.3.1

func NewGraphStorageServiceGetDstBySrcArgsBuilder() *GraphStorageServiceGetDstBySrcArgsBuilder

func (GraphStorageServiceGetDstBySrcArgsBuilder) Emit added in v3.3.1

func (*GraphStorageServiceGetDstBySrcArgsBuilder) Req added in v3.3.1

type GraphStorageServiceGetDstBySrcResult added in v3.3.1

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

Attributes:

  • Success

func NewGraphStorageServiceGetDstBySrcResult added in v3.3.1

func NewGraphStorageServiceGetDstBySrcResult() *GraphStorageServiceGetDstBySrcResult

func (*GraphStorageServiceGetDstBySrcResult) Exception added in v3.3.1

func (*GraphStorageServiceGetDstBySrcResult) GetSuccess added in v3.3.1

func (*GraphStorageServiceGetDstBySrcResult) IsSetSuccess added in v3.3.1

func (p *GraphStorageServiceGetDstBySrcResult) IsSetSuccess() bool

func (*GraphStorageServiceGetDstBySrcResult) Read added in v3.3.1

func (*GraphStorageServiceGetDstBySrcResult) ReadField0 added in v3.3.1

func (*GraphStorageServiceGetDstBySrcResult) SetSuccess added in v3.3.1

func (*GraphStorageServiceGetDstBySrcResult) String added in v3.3.1

func (*GraphStorageServiceGetDstBySrcResult) Write added in v3.3.1

type GraphStorageServiceGetDstBySrcResultBuilder added in v3.3.1

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

func NewGraphStorageServiceGetDstBySrcResultBuilder added in v3.3.1

func NewGraphStorageServiceGetDstBySrcResultBuilder() *GraphStorageServiceGetDstBySrcResultBuilder

func (GraphStorageServiceGetDstBySrcResultBuilder) Emit added in v3.3.1

func (*GraphStorageServiceGetDstBySrcResultBuilder) Success added in v3.3.1

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 (*GraphStorageServiceGetNeighborsArgs) IsSetReq

func (*GraphStorageServiceGetNeighborsArgs) Read

func (*GraphStorageServiceGetNeighborsArgs) ReadField1

func (*GraphStorageServiceGetNeighborsArgs) SetReq

func (*GraphStorageServiceGetNeighborsArgs) String

func (*GraphStorageServiceGetNeighborsArgs) Write

type GraphStorageServiceGetNeighborsArgsBuilder

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

func NewGraphStorageServiceGetNeighborsArgsBuilder

func NewGraphStorageServiceGetNeighborsArgsBuilder() *GraphStorageServiceGetNeighborsArgsBuilder

func (GraphStorageServiceGetNeighborsArgsBuilder) Emit

func (*GraphStorageServiceGetNeighborsArgsBuilder) Req

type GraphStorageServiceGetNeighborsResult

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

Attributes:

  • Success

func NewGraphStorageServiceGetNeighborsResult

func NewGraphStorageServiceGetNeighborsResult() *GraphStorageServiceGetNeighborsResult

func (*GraphStorageServiceGetNeighborsResult) Exception

func (*GraphStorageServiceGetNeighborsResult) GetSuccess

func (*GraphStorageServiceGetNeighborsResult) IsSetSuccess

func (p *GraphStorageServiceGetNeighborsResult) IsSetSuccess() bool

func (*GraphStorageServiceGetNeighborsResult) Read

func (*GraphStorageServiceGetNeighborsResult) ReadField0

func (*GraphStorageServiceGetNeighborsResult) SetSuccess

func (*GraphStorageServiceGetNeighborsResult) String

func (*GraphStorageServiceGetNeighborsResult) Write

type GraphStorageServiceGetNeighborsResultBuilder

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

func NewGraphStorageServiceGetNeighborsResultBuilder

func NewGraphStorageServiceGetNeighborsResultBuilder() *GraphStorageServiceGetNeighborsResultBuilder

func (GraphStorageServiceGetNeighborsResultBuilder) Emit

func (*GraphStorageServiceGetNeighborsResultBuilder) Success

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 (*GraphStorageServiceGetPropsArgs) IsSetReq

func (p *GraphStorageServiceGetPropsArgs) IsSetReq() bool

func (*GraphStorageServiceGetPropsArgs) Read

func (*GraphStorageServiceGetPropsArgs) ReadField1

func (*GraphStorageServiceGetPropsArgs) SetReq

func (*GraphStorageServiceGetPropsArgs) String

func (*GraphStorageServiceGetPropsArgs) Write

type GraphStorageServiceGetPropsArgsBuilder

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

func NewGraphStorageServiceGetPropsArgsBuilder

func NewGraphStorageServiceGetPropsArgsBuilder() *GraphStorageServiceGetPropsArgsBuilder

func (GraphStorageServiceGetPropsArgsBuilder) Emit

func (*GraphStorageServiceGetPropsArgsBuilder) Req

type GraphStorageServiceGetPropsResult

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

Attributes:

  • Success

func NewGraphStorageServiceGetPropsResult

func NewGraphStorageServiceGetPropsResult() *GraphStorageServiceGetPropsResult

func (*GraphStorageServiceGetPropsResult) Exception

func (*GraphStorageServiceGetPropsResult) GetSuccess

func (*GraphStorageServiceGetPropsResult) IsSetSuccess

func (p *GraphStorageServiceGetPropsResult) IsSetSuccess() bool

func (*GraphStorageServiceGetPropsResult) Read

func (*GraphStorageServiceGetPropsResult) ReadField0

func (*GraphStorageServiceGetPropsResult) SetSuccess

func (*GraphStorageServiceGetPropsResult) String

func (*GraphStorageServiceGetPropsResult) Write

type GraphStorageServiceGetPropsResultBuilder

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

func NewGraphStorageServiceGetPropsResultBuilder

func NewGraphStorageServiceGetPropsResultBuilder() *GraphStorageServiceGetPropsResultBuilder

func (GraphStorageServiceGetPropsResultBuilder) Emit

func (*GraphStorageServiceGetPropsResultBuilder) Success

type GraphStorageServiceGetResult

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

Attributes:

  • Success

func NewGraphStorageServiceGetResult

func NewGraphStorageServiceGetResult() *GraphStorageServiceGetResult

func (*GraphStorageServiceGetResult) Exception

func (*GraphStorageServiceGetResult) GetSuccess

func (*GraphStorageServiceGetResult) IsSetSuccess

func (p *GraphStorageServiceGetResult) IsSetSuccess() bool

func (*GraphStorageServiceGetResult) Read

func (*GraphStorageServiceGetResult) ReadField0

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

func (*GraphStorageServiceGetResult) SetSuccess

func (*GraphStorageServiceGetResult) String

func (*GraphStorageServiceGetResult) Write

type GraphStorageServiceGetResultBuilder

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

func NewGraphStorageServiceGetResultBuilder

func NewGraphStorageServiceGetResultBuilder() *GraphStorageServiceGetResultBuilder

func (GraphStorageServiceGetResultBuilder) Emit

func (*GraphStorageServiceGetResultBuilder) Success

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 (*GraphStorageServiceGetUUIDArgs) IsSetReq

func (p *GraphStorageServiceGetUUIDArgs) IsSetReq() bool

func (*GraphStorageServiceGetUUIDArgs) Read

func (*GraphStorageServiceGetUUIDArgs) ReadField1

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

func (*GraphStorageServiceGetUUIDArgs) SetReq

func (*GraphStorageServiceGetUUIDArgs) String

func (*GraphStorageServiceGetUUIDArgs) Write

type GraphStorageServiceGetUUIDArgsBuilder

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

func NewGraphStorageServiceGetUUIDArgsBuilder

func NewGraphStorageServiceGetUUIDArgsBuilder() *GraphStorageServiceGetUUIDArgsBuilder

func (GraphStorageServiceGetUUIDArgsBuilder) Emit

func (*GraphStorageServiceGetUUIDArgsBuilder) Req

type GraphStorageServiceGetUUIDResult

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

Attributes:

  • Success

func NewGraphStorageServiceGetUUIDResult

func NewGraphStorageServiceGetUUIDResult() *GraphStorageServiceGetUUIDResult

func (*GraphStorageServiceGetUUIDResult) Exception

func (*GraphStorageServiceGetUUIDResult) GetSuccess

func (*GraphStorageServiceGetUUIDResult) IsSetSuccess

func (p *GraphStorageServiceGetUUIDResult) IsSetSuccess() bool

func (*GraphStorageServiceGetUUIDResult) Read

func (*GraphStorageServiceGetUUIDResult) ReadField0

func (*GraphStorageServiceGetUUIDResult) SetSuccess

func (*GraphStorageServiceGetUUIDResult) String

func (*GraphStorageServiceGetUUIDResult) Write

type GraphStorageServiceGetUUIDResultBuilder

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

func NewGraphStorageServiceGetUUIDResultBuilder

func NewGraphStorageServiceGetUUIDResultBuilder() *GraphStorageServiceGetUUIDResultBuilder

func (GraphStorageServiceGetUUIDResultBuilder) Emit

func (*GraphStorageServiceGetUUIDResultBuilder) Success

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 (*GraphStorageServiceLookupAndTraverseArgs) IsSetReq

func (*GraphStorageServiceLookupAndTraverseArgs) Read

func (*GraphStorageServiceLookupAndTraverseArgs) ReadField1

func (*GraphStorageServiceLookupAndTraverseArgs) SetReq

func (*GraphStorageServiceLookupAndTraverseArgs) String

func (*GraphStorageServiceLookupAndTraverseArgs) Write

type GraphStorageServiceLookupAndTraverseArgsBuilder

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

func NewGraphStorageServiceLookupAndTraverseArgsBuilder

func NewGraphStorageServiceLookupAndTraverseArgsBuilder() *GraphStorageServiceLookupAndTraverseArgsBuilder

func (GraphStorageServiceLookupAndTraverseArgsBuilder) Emit

func (*GraphStorageServiceLookupAndTraverseArgsBuilder) Req

type GraphStorageServiceLookupAndTraverseResult

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

Attributes:

  • Success

func NewGraphStorageServiceLookupAndTraverseResult

func NewGraphStorageServiceLookupAndTraverseResult() *GraphStorageServiceLookupAndTraverseResult

func (*GraphStorageServiceLookupAndTraverseResult) Exception

func (*GraphStorageServiceLookupAndTraverseResult) GetSuccess

func (*GraphStorageServiceLookupAndTraverseResult) IsSetSuccess

func (*GraphStorageServiceLookupAndTraverseResult) Read

func (*GraphStorageServiceLookupAndTraverseResult) ReadField0

func (*GraphStorageServiceLookupAndTraverseResult) SetSuccess

func (*GraphStorageServiceLookupAndTraverseResult) String

func (*GraphStorageServiceLookupAndTraverseResult) Write

type GraphStorageServiceLookupAndTraverseResultBuilder

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

func NewGraphStorageServiceLookupAndTraverseResultBuilder

func NewGraphStorageServiceLookupAndTraverseResultBuilder() *GraphStorageServiceLookupAndTraverseResultBuilder

func (GraphStorageServiceLookupAndTraverseResultBuilder) Emit

func (*GraphStorageServiceLookupAndTraverseResultBuilder) Success

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 (*GraphStorageServiceLookupIndexArgs) IsSetReq

func (*GraphStorageServiceLookupIndexArgs) Read

func (*GraphStorageServiceLookupIndexArgs) ReadField1

func (*GraphStorageServiceLookupIndexArgs) SetReq

func (*GraphStorageServiceLookupIndexArgs) String

func (*GraphStorageServiceLookupIndexArgs) Write

type GraphStorageServiceLookupIndexArgsBuilder

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

func NewGraphStorageServiceLookupIndexArgsBuilder

func NewGraphStorageServiceLookupIndexArgsBuilder() *GraphStorageServiceLookupIndexArgsBuilder

func (GraphStorageServiceLookupIndexArgsBuilder) Emit

func (*GraphStorageServiceLookupIndexArgsBuilder) Req

type GraphStorageServiceLookupIndexResult

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

Attributes:

  • Success

func NewGraphStorageServiceLookupIndexResult

func NewGraphStorageServiceLookupIndexResult() *GraphStorageServiceLookupIndexResult

func (*GraphStorageServiceLookupIndexResult) Exception

func (*GraphStorageServiceLookupIndexResult) GetSuccess

func (*GraphStorageServiceLookupIndexResult) IsSetSuccess

func (p *GraphStorageServiceLookupIndexResult) IsSetSuccess() bool

func (*GraphStorageServiceLookupIndexResult) Read

func (*GraphStorageServiceLookupIndexResult) ReadField0

func (*GraphStorageServiceLookupIndexResult) SetSuccess

func (*GraphStorageServiceLookupIndexResult) String

func (*GraphStorageServiceLookupIndexResult) Write

type GraphStorageServiceLookupIndexResultBuilder

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

func NewGraphStorageServiceLookupIndexResultBuilder

func NewGraphStorageServiceLookupIndexResultBuilder() *GraphStorageServiceLookupIndexResultBuilder

func (GraphStorageServiceLookupIndexResultBuilder) Emit

func (*GraphStorageServiceLookupIndexResultBuilder) Success

type GraphStorageServiceProcessor

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

func NewGraphStorageServiceProcessor

func NewGraphStorageServiceProcessor(handler GraphStorageService) *GraphStorageServiceProcessor

func (*GraphStorageServiceProcessor) AddToFunctionServiceMap

func (p *GraphStorageServiceProcessor) AddToFunctionServiceMap(key, service string)

func (*GraphStorageServiceProcessor) AddToProcessorMap

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

func (*GraphStorageServiceProcessor) FunctionServiceMap

func (p *GraphStorageServiceProcessor) FunctionServiceMap() map[string]string

func (*GraphStorageServiceProcessor) GetProcessorFunctionContext

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

func (*GraphStorageServiceProcessor) ProcessorMap

type GraphStorageServicePutArgs

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

Attributes:

  • Req

func NewGraphStorageServicePutArgs

func NewGraphStorageServicePutArgs() *GraphStorageServicePutArgs

func (*GraphStorageServicePutArgs) GetReq

func (*GraphStorageServicePutArgs) IsSetReq

func (p *GraphStorageServicePutArgs) IsSetReq() bool

func (*GraphStorageServicePutArgs) Read

func (*GraphStorageServicePutArgs) ReadField1

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

func (*GraphStorageServicePutArgs) SetReq

func (*GraphStorageServicePutArgs) String

func (p *GraphStorageServicePutArgs) String() string

func (*GraphStorageServicePutArgs) Write

type GraphStorageServicePutArgsBuilder

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

func NewGraphStorageServicePutArgsBuilder

func NewGraphStorageServicePutArgsBuilder() *GraphStorageServicePutArgsBuilder

func (GraphStorageServicePutArgsBuilder) Emit

func (*GraphStorageServicePutArgsBuilder) Req

type GraphStorageServicePutResult

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

Attributes:

  • Success

func NewGraphStorageServicePutResult

func NewGraphStorageServicePutResult() *GraphStorageServicePutResult

func (*GraphStorageServicePutResult) Exception

func (*GraphStorageServicePutResult) GetSuccess

func (p *GraphStorageServicePutResult) GetSuccess() *ExecResponse

func (*GraphStorageServicePutResult) IsSetSuccess

func (p *GraphStorageServicePutResult) IsSetSuccess() bool

func (*GraphStorageServicePutResult) Read

func (*GraphStorageServicePutResult) ReadField0

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

func (*GraphStorageServicePutResult) SetSuccess

func (*GraphStorageServicePutResult) String

func (*GraphStorageServicePutResult) Write

type GraphStorageServicePutResultBuilder

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

func NewGraphStorageServicePutResultBuilder

func NewGraphStorageServicePutResultBuilder() *GraphStorageServicePutResultBuilder

func (GraphStorageServicePutResultBuilder) Emit

func (*GraphStorageServicePutResultBuilder) Success

type GraphStorageServiceRemoveArgs

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

Attributes:

  • Req

func NewGraphStorageServiceRemoveArgs

func NewGraphStorageServiceRemoveArgs() *GraphStorageServiceRemoveArgs

func (*GraphStorageServiceRemoveArgs) GetReq

func (*GraphStorageServiceRemoveArgs) IsSetReq

func (p *GraphStorageServiceRemoveArgs) IsSetReq() bool

func (*GraphStorageServiceRemoveArgs) Read

func (*GraphStorageServiceRemoveArgs) ReadField1

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

func (*GraphStorageServiceRemoveArgs) SetReq

func (*GraphStorageServiceRemoveArgs) String

func (*GraphStorageServiceRemoveArgs) Write

type GraphStorageServiceRemoveArgsBuilder

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

func NewGraphStorageServiceRemoveArgsBuilder

func NewGraphStorageServiceRemoveArgsBuilder() *GraphStorageServiceRemoveArgsBuilder

func (GraphStorageServiceRemoveArgsBuilder) Emit

func (*GraphStorageServiceRemoveArgsBuilder) Req

type GraphStorageServiceRemoveResult

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

Attributes:

  • Success

func NewGraphStorageServiceRemoveResult

func NewGraphStorageServiceRemoveResult() *GraphStorageServiceRemoveResult

func (*GraphStorageServiceRemoveResult) Exception

func (*GraphStorageServiceRemoveResult) GetSuccess

func (*GraphStorageServiceRemoveResult) IsSetSuccess

func (p *GraphStorageServiceRemoveResult) IsSetSuccess() bool

func (*GraphStorageServiceRemoveResult) Read

func (*GraphStorageServiceRemoveResult) ReadField0

func (*GraphStorageServiceRemoveResult) SetSuccess

func (*GraphStorageServiceRemoveResult) String

func (*GraphStorageServiceRemoveResult) Write

type GraphStorageServiceRemoveResultBuilder

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

func NewGraphStorageServiceRemoveResultBuilder

func NewGraphStorageServiceRemoveResultBuilder() *GraphStorageServiceRemoveResultBuilder

func (GraphStorageServiceRemoveResultBuilder) Emit

func (*GraphStorageServiceRemoveResultBuilder) Success

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 (*GraphStorageServiceScanEdgeArgs) IsSetReq

func (p *GraphStorageServiceScanEdgeArgs) IsSetReq() bool

func (*GraphStorageServiceScanEdgeArgs) Read

func (*GraphStorageServiceScanEdgeArgs) ReadField1

func (*GraphStorageServiceScanEdgeArgs) SetReq

func (*GraphStorageServiceScanEdgeArgs) String

func (*GraphStorageServiceScanEdgeArgs) Write

type GraphStorageServiceScanEdgeArgsBuilder

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

func NewGraphStorageServiceScanEdgeArgsBuilder

func NewGraphStorageServiceScanEdgeArgsBuilder() *GraphStorageServiceScanEdgeArgsBuilder

func (GraphStorageServiceScanEdgeArgsBuilder) Emit

func (*GraphStorageServiceScanEdgeArgsBuilder) Req

type GraphStorageServiceScanEdgeResult

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

Attributes:

  • Success

func NewGraphStorageServiceScanEdgeResult

func NewGraphStorageServiceScanEdgeResult() *GraphStorageServiceScanEdgeResult

func (*GraphStorageServiceScanEdgeResult) Exception

func (*GraphStorageServiceScanEdgeResult) GetSuccess

func (*GraphStorageServiceScanEdgeResult) IsSetSuccess

func (p *GraphStorageServiceScanEdgeResult) IsSetSuccess() bool

func (*GraphStorageServiceScanEdgeResult) Read

func (*GraphStorageServiceScanEdgeResult) ReadField0

func (*GraphStorageServiceScanEdgeResult) SetSuccess

func (*GraphStorageServiceScanEdgeResult) String

func (*GraphStorageServiceScanEdgeResult) Write

type GraphStorageServiceScanEdgeResultBuilder

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

func NewGraphStorageServiceScanEdgeResultBuilder

func NewGraphStorageServiceScanEdgeResultBuilder() *GraphStorageServiceScanEdgeResultBuilder

func (GraphStorageServiceScanEdgeResultBuilder) Emit

func (*GraphStorageServiceScanEdgeResultBuilder) Success

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 (*GraphStorageServiceScanVertexArgs) IsSetReq

func (*GraphStorageServiceScanVertexArgs) Read

func (*GraphStorageServiceScanVertexArgs) ReadField1

func (*GraphStorageServiceScanVertexArgs) SetReq

func (*GraphStorageServiceScanVertexArgs) String

func (*GraphStorageServiceScanVertexArgs) Write

type GraphStorageServiceScanVertexArgsBuilder

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

func NewGraphStorageServiceScanVertexArgsBuilder

func NewGraphStorageServiceScanVertexArgsBuilder() *GraphStorageServiceScanVertexArgsBuilder

func (GraphStorageServiceScanVertexArgsBuilder) Emit

func (*GraphStorageServiceScanVertexArgsBuilder) Req

type GraphStorageServiceScanVertexResult

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

Attributes:

  • Success

func NewGraphStorageServiceScanVertexResult

func NewGraphStorageServiceScanVertexResult() *GraphStorageServiceScanVertexResult

func (*GraphStorageServiceScanVertexResult) Exception

func (*GraphStorageServiceScanVertexResult) GetSuccess

func (*GraphStorageServiceScanVertexResult) IsSetSuccess

func (p *GraphStorageServiceScanVertexResult) IsSetSuccess() bool

func (*GraphStorageServiceScanVertexResult) Read

func (*GraphStorageServiceScanVertexResult) ReadField0

func (*GraphStorageServiceScanVertexResult) SetSuccess

func (*GraphStorageServiceScanVertexResult) String

func (*GraphStorageServiceScanVertexResult) Write

type GraphStorageServiceScanVertexResultBuilder

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

func NewGraphStorageServiceScanVertexResultBuilder

func NewGraphStorageServiceScanVertexResultBuilder() *GraphStorageServiceScanVertexResultBuilder

func (GraphStorageServiceScanVertexResultBuilder) Emit

func (*GraphStorageServiceScanVertexResultBuilder) Success

type GraphStorageServiceThreadsafeClient

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

func NewGraphStorageServiceThreadsafeClientProtocol

func NewGraphStorageServiceThreadsafeClientProtocol(prot thrift.Protocol) *GraphStorageServiceThreadsafeClient

func (*GraphStorageServiceThreadsafeClient) AddEdges

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) AddVertices

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) ChainAddEdges

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

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) ChainDeleteEdges

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

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) ChainUpdateEdge

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

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) Close

func (*GraphStorageServiceThreadsafeClient) DeleteEdges

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) DeleteTags

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) DeleteVertices

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) Get

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) GetDstBySrc added in v3.3.1

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) GetNeighbors

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) GetProps

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) GetUUID

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) IsOpen

func (client *GraphStorageServiceThreadsafeClient) IsOpen() bool

func (*GraphStorageServiceThreadsafeClient) LookupAndTraverse

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) LookupIndex

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) Open

func (*GraphStorageServiceThreadsafeClient) Put

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) Remove

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) ScanEdge

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) ScanVertex

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) UpdateEdge

Parameters:

  • Req

func (*GraphStorageServiceThreadsafeClient) UpdateVertex

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 (*GraphStorageServiceUpdateEdgeArgs) IsSetReq

func (*GraphStorageServiceUpdateEdgeArgs) Read

func (*GraphStorageServiceUpdateEdgeArgs) ReadField1

func (*GraphStorageServiceUpdateEdgeArgs) SetReq

func (*GraphStorageServiceUpdateEdgeArgs) String

func (*GraphStorageServiceUpdateEdgeArgs) Write

type GraphStorageServiceUpdateEdgeArgsBuilder

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

func NewGraphStorageServiceUpdateEdgeArgsBuilder

func NewGraphStorageServiceUpdateEdgeArgsBuilder() *GraphStorageServiceUpdateEdgeArgsBuilder

func (GraphStorageServiceUpdateEdgeArgsBuilder) Emit

func (*GraphStorageServiceUpdateEdgeArgsBuilder) Req

type GraphStorageServiceUpdateEdgeResult

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

Attributes:

  • Success

func NewGraphStorageServiceUpdateEdgeResult

func NewGraphStorageServiceUpdateEdgeResult() *GraphStorageServiceUpdateEdgeResult

func (*GraphStorageServiceUpdateEdgeResult) Exception

func (*GraphStorageServiceUpdateEdgeResult) GetSuccess

func (*GraphStorageServiceUpdateEdgeResult) IsSetSuccess

func (p *GraphStorageServiceUpdateEdgeResult) IsSetSuccess() bool

func (*GraphStorageServiceUpdateEdgeResult) Read

func (*GraphStorageServiceUpdateEdgeResult) ReadField0

func (*GraphStorageServiceUpdateEdgeResult) SetSuccess

func (*GraphStorageServiceUpdateEdgeResult) String

func (*GraphStorageServiceUpdateEdgeResult) Write

type GraphStorageServiceUpdateEdgeResultBuilder

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

func NewGraphStorageServiceUpdateEdgeResultBuilder

func NewGraphStorageServiceUpdateEdgeResultBuilder() *GraphStorageServiceUpdateEdgeResultBuilder

func (GraphStorageServiceUpdateEdgeResultBuilder) Emit

func (*GraphStorageServiceUpdateEdgeResultBuilder) Success

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 (*GraphStorageServiceUpdateVertexArgs) IsSetReq

func (*GraphStorageServiceUpdateVertexArgs) Read

func (*GraphStorageServiceUpdateVertexArgs) ReadField1

func (*GraphStorageServiceUpdateVertexArgs) SetReq

func (*GraphStorageServiceUpdateVertexArgs) String

func (*GraphStorageServiceUpdateVertexArgs) Write

type GraphStorageServiceUpdateVertexArgsBuilder

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

func NewGraphStorageServiceUpdateVertexArgsBuilder

func NewGraphStorageServiceUpdateVertexArgsBuilder() *GraphStorageServiceUpdateVertexArgsBuilder

func (GraphStorageServiceUpdateVertexArgsBuilder) Emit

func (*GraphStorageServiceUpdateVertexArgsBuilder) Req

type GraphStorageServiceUpdateVertexResult

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

Attributes:

  • Success

func NewGraphStorageServiceUpdateVertexResult

func NewGraphStorageServiceUpdateVertexResult() *GraphStorageServiceUpdateVertexResult

func (*GraphStorageServiceUpdateVertexResult) Exception

func (*GraphStorageServiceUpdateVertexResult) GetSuccess

func (*GraphStorageServiceUpdateVertexResult) IsSetSuccess

func (p *GraphStorageServiceUpdateVertexResult) IsSetSuccess() bool

func (*GraphStorageServiceUpdateVertexResult) Read

func (*GraphStorageServiceUpdateVertexResult) ReadField0

func (*GraphStorageServiceUpdateVertexResult) SetSuccess

func (*GraphStorageServiceUpdateVertexResult) String

func (*GraphStorageServiceUpdateVertexResult) Write

type GraphStorageServiceUpdateVertexResultBuilder

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

func NewGraphStorageServiceUpdateVertexResultBuilder

func NewGraphStorageServiceUpdateVertexResultBuilder() *GraphStorageServiceUpdateVertexResultBuilder

func (GraphStorageServiceUpdateVertexResultBuilder) Emit

func (*GraphStorageServiceUpdateVertexResultBuilder) Success

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"`
	IncludeBegin bool           `thrift:"include_begin,5" db:"include_begin" json:"include_begin"`
	IncludeEnd   bool           `thrift:"include_end,6" db:"include_end" json:"include_end"`
}

Attributes:

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

func NewIndexColumnHint

func NewIndexColumnHint() *IndexColumnHint

func (*IndexColumnHint) 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) GetIncludeBegin

func (p *IndexColumnHint) GetIncludeBegin() bool

func (*IndexColumnHint) GetIncludeEnd

func (p *IndexColumnHint) GetIncludeEnd() bool

func (*IndexColumnHint) GetScanType

func (p *IndexColumnHint) GetScanType() ScanType

func (*IndexColumnHint) IsSetBeginValue

func (p *IndexColumnHint) IsSetBeginValue() bool

func (*IndexColumnHint) IsSetEndValue

func (p *IndexColumnHint) IsSetEndValue() bool

func (*IndexColumnHint) 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) ReadField5

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

func (*IndexColumnHint) ReadField6

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

func (*IndexColumnHint) SetBeginValue

func (i *IndexColumnHint) SetBeginValue(beginValue *nebula0.Value) *IndexColumnHint

func (*IndexColumnHint) SetColumnName

func (i *IndexColumnHint) SetColumnName(columnName []byte) *IndexColumnHint

func (*IndexColumnHint) SetEndValue

func (i *IndexColumnHint) SetEndValue(endValue *nebula0.Value) *IndexColumnHint

func (*IndexColumnHint) SetIncludeBegin

func (i *IndexColumnHint) SetIncludeBegin(includeBegin bool) *IndexColumnHint

func (*IndexColumnHint) SetIncludeEnd

func (i *IndexColumnHint) SetIncludeEnd(includeEnd bool) *IndexColumnHint

func (*IndexColumnHint) SetScanType

func (i *IndexColumnHint) SetScanType(scanType ScanType) *IndexColumnHint

func (*IndexColumnHint) String

func (p *IndexColumnHint) String() string

func (*IndexColumnHint) Write

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

type IndexColumnHintBuilder

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

func NewIndexColumnHintBuilder

func NewIndexColumnHintBuilder() *IndexColumnHintBuilder

func (*IndexColumnHintBuilder) BeginValue

func (i *IndexColumnHintBuilder) BeginValue(beginValue *nebula0.Value) *IndexColumnHintBuilder

func (*IndexColumnHintBuilder) ColumnName

func (i *IndexColumnHintBuilder) ColumnName(columnName []byte) *IndexColumnHintBuilder

func (IndexColumnHintBuilder) Emit

func (*IndexColumnHintBuilder) EndValue

func (*IndexColumnHintBuilder) IncludeBegin

func (i *IndexColumnHintBuilder) IncludeBegin(includeBegin bool) *IndexColumnHintBuilder

func (*IndexColumnHintBuilder) IncludeEnd

func (i *IndexColumnHintBuilder) IncludeEnd(includeEnd bool) *IndexColumnHintBuilder

func (*IndexColumnHintBuilder) ScanType

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

func (i *IndexQueryContext) SetColumnHints(columnHints []*IndexColumnHint) *IndexQueryContext

func (*IndexQueryContext) SetFilter

func (i *IndexQueryContext) SetFilter(filter []byte) *IndexQueryContext

func (*IndexQueryContext) SetIndexID

func (i *IndexQueryContext) SetIndexID(indexID nebula0.IndexID) *IndexQueryContext

func (*IndexQueryContext) String

func (p *IndexQueryContext) String() string

func (*IndexQueryContext) Write

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

type IndexQueryContextBuilder

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

func NewIndexQueryContextBuilder

func NewIndexQueryContextBuilder() *IndexQueryContextBuilder

func (*IndexQueryContextBuilder) ColumnHints

func (i *IndexQueryContextBuilder) ColumnHints(columnHints []*IndexColumnHint) *IndexQueryContextBuilder

func (IndexQueryContextBuilder) Emit

func (*IndexQueryContextBuilder) Filter

func (*IndexQueryContextBuilder) IndexID

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

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

func (*IndexSpec) IsSetSchemaID

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

func (i *IndexSpec) SetContexts(contexts []*IndexQueryContext) *IndexSpec

func (*IndexSpec) SetSchemaID

func (i *IndexSpec) SetSchemaID(schemaID *nebula0.SchemaID) *IndexSpec

func (*IndexSpec) String

func (p *IndexSpec) String() string

func (*IndexSpec) Write

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

type IndexSpecBuilder

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

func NewIndexSpecBuilder

func NewIndexSpecBuilder() *IndexSpecBuilder

func (*IndexSpecBuilder) Contexts

func (i *IndexSpecBuilder) Contexts(contexts []*IndexQueryContext) *IndexSpecBuilder

func (IndexSpecBuilder) Emit

func (p IndexSpecBuilder) Emit() *IndexSpec

func (*IndexSpecBuilder) SchemaID

func (i *IndexSpecBuilder) SchemaID(schemaID *nebula0.SchemaID) *IndexSpecBuilder

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 GraphStorageServiceGetArgs_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) SetParts

func (k *KVGetRequest) SetParts(parts map[nebula0.PartitionID][][]byte) *KVGetRequest

func (*KVGetRequest) SetReturnPartly

func (k *KVGetRequest) SetReturnPartly(returnPartly bool) *KVGetRequest

func (*KVGetRequest) SetSpaceID

func (k *KVGetRequest) SetSpaceID(spaceID nebula0.GraphSpaceID) *KVGetRequest

func (*KVGetRequest) String

func (p *KVGetRequest) String() string

func (*KVGetRequest) Write

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

type KVGetRequestBuilder

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

func NewKVGetRequestBuilder

func NewKVGetRequestBuilder() *KVGetRequestBuilder

func (KVGetRequestBuilder) Emit

func (*KVGetRequestBuilder) Parts

func (*KVGetRequestBuilder) ReturnPartly

func (k *KVGetRequestBuilder) ReturnPartly(returnPartly bool) *KVGetRequestBuilder

func (*KVGetRequestBuilder) SpaceID

type KVGetResponse

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

Attributes:

  • Result_
  • KeyValues
var GraphStorageServiceGetResult_Success_DEFAULT *KVGetResponse

func NewKVGetResponse

func NewKVGetResponse() *KVGetResponse

func (*KVGetResponse) 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) SetKeyValues

func (k *KVGetResponse) SetKeyValues(keyValues map[string][]byte) *KVGetResponse

func (*KVGetResponse) SetResult_

func (k *KVGetResponse) SetResult_(result *ResponseCommon) *KVGetResponse

func (*KVGetResponse) String

func (p *KVGetResponse) String() string

func (*KVGetResponse) Write

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

type KVGetResponseBuilder

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

func NewKVGetResponseBuilder

func NewKVGetResponseBuilder() *KVGetResponseBuilder

func (KVGetResponseBuilder) Emit

func (*KVGetResponseBuilder) KeyValues

func (k *KVGetResponseBuilder) KeyValues(keyValues map[string][]byte) *KVGetResponseBuilder

func (*KVGetResponseBuilder) Result_

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 GraphStorageServicePutArgs_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) SetParts

func (k *KVPutRequest) SetParts(parts map[nebula0.PartitionID][]*nebula0.KeyValue) *KVPutRequest

func (*KVPutRequest) SetSpaceID

func (k *KVPutRequest) SetSpaceID(spaceID nebula0.GraphSpaceID) *KVPutRequest

func (*KVPutRequest) String

func (p *KVPutRequest) String() string

func (*KVPutRequest) Write

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

type KVPutRequestBuilder

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

func NewKVPutRequestBuilder

func NewKVPutRequestBuilder() *KVPutRequestBuilder

func (KVPutRequestBuilder) Emit

func (*KVPutRequestBuilder) Parts

func (*KVPutRequestBuilder) SpaceID

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 GraphStorageServiceRemoveArgs_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) SetParts

func (k *KVRemoveRequest) SetParts(parts map[nebula0.PartitionID][][]byte) *KVRemoveRequest

func (*KVRemoveRequest) SetSpaceID

func (k *KVRemoveRequest) SetSpaceID(spaceID nebula0.GraphSpaceID) *KVRemoveRequest

func (*KVRemoveRequest) String

func (p *KVRemoveRequest) String() string

func (*KVRemoveRequest) Write

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

type KVRemoveRequestBuilder

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

func NewKVRemoveRequestBuilder

func NewKVRemoveRequestBuilder() *KVRemoveRequestBuilder

func (KVRemoveRequestBuilder) Emit

func (*KVRemoveRequestBuilder) Parts

func (*KVRemoveRequestBuilder) SpaceID

type ListClusterInfoReq

type ListClusterInfoReq struct {
}

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 ListClusterInfoReqBuilder

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

func NewListClusterInfoReqBuilder

func NewListClusterInfoReqBuilder() *ListClusterInfoReqBuilder

func (ListClusterInfoReqBuilder) Emit

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

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

func (*ListClusterInfoResp) SetResult_

func (l *ListClusterInfoResp) SetResult_(result *ResponseCommon) *ListClusterInfoResp

func (*ListClusterInfoResp) String

func (p *ListClusterInfoResp) String() string

func (*ListClusterInfoResp) Write

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

type ListClusterInfoRespBuilder

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

func NewListClusterInfoRespBuilder

func NewListClusterInfoRespBuilder() *ListClusterInfoRespBuilder

func (*ListClusterInfoRespBuilder) Dir

func (ListClusterInfoRespBuilder) Emit

func (*ListClusterInfoRespBuilder) Result_

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,optional" db:"common" json:"common,omitempty"`
}

Attributes:

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

func NewLookupAndTraverseRequest

func NewLookupAndTraverseRequest() *LookupAndTraverseRequest

func (*LookupAndTraverseRequest) GetCommon

func (p *LookupAndTraverseRequest) GetCommon() *RequestCommon

func (*LookupAndTraverseRequest) GetIndices

func (p *LookupAndTraverseRequest) GetIndices() *IndexSpec

func (*LookupAndTraverseRequest) GetParts

func (*LookupAndTraverseRequest) GetSpaceID

func (*LookupAndTraverseRequest) GetTraverseSpec

func (p *LookupAndTraverseRequest) GetTraverseSpec() *TraverseSpec

func (*LookupAndTraverseRequest) IsSetCommon

func (p *LookupAndTraverseRequest) IsSetCommon() bool

func (*LookupAndTraverseRequest) IsSetIndices

func (p *LookupAndTraverseRequest) IsSetIndices() bool

func (*LookupAndTraverseRequest) IsSetTraverseSpec

func (p *LookupAndTraverseRequest) IsSetTraverseSpec() bool

func (*LookupAndTraverseRequest) Read

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

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

func (*LookupAndTraverseRequest) SetCommon

func (*LookupAndTraverseRequest) SetIndices

func (*LookupAndTraverseRequest) SetParts

func (*LookupAndTraverseRequest) SetSpaceID

func (*LookupAndTraverseRequest) SetTraverseSpec

func (l *LookupAndTraverseRequest) SetTraverseSpec(traverseSpec *TraverseSpec) *LookupAndTraverseRequest

func (*LookupAndTraverseRequest) String

func (p *LookupAndTraverseRequest) String() string

func (*LookupAndTraverseRequest) Write

type LookupAndTraverseRequestBuilder

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

func NewLookupAndTraverseRequestBuilder

func NewLookupAndTraverseRequestBuilder() *LookupAndTraverseRequestBuilder

func (*LookupAndTraverseRequestBuilder) Common

func (LookupAndTraverseRequestBuilder) Emit

func (*LookupAndTraverseRequestBuilder) Indices

func (*LookupAndTraverseRequestBuilder) Parts

func (*LookupAndTraverseRequestBuilder) SpaceID

func (*LookupAndTraverseRequestBuilder) TraverseSpec

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,optional" db:"return_columns" json:"return_columns,omitempty"`
	Common        *RequestCommon        `thrift:"common,5,optional" db:"common" json:"common,omitempty"`
	Limit         *int64                `thrift:"limit,6,optional" db:"limit" json:"limit,omitempty"`
	OrderBy       []*OrderBy            `thrift:"order_by,7,optional" db:"order_by" json:"order_by,omitempty"`
	StatColumns   []*StatProp           `thrift:"stat_columns,8,optional" db:"stat_columns" json:"stat_columns,omitempty"`
}

Attributes:

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

func NewLookupIndexRequest

func NewLookupIndexRequest() *LookupIndexRequest

func (*LookupIndexRequest) GetCommon

func (p *LookupIndexRequest) GetCommon() *RequestCommon

func (*LookupIndexRequest) GetIndices

func (p *LookupIndexRequest) GetIndices() *IndexSpec

func (*LookupIndexRequest) GetLimit

func (p *LookupIndexRequest) GetLimit() int64

func (*LookupIndexRequest) GetOrderBy

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

func (*LookupIndexRequest) GetParts

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

func (*LookupIndexRequest) GetReturnColumns

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

func (*LookupIndexRequest) GetSpaceID

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

func (*LookupIndexRequest) GetStatColumns

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

func (*LookupIndexRequest) IsSetCommon

func (p *LookupIndexRequest) IsSetCommon() bool

func (*LookupIndexRequest) IsSetIndices

func (p *LookupIndexRequest) IsSetIndices() bool

func (*LookupIndexRequest) IsSetLimit

func (p *LookupIndexRequest) IsSetLimit() bool

func (*LookupIndexRequest) IsSetOrderBy

func (p *LookupIndexRequest) IsSetOrderBy() bool

func (*LookupIndexRequest) IsSetReturnColumns

func (p *LookupIndexRequest) IsSetReturnColumns() bool

func (*LookupIndexRequest) IsSetStatColumns

func (p *LookupIndexRequest) IsSetStatColumns() bool

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

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

func (*LookupIndexRequest) ReadField6

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

func (*LookupIndexRequest) ReadField7

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

func (*LookupIndexRequest) ReadField8

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

func (*LookupIndexRequest) SetCommon

func (l *LookupIndexRequest) SetCommon(common *RequestCommon) *LookupIndexRequest

func (*LookupIndexRequest) SetIndices

func (l *LookupIndexRequest) SetIndices(indices *IndexSpec) *LookupIndexRequest

func (*LookupIndexRequest) SetLimit

func (l *LookupIndexRequest) SetLimit(limit *int64) *LookupIndexRequest

func (*LookupIndexRequest) SetOrderBy

func (l *LookupIndexRequest) SetOrderBy(orderBy []*OrderBy) *LookupIndexRequest

func (*LookupIndexRequest) SetParts

func (*LookupIndexRequest) SetReturnColumns

func (l *LookupIndexRequest) SetReturnColumns(returnColumns [][]byte) *LookupIndexRequest

func (*LookupIndexRequest) SetSpaceID

func (*LookupIndexRequest) SetStatColumns

func (l *LookupIndexRequest) SetStatColumns(statColumns []*StatProp) *LookupIndexRequest

func (*LookupIndexRequest) String

func (p *LookupIndexRequest) String() string

func (*LookupIndexRequest) Write

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

type LookupIndexRequestBuilder

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

func NewLookupIndexRequestBuilder

func NewLookupIndexRequestBuilder() *LookupIndexRequestBuilder

func (*LookupIndexRequestBuilder) Common

func (LookupIndexRequestBuilder) Emit

func (*LookupIndexRequestBuilder) Indices

func (*LookupIndexRequestBuilder) Limit

func (*LookupIndexRequestBuilder) OrderBy

func (*LookupIndexRequestBuilder) Parts

func (*LookupIndexRequestBuilder) ReturnColumns

func (l *LookupIndexRequestBuilder) ReturnColumns(returnColumns [][]byte) *LookupIndexRequestBuilder

func (*LookupIndexRequestBuilder) SpaceID

func (*LookupIndexRequestBuilder) StatColumns

func (l *LookupIndexRequestBuilder) StatColumns(statColumns []*StatProp) *LookupIndexRequestBuilder

type LookupIndexResp

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

Attributes:

  • Result_
  • Data
  • StatData
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) GetStatData

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

func (*LookupIndexResp) IsSetData

func (p *LookupIndexResp) IsSetData() bool

func (*LookupIndexResp) IsSetResult_

func (p *LookupIndexResp) IsSetResult_() bool

func (*LookupIndexResp) IsSetStatData

func (p *LookupIndexResp) IsSetStatData() bool

func (*LookupIndexResp) 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) ReadField3

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

func (*LookupIndexResp) SetData

func (l *LookupIndexResp) SetData(data *nebula0.DataSet) *LookupIndexResp

func (*LookupIndexResp) SetResult_

func (l *LookupIndexResp) SetResult_(result *ResponseCommon) *LookupIndexResp

func (*LookupIndexResp) SetStatData

func (l *LookupIndexResp) SetStatData(statData *nebula0.DataSet) *LookupIndexResp

func (*LookupIndexResp) String

func (p *LookupIndexResp) String() string

func (*LookupIndexResp) Write

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

type LookupIndexRespBuilder

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

func NewLookupIndexRespBuilder

func NewLookupIndexRespBuilder() *LookupIndexRespBuilder

func (*LookupIndexRespBuilder) Data

func (LookupIndexRespBuilder) Emit

func (*LookupIndexRespBuilder) Result_

func (*LookupIndexRespBuilder) StatData

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

func (m *MemberChangeReq) SetAdd(add bool) *MemberChangeReq

func (*MemberChangeReq) SetPartID

func (m *MemberChangeReq) SetPartID(partID nebula0.PartitionID) *MemberChangeReq

func (*MemberChangeReq) SetPeer

func (m *MemberChangeReq) SetPeer(peer *nebula0.HostAddr) *MemberChangeReq

func (*MemberChangeReq) SetSpaceID

func (m *MemberChangeReq) SetSpaceID(spaceID nebula0.GraphSpaceID) *MemberChangeReq

func (*MemberChangeReq) String

func (p *MemberChangeReq) String() string

func (*MemberChangeReq) Write

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

type MemberChangeReqBuilder

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

func NewMemberChangeReqBuilder

func NewMemberChangeReqBuilder() *MemberChangeReqBuilder

func (*MemberChangeReqBuilder) Add

func (MemberChangeReqBuilder) Emit

func (*MemberChangeReqBuilder) PartID

func (*MemberChangeReqBuilder) Peer

func (*MemberChangeReqBuilder) SpaceID

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_) SetKey

func (n *NewEdge_) SetKey(key *EdgeKey) *NewEdge_

func (*NewEdge_) SetProps

func (n *NewEdge_) SetProps(props []*nebula0.Value) *NewEdge_

func (*NewEdge_) String

func (p *NewEdge_) String() string

func (*NewEdge_) Write

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

type NewEdge_Builder

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

func NewNewEdge_Builder

func NewNewEdge_Builder() *NewEdge_Builder

func (NewEdge_Builder) Emit

func (p NewEdge_Builder) Emit() *NewEdge_

func (*NewEdge_Builder) Key

func (n *NewEdge_Builder) Key(key *EdgeKey) *NewEdge_Builder

func (*NewEdge_Builder) Props

func (n *NewEdge_Builder) Props(props []*nebula0.Value) *NewEdge_Builder

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_) SetProps

func (n *NewTag_) SetProps(props []*nebula0.Value) *NewTag_

func (*NewTag_) SetTagID

func (n *NewTag_) SetTagID(tagID nebula0.TagID) *NewTag_

func (*NewTag_) String

func (p *NewTag_) String() string

func (*NewTag_) Write

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

type NewTag_Builder

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

func NewNewTag_Builder

func NewNewTag_Builder() *NewTag_Builder

func (NewTag_Builder) Emit

func (p NewTag_Builder) Emit() *NewTag_

func (*NewTag_Builder) Props

func (n *NewTag_Builder) Props(props []*nebula0.Value) *NewTag_Builder

func (*NewTag_Builder) TagID

func (n *NewTag_Builder) TagID(tagID nebula0.TagID) *NewTag_Builder

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_) SetId

func (n *NewVertex_) SetId(id *nebula0.Value) *NewVertex_

func (*NewVertex_) SetTags

func (n *NewVertex_) SetTags(tags []*NewTag_) *NewVertex_

func (*NewVertex_) String

func (p *NewVertex_) String() string

func (*NewVertex_) Write

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

type NewVertex_Builder

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

func NewNewVertex_Builder

func NewNewVertex_Builder() *NewVertex_Builder

func (NewVertex_Builder) Emit

func (p NewVertex_Builder) Emit() *NewVertex_

func (*NewVertex_Builder) Id

func (*NewVertex_Builder) Tags

func (n *NewVertex_Builder) Tags(tags []*NewTag_) *NewVertex_Builder

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

func (o *OrderBy) SetDirection(direction OrderDirection) *OrderBy

func (*OrderBy) SetProp

func (o *OrderBy) SetProp(prop []byte) *OrderBy

func (*OrderBy) String

func (p *OrderBy) String() string

func (*OrderBy) Write

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

type OrderByBuilder

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

func NewOrderByBuilder

func NewOrderByBuilder() *OrderByBuilder

func (*OrderByBuilder) Direction

func (o *OrderByBuilder) Direction(direction OrderDirection) *OrderByBuilder

func (OrderByBuilder) Emit

func (p OrderByBuilder) Emit() *OrderBy

func (*OrderByBuilder) Prop

func (o *OrderByBuilder) Prop(prop []byte) *OrderByBuilder

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,optional" 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_) SetCode

func (*PartitionResult_) SetLeader

func (p *PartitionResult_) SetLeader(leader *nebula0.HostAddr) *PartitionResult_

func (*PartitionResult_) SetPartID

func (p *PartitionResult_) SetPartID(partID nebula0.PartitionID) *PartitionResult_

func (*PartitionResult_) String

func (p *PartitionResult_) String() string

func (*PartitionResult_) Write

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

type PartitionResult_Builder

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

func NewPartitionResult_Builder

func NewPartitionResult_Builder() *PartitionResult_Builder

func (*PartitionResult_Builder) Code

func (PartitionResult_Builder) Emit

func (*PartitionResult_Builder) Leader

func (*PartitionResult_Builder) PartID

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

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

func (r *RebuildIndexRequest) SetIndexID(indexID nebula0.IndexID) *RebuildIndexRequest

func (*RebuildIndexRequest) SetParts

func (*RebuildIndexRequest) SetSpaceID

func (*RebuildIndexRequest) String

func (p *RebuildIndexRequest) String() string

func (*RebuildIndexRequest) Write

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

type RebuildIndexRequestBuilder

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

func NewRebuildIndexRequestBuilder

func NewRebuildIndexRequestBuilder() *RebuildIndexRequestBuilder

func (RebuildIndexRequestBuilder) Emit

func (*RebuildIndexRequestBuilder) IndexID

func (*RebuildIndexRequestBuilder) Parts

func (*RebuildIndexRequestBuilder) SpaceID

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

func (r *RemovePartReq) SetPartID(partID nebula0.PartitionID) *RemovePartReq

func (*RemovePartReq) SetSpaceID

func (r *RemovePartReq) SetSpaceID(spaceID nebula0.GraphSpaceID) *RemovePartReq

func (*RemovePartReq) String

func (p *RemovePartReq) String() string

func (*RemovePartReq) Write

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

type RemovePartReqBuilder

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

func NewRemovePartReqBuilder

func NewRemovePartReqBuilder() *RemovePartReqBuilder

func (RemovePartReqBuilder) Emit

func (*RemovePartReqBuilder) PartID

func (*RemovePartReqBuilder) SpaceID

type RequestCommon

type RequestCommon struct {
	SessionID     *nebula0.SessionID       `thrift:"session_id,1,optional" db:"session_id" json:"session_id,omitempty"`
	PlanID        *nebula0.ExecutionPlanID `thrift:"plan_id,2,optional" db:"plan_id" json:"plan_id,omitempty"`
	ProfileDetail *bool                    `thrift:"profile_detail,3,optional" db:"profile_detail" json:"profile_detail,omitempty"`
}

Attributes:

  • SessionID
  • PlanID
  • ProfileDetail
var AddEdgesRequest_Common_DEFAULT *RequestCommon
var AddVerticesRequest_Common_DEFAULT *RequestCommon
var DeleteEdgesRequest_Common_DEFAULT *RequestCommon
var DeleteTagsRequest_Common_DEFAULT *RequestCommon
var DeleteVerticesRequest_Common_DEFAULT *RequestCommon
var GetDstBySrcRequest_Common_DEFAULT *RequestCommon
var GetNeighborsRequest_Common_DEFAULT *RequestCommon
var GetPropRequest_Common_DEFAULT *RequestCommon
var GetUUIDReq_Common_DEFAULT *RequestCommon
var LookupAndTraverseRequest_Common_DEFAULT *RequestCommon
var LookupIndexRequest_Common_DEFAULT *RequestCommon
var ScanEdgeRequest_Common_DEFAULT *RequestCommon
var ScanVertexRequest_Common_DEFAULT *RequestCommon
var UpdateEdgeRequest_Common_DEFAULT *RequestCommon
var UpdateVertexRequest_Common_DEFAULT *RequestCommon

func NewRequestCommon

func NewRequestCommon() *RequestCommon

func (*RequestCommon) GetPlanID

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

func (*RequestCommon) GetProfileDetail

func (p *RequestCommon) GetProfileDetail() bool

func (*RequestCommon) GetSessionID

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

func (*RequestCommon) IsSetPlanID

func (p *RequestCommon) IsSetPlanID() bool

func (*RequestCommon) IsSetProfileDetail

func (p *RequestCommon) IsSetProfileDetail() bool

func (*RequestCommon) IsSetSessionID

func (p *RequestCommon) IsSetSessionID() bool

func (*RequestCommon) Read

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

func (*RequestCommon) ReadField1

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

func (*RequestCommon) ReadField2

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

func (*RequestCommon) ReadField3

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

func (*RequestCommon) SetPlanID

func (r *RequestCommon) SetPlanID(planID *nebula0.ExecutionPlanID) *RequestCommon

func (*RequestCommon) SetProfileDetail

func (r *RequestCommon) SetProfileDetail(profileDetail *bool) *RequestCommon

func (*RequestCommon) SetSessionID

func (r *RequestCommon) SetSessionID(sessionID *nebula0.SessionID) *RequestCommon

func (*RequestCommon) String

func (p *RequestCommon) String() string

func (*RequestCommon) Write

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

type RequestCommonBuilder

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

func NewRequestCommonBuilder

func NewRequestCommonBuilder() *RequestCommonBuilder

func (RequestCommonBuilder) Emit

func (*RequestCommonBuilder) PlanID

func (*RequestCommonBuilder) ProfileDetail

func (r *RequestCommonBuilder) ProfileDetail(profileDetail *bool) *RequestCommonBuilder

func (*RequestCommonBuilder) SessionID

func (r *RequestCommonBuilder) SessionID(sessionID *nebula0.SessionID) *RequestCommonBuilder

type ResponseCommon

type ResponseCommon struct {
	FailedParts     []*PartitionResult_ `thrift:"failed_parts,1,required" db:"failed_parts" json:"failed_parts"`
	LatencyInUs     int64               `thrift:"latency_in_us,2,required" db:"latency_in_us" json:"latency_in_us"`
	LatencyDetailUs map[string]int32    `thrift:"latency_detail_us,3,optional" db:"latency_detail_us" json:"latency_detail_us,omitempty"`
}

Attributes:

  • FailedParts
  • LatencyInUs
  • LatencyDetailUs
var AdminExecResp_Result__DEFAULT *ResponseCommon
var ExecResponse_Result__DEFAULT *ResponseCommon
var GetDstBySrcResponse_Result__DEFAULT *ResponseCommon
var GetNeighborsResponse_Result__DEFAULT *ResponseCommon
var GetPropResponse_Result__DEFAULT *ResponseCommon
var GetUUIDResp_Result__DEFAULT *ResponseCommon
var KVGetResponse_Result__DEFAULT *ResponseCommon
var ListClusterInfoResp_Result__DEFAULT *ResponseCommon
var LookupIndexResp_Result__DEFAULT *ResponseCommon
var ScanResponse_Result__DEFAULT *ResponseCommon
var UpdateResponse_Result__DEFAULT *ResponseCommon

func NewResponseCommon

func NewResponseCommon() *ResponseCommon

func (*ResponseCommon) GetFailedParts

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

func (*ResponseCommon) GetLatencyDetailUs

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

func (*ResponseCommon) GetLatencyInUs

func (p *ResponseCommon) GetLatencyInUs() int64

func (*ResponseCommon) IsSetLatencyDetailUs

func (p *ResponseCommon) IsSetLatencyDetailUs() bool

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

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

func (*ResponseCommon) SetFailedParts

func (r *ResponseCommon) SetFailedParts(failedParts []*PartitionResult_) *ResponseCommon

func (*ResponseCommon) SetLatencyDetailUs

func (r *ResponseCommon) SetLatencyDetailUs(latencyDetailUs map[string]int32) *ResponseCommon

func (*ResponseCommon) SetLatencyInUs

func (r *ResponseCommon) SetLatencyInUs(latencyInUs int64) *ResponseCommon

func (*ResponseCommon) String

func (p *ResponseCommon) String() string

func (*ResponseCommon) Write

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

type ResponseCommonBuilder

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

func NewResponseCommonBuilder

func NewResponseCommonBuilder() *ResponseCommonBuilder

func (ResponseCommonBuilder) Emit

func (*ResponseCommonBuilder) FailedParts

func (r *ResponseCommonBuilder) FailedParts(failedParts []*PartitionResult_) *ResponseCommonBuilder

func (*ResponseCommonBuilder) LatencyDetailUs

func (r *ResponseCommonBuilder) LatencyDetailUs(latencyDetailUs map[string]int32) *ResponseCommonBuilder

func (*ResponseCommonBuilder) LatencyInUs

func (r *ResponseCommonBuilder) LatencyInUs(latencyInUs int64) *ResponseCommonBuilder

type ScanCursor

type ScanCursor struct {
	NextCursor []byte `thrift:"next_cursor,1,optional" db:"next_cursor" json:"next_cursor,omitempty"`
}

Attributes:

  • NextCursor

func NewScanCursor

func NewScanCursor() *ScanCursor

func (*ScanCursor) GetNextCursor

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

func (*ScanCursor) IsSetNextCursor

func (p *ScanCursor) IsSetNextCursor() bool

func (*ScanCursor) Read

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

func (*ScanCursor) ReadField1

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

func (*ScanCursor) SetNextCursor

func (s *ScanCursor) SetNextCursor(nextCursor []byte) *ScanCursor

func (*ScanCursor) String

func (p *ScanCursor) String() string

func (*ScanCursor) Write

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

type ScanCursorBuilder

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

func NewScanCursorBuilder

func NewScanCursorBuilder() *ScanCursorBuilder

func (ScanCursorBuilder) Emit

func (p ScanCursorBuilder) Emit() *ScanCursor

func (*ScanCursorBuilder) NextCursor

func (s *ScanCursorBuilder) NextCursor(nextCursor []byte) *ScanCursorBuilder

type ScanEdgeRequest

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

Attributes:

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

func NewScanEdgeRequest

func NewScanEdgeRequest() *ScanEdgeRequest

func (*ScanEdgeRequest) GetCommon

func (p *ScanEdgeRequest) GetCommon() *RequestCommon

func (*ScanEdgeRequest) GetEnableReadFromFollower

func (p *ScanEdgeRequest) GetEnableReadFromFollower() bool

func (*ScanEdgeRequest) GetEndTime

func (p *ScanEdgeRequest) GetEndTime() int64

func (*ScanEdgeRequest) GetFilter

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

func (*ScanEdgeRequest) GetLimit

func (p *ScanEdgeRequest) GetLimit() int64

func (*ScanEdgeRequest) GetOnlyLatestVersion

func (p *ScanEdgeRequest) GetOnlyLatestVersion() bool

func (*ScanEdgeRequest) GetParts

func (p *ScanEdgeRequest) GetParts() map[nebula0.PartitionID]*ScanCursor

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

func (p *ScanEdgeRequest) IsSetCommon() bool

func (*ScanEdgeRequest) IsSetEndTime

func (p *ScanEdgeRequest) IsSetEndTime() bool

func (*ScanEdgeRequest) IsSetFilter

func (p *ScanEdgeRequest) IsSetFilter() bool

func (*ScanEdgeRequest) IsSetStartTime

func (p *ScanEdgeRequest) IsSetStartTime() bool

func (*ScanEdgeRequest) 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) 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) SetCommon

func (s *ScanEdgeRequest) SetCommon(common *RequestCommon) *ScanEdgeRequest

func (*ScanEdgeRequest) SetEnableReadFromFollower

func (s *ScanEdgeRequest) SetEnableReadFromFollower(enableReadFromFollower bool) *ScanEdgeRequest

func (*ScanEdgeRequest) SetEndTime

func (s *ScanEdgeRequest) SetEndTime(endTime *int64) *ScanEdgeRequest

func (*ScanEdgeRequest) SetFilter

func (s *ScanEdgeRequest) SetFilter(filter []byte) *ScanEdgeRequest

func (*ScanEdgeRequest) SetLimit

func (s *ScanEdgeRequest) SetLimit(limit int64) *ScanEdgeRequest

func (*ScanEdgeRequest) SetOnlyLatestVersion

func (s *ScanEdgeRequest) SetOnlyLatestVersion(onlyLatestVersion bool) *ScanEdgeRequest

func (*ScanEdgeRequest) SetParts

func (*ScanEdgeRequest) SetReturnColumns

func (s *ScanEdgeRequest) SetReturnColumns(returnColumns []*EdgeProp) *ScanEdgeRequest

func (*ScanEdgeRequest) SetSpaceID

func (s *ScanEdgeRequest) SetSpaceID(spaceID nebula0.GraphSpaceID) *ScanEdgeRequest

func (*ScanEdgeRequest) SetStartTime

func (s *ScanEdgeRequest) SetStartTime(startTime *int64) *ScanEdgeRequest

func (*ScanEdgeRequest) String

func (p *ScanEdgeRequest) String() string

func (*ScanEdgeRequest) Write

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

type ScanEdgeRequestBuilder

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

func NewScanEdgeRequestBuilder

func NewScanEdgeRequestBuilder() *ScanEdgeRequestBuilder

func (*ScanEdgeRequestBuilder) Common

func (ScanEdgeRequestBuilder) Emit

func (*ScanEdgeRequestBuilder) EnableReadFromFollower

func (s *ScanEdgeRequestBuilder) EnableReadFromFollower(enableReadFromFollower bool) *ScanEdgeRequestBuilder

func (*ScanEdgeRequestBuilder) EndTime

func (s *ScanEdgeRequestBuilder) EndTime(endTime *int64) *ScanEdgeRequestBuilder

func (*ScanEdgeRequestBuilder) Filter

func (s *ScanEdgeRequestBuilder) Filter(filter []byte) *ScanEdgeRequestBuilder

func (*ScanEdgeRequestBuilder) Limit

func (*ScanEdgeRequestBuilder) OnlyLatestVersion

func (s *ScanEdgeRequestBuilder) OnlyLatestVersion(onlyLatestVersion bool) *ScanEdgeRequestBuilder

func (*ScanEdgeRequestBuilder) Parts

func (*ScanEdgeRequestBuilder) ReturnColumns

func (s *ScanEdgeRequestBuilder) ReturnColumns(returnColumns []*EdgeProp) *ScanEdgeRequestBuilder

func (*ScanEdgeRequestBuilder) SpaceID

func (*ScanEdgeRequestBuilder) StartTime

func (s *ScanEdgeRequestBuilder) StartTime(startTime *int64) *ScanEdgeRequestBuilder

type ScanResponse

type ScanResponse struct {
	Result_ *ResponseCommon                     `thrift:"result,1,required" db:"result" json:"result"`
	Props   *nebula0.DataSet                    `thrift:"props,2,optional" db:"props" json:"props,omitempty"`
	Cursors map[nebula0.PartitionID]*ScanCursor `thrift:"cursors,3" db:"cursors" json:"cursors"`
}

Attributes:

  • Result_
  • Props
  • Cursors
var GraphStorageServiceScanEdgeResult_Success_DEFAULT *ScanResponse
var GraphStorageServiceScanVertexResult_Success_DEFAULT *ScanResponse

func NewScanResponse

func NewScanResponse() *ScanResponse

func (*ScanResponse) GetCursors

func (p *ScanResponse) GetCursors() map[nebula0.PartitionID]*ScanCursor

func (*ScanResponse) GetProps

func (p *ScanResponse) GetProps() *nebula0.DataSet

func (*ScanResponse) GetResult_

func (p *ScanResponse) GetResult_() *ResponseCommon

func (*ScanResponse) IsSetProps

func (p *ScanResponse) IsSetProps() bool

func (*ScanResponse) IsSetResult_

func (p *ScanResponse) IsSetResult_() bool

func (*ScanResponse) Read

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

func (*ScanResponse) ReadField1

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

func (*ScanResponse) ReadField2

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

func (*ScanResponse) ReadField3

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

func (*ScanResponse) SetCursors

func (s *ScanResponse) SetCursors(cursors map[nebula0.PartitionID]*ScanCursor) *ScanResponse

func (*ScanResponse) SetProps

func (s *ScanResponse) SetProps(props *nebula0.DataSet) *ScanResponse

func (*ScanResponse) SetResult_

func (s *ScanResponse) SetResult_(result *ResponseCommon) *ScanResponse

func (*ScanResponse) String

func (p *ScanResponse) String() string

func (*ScanResponse) Write

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

type ScanResponseBuilder

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

func NewScanResponseBuilder

func NewScanResponseBuilder() *ScanResponseBuilder

func (*ScanResponseBuilder) Cursors

func (ScanResponseBuilder) Emit

func (*ScanResponseBuilder) Props

func (*ScanResponseBuilder) Result_

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"`
	Parts                  map[nebula0.PartitionID]*ScanCursor `thrift:"parts,2" db:"parts" json:"parts"`
	ReturnColumns          []*VertexProp                       `thrift:"return_columns,3" db:"return_columns" json:"return_columns"`
	Limit                  int64                               `thrift:"limit,4" db:"limit" json:"limit"`
	StartTime              *int64                              `thrift:"start_time,5,optional" db:"start_time" json:"start_time,omitempty"`
	EndTime                *int64                              `thrift:"end_time,6,optional" db:"end_time" json:"end_time,omitempty"`
	Filter                 []byte                              `thrift:"filter,7,optional" db:"filter" json:"filter,omitempty"`
	OnlyLatestVersion      bool                                `thrift:"only_latest_version,8" db:"only_latest_version" json:"only_latest_version"`
	EnableReadFromFollower bool                                `thrift:"enable_read_from_follower,9" db:"enable_read_from_follower" json:"enable_read_from_follower"`
	Common                 *RequestCommon                      `thrift:"common,10,optional" db:"common" json:"common,omitempty"`
}

Attributes:

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

func NewScanVertexRequest

func NewScanVertexRequest() *ScanVertexRequest

func (*ScanVertexRequest) GetCommon

func (p *ScanVertexRequest) GetCommon() *RequestCommon

func (*ScanVertexRequest) GetEnableReadFromFollower

func (p *ScanVertexRequest) GetEnableReadFromFollower() bool

func (*ScanVertexRequest) GetEndTime

func (p *ScanVertexRequest) GetEndTime() int64

func (*ScanVertexRequest) GetFilter

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

func (*ScanVertexRequest) GetLimit

func (p *ScanVertexRequest) GetLimit() int64

func (*ScanVertexRequest) GetOnlyLatestVersion

func (p *ScanVertexRequest) GetOnlyLatestVersion() bool

func (*ScanVertexRequest) GetParts

func (p *ScanVertexRequest) GetParts() map[nebula0.PartitionID]*ScanCursor

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

func (p *ScanVertexRequest) IsSetCommon() bool

func (*ScanVertexRequest) IsSetEndTime

func (p *ScanVertexRequest) IsSetEndTime() bool

func (*ScanVertexRequest) IsSetFilter

func (p *ScanVertexRequest) IsSetFilter() bool

func (*ScanVertexRequest) IsSetStartTime

func (p *ScanVertexRequest) IsSetStartTime() bool

func (*ScanVertexRequest) 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) 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) SetCommon

func (s *ScanVertexRequest) SetCommon(common *RequestCommon) *ScanVertexRequest

func (*ScanVertexRequest) SetEnableReadFromFollower

func (s *ScanVertexRequest) SetEnableReadFromFollower(enableReadFromFollower bool) *ScanVertexRequest

func (*ScanVertexRequest) SetEndTime

func (s *ScanVertexRequest) SetEndTime(endTime *int64) *ScanVertexRequest

func (*ScanVertexRequest) SetFilter

func (s *ScanVertexRequest) SetFilter(filter []byte) *ScanVertexRequest

func (*ScanVertexRequest) SetLimit

func (s *ScanVertexRequest) SetLimit(limit int64) *ScanVertexRequest

func (*ScanVertexRequest) SetOnlyLatestVersion

func (s *ScanVertexRequest) SetOnlyLatestVersion(onlyLatestVersion bool) *ScanVertexRequest

func (*ScanVertexRequest) SetParts

func (*ScanVertexRequest) SetReturnColumns

func (s *ScanVertexRequest) SetReturnColumns(returnColumns []*VertexProp) *ScanVertexRequest

func (*ScanVertexRequest) SetSpaceID

func (s *ScanVertexRequest) SetSpaceID(spaceID nebula0.GraphSpaceID) *ScanVertexRequest

func (*ScanVertexRequest) SetStartTime

func (s *ScanVertexRequest) SetStartTime(startTime *int64) *ScanVertexRequest

func (*ScanVertexRequest) String

func (p *ScanVertexRequest) String() string

func (*ScanVertexRequest) Write

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

type ScanVertexRequestBuilder

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

func NewScanVertexRequestBuilder

func NewScanVertexRequestBuilder() *ScanVertexRequestBuilder

func (*ScanVertexRequestBuilder) Common

func (ScanVertexRequestBuilder) Emit

func (*ScanVertexRequestBuilder) EnableReadFromFollower

func (s *ScanVertexRequestBuilder) EnableReadFromFollower(enableReadFromFollower bool) *ScanVertexRequestBuilder

func (*ScanVertexRequestBuilder) EndTime

func (*ScanVertexRequestBuilder) Filter

func (*ScanVertexRequestBuilder) Limit

func (*ScanVertexRequestBuilder) OnlyLatestVersion

func (s *ScanVertexRequestBuilder) OnlyLatestVersion(onlyLatestVersion bool) *ScanVertexRequestBuilder

func (*ScanVertexRequestBuilder) Parts

func (*ScanVertexRequestBuilder) ReturnColumns

func (s *ScanVertexRequestBuilder) ReturnColumns(returnColumns []*VertexProp) *ScanVertexRequestBuilder

func (*ScanVertexRequestBuilder) SpaceID

func (*ScanVertexRequestBuilder) StartTime

func (s *ScanVertexRequestBuilder) StartTime(startTime *int64) *ScanVertexRequestBuilder

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

func (s *StatProp) SetAlias(alias []byte) *StatProp

func (*StatProp) SetProp

func (s *StatProp) SetProp(prop []byte) *StatProp

func (*StatProp) SetStat

func (s *StatProp) SetStat(stat StatType) *StatProp

func (*StatProp) String

func (p *StatProp) String() string

func (*StatProp) Write

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

type StatPropBuilder

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

func NewStatPropBuilder

func NewStatPropBuilder() *StatPropBuilder

func (*StatPropBuilder) Alias

func (s *StatPropBuilder) Alias(alias []byte) *StatPropBuilder

func (StatPropBuilder) Emit

func (p StatPropBuilder) Emit() *StatProp

func (*StatPropBuilder) Prop

func (s *StatPropBuilder) Prop(prop []byte) *StatPropBuilder

func (*StatPropBuilder) Stat

func (s *StatPropBuilder) Stat(stat StatType) *StatPropBuilder

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 StopTaskRequest added in v3.1.0

type StopTaskRequest struct {
	JobID  int32 `thrift:"job_id,1" db:"job_id" json:"job_id"`
	TaskID int32 `thrift:"task_id,2" db:"task_id" json:"task_id"`
}

Attributes:

  • JobID
  • TaskID
var StorageAdminServiceStopAdminTaskArgs_Req_DEFAULT *StopTaskRequest

func NewStopTaskRequest added in v3.1.0

func NewStopTaskRequest() *StopTaskRequest

func (*StopTaskRequest) GetJobID added in v3.1.0

func (p *StopTaskRequest) GetJobID() int32

func (*StopTaskRequest) GetTaskID added in v3.1.0

func (p *StopTaskRequest) GetTaskID() int32

func (*StopTaskRequest) Read added in v3.1.0

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

func (*StopTaskRequest) ReadField1 added in v3.1.0

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

func (*StopTaskRequest) ReadField2 added in v3.1.0

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

func (*StopTaskRequest) SetJobID added in v3.1.0

func (s *StopTaskRequest) SetJobID(jobID int32) *StopTaskRequest

func (*StopTaskRequest) SetTaskID added in v3.1.0

func (s *StopTaskRequest) SetTaskID(taskID int32) *StopTaskRequest

func (*StopTaskRequest) String added in v3.1.0

func (p *StopTaskRequest) String() string

func (*StopTaskRequest) Write added in v3.1.0

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

type StopTaskRequestBuilder added in v3.1.0

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

func NewStopTaskRequestBuilder added in v3.1.0

func NewStopTaskRequestBuilder() *StopTaskRequestBuilder

func (StopTaskRequestBuilder) Emit added in v3.1.0

func (*StopTaskRequestBuilder) JobID added in v3.1.0

func (*StopTaskRequestBuilder) TaskID added in v3.1.0

type StopTaskResp added in v3.1.0

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

Attributes:

  • Code
var StorageAdminServiceStopAdminTaskResult_Success_DEFAULT *StopTaskResp

func NewStopTaskResp added in v3.1.0

func NewStopTaskResp() *StopTaskResp

func (*StopTaskResp) GetCode added in v3.1.0

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

func (*StopTaskResp) Read added in v3.1.0

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

func (*StopTaskResp) ReadField1 added in v3.1.0

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

func (*StopTaskResp) SetCode added in v3.1.0

func (s *StopTaskResp) SetCode(code nebula0.ErrorCode) *StopTaskResp

func (*StopTaskResp) String added in v3.1.0

func (p *StopTaskResp) String() string

func (*StopTaskResp) Write added in v3.1.0

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

type StopTaskRespBuilder added in v3.1.0

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

func NewStopTaskRespBuilder added in v3.1.0

func NewStopTaskRespBuilder() *StopTaskRespBuilder

func (*StopTaskRespBuilder) Code added in v3.1.0

func (StopTaskRespBuilder) Emit added in v3.1.0

type StorageAdminService

type StorageAdminService interface {
	// Parameters:
	//  - Req
	TransLeader(ctx context.Context, req *TransLeaderReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	AddPart(ctx context.Context, req *AddPartReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	AddLearner(ctx context.Context, req *AddLearnerReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	RemovePart(ctx context.Context, req *RemovePartReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	MemberChange(ctx context.Context, req *MemberChangeReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	WaitingForCatchUpData(ctx context.Context, req *CatchUpDataReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	CreateCheckpoint(ctx context.Context, req *CreateCPRequest) (_r *CreateCPResp, err error)
	// Parameters:
	//  - Req
	DropCheckpoint(ctx context.Context, req *DropCPRequest) (_r *DropCPResp, err error)
	// Parameters:
	//  - Req
	BlockingWrites(ctx context.Context, req *BlockingSignRequest) (_r *BlockingSignResp, err error)
	// Parameters:
	//  - Req
	GetLeaderParts(ctx context.Context, req *GetLeaderReq) (_r *GetLeaderPartsResp, err error)
	// Parameters:
	//  - Req
	CheckPeers(ctx context.Context, req *CheckPeersReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	AddAdminTask(ctx context.Context, req *AddTaskRequest) (_r *AddTaskResp, err error)
	// Parameters:
	//  - Req
	StopAdminTask(ctx context.Context, req *StopTaskRequest) (_r *StopTaskResp, err error)
	// Parameters:
	//  - Req
	ClearSpace(ctx context.Context, req *ClearSpaceReq) (_r *ClearSpaceResp, err error)
}

type StorageAdminServiceAddAdminTaskArgs

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

Attributes:

  • Req

func NewStorageAdminServiceAddAdminTaskArgs

func NewStorageAdminServiceAddAdminTaskArgs() *StorageAdminServiceAddAdminTaskArgs

func (*StorageAdminServiceAddAdminTaskArgs) GetReq

func (*StorageAdminServiceAddAdminTaskArgs) IsSetReq

func (*StorageAdminServiceAddAdminTaskArgs) Read

func (*StorageAdminServiceAddAdminTaskArgs) ReadField1

func (*StorageAdminServiceAddAdminTaskArgs) SetReq

func (*StorageAdminServiceAddAdminTaskArgs) String

func (*StorageAdminServiceAddAdminTaskArgs) Write

type StorageAdminServiceAddAdminTaskArgsBuilder

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

func NewStorageAdminServiceAddAdminTaskArgsBuilder

func NewStorageAdminServiceAddAdminTaskArgsBuilder() *StorageAdminServiceAddAdminTaskArgsBuilder

func (StorageAdminServiceAddAdminTaskArgsBuilder) Emit

func (*StorageAdminServiceAddAdminTaskArgsBuilder) Req

type StorageAdminServiceAddAdminTaskResult

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

Attributes:

  • Success

func NewStorageAdminServiceAddAdminTaskResult

func NewStorageAdminServiceAddAdminTaskResult() *StorageAdminServiceAddAdminTaskResult

func (*StorageAdminServiceAddAdminTaskResult) Exception

func (*StorageAdminServiceAddAdminTaskResult) GetSuccess

func (*StorageAdminServiceAddAdminTaskResult) IsSetSuccess

func (p *StorageAdminServiceAddAdminTaskResult) IsSetSuccess() bool

func (*StorageAdminServiceAddAdminTaskResult) Read

func (*StorageAdminServiceAddAdminTaskResult) ReadField0

func (*StorageAdminServiceAddAdminTaskResult) SetSuccess

func (*StorageAdminServiceAddAdminTaskResult) String

func (*StorageAdminServiceAddAdminTaskResult) Write

type StorageAdminServiceAddAdminTaskResultBuilder

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

func NewStorageAdminServiceAddAdminTaskResultBuilder

func NewStorageAdminServiceAddAdminTaskResultBuilder() *StorageAdminServiceAddAdminTaskResultBuilder

func (StorageAdminServiceAddAdminTaskResultBuilder) Emit

func (*StorageAdminServiceAddAdminTaskResultBuilder) Success

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 (*StorageAdminServiceAddLearnerArgs) IsSetReq

func (*StorageAdminServiceAddLearnerArgs) Read

func (*StorageAdminServiceAddLearnerArgs) ReadField1

func (*StorageAdminServiceAddLearnerArgs) SetReq

func (*StorageAdminServiceAddLearnerArgs) String

func (*StorageAdminServiceAddLearnerArgs) Write

type StorageAdminServiceAddLearnerArgsBuilder

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

func NewStorageAdminServiceAddLearnerArgsBuilder

func NewStorageAdminServiceAddLearnerArgsBuilder() *StorageAdminServiceAddLearnerArgsBuilder

func (StorageAdminServiceAddLearnerArgsBuilder) Emit

func (*StorageAdminServiceAddLearnerArgsBuilder) Req

type StorageAdminServiceAddLearnerResult

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

Attributes:

  • Success

func NewStorageAdminServiceAddLearnerResult

func NewStorageAdminServiceAddLearnerResult() *StorageAdminServiceAddLearnerResult

func (*StorageAdminServiceAddLearnerResult) Exception

func (*StorageAdminServiceAddLearnerResult) GetSuccess

func (*StorageAdminServiceAddLearnerResult) IsSetSuccess

func (p *StorageAdminServiceAddLearnerResult) IsSetSuccess() bool

func (*StorageAdminServiceAddLearnerResult) Read

func (*StorageAdminServiceAddLearnerResult) ReadField0

func (*StorageAdminServiceAddLearnerResult) SetSuccess

func (*StorageAdminServiceAddLearnerResult) String

func (*StorageAdminServiceAddLearnerResult) Write

type StorageAdminServiceAddLearnerResultBuilder

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

func NewStorageAdminServiceAddLearnerResultBuilder

func NewStorageAdminServiceAddLearnerResultBuilder() *StorageAdminServiceAddLearnerResultBuilder

func (StorageAdminServiceAddLearnerResultBuilder) Emit

func (*StorageAdminServiceAddLearnerResultBuilder) Success

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 (*StorageAdminServiceAddPartArgs) IsSetReq

func (p *StorageAdminServiceAddPartArgs) IsSetReq() bool

func (*StorageAdminServiceAddPartArgs) Read

func (*StorageAdminServiceAddPartArgs) ReadField1

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

func (*StorageAdminServiceAddPartArgs) SetReq

func (*StorageAdminServiceAddPartArgs) String

func (*StorageAdminServiceAddPartArgs) Write

type StorageAdminServiceAddPartArgsBuilder

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

func NewStorageAdminServiceAddPartArgsBuilder

func NewStorageAdminServiceAddPartArgsBuilder() *StorageAdminServiceAddPartArgsBuilder

func (StorageAdminServiceAddPartArgsBuilder) Emit

func (*StorageAdminServiceAddPartArgsBuilder) Req

type StorageAdminServiceAddPartResult

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

Attributes:

  • Success

func NewStorageAdminServiceAddPartResult

func NewStorageAdminServiceAddPartResult() *StorageAdminServiceAddPartResult

func (*StorageAdminServiceAddPartResult) Exception

func (*StorageAdminServiceAddPartResult) GetSuccess

func (*StorageAdminServiceAddPartResult) IsSetSuccess

func (p *StorageAdminServiceAddPartResult) IsSetSuccess() bool

func (*StorageAdminServiceAddPartResult) Read

func (*StorageAdminServiceAddPartResult) ReadField0

func (*StorageAdminServiceAddPartResult) SetSuccess

func (*StorageAdminServiceAddPartResult) String

func (*StorageAdminServiceAddPartResult) Write

type StorageAdminServiceAddPartResultBuilder

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

func NewStorageAdminServiceAddPartResultBuilder

func NewStorageAdminServiceAddPartResultBuilder() *StorageAdminServiceAddPartResultBuilder

func (StorageAdminServiceAddPartResultBuilder) Emit

func (*StorageAdminServiceAddPartResultBuilder) Success

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 (*StorageAdminServiceBlockingWritesArgs) IsSetReq

func (*StorageAdminServiceBlockingWritesArgs) Read

func (*StorageAdminServiceBlockingWritesArgs) ReadField1

func (*StorageAdminServiceBlockingWritesArgs) SetReq

func (*StorageAdminServiceBlockingWritesArgs) String

func (*StorageAdminServiceBlockingWritesArgs) Write

type StorageAdminServiceBlockingWritesArgsBuilder

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

func NewStorageAdminServiceBlockingWritesArgsBuilder

func NewStorageAdminServiceBlockingWritesArgsBuilder() *StorageAdminServiceBlockingWritesArgsBuilder

func (StorageAdminServiceBlockingWritesArgsBuilder) Emit

func (*StorageAdminServiceBlockingWritesArgsBuilder) Req

type StorageAdminServiceBlockingWritesResult

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

Attributes:

  • Success

func NewStorageAdminServiceBlockingWritesResult

func NewStorageAdminServiceBlockingWritesResult() *StorageAdminServiceBlockingWritesResult

func (*StorageAdminServiceBlockingWritesResult) Exception

func (*StorageAdminServiceBlockingWritesResult) GetSuccess

func (*StorageAdminServiceBlockingWritesResult) IsSetSuccess

func (*StorageAdminServiceBlockingWritesResult) Read

func (*StorageAdminServiceBlockingWritesResult) ReadField0

func (*StorageAdminServiceBlockingWritesResult) SetSuccess

func (*StorageAdminServiceBlockingWritesResult) String

func (*StorageAdminServiceBlockingWritesResult) Write

type StorageAdminServiceBlockingWritesResultBuilder

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

func NewStorageAdminServiceBlockingWritesResultBuilder

func NewStorageAdminServiceBlockingWritesResultBuilder() *StorageAdminServiceBlockingWritesResultBuilder

func (StorageAdminServiceBlockingWritesResultBuilder) Emit

func (*StorageAdminServiceBlockingWritesResultBuilder) Success

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 *AddTaskRequest) (_r *AddTaskResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) AddLearner

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) AddPart

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) BlockingWrites

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) CheckPeers

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) ClearSpace added in v3.1.0

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) Close

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 *DropCPResp, 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 (*StorageAdminServiceChannelClient) MemberChange

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) Open

func (*StorageAdminServiceChannelClient) RemovePart

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) StopAdminTask

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

Parameters:

  • Req

func (*StorageAdminServiceChannelClient) TransLeader

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 (*StorageAdminServiceCheckPeersArgs) IsSetReq

func (*StorageAdminServiceCheckPeersArgs) Read

func (*StorageAdminServiceCheckPeersArgs) ReadField1

func (*StorageAdminServiceCheckPeersArgs) SetReq

func (*StorageAdminServiceCheckPeersArgs) String

func (*StorageAdminServiceCheckPeersArgs) Write

type StorageAdminServiceCheckPeersArgsBuilder

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

func NewStorageAdminServiceCheckPeersArgsBuilder

func NewStorageAdminServiceCheckPeersArgsBuilder() *StorageAdminServiceCheckPeersArgsBuilder

func (StorageAdminServiceCheckPeersArgsBuilder) Emit

func (*StorageAdminServiceCheckPeersArgsBuilder) Req

type StorageAdminServiceCheckPeersResult

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

Attributes:

  • Success

func NewStorageAdminServiceCheckPeersResult

func NewStorageAdminServiceCheckPeersResult() *StorageAdminServiceCheckPeersResult

func (*StorageAdminServiceCheckPeersResult) Exception

func (*StorageAdminServiceCheckPeersResult) GetSuccess

func (*StorageAdminServiceCheckPeersResult) IsSetSuccess

func (p *StorageAdminServiceCheckPeersResult) IsSetSuccess() bool

func (*StorageAdminServiceCheckPeersResult) Read

func (*StorageAdminServiceCheckPeersResult) ReadField0

func (*StorageAdminServiceCheckPeersResult) SetSuccess

func (*StorageAdminServiceCheckPeersResult) String

func (*StorageAdminServiceCheckPeersResult) Write

type StorageAdminServiceCheckPeersResultBuilder

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

func NewStorageAdminServiceCheckPeersResultBuilder

func NewStorageAdminServiceCheckPeersResultBuilder() *StorageAdminServiceCheckPeersResultBuilder

func (StorageAdminServiceCheckPeersResultBuilder) Emit

func (*StorageAdminServiceCheckPeersResultBuilder) Success

type StorageAdminServiceClearSpaceArgs added in v3.1.0

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

Attributes:

  • Req

func NewStorageAdminServiceClearSpaceArgs added in v3.1.0

func NewStorageAdminServiceClearSpaceArgs() *StorageAdminServiceClearSpaceArgs

func (*StorageAdminServiceClearSpaceArgs) GetReq added in v3.1.0

func (*StorageAdminServiceClearSpaceArgs) IsSetReq added in v3.1.0

func (*StorageAdminServiceClearSpaceArgs) Read added in v3.1.0

func (*StorageAdminServiceClearSpaceArgs) ReadField1 added in v3.1.0

func (*StorageAdminServiceClearSpaceArgs) SetReq added in v3.1.0

func (*StorageAdminServiceClearSpaceArgs) String added in v3.1.0

func (*StorageAdminServiceClearSpaceArgs) Write added in v3.1.0

type StorageAdminServiceClearSpaceArgsBuilder added in v3.1.0

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

func NewStorageAdminServiceClearSpaceArgsBuilder added in v3.1.0

func NewStorageAdminServiceClearSpaceArgsBuilder() *StorageAdminServiceClearSpaceArgsBuilder

func (StorageAdminServiceClearSpaceArgsBuilder) Emit added in v3.1.0

func (*StorageAdminServiceClearSpaceArgsBuilder) Req added in v3.1.0

type StorageAdminServiceClearSpaceResult added in v3.1.0

type StorageAdminServiceClearSpaceResult struct {
	thrift.IResponse
	Success *ClearSpaceResp `thrift:"success,0,optional" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceClearSpaceResult added in v3.1.0

func NewStorageAdminServiceClearSpaceResult() *StorageAdminServiceClearSpaceResult

func (*StorageAdminServiceClearSpaceResult) Exception added in v3.1.0

func (*StorageAdminServiceClearSpaceResult) GetSuccess added in v3.1.0

func (*StorageAdminServiceClearSpaceResult) IsSetSuccess added in v3.1.0

func (p *StorageAdminServiceClearSpaceResult) IsSetSuccess() bool

func (*StorageAdminServiceClearSpaceResult) Read added in v3.1.0

func (*StorageAdminServiceClearSpaceResult) ReadField0 added in v3.1.0

func (*StorageAdminServiceClearSpaceResult) SetSuccess added in v3.1.0

func (*StorageAdminServiceClearSpaceResult) String added in v3.1.0

func (*StorageAdminServiceClearSpaceResult) Write added in v3.1.0

type StorageAdminServiceClearSpaceResultBuilder added in v3.1.0

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

func NewStorageAdminServiceClearSpaceResultBuilder added in v3.1.0

func NewStorageAdminServiceClearSpaceResultBuilder() *StorageAdminServiceClearSpaceResultBuilder

func (StorageAdminServiceClearSpaceResultBuilder) Emit added in v3.1.0

func (*StorageAdminServiceClearSpaceResultBuilder) Success added in v3.1.0

type StorageAdminServiceClient

type StorageAdminServiceClient struct {
	StorageAdminServiceClientInterface
	CC thrift.ClientConn
}

func NewStorageAdminServiceClient

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

func NewStorageAdminServiceClientProtocol

func NewStorageAdminServiceClientProtocol(prot thrift.Protocol) *StorageAdminServiceClient

func (*StorageAdminServiceClient) AddAdminTask

func (p *StorageAdminServiceClient) AddAdminTask(req *AddTaskRequest) (_r *AddTaskResp, 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 *BlockingSignResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceClient) CheckPeers

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

Parameters:

  • Req

func (*StorageAdminServiceClient) ClearSpace added in v3.1.0

func (p *StorageAdminServiceClient) ClearSpace(req *ClearSpaceReq) (_r *ClearSpaceResp, 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 *DropCPResp, 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) MemberChange

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

Parameters:

  • Req

func (*StorageAdminServiceClient) Open

func (client *StorageAdminServiceClient) Open() error

func (*StorageAdminServiceClient) RemovePart

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

Parameters:

  • Req

func (*StorageAdminServiceClient) StopAdminTask

func (p *StorageAdminServiceClient) StopAdminTask(req *StopTaskRequest) (_r *StopTaskResp, 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 *DropCPResp, err error)
	// Parameters:
	//  - Req
	BlockingWrites(req *BlockingSignRequest) (_r *BlockingSignResp, err error)
	// Parameters:
	//  - Req
	GetLeaderParts(req *GetLeaderReq) (_r *GetLeaderPartsResp, err error)
	// Parameters:
	//  - Req
	CheckPeers(req *CheckPeersReq) (_r *AdminExecResp, err error)
	// Parameters:
	//  - Req
	AddAdminTask(req *AddTaskRequest) (_r *AddTaskResp, err error)
	// Parameters:
	//  - Req
	StopAdminTask(req *StopTaskRequest) (_r *StopTaskResp, err error)
	// Parameters:
	//  - Req
	ClearSpace(req *ClearSpaceReq) (_r *ClearSpaceResp, 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 (*StorageAdminServiceCreateCheckpointArgs) IsSetReq

func (*StorageAdminServiceCreateCheckpointArgs) Read

func (*StorageAdminServiceCreateCheckpointArgs) ReadField1

func (*StorageAdminServiceCreateCheckpointArgs) SetReq

func (*StorageAdminServiceCreateCheckpointArgs) String

func (*StorageAdminServiceCreateCheckpointArgs) Write

type StorageAdminServiceCreateCheckpointArgsBuilder

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

func NewStorageAdminServiceCreateCheckpointArgsBuilder

func NewStorageAdminServiceCreateCheckpointArgsBuilder() *StorageAdminServiceCreateCheckpointArgsBuilder

func (StorageAdminServiceCreateCheckpointArgsBuilder) Emit

func (*StorageAdminServiceCreateCheckpointArgsBuilder) Req

type StorageAdminServiceCreateCheckpointResult

type StorageAdminServiceCreateCheckpointResult struct {
	thrift.IResponse
	Success *CreateCPResp `thrift:"success,0,optional" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceCreateCheckpointResult

func NewStorageAdminServiceCreateCheckpointResult() *StorageAdminServiceCreateCheckpointResult

func (*StorageAdminServiceCreateCheckpointResult) Exception

func (*StorageAdminServiceCreateCheckpointResult) GetSuccess

func (*StorageAdminServiceCreateCheckpointResult) IsSetSuccess

func (*StorageAdminServiceCreateCheckpointResult) Read

func (*StorageAdminServiceCreateCheckpointResult) ReadField0

func (*StorageAdminServiceCreateCheckpointResult) SetSuccess

func (*StorageAdminServiceCreateCheckpointResult) String

func (*StorageAdminServiceCreateCheckpointResult) Write

type StorageAdminServiceCreateCheckpointResultBuilder

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

func NewStorageAdminServiceCreateCheckpointResultBuilder

func NewStorageAdminServiceCreateCheckpointResultBuilder() *StorageAdminServiceCreateCheckpointResultBuilder

func (StorageAdminServiceCreateCheckpointResultBuilder) Emit

func (*StorageAdminServiceCreateCheckpointResultBuilder) Success

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 (*StorageAdminServiceDropCheckpointArgs) IsSetReq

func (*StorageAdminServiceDropCheckpointArgs) Read

func (*StorageAdminServiceDropCheckpointArgs) ReadField1

func (*StorageAdminServiceDropCheckpointArgs) SetReq

func (*StorageAdminServiceDropCheckpointArgs) String

func (*StorageAdminServiceDropCheckpointArgs) Write

type StorageAdminServiceDropCheckpointArgsBuilder

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

func NewStorageAdminServiceDropCheckpointArgsBuilder

func NewStorageAdminServiceDropCheckpointArgsBuilder() *StorageAdminServiceDropCheckpointArgsBuilder

func (StorageAdminServiceDropCheckpointArgsBuilder) Emit

func (*StorageAdminServiceDropCheckpointArgsBuilder) Req

type StorageAdminServiceDropCheckpointResult

type StorageAdminServiceDropCheckpointResult struct {
	thrift.IResponse
	Success *DropCPResp `thrift:"success,0,optional" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceDropCheckpointResult

func NewStorageAdminServiceDropCheckpointResult() *StorageAdminServiceDropCheckpointResult

func (*StorageAdminServiceDropCheckpointResult) Exception

func (*StorageAdminServiceDropCheckpointResult) GetSuccess

func (*StorageAdminServiceDropCheckpointResult) IsSetSuccess

func (*StorageAdminServiceDropCheckpointResult) Read

func (*StorageAdminServiceDropCheckpointResult) ReadField0

func (*StorageAdminServiceDropCheckpointResult) SetSuccess

func (*StorageAdminServiceDropCheckpointResult) String

func (*StorageAdminServiceDropCheckpointResult) Write

type StorageAdminServiceDropCheckpointResultBuilder

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

func NewStorageAdminServiceDropCheckpointResultBuilder

func NewStorageAdminServiceDropCheckpointResultBuilder() *StorageAdminServiceDropCheckpointResultBuilder

func (StorageAdminServiceDropCheckpointResultBuilder) Emit

func (*StorageAdminServiceDropCheckpointResultBuilder) Success

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 (*StorageAdminServiceGetLeaderPartsArgs) IsSetReq

func (*StorageAdminServiceGetLeaderPartsArgs) Read

func (*StorageAdminServiceGetLeaderPartsArgs) ReadField1

func (*StorageAdminServiceGetLeaderPartsArgs) SetReq

func (*StorageAdminServiceGetLeaderPartsArgs) String

func (*StorageAdminServiceGetLeaderPartsArgs) Write

type StorageAdminServiceGetLeaderPartsArgsBuilder

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

func NewStorageAdminServiceGetLeaderPartsArgsBuilder

func NewStorageAdminServiceGetLeaderPartsArgsBuilder() *StorageAdminServiceGetLeaderPartsArgsBuilder

func (StorageAdminServiceGetLeaderPartsArgsBuilder) Emit

func (*StorageAdminServiceGetLeaderPartsArgsBuilder) Req

type StorageAdminServiceGetLeaderPartsResult

type StorageAdminServiceGetLeaderPartsResult struct {
	thrift.IResponse
	Success *GetLeaderPartsResp `thrift:"success,0,optional" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceGetLeaderPartsResult

func NewStorageAdminServiceGetLeaderPartsResult() *StorageAdminServiceGetLeaderPartsResult

func (*StorageAdminServiceGetLeaderPartsResult) Exception

func (*StorageAdminServiceGetLeaderPartsResult) GetSuccess

func (*StorageAdminServiceGetLeaderPartsResult) IsSetSuccess

func (*StorageAdminServiceGetLeaderPartsResult) Read

func (*StorageAdminServiceGetLeaderPartsResult) ReadField0

func (*StorageAdminServiceGetLeaderPartsResult) SetSuccess

func (*StorageAdminServiceGetLeaderPartsResult) String

func (*StorageAdminServiceGetLeaderPartsResult) Write

type StorageAdminServiceGetLeaderPartsResultBuilder

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

func NewStorageAdminServiceGetLeaderPartsResultBuilder

func NewStorageAdminServiceGetLeaderPartsResultBuilder() *StorageAdminServiceGetLeaderPartsResultBuilder

func (StorageAdminServiceGetLeaderPartsResultBuilder) Emit

func (*StorageAdminServiceGetLeaderPartsResultBuilder) Success

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 (*StorageAdminServiceMemberChangeArgs) IsSetReq

func (*StorageAdminServiceMemberChangeArgs) Read

func (*StorageAdminServiceMemberChangeArgs) ReadField1

func (*StorageAdminServiceMemberChangeArgs) SetReq

func (*StorageAdminServiceMemberChangeArgs) String

func (*StorageAdminServiceMemberChangeArgs) Write

type StorageAdminServiceMemberChangeArgsBuilder

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

func NewStorageAdminServiceMemberChangeArgsBuilder

func NewStorageAdminServiceMemberChangeArgsBuilder() *StorageAdminServiceMemberChangeArgsBuilder

func (StorageAdminServiceMemberChangeArgsBuilder) Emit

func (*StorageAdminServiceMemberChangeArgsBuilder) Req

type StorageAdminServiceMemberChangeResult

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

Attributes:

  • Success

func NewStorageAdminServiceMemberChangeResult

func NewStorageAdminServiceMemberChangeResult() *StorageAdminServiceMemberChangeResult

func (*StorageAdminServiceMemberChangeResult) Exception

func (*StorageAdminServiceMemberChangeResult) GetSuccess

func (*StorageAdminServiceMemberChangeResult) IsSetSuccess

func (p *StorageAdminServiceMemberChangeResult) IsSetSuccess() bool

func (*StorageAdminServiceMemberChangeResult) Read

func (*StorageAdminServiceMemberChangeResult) ReadField0

func (*StorageAdminServiceMemberChangeResult) SetSuccess

func (*StorageAdminServiceMemberChangeResult) String

func (*StorageAdminServiceMemberChangeResult) Write

type StorageAdminServiceMemberChangeResultBuilder

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

func NewStorageAdminServiceMemberChangeResultBuilder

func NewStorageAdminServiceMemberChangeResultBuilder() *StorageAdminServiceMemberChangeResultBuilder

func (StorageAdminServiceMemberChangeResultBuilder) Emit

func (*StorageAdminServiceMemberChangeResultBuilder) Success

type StorageAdminServiceProcessor

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

func NewStorageAdminServiceProcessor

func NewStorageAdminServiceProcessor(handler StorageAdminService) *StorageAdminServiceProcessor

func (*StorageAdminServiceProcessor) AddToFunctionServiceMap

func (p *StorageAdminServiceProcessor) AddToFunctionServiceMap(key, service string)

func (*StorageAdminServiceProcessor) AddToProcessorMap

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

func (*StorageAdminServiceProcessor) FunctionServiceMap

func (p *StorageAdminServiceProcessor) FunctionServiceMap() map[string]string

func (*StorageAdminServiceProcessor) GetProcessorFunctionContext

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

func (*StorageAdminServiceProcessor) ProcessorMap

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 (*StorageAdminServiceRemovePartArgs) IsSetReq

func (*StorageAdminServiceRemovePartArgs) Read

func (*StorageAdminServiceRemovePartArgs) ReadField1

func (*StorageAdminServiceRemovePartArgs) SetReq

func (*StorageAdminServiceRemovePartArgs) String

func (*StorageAdminServiceRemovePartArgs) Write

type StorageAdminServiceRemovePartArgsBuilder

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

func NewStorageAdminServiceRemovePartArgsBuilder

func NewStorageAdminServiceRemovePartArgsBuilder() *StorageAdminServiceRemovePartArgsBuilder

func (StorageAdminServiceRemovePartArgsBuilder) Emit

func (*StorageAdminServiceRemovePartArgsBuilder) Req

type StorageAdminServiceRemovePartResult

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

Attributes:

  • Success

func NewStorageAdminServiceRemovePartResult

func NewStorageAdminServiceRemovePartResult() *StorageAdminServiceRemovePartResult

func (*StorageAdminServiceRemovePartResult) Exception

func (*StorageAdminServiceRemovePartResult) GetSuccess

func (*StorageAdminServiceRemovePartResult) IsSetSuccess

func (p *StorageAdminServiceRemovePartResult) IsSetSuccess() bool

func (*StorageAdminServiceRemovePartResult) Read

func (*StorageAdminServiceRemovePartResult) ReadField0

func (*StorageAdminServiceRemovePartResult) SetSuccess

func (*StorageAdminServiceRemovePartResult) String

func (*StorageAdminServiceRemovePartResult) Write

type StorageAdminServiceRemovePartResultBuilder

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

func NewStorageAdminServiceRemovePartResultBuilder

func NewStorageAdminServiceRemovePartResultBuilder() *StorageAdminServiceRemovePartResultBuilder

func (StorageAdminServiceRemovePartResultBuilder) Emit

func (*StorageAdminServiceRemovePartResultBuilder) Success

type StorageAdminServiceStopAdminTaskArgs

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

Attributes:

  • Req

func NewStorageAdminServiceStopAdminTaskArgs

func NewStorageAdminServiceStopAdminTaskArgs() *StorageAdminServiceStopAdminTaskArgs

func (*StorageAdminServiceStopAdminTaskArgs) GetReq

func (*StorageAdminServiceStopAdminTaskArgs) IsSetReq

func (*StorageAdminServiceStopAdminTaskArgs) Read

func (*StorageAdminServiceStopAdminTaskArgs) ReadField1

func (*StorageAdminServiceStopAdminTaskArgs) SetReq

func (*StorageAdminServiceStopAdminTaskArgs) String

func (*StorageAdminServiceStopAdminTaskArgs) Write

type StorageAdminServiceStopAdminTaskArgsBuilder

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

func NewStorageAdminServiceStopAdminTaskArgsBuilder

func NewStorageAdminServiceStopAdminTaskArgsBuilder() *StorageAdminServiceStopAdminTaskArgsBuilder

func (StorageAdminServiceStopAdminTaskArgsBuilder) Emit

func (*StorageAdminServiceStopAdminTaskArgsBuilder) Req

type StorageAdminServiceStopAdminTaskResult

type StorageAdminServiceStopAdminTaskResult struct {
	thrift.IResponse
	Success *StopTaskResp `thrift:"success,0,optional" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewStorageAdminServiceStopAdminTaskResult

func NewStorageAdminServiceStopAdminTaskResult() *StorageAdminServiceStopAdminTaskResult

func (*StorageAdminServiceStopAdminTaskResult) Exception

func (*StorageAdminServiceStopAdminTaskResult) GetSuccess

func (*StorageAdminServiceStopAdminTaskResult) IsSetSuccess

func (p *StorageAdminServiceStopAdminTaskResult) IsSetSuccess() bool

func (*StorageAdminServiceStopAdminTaskResult) Read

func (*StorageAdminServiceStopAdminTaskResult) ReadField0

func (*StorageAdminServiceStopAdminTaskResult) SetSuccess

func (*StorageAdminServiceStopAdminTaskResult) String

func (*StorageAdminServiceStopAdminTaskResult) Write

type StorageAdminServiceStopAdminTaskResultBuilder

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

func NewStorageAdminServiceStopAdminTaskResultBuilder

func NewStorageAdminServiceStopAdminTaskResultBuilder() *StorageAdminServiceStopAdminTaskResultBuilder

func (StorageAdminServiceStopAdminTaskResultBuilder) Emit

func (*StorageAdminServiceStopAdminTaskResultBuilder) Success

type StorageAdminServiceThreadsafeClient

type StorageAdminServiceThreadsafeClient struct {
	StorageAdminServiceClientInterface
	CC thrift.ClientConn
	Mu sync.Mutex
}

func NewStorageAdminServiceThreadsafeClientProtocol

func NewStorageAdminServiceThreadsafeClientProtocol(prot thrift.Protocol) *StorageAdminServiceThreadsafeClient

func (*StorageAdminServiceThreadsafeClient) AddAdminTask

func (p *StorageAdminServiceThreadsafeClient) AddAdminTask(req *AddTaskRequest) (_r *AddTaskResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) AddLearner

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) AddPart

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) BlockingWrites

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) CheckPeers

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) ClearSpace added in v3.1.0

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) Close

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 *DropCPResp, 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) MemberChange

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) Open

func (*StorageAdminServiceThreadsafeClient) RemovePart

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) StopAdminTask

func (p *StorageAdminServiceThreadsafeClient) StopAdminTask(req *StopTaskRequest) (_r *StopTaskResp, err error)

Parameters:

  • Req

func (*StorageAdminServiceThreadsafeClient) TransLeader

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 (*StorageAdminServiceTransLeaderArgs) IsSetReq

func (*StorageAdminServiceTransLeaderArgs) Read

func (*StorageAdminServiceTransLeaderArgs) ReadField1

func (*StorageAdminServiceTransLeaderArgs) SetReq

func (*StorageAdminServiceTransLeaderArgs) String

func (*StorageAdminServiceTransLeaderArgs) Write

type StorageAdminServiceTransLeaderArgsBuilder

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

func NewStorageAdminServiceTransLeaderArgsBuilder

func NewStorageAdminServiceTransLeaderArgsBuilder() *StorageAdminServiceTransLeaderArgsBuilder

func (StorageAdminServiceTransLeaderArgsBuilder) Emit

func (*StorageAdminServiceTransLeaderArgsBuilder) Req

type StorageAdminServiceTransLeaderResult

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

Attributes:

  • Success

func NewStorageAdminServiceTransLeaderResult

func NewStorageAdminServiceTransLeaderResult() *StorageAdminServiceTransLeaderResult

func (*StorageAdminServiceTransLeaderResult) Exception

func (*StorageAdminServiceTransLeaderResult) GetSuccess

func (*StorageAdminServiceTransLeaderResult) IsSetSuccess

func (p *StorageAdminServiceTransLeaderResult) IsSetSuccess() bool

func (*StorageAdminServiceTransLeaderResult) Read

func (*StorageAdminServiceTransLeaderResult) ReadField0

func (*StorageAdminServiceTransLeaderResult) SetSuccess

func (*StorageAdminServiceTransLeaderResult) String

func (*StorageAdminServiceTransLeaderResult) Write

type StorageAdminServiceTransLeaderResultBuilder

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

func NewStorageAdminServiceTransLeaderResultBuilder

func NewStorageAdminServiceTransLeaderResultBuilder() *StorageAdminServiceTransLeaderResultBuilder

func (StorageAdminServiceTransLeaderResultBuilder) Emit

func (*StorageAdminServiceTransLeaderResultBuilder) Success

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 (*StorageAdminServiceWaitingForCatchUpDataArgs) IsSetReq

func (*StorageAdminServiceWaitingForCatchUpDataArgs) Read

func (*StorageAdminServiceWaitingForCatchUpDataArgs) ReadField1

func (*StorageAdminServiceWaitingForCatchUpDataArgs) SetReq

func (*StorageAdminServiceWaitingForCatchUpDataArgs) String

func (*StorageAdminServiceWaitingForCatchUpDataArgs) Write

type StorageAdminServiceWaitingForCatchUpDataArgsBuilder

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

func NewStorageAdminServiceWaitingForCatchUpDataArgsBuilder

func NewStorageAdminServiceWaitingForCatchUpDataArgsBuilder() *StorageAdminServiceWaitingForCatchUpDataArgsBuilder

func (StorageAdminServiceWaitingForCatchUpDataArgsBuilder) Emit

func (*StorageAdminServiceWaitingForCatchUpDataArgsBuilder) Req

type StorageAdminServiceWaitingForCatchUpDataResult

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

Attributes:

  • Success

func NewStorageAdminServiceWaitingForCatchUpDataResult

func NewStorageAdminServiceWaitingForCatchUpDataResult() *StorageAdminServiceWaitingForCatchUpDataResult

func (*StorageAdminServiceWaitingForCatchUpDataResult) Exception

func (*StorageAdminServiceWaitingForCatchUpDataResult) GetSuccess

func (*StorageAdminServiceWaitingForCatchUpDataResult) IsSetSuccess

func (*StorageAdminServiceWaitingForCatchUpDataResult) Read

func (*StorageAdminServiceWaitingForCatchUpDataResult) ReadField0

func (*StorageAdminServiceWaitingForCatchUpDataResult) SetSuccess

func (*StorageAdminServiceWaitingForCatchUpDataResult) String

func (*StorageAdminServiceWaitingForCatchUpDataResult) Write

type StorageAdminServiceWaitingForCatchUpDataResultBuilder

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

func NewStorageAdminServiceWaitingForCatchUpDataResultBuilder

func NewStorageAdminServiceWaitingForCatchUpDataResultBuilder() *StorageAdminServiceWaitingForCatchUpDataResultBuilder

func (StorageAdminServiceWaitingForCatchUpDataResultBuilder) Emit

func (*StorageAdminServiceWaitingForCatchUpDataResultBuilder) Success

type TaskPara

type TaskPara struct {
	SpaceID           nebula0.GraphSpaceID  `thrift:"space_id,1" db:"space_id" json:"space_id"`
	Parts             []nebula0.PartitionID `thrift:"parts,2,optional" db:"parts" json:"parts,omitempty"`
	TaskSpecificParas [][]byte              `thrift:"task_specific_paras,3,optional" db:"task_specific_paras" json:"task_specific_paras,omitempty"`
}

Attributes:

  • SpaceID
  • Parts
  • TaskSpecificParas
var AddTaskRequest_Para_DEFAULT *TaskPara

func NewTaskPara

func NewTaskPara() *TaskPara

func (*TaskPara) GetParts

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

func (*TaskPara) GetSpaceID

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

func (*TaskPara) GetTaskSpecificParas

func (p *TaskPara) GetTaskSpecificParas() [][]byte

func (*TaskPara) IsSetParts

func (p *TaskPara) IsSetParts() bool

func (*TaskPara) IsSetTaskSpecificParas

func (p *TaskPara) IsSetTaskSpecificParas() bool

func (*TaskPara) 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) SetParts

func (t *TaskPara) SetParts(parts []nebula0.PartitionID) *TaskPara

func (*TaskPara) SetSpaceID

func (t *TaskPara) SetSpaceID(spaceID nebula0.GraphSpaceID) *TaskPara

func (*TaskPara) SetTaskSpecificParas

func (t *TaskPara) SetTaskSpecificParas(taskSpecificParas [][]byte) *TaskPara

func (*TaskPara) String

func (p *TaskPara) String() string

func (*TaskPara) Write

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

type TaskParaBuilder

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

func NewTaskParaBuilder

func NewTaskParaBuilder() *TaskParaBuilder

func (TaskParaBuilder) Emit

func (p TaskParaBuilder) Emit() *TaskPara

func (*TaskParaBuilder) Parts

func (*TaskParaBuilder) SpaceID

func (t *TaskParaBuilder) SpaceID(spaceID nebula0.GraphSpaceID) *TaskParaBuilder

func (*TaskParaBuilder) TaskSpecificParas

func (t *TaskParaBuilder) TaskSpecificParas(taskSpecificParas [][]byte) *TaskParaBuilder

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

func (t *TransLeaderReq) SetNewLeader_(newLeader *nebula0.HostAddr) *TransLeaderReq

func (*TransLeaderReq) SetPartID

func (t *TransLeaderReq) SetPartID(partID nebula0.PartitionID) *TransLeaderReq

func (*TransLeaderReq) SetSpaceID

func (t *TransLeaderReq) SetSpaceID(spaceID nebula0.GraphSpaceID) *TransLeaderReq

func (*TransLeaderReq) String

func (p *TransLeaderReq) String() string

func (*TransLeaderReq) Write

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

type TransLeaderReqBuilder

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

func NewTransLeaderReqBuilder

func NewTransLeaderReqBuilder() *TransLeaderReqBuilder

func (TransLeaderReqBuilder) Emit

func (*TransLeaderReqBuilder) NewLeader_

func (t *TransLeaderReqBuilder) NewLeader_(newLeader *nebula0.HostAddr) *TransLeaderReqBuilder

func (*TransLeaderReqBuilder) PartID

func (*TransLeaderReqBuilder) SpaceID

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,optional" db:"stat_props" json:"stat_props,omitempty"`
	VertexProps   []*VertexProp      `thrift:"vertex_props,5,optional" db:"vertex_props" json:"vertex_props,omitempty"`
	EdgeProps     []*EdgeProp        `thrift:"edge_props,6,optional" db:"edge_props" json:"edge_props,omitempty"`
	Expressions   []*Expr            `thrift:"expressions,7,optional" db:"expressions" json:"expressions,omitempty"`
	OrderBy       []*OrderBy         `thrift:"order_by,8,optional" db:"order_by" json:"order_by,omitempty"`
	Random        *bool              `thrift:"random,9,optional" db:"random" json:"random,omitempty"`
	Limit         *int64             `thrift:"limit,10,optional" db:"limit" json:"limit,omitempty"`
	Filter        []byte             `thrift:"filter,11,optional" db:"filter" json:"filter,omitempty"`
	TagFilter     []byte             `thrift:"tag_filter,12,optional" db:"tag_filter" json:"tag_filter,omitempty"`
}

Attributes:

  • EdgeTypes
  • EdgeDirection
  • Dedup
  • StatProps
  • VertexProps
  • EdgeProps
  • Expressions
  • OrderBy
  • Random
  • Limit
  • Filter
  • TagFilter
var GetNeighborsRequest_TraverseSpec_DEFAULT *TraverseSpec
var LookupAndTraverseRequest_TraverseSpec_DEFAULT *TraverseSpec

func NewTraverseSpec

func NewTraverseSpec() *TraverseSpec

func (*TraverseSpec) 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) GetTagFilter added in v3.3.1

func (p *TraverseSpec) GetTagFilter() []byte

func (*TraverseSpec) GetVertexProps

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

func (*TraverseSpec) IsSetEdgeProps

func (p *TraverseSpec) IsSetEdgeProps() bool

func (*TraverseSpec) IsSetExpressions

func (p *TraverseSpec) IsSetExpressions() bool

func (*TraverseSpec) IsSetFilter

func (p *TraverseSpec) IsSetFilter() bool

func (*TraverseSpec) IsSetLimit

func (p *TraverseSpec) IsSetLimit() bool

func (*TraverseSpec) IsSetOrderBy

func (p *TraverseSpec) IsSetOrderBy() bool

func (*TraverseSpec) IsSetRandom

func (p *TraverseSpec) IsSetRandom() bool

func (*TraverseSpec) IsSetStatProps

func (p *TraverseSpec) IsSetStatProps() bool

func (*TraverseSpec) IsSetTagFilter added in v3.3.1

func (p *TraverseSpec) IsSetTagFilter() 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) ReadField12 added in v3.3.1

func (p *TraverseSpec) ReadField12(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) SetDedup

func (t *TraverseSpec) SetDedup(dedup bool) *TraverseSpec

func (*TraverseSpec) SetEdgeDirection

func (t *TraverseSpec) SetEdgeDirection(edgeDirection EdgeDirection) *TraverseSpec

func (*TraverseSpec) SetEdgeProps

func (t *TraverseSpec) SetEdgeProps(edgeProps []*EdgeProp) *TraverseSpec

func (*TraverseSpec) SetEdgeTypes

func (t *TraverseSpec) SetEdgeTypes(edgeTypes []nebula0.EdgeType) *TraverseSpec

func (*TraverseSpec) SetExpressions

func (t *TraverseSpec) SetExpressions(expressions []*Expr) *TraverseSpec

func (*TraverseSpec) SetFilter

func (t *TraverseSpec) SetFilter(filter []byte) *TraverseSpec

func (*TraverseSpec) SetLimit

func (t *TraverseSpec) SetLimit(limit *int64) *TraverseSpec

func (*TraverseSpec) SetOrderBy

func (t *TraverseSpec) SetOrderBy(orderBy []*OrderBy) *TraverseSpec

func (*TraverseSpec) SetRandom

func (t *TraverseSpec) SetRandom(random *bool) *TraverseSpec

func (*TraverseSpec) SetStatProps

func (t *TraverseSpec) SetStatProps(statProps []*StatProp) *TraverseSpec

func (*TraverseSpec) SetTagFilter added in v3.3.1

func (t *TraverseSpec) SetTagFilter(tagFilter []byte) *TraverseSpec

func (*TraverseSpec) SetVertexProps

func (t *TraverseSpec) SetVertexProps(vertexProps []*VertexProp) *TraverseSpec

func (*TraverseSpec) String

func (p *TraverseSpec) String() string

func (*TraverseSpec) Write

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

type TraverseSpecBuilder

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

func NewTraverseSpecBuilder

func NewTraverseSpecBuilder() *TraverseSpecBuilder

func (*TraverseSpecBuilder) Dedup

func (t *TraverseSpecBuilder) Dedup(dedup bool) *TraverseSpecBuilder

func (*TraverseSpecBuilder) EdgeDirection

func (t *TraverseSpecBuilder) EdgeDirection(edgeDirection EdgeDirection) *TraverseSpecBuilder

func (*TraverseSpecBuilder) EdgeProps

func (t *TraverseSpecBuilder) EdgeProps(edgeProps []*EdgeProp) *TraverseSpecBuilder

func (*TraverseSpecBuilder) EdgeTypes

func (t *TraverseSpecBuilder) EdgeTypes(edgeTypes []nebula0.EdgeType) *TraverseSpecBuilder

func (TraverseSpecBuilder) Emit

func (*TraverseSpecBuilder) Expressions

func (t *TraverseSpecBuilder) Expressions(expressions []*Expr) *TraverseSpecBuilder

func (*TraverseSpecBuilder) Filter

func (t *TraverseSpecBuilder) Filter(filter []byte) *TraverseSpecBuilder

func (*TraverseSpecBuilder) Limit

func (t *TraverseSpecBuilder) Limit(limit *int64) *TraverseSpecBuilder

func (*TraverseSpecBuilder) OrderBy

func (t *TraverseSpecBuilder) OrderBy(orderBy []*OrderBy) *TraverseSpecBuilder

func (*TraverseSpecBuilder) Random

func (t *TraverseSpecBuilder) Random(random *bool) *TraverseSpecBuilder

func (*TraverseSpecBuilder) StatProps

func (t *TraverseSpecBuilder) StatProps(statProps []*StatProp) *TraverseSpecBuilder

func (*TraverseSpecBuilder) TagFilter added in v3.3.1

func (t *TraverseSpecBuilder) TagFilter(tagFilter []byte) *TraverseSpecBuilder

func (*TraverseSpecBuilder) VertexProps

func (t *TraverseSpecBuilder) VertexProps(vertexProps []*VertexProp) *TraverseSpecBuilder

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,optional" db:"insertable" json:"insertable,omitempty"`
	ReturnProps  [][]byte             `thrift:"return_props,6,optional" db:"return_props" json:"return_props,omitempty"`
	Condition    []byte               `thrift:"condition,7,optional" db:"condition" json:"condition,omitempty"`
	Common       *RequestCommon       `thrift:"common,8,optional" db:"common" json:"common,omitempty"`
}

Attributes:

  • SpaceID
  • PartID
  • EdgeKey
  • UpdatedProps
  • Insertable
  • ReturnProps
  • Condition
  • Common
var ChainUpdateEdgeRequest_UpdateEdgeRequest_DEFAULT *UpdateEdgeRequest
var GraphStorageServiceChainUpdateEdgeArgs_Req_DEFAULT *UpdateEdgeRequest
var GraphStorageServiceUpdateEdgeArgs_Req_DEFAULT *UpdateEdgeRequest

func NewUpdateEdgeRequest

func NewUpdateEdgeRequest() *UpdateEdgeRequest

func (*UpdateEdgeRequest) GetCommon

func (p *UpdateEdgeRequest) GetCommon() *RequestCommon

func (*UpdateEdgeRequest) GetCondition

func (p *UpdateEdgeRequest) GetCondition() []byte

func (*UpdateEdgeRequest) GetEdgeKey

func (p *UpdateEdgeRequest) GetEdgeKey() *EdgeKey

func (*UpdateEdgeRequest) GetInsertable

func (p *UpdateEdgeRequest) GetInsertable() bool

func (*UpdateEdgeRequest) GetPartID

func (p *UpdateEdgeRequest) GetPartID() 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

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

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

func (*UpdateEdgeRequest) SetCommon

func (u *UpdateEdgeRequest) SetCommon(common *RequestCommon) *UpdateEdgeRequest

func (*UpdateEdgeRequest) SetCondition

func (u *UpdateEdgeRequest) SetCondition(condition []byte) *UpdateEdgeRequest

func (*UpdateEdgeRequest) SetEdgeKey

func (u *UpdateEdgeRequest) SetEdgeKey(edgeKey *EdgeKey) *UpdateEdgeRequest

func (*UpdateEdgeRequest) SetInsertable

func (u *UpdateEdgeRequest) SetInsertable(insertable bool) *UpdateEdgeRequest

func (*UpdateEdgeRequest) SetPartID

func (*UpdateEdgeRequest) SetReturnProps

func (u *UpdateEdgeRequest) SetReturnProps(returnProps [][]byte) *UpdateEdgeRequest

func (*UpdateEdgeRequest) SetSpaceID

func (u *UpdateEdgeRequest) SetSpaceID(spaceID nebula0.GraphSpaceID) *UpdateEdgeRequest

func (*UpdateEdgeRequest) SetUpdatedProps

func (u *UpdateEdgeRequest) SetUpdatedProps(updatedProps []*UpdatedProp) *UpdateEdgeRequest

func (*UpdateEdgeRequest) String

func (p *UpdateEdgeRequest) String() string

func (*UpdateEdgeRequest) Write

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

type UpdateEdgeRequestBuilder

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

func NewUpdateEdgeRequestBuilder

func NewUpdateEdgeRequestBuilder() *UpdateEdgeRequestBuilder

func (*UpdateEdgeRequestBuilder) Common

func (*UpdateEdgeRequestBuilder) Condition

func (u *UpdateEdgeRequestBuilder) Condition(condition []byte) *UpdateEdgeRequestBuilder

func (*UpdateEdgeRequestBuilder) EdgeKey

func (UpdateEdgeRequestBuilder) Emit

func (*UpdateEdgeRequestBuilder) Insertable

func (u *UpdateEdgeRequestBuilder) Insertable(insertable bool) *UpdateEdgeRequestBuilder

func (*UpdateEdgeRequestBuilder) PartID

func (*UpdateEdgeRequestBuilder) ReturnProps

func (u *UpdateEdgeRequestBuilder) ReturnProps(returnProps [][]byte) *UpdateEdgeRequestBuilder

func (*UpdateEdgeRequestBuilder) SpaceID

func (*UpdateEdgeRequestBuilder) UpdatedProps

func (u *UpdateEdgeRequestBuilder) UpdatedProps(updatedProps []*UpdatedProp) *UpdateEdgeRequestBuilder

type UpdateResponse

type UpdateResponse struct {
	Result_ *ResponseCommon  `thrift:"result,1,required" db:"result" json:"result"`
	Props   *nebula0.DataSet `thrift:"props,2,optional" 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) SetProps

func (u *UpdateResponse) SetProps(props *nebula0.DataSet) *UpdateResponse

func (*UpdateResponse) SetResult_

func (u *UpdateResponse) SetResult_(result *ResponseCommon) *UpdateResponse

func (*UpdateResponse) String

func (p *UpdateResponse) String() string

func (*UpdateResponse) Write

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

type UpdateResponseBuilder

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

func NewUpdateResponseBuilder

func NewUpdateResponseBuilder() *UpdateResponseBuilder

func (UpdateResponseBuilder) Emit

func (*UpdateResponseBuilder) Props

func (*UpdateResponseBuilder) Result_

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,optional" db:"insertable" json:"insertable,omitempty"`
	ReturnProps  [][]byte             `thrift:"return_props,7,optional" db:"return_props" json:"return_props,omitempty"`
	Condition    []byte               `thrift:"condition,8,optional" db:"condition" json:"condition,omitempty"`
	Common       *RequestCommon       `thrift:"common,9,optional" 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

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

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

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

func (*UpdateVertexRequest) SetCommon

func (u *UpdateVertexRequest) SetCommon(common *RequestCommon) *UpdateVertexRequest

func (*UpdateVertexRequest) SetCondition

func (u *UpdateVertexRequest) SetCondition(condition []byte) *UpdateVertexRequest

func (*UpdateVertexRequest) SetInsertable

func (u *UpdateVertexRequest) SetInsertable(insertable bool) *UpdateVertexRequest

func (*UpdateVertexRequest) SetPartID

func (*UpdateVertexRequest) SetReturnProps

func (u *UpdateVertexRequest) SetReturnProps(returnProps [][]byte) *UpdateVertexRequest

func (*UpdateVertexRequest) SetSpaceID

func (*UpdateVertexRequest) SetTagID

func (*UpdateVertexRequest) SetUpdatedProps

func (u *UpdateVertexRequest) SetUpdatedProps(updatedProps []*UpdatedProp) *UpdateVertexRequest

func (*UpdateVertexRequest) SetVertexID

func (u *UpdateVertexRequest) SetVertexID(vertexID *nebula0.Value) *UpdateVertexRequest

func (*UpdateVertexRequest) String

func (p *UpdateVertexRequest) String() string

func (*UpdateVertexRequest) Write

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

type UpdateVertexRequestBuilder

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

func NewUpdateVertexRequestBuilder

func NewUpdateVertexRequestBuilder() *UpdateVertexRequestBuilder

func (*UpdateVertexRequestBuilder) Common

func (*UpdateVertexRequestBuilder) Condition

func (u *UpdateVertexRequestBuilder) Condition(condition []byte) *UpdateVertexRequestBuilder

func (UpdateVertexRequestBuilder) Emit

func (*UpdateVertexRequestBuilder) Insertable

func (u *UpdateVertexRequestBuilder) Insertable(insertable bool) *UpdateVertexRequestBuilder

func (*UpdateVertexRequestBuilder) PartID

func (*UpdateVertexRequestBuilder) ReturnProps

func (u *UpdateVertexRequestBuilder) ReturnProps(returnProps [][]byte) *UpdateVertexRequestBuilder

func (*UpdateVertexRequestBuilder) SpaceID

func (*UpdateVertexRequestBuilder) TagID

func (*UpdateVertexRequestBuilder) UpdatedProps

func (u *UpdateVertexRequestBuilder) UpdatedProps(updatedProps []*UpdatedProp) *UpdateVertexRequestBuilder

func (*UpdateVertexRequestBuilder) VertexID

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

func (u *UpdatedProp) SetName(name []byte) *UpdatedProp

func (*UpdatedProp) SetValue

func (u *UpdatedProp) SetValue(value []byte) *UpdatedProp

func (*UpdatedProp) String

func (p *UpdatedProp) String() string

func (*UpdatedProp) Write

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

type UpdatedPropBuilder

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

func NewUpdatedPropBuilder

func NewUpdatedPropBuilder() *UpdatedPropBuilder

func (UpdatedPropBuilder) Emit

func (p UpdatedPropBuilder) Emit() *UpdatedProp

func (*UpdatedPropBuilder) Name

func (u *UpdatedPropBuilder) Name(name []byte) *UpdatedPropBuilder

func (*UpdatedPropBuilder) Value

func (u *UpdatedPropBuilder) Value(value []byte) *UpdatedPropBuilder

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

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

func (v *VertexProp) SetProps(props [][]byte) *VertexProp

func (*VertexProp) SetTag

func (v *VertexProp) SetTag(tag nebula0.TagID) *VertexProp

func (*VertexProp) String

func (p *VertexProp) String() string

func (*VertexProp) Write

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

type VertexPropBuilder

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

func NewVertexPropBuilder

func NewVertexPropBuilder() *VertexPropBuilder

func (VertexPropBuilder) Emit

func (p VertexPropBuilder) Emit() *VertexProp

func (*VertexPropBuilder) Props

func (v *VertexPropBuilder) Props(props [][]byte) *VertexPropBuilder

func (*VertexPropBuilder) Tag

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL