graph

package
v2.6.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AuthResponse_ErrorMsg_DEFAULT []byte
View Source 
var AuthResponse_SessionID_DEFAULT int64
View Source 
var AuthResponse_TimeZoneName_DEFAULT []byte
View Source 
var AuthResponse_TimeZoneOffsetSeconds_DEFAULT int32
View Source 
var ExecutionResponse_Comment_DEFAULT []byte
View Source 
var ExecutionResponse_Data_DEFAULT *nebula0.DataSet
View Source 
var ExecutionResponse_ErrorMsg_DEFAULT []byte
View Source 
var ExecutionResponse_SpaceName_DEFAULT []byte
View Source 
var GoUnusedProtection__ int
View Source 
var GraphServiceExecuteJsonResult_Success_DEFAULT []byte
View Source 
var PlanNodeDescription_Dependencies_DEFAULT []int64
View Source 
var PlanNodeDescription_Description_DEFAULT []*Pair
View Source 
var PlanNodeDescription_Profiles_DEFAULT []*ProfilingStats
View Source 
var ProfilingStats_OtherStats_DEFAULT map[string][]byte
View Source 
var VerifyClientVersionResp_ErrorMsg_DEFAULT []byte

Functions

This section is empty.

Types

type AuthResponse 

type AuthResponse struct {
	ErrorCode             nebula0.ErrorCode `thrift:"error_code,1,required" db:"error_code" json:"error_code"`
	ErrorMsg              []byte            `thrift:"error_msg,2" db:"error_msg" json:"error_msg,omitempty"`
	SessionID             *int64            `thrift:"session_id,3" db:"session_id" json:"session_id,omitempty"`
	TimeZoneOffsetSeconds *int32            `thrift:"time_zone_offset_seconds,4" db:"time_zone_offset_seconds" json:"time_zone_offset_seconds,omitempty"`
	TimeZoneName          []byte            `thrift:"time_zone_name,5" db:"time_zone_name" json:"time_zone_name,omitempty"`
}

Attributes:

  • ErrorCode
  • ErrorMsg
  • SessionID
  • TimeZoneOffsetSeconds
  • TimeZoneName
var GraphServiceAuthenticateResult_Success_DEFAULT *AuthResponse

func NewAuthResponse 

func NewAuthResponse() *AuthResponse

func (*AuthResponse) GetErrorCode 

func (p *AuthResponse) GetErrorCode() nebula0.ErrorCode

func (*AuthResponse) GetErrorMsg 

func (p *AuthResponse) GetErrorMsg() []byte

func (*AuthResponse) GetSessionID 

func (p *AuthResponse) GetSessionID() int64

func (*AuthResponse) GetTimeZoneName 

func (p *AuthResponse) GetTimeZoneName() []byte

func (*AuthResponse) GetTimeZoneOffsetSeconds 

func (p *AuthResponse) GetTimeZoneOffsetSeconds() int32

func (*AuthResponse) IsSetErrorMsg 

func (p *AuthResponse) IsSetErrorMsg() bool

func (*AuthResponse) IsSetSessionID 

func (p *AuthResponse) IsSetSessionID() bool

func (*AuthResponse) IsSetTimeZoneName 

func (p *AuthResponse) IsSetTimeZoneName() bool

func (*AuthResponse) IsSetTimeZoneOffsetSeconds 

func (p *AuthResponse) IsSetTimeZoneOffsetSeconds() bool

func (*AuthResponse) Read 

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

func (*AuthResponse) ReadField1 

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

func (*AuthResponse) ReadField2 

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

func (*AuthResponse) ReadField3 

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

func (*AuthResponse) ReadField4 

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

func (*AuthResponse) ReadField5 

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

func (*AuthResponse) String 

func (p *AuthResponse) String() string

func (*AuthResponse) Write 

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

type ExecutionResponse 

type ExecutionResponse struct {
	ErrorCode   nebula0.ErrorCode `thrift:"error_code,1,required" db:"error_code" json:"error_code"`
	LatencyInUs int32             `thrift:"latency_in_us,2,required" db:"latency_in_us" json:"latency_in_us"`
	Data        *nebula0.DataSet  `thrift:"data,3" db:"data" json:"data,omitempty"`
	SpaceName   []byte            `thrift:"space_name,4" db:"space_name" json:"space_name,omitempty"`
	ErrorMsg    []byte            `thrift:"error_msg,5" db:"error_msg" json:"error_msg,omitempty"`
	PlanDesc    *PlanDescription  `thrift:"plan_desc,6" db:"plan_desc" json:"plan_desc,omitempty"`
	Comment     []byte            `thrift:"comment,7" db:"comment" json:"comment,omitempty"`
}

Attributes:

  • ErrorCode
  • LatencyInUs
  • Data
  • SpaceName
  • ErrorMsg
  • PlanDesc
  • Comment
var GraphServiceExecuteResult_Success_DEFAULT *ExecutionResponse

func NewExecutionResponse 

func NewExecutionResponse() *ExecutionResponse

func (*ExecutionResponse) GetComment 

func (p *ExecutionResponse) GetComment() []byte

func (*ExecutionResponse) GetData 

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

func (*ExecutionResponse) GetErrorCode 

func (p *ExecutionResponse) GetErrorCode() nebula0.ErrorCode

func (*ExecutionResponse) GetErrorMsg 

func (p *ExecutionResponse) GetErrorMsg() []byte

func (*ExecutionResponse) GetLatencyInUs 

func (p *ExecutionResponse) GetLatencyInUs() int32

func (*ExecutionResponse) GetPlanDesc 

func (p *ExecutionResponse) GetPlanDesc() *PlanDescription

func (*ExecutionResponse) GetSpaceName 

func (p *ExecutionResponse) GetSpaceName() []byte

func (*ExecutionResponse) IsSetComment 

func (p *ExecutionResponse) IsSetComment() bool

func (*ExecutionResponse) IsSetData 

func (p *ExecutionResponse) IsSetData() bool

func (*ExecutionResponse) IsSetErrorMsg 

func (p *ExecutionResponse) IsSetErrorMsg() bool

func (*ExecutionResponse) IsSetPlanDesc 

func (p *ExecutionResponse) IsSetPlanDesc() bool

func (*ExecutionResponse) IsSetSpaceName 

func (p *ExecutionResponse) IsSetSpaceName() bool

func (*ExecutionResponse) Read 

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

func (*ExecutionResponse) ReadField1 

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

func (*ExecutionResponse) ReadField2 

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

func (*ExecutionResponse) ReadField3 

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

func (*ExecutionResponse) ReadField4 

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

func (*ExecutionResponse) ReadField5 

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

func (*ExecutionResponse) ReadField6 

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

func (*ExecutionResponse) ReadField7 

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

func (*ExecutionResponse) String 

func (p *ExecutionResponse) String() string

func (*ExecutionResponse) Write 

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

type GraphService 

type GraphService interface {
	// Parameters:
	//  - Username
	//  - Password
	Authenticate(ctx context.Context, username []byte, password []byte) (_r *AuthResponse, err error)
	// Parameters:
	//  - SessionId
	Signout(ctx context.Context, sessionId int64) (err error)
	// Parameters:
	//  - SessionId
	//  - Stmt
	Execute(ctx context.Context, sessionId int64, stmt []byte) (_r *ExecutionResponse, err error)
	// Parameters:
	//  - SessionId
	//  - Stmt
	ExecuteJson(ctx context.Context, sessionId int64, stmt []byte) (_r []byte, err error)
	// Parameters:
	//  - Req
	VerifyClientVersion(ctx context.Context, req *VerifyClientVersionReq) (_r *VerifyClientVersionResp, err error)
}

type GraphServiceAuthenticateArgs 

type GraphServiceAuthenticateArgs struct {
	thrift.IRequest
	Username []byte `thrift:"username,1" db:"username" json:"username"`
	Password []byte `thrift:"password,2" db:"password" json:"password"`
}

Attributes:

  • Username
  • Password

func NewGraphServiceAuthenticateArgs 

func NewGraphServiceAuthenticateArgs() *GraphServiceAuthenticateArgs

func (*GraphServiceAuthenticateArgs) GetPassword 

func (p *GraphServiceAuthenticateArgs) GetPassword() []byte

func (*GraphServiceAuthenticateArgs) GetUsername 

func (p *GraphServiceAuthenticateArgs) GetUsername() []byte

func (*GraphServiceAuthenticateArgs) Read 

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

func (*GraphServiceAuthenticateArgs) ReadField1 

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

func (*GraphServiceAuthenticateArgs) ReadField2 

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

func (*GraphServiceAuthenticateArgs) String 

func (p *GraphServiceAuthenticateArgs) String() string

func (*GraphServiceAuthenticateArgs) Write 

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

type GraphServiceAuthenticateResult 

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

Attributes:

  • Success

func NewGraphServiceAuthenticateResult 

func NewGraphServiceAuthenticateResult() *GraphServiceAuthenticateResult

func (*GraphServiceAuthenticateResult) GetSuccess 

func (p *GraphServiceAuthenticateResult) GetSuccess() *AuthResponse

func (*GraphServiceAuthenticateResult) IsSetSuccess 

func (p *GraphServiceAuthenticateResult) IsSetSuccess() bool

func (*GraphServiceAuthenticateResult) Read 

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

func (*GraphServiceAuthenticateResult) ReadField0 

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

func (*GraphServiceAuthenticateResult) String 

func (p *GraphServiceAuthenticateResult) String() string

func (*GraphServiceAuthenticateResult) Write 

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

type GraphServiceChannelClient 

type GraphServiceChannelClient struct {
	RequestChannel thrift.RequestChannel
}

func NewGraphServiceChannelClient 

func NewGraphServiceChannelClient(channel thrift.RequestChannel) *GraphServiceChannelClient

func (*GraphServiceChannelClient) Authenticate 

func (p *GraphServiceChannelClient) Authenticate(ctx context.Context, username []byte, password []byte) (_r *AuthResponse, err error)

Parameters:

  • Username
  • Password

func (*GraphServiceChannelClient) Close 

func (c *GraphServiceChannelClient) Close() error

func (*GraphServiceChannelClient) Execute 

func (p *GraphServiceChannelClient) Execute(ctx context.Context, sessionId int64, stmt []byte) (_r *ExecutionResponse, err error)

Parameters:

  • SessionId
  • Stmt

func (*GraphServiceChannelClient) ExecuteJson 

func (p *GraphServiceChannelClient) ExecuteJson(ctx context.Context, sessionId int64, stmt []byte) (_r []byte, err error)

Parameters:

  • SessionId
  • Stmt

func (*GraphServiceChannelClient) IsOpen 

func (c *GraphServiceChannelClient) IsOpen() bool

func (*GraphServiceChannelClient) Open 

func (c *GraphServiceChannelClient) Open() error

func (*GraphServiceChannelClient) Signout 

func (p *GraphServiceChannelClient) Signout(ctx context.Context, sessionId int64) (err error)

Parameters:

  • SessionId

func (*GraphServiceChannelClient) VerifyClientVersion added in v2.6.0 

func (p *GraphServiceChannelClient) VerifyClientVersion(ctx context.Context, req *VerifyClientVersionReq) (_r *VerifyClientVersionResp, err error)

Parameters:

  • Req

type GraphServiceClient 

type GraphServiceClient struct {
	GraphServiceClientInterface
	CC thrift.ClientConn
}

func NewGraphServiceClient 

func NewGraphServiceClient(t thrift.Transport, iprot thrift.Protocol, oprot thrift.Protocol) *GraphServiceClient

func NewGraphServiceClientFactory 

func NewGraphServiceClientFactory(t thrift.Transport, f thrift.ProtocolFactory) *GraphServiceClient

func NewGraphServiceClientProtocol 

func NewGraphServiceClientProtocol(prot thrift.Protocol) *GraphServiceClient

func (*GraphServiceClient) Authenticate 

func (p *GraphServiceClient) Authenticate(username []byte, password []byte) (_r *AuthResponse, err error)

Parameters:

  • Username
  • Password

func (*GraphServiceClient) Close 

func (client *GraphServiceClient) Close() error

func (*GraphServiceClient) Execute 

func (p *GraphServiceClient) Execute(sessionId int64, stmt []byte) (_r *ExecutionResponse, err error)

Parameters:

  • SessionId
  • Stmt

func (*GraphServiceClient) ExecuteJson 

func (p *GraphServiceClient) ExecuteJson(sessionId int64, stmt []byte) (_r []byte, err error)

Parameters:

  • SessionId
  • Stmt

func (*GraphServiceClient) IsOpen 

func (client *GraphServiceClient) IsOpen() bool

func (*GraphServiceClient) Open 

func (client *GraphServiceClient) Open() error

func (*GraphServiceClient) Signout 

func (p *GraphServiceClient) Signout(sessionId int64) (err error)

Parameters:

  • SessionId

func (*GraphServiceClient) VerifyClientVersion added in v2.6.0 

func (p *GraphServiceClient) VerifyClientVersion(req *VerifyClientVersionReq) (_r *VerifyClientVersionResp, err error)

Parameters:

  • Req

type GraphServiceClientInterface 

type GraphServiceClientInterface interface {
	thrift.ClientInterface
	// Parameters:
	//  - Username
	//  - Password
	Authenticate(username []byte, password []byte) (_r *AuthResponse, err error)
	// Parameters:
	//  - SessionId
	Signout(sessionId int64) (err error)
	// Parameters:
	//  - SessionId
	//  - Stmt
	Execute(sessionId int64, stmt []byte) (_r *ExecutionResponse, err error)
	// Parameters:
	//  - SessionId
	//  - Stmt
	ExecuteJson(sessionId int64, stmt []byte) (_r []byte, err error)
	// Parameters:
	//  - Req
	VerifyClientVersion(req *VerifyClientVersionReq) (_r *VerifyClientVersionResp, err error)
}

type GraphServiceExecuteArgs 

type GraphServiceExecuteArgs struct {
	thrift.IRequest
	SessionId int64  `thrift:"sessionId,1" db:"sessionId" json:"sessionId"`
	Stmt      []byte `thrift:"stmt,2" db:"stmt" json:"stmt"`
}

Attributes:

  • SessionId
  • Stmt

func NewGraphServiceExecuteArgs 

func NewGraphServiceExecuteArgs() *GraphServiceExecuteArgs

func (*GraphServiceExecuteArgs) GetSessionId 

func (p *GraphServiceExecuteArgs) GetSessionId() int64

func (*GraphServiceExecuteArgs) GetStmt 

func (p *GraphServiceExecuteArgs) GetStmt() []byte

func (*GraphServiceExecuteArgs) Read 

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

func (*GraphServiceExecuteArgs) ReadField1 

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

func (*GraphServiceExecuteArgs) ReadField2 

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

func (*GraphServiceExecuteArgs) String 

func (p *GraphServiceExecuteArgs) String() string

func (*GraphServiceExecuteArgs) Write 

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

type GraphServiceExecuteJsonArgs 

type GraphServiceExecuteJsonArgs struct {
	thrift.IRequest
	SessionId int64  `thrift:"sessionId,1" db:"sessionId" json:"sessionId"`
	Stmt      []byte `thrift:"stmt,2" db:"stmt" json:"stmt"`
}

Attributes:

  • SessionId
  • Stmt

func NewGraphServiceExecuteJsonArgs 

func NewGraphServiceExecuteJsonArgs() *GraphServiceExecuteJsonArgs

func (*GraphServiceExecuteJsonArgs) GetSessionId 

func (p *GraphServiceExecuteJsonArgs) GetSessionId() int64

func (*GraphServiceExecuteJsonArgs) GetStmt 

func (p *GraphServiceExecuteJsonArgs) GetStmt() []byte

func (*GraphServiceExecuteJsonArgs) Read 

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

func (*GraphServiceExecuteJsonArgs) ReadField1 

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

func (*GraphServiceExecuteJsonArgs) ReadField2 

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

func (*GraphServiceExecuteJsonArgs) String 

func (p *GraphServiceExecuteJsonArgs) String() string

func (*GraphServiceExecuteJsonArgs) Write 

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

type GraphServiceExecuteJsonResult 

type GraphServiceExecuteJsonResult struct {
	thrift.IResponse
	Success []byte `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewGraphServiceExecuteJsonResult 

func NewGraphServiceExecuteJsonResult() *GraphServiceExecuteJsonResult

func (*GraphServiceExecuteJsonResult) GetSuccess 

func (p *GraphServiceExecuteJsonResult) GetSuccess() []byte

func (*GraphServiceExecuteJsonResult) IsSetSuccess 

func (p *GraphServiceExecuteJsonResult) IsSetSuccess() bool

func (*GraphServiceExecuteJsonResult) Read 

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

func (*GraphServiceExecuteJsonResult) ReadField0 

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

func (*GraphServiceExecuteJsonResult) String 

func (p *GraphServiceExecuteJsonResult) String() string

func (*GraphServiceExecuteJsonResult) Write 

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

type GraphServiceExecuteResult 

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

Attributes:

  • Success

func NewGraphServiceExecuteResult 

func NewGraphServiceExecuteResult() *GraphServiceExecuteResult

func (*GraphServiceExecuteResult) GetSuccess 

func (p *GraphServiceExecuteResult) GetSuccess() *ExecutionResponse

func (*GraphServiceExecuteResult) IsSetSuccess 

func (p *GraphServiceExecuteResult) IsSetSuccess() bool

func (*GraphServiceExecuteResult) Read 

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

func (*GraphServiceExecuteResult) ReadField0 

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

func (*GraphServiceExecuteResult) String 

func (p *GraphServiceExecuteResult) String() string

func (*GraphServiceExecuteResult) Write 

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

type GraphServiceProcessor 

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

func NewGraphServiceProcessor 

func NewGraphServiceProcessor(handler GraphService) *GraphServiceProcessor

func (*GraphServiceProcessor) AddToProcessorMap 

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

func (*GraphServiceProcessor) GetProcessorFunctionContext 

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

func (*GraphServiceProcessor) ProcessorMap 

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

type GraphServiceSignoutArgs 

type GraphServiceSignoutArgs struct {
	thrift.IRequest
	SessionId int64 `thrift:"sessionId,1" db:"sessionId" json:"sessionId"`
}

Attributes:

  • SessionId

func NewGraphServiceSignoutArgs 

func NewGraphServiceSignoutArgs() *GraphServiceSignoutArgs

func (*GraphServiceSignoutArgs) GetSessionId 

func (p *GraphServiceSignoutArgs) GetSessionId() int64

func (*GraphServiceSignoutArgs) Read 

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

func (*GraphServiceSignoutArgs) ReadField1 

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

func (*GraphServiceSignoutArgs) String 

func (p *GraphServiceSignoutArgs) String() string

func (*GraphServiceSignoutArgs) Write 

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

type GraphServiceThreadsafeClient 

type GraphServiceThreadsafeClient struct {
	GraphServiceClientInterface
	CC thrift.ClientConn
	Mu sync.Mutex
}

func NewGraphServiceThreadsafeClient 

func NewGraphServiceThreadsafeClient(t thrift.Transport, iprot thrift.Protocol, oprot thrift.Protocol) *GraphServiceThreadsafeClient

func NewGraphServiceThreadsafeClientFactory 

func NewGraphServiceThreadsafeClientFactory(t thrift.Transport, f thrift.ProtocolFactory) *GraphServiceThreadsafeClient

func NewGraphServiceThreadsafeClientProtocol 

func NewGraphServiceThreadsafeClientProtocol(prot thrift.Protocol) *GraphServiceThreadsafeClient

func (*GraphServiceThreadsafeClient) Authenticate 

func (p *GraphServiceThreadsafeClient) Authenticate(username []byte, password []byte) (_r *AuthResponse, err error)

Parameters:

  • Username
  • Password

func (*GraphServiceThreadsafeClient) Close 

func (client *GraphServiceThreadsafeClient) Close() error

func (*GraphServiceThreadsafeClient) Execute 

func (p *GraphServiceThreadsafeClient) Execute(sessionId int64, stmt []byte) (_r *ExecutionResponse, err error)

Parameters:

  • SessionId
  • Stmt

func (*GraphServiceThreadsafeClient) ExecuteJson 

func (p *GraphServiceThreadsafeClient) ExecuteJson(sessionId int64, stmt []byte) (_r []byte, err error)

Parameters:

  • SessionId
  • Stmt

func (*GraphServiceThreadsafeClient) IsOpen 

func (client *GraphServiceThreadsafeClient) IsOpen() bool

func (*GraphServiceThreadsafeClient) Open 

func (client *GraphServiceThreadsafeClient) Open() error

func (*GraphServiceThreadsafeClient) Signout 

func (p *GraphServiceThreadsafeClient) Signout(sessionId int64) (err error)

Parameters:

  • SessionId

func (*GraphServiceThreadsafeClient) VerifyClientVersion added in v2.6.0 

func (p *GraphServiceThreadsafeClient) VerifyClientVersion(req *VerifyClientVersionReq) (_r *VerifyClientVersionResp, err error)

Parameters:

  • Req

type GraphServiceVerifyClientVersionArgs added in v2.6.0 

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

Attributes:

  • Req

func NewGraphServiceVerifyClientVersionArgs added in v2.6.0 

func NewGraphServiceVerifyClientVersionArgs() *GraphServiceVerifyClientVersionArgs

func (*GraphServiceVerifyClientVersionArgs) GetReq added in v2.6.0 

func (p *GraphServiceVerifyClientVersionArgs) GetReq() *VerifyClientVersionReq

func (*GraphServiceVerifyClientVersionArgs) IsSetReq added in v2.6.0 

func (p *GraphServiceVerifyClientVersionArgs) IsSetReq() bool

func (*GraphServiceVerifyClientVersionArgs) Read added in v2.6.0 

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

func (*GraphServiceVerifyClientVersionArgs) ReadField1 added in v2.6.0 

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

func (*GraphServiceVerifyClientVersionArgs) String added in v2.6.0 

func (p *GraphServiceVerifyClientVersionArgs) String() string

func (*GraphServiceVerifyClientVersionArgs) Write added in v2.6.0 

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

type GraphServiceVerifyClientVersionResult added in v2.6.0 

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

Attributes:

  • Success

func NewGraphServiceVerifyClientVersionResult added in v2.6.0 

func NewGraphServiceVerifyClientVersionResult() *GraphServiceVerifyClientVersionResult

func (*GraphServiceVerifyClientVersionResult) GetSuccess added in v2.6.0 

func (p *GraphServiceVerifyClientVersionResult) GetSuccess() *VerifyClientVersionResp

func (*GraphServiceVerifyClientVersionResult) IsSetSuccess added in v2.6.0 

func (p *GraphServiceVerifyClientVersionResult) IsSetSuccess() bool

func (*GraphServiceVerifyClientVersionResult) Read added in v2.6.0 

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

func (*GraphServiceVerifyClientVersionResult) ReadField0 added in v2.6.0 

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

func (*GraphServiceVerifyClientVersionResult) String added in v2.6.0 

func (p *GraphServiceVerifyClientVersionResult) String() string

func (*GraphServiceVerifyClientVersionResult) Write added in v2.6.0 

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

type Pair 

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

Attributes:

  • Key
  • Value

func NewPair 

func NewPair() *Pair

func (*Pair) GetKey 

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

func (*Pair) GetValue 

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

func (*Pair) Read 

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

func (*Pair) ReadField1 

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

func (*Pair) ReadField2 

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

func (*Pair) String 

func (p *Pair) String() string

func (*Pair) Write 

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

type PlanDescription 

type PlanDescription struct {
	PlanNodeDescs    []*PlanNodeDescription `thrift:"plan_node_descs,1,required" db:"plan_node_descs" json:"plan_node_descs"`
	NodeIndexMap     map[int64]int64        `thrift:"node_index_map,2,required" db:"node_index_map" json:"node_index_map"`
	Format           []byte                 `thrift:"format,3,required" db:"format" json:"format"`
	OptimizeTimeInUs int32                  `thrift:"optimize_time_in_us,4,required" db:"optimize_time_in_us" json:"optimize_time_in_us"`
}

Attributes:

  • PlanNodeDescs
  • NodeIndexMap
  • Format
  • OptimizeTimeInUs
var ExecutionResponse_PlanDesc_DEFAULT *PlanDescription

func NewPlanDescription 

func NewPlanDescription() *PlanDescription

func (*PlanDescription) GetFormat 

func (p *PlanDescription) GetFormat() []byte

func (*PlanDescription) GetNodeIndexMap 

func (p *PlanDescription) GetNodeIndexMap() map[int64]int64

func (*PlanDescription) GetOptimizeTimeInUs 

func (p *PlanDescription) GetOptimizeTimeInUs() int32

func (*PlanDescription) GetPlanNodeDescs 

func (p *PlanDescription) GetPlanNodeDescs() []*PlanNodeDescription

func (*PlanDescription) Read 

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

func (*PlanDescription) ReadField1 

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

func (*PlanDescription) ReadField2 

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

func (*PlanDescription) ReadField3 

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

func (*PlanDescription) ReadField4 

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

func (*PlanDescription) String 

func (p *PlanDescription) String() string

func (*PlanDescription) Write 

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

type PlanNodeBranchInfo 

type PlanNodeBranchInfo struct {
	IsDoBranch      bool  `thrift:"is_do_branch,1,required" db:"is_do_branch" json:"is_do_branch"`
	ConditionNodeID int64 `thrift:"condition_node_id,2,required" db:"condition_node_id" json:"condition_node_id"`
}

Attributes:

  • IsDoBranch
  • ConditionNodeID
var PlanNodeDescription_BranchInfo_DEFAULT *PlanNodeBranchInfo

func NewPlanNodeBranchInfo 

func NewPlanNodeBranchInfo() *PlanNodeBranchInfo

func (*PlanNodeBranchInfo) GetConditionNodeID 

func (p *PlanNodeBranchInfo) GetConditionNodeID() int64

func (*PlanNodeBranchInfo) GetIsDoBranch 

func (p *PlanNodeBranchInfo) GetIsDoBranch() bool

func (*PlanNodeBranchInfo) Read 

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

func (*PlanNodeBranchInfo) ReadField1 

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

func (*PlanNodeBranchInfo) ReadField2 

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

func (*PlanNodeBranchInfo) String 

func (p *PlanNodeBranchInfo) String() string

func (*PlanNodeBranchInfo) Write 

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

type PlanNodeDescription 

type PlanNodeDescription struct {
	Name         []byte              `thrift:"name,1,required" db:"name" json:"name"`
	Id           int64               `thrift:"id,2,required" db:"id" json:"id"`
	OutputVar    []byte              `thrift:"output_var,3,required" db:"output_var" json:"output_var"`
	Description  []*Pair             `thrift:"description,4" db:"description" json:"description,omitempty"`
	Profiles     []*ProfilingStats   `thrift:"profiles,5" db:"profiles" json:"profiles,omitempty"`
	BranchInfo   *PlanNodeBranchInfo `thrift:"branch_info,6" db:"branch_info" json:"branch_info,omitempty"`
	Dependencies []int64             `thrift:"dependencies,7" db:"dependencies" json:"dependencies,omitempty"`
}

Attributes:

  • Name
  • Id
  • OutputVar
  • Description
  • Profiles
  • BranchInfo
  • Dependencies

func NewPlanNodeDescription 

func NewPlanNodeDescription() *PlanNodeDescription

func (*PlanNodeDescription) GetBranchInfo 

func (p *PlanNodeDescription) GetBranchInfo() *PlanNodeBranchInfo

func (*PlanNodeDescription) GetDependencies 

func (p *PlanNodeDescription) GetDependencies() []int64

func (*PlanNodeDescription) GetDescription 

func (p *PlanNodeDescription) GetDescription() []*Pair

func (*PlanNodeDescription) GetId 

func (p *PlanNodeDescription) GetId() int64

func (*PlanNodeDescription) GetName 

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

func (*PlanNodeDescription) GetOutputVar 

func (p *PlanNodeDescription) GetOutputVar() []byte

func (*PlanNodeDescription) GetProfiles 

func (p *PlanNodeDescription) GetProfiles() []*ProfilingStats

func (*PlanNodeDescription) IsSetBranchInfo 

func (p *PlanNodeDescription) IsSetBranchInfo() bool

func (*PlanNodeDescription) IsSetDependencies 

func (p *PlanNodeDescription) IsSetDependencies() bool

func (*PlanNodeDescription) IsSetDescription 

func (p *PlanNodeDescription) IsSetDescription() bool

func (*PlanNodeDescription) IsSetProfiles 

func (p *PlanNodeDescription) IsSetProfiles() bool

func (*PlanNodeDescription) Read 

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

func (*PlanNodeDescription) ReadField1 

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

func (*PlanNodeDescription) ReadField2 

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

func (*PlanNodeDescription) ReadField3 

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

func (*PlanNodeDescription) ReadField4 

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

func (*PlanNodeDescription) ReadField5 

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

func (*PlanNodeDescription) ReadField6 

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

func (*PlanNodeDescription) ReadField7 

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

func (*PlanNodeDescription) String 

func (p *PlanNodeDescription) String() string

func (*PlanNodeDescription) Write 

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

type ProfilingStats 

type ProfilingStats struct {
	Rows              int64             `thrift:"rows,1,required" db:"rows" json:"rows"`
	ExecDurationInUs  int64             `thrift:"exec_duration_in_us,2,required" db:"exec_duration_in_us" json:"exec_duration_in_us"`
	TotalDurationInUs int64             `thrift:"total_duration_in_us,3,required" db:"total_duration_in_us" json:"total_duration_in_us"`
	OtherStats        map[string][]byte `thrift:"other_stats,4" db:"other_stats" json:"other_stats,omitempty"`
}

Attributes:

  • Rows
  • ExecDurationInUs
  • TotalDurationInUs
  • OtherStats

func NewProfilingStats 

func NewProfilingStats() *ProfilingStats

func (*ProfilingStats) GetExecDurationInUs 

func (p *ProfilingStats) GetExecDurationInUs() int64

func (*ProfilingStats) GetOtherStats 

func (p *ProfilingStats) GetOtherStats() map[string][]byte

func (*ProfilingStats) GetRows 

func (p *ProfilingStats) GetRows() int64

func (*ProfilingStats) GetTotalDurationInUs 

func (p *ProfilingStats) GetTotalDurationInUs() int64

func (*ProfilingStats) IsSetOtherStats 

func (p *ProfilingStats) IsSetOtherStats() bool

func (*ProfilingStats) Read 

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

func (*ProfilingStats) ReadField1 

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

func (*ProfilingStats) ReadField2 

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

func (*ProfilingStats) ReadField3 

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

func (*ProfilingStats) ReadField4 

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

func (*ProfilingStats) String 

func (p *ProfilingStats) String() string

func (*ProfilingStats) Write 

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

type VerifyClientVersionReq added in v2.6.0 

type VerifyClientVersionReq struct {
	Version []byte `thrift:"version,1,required" db:"version" json:"version"`
}

Attributes:

  • Version
var GraphServiceVerifyClientVersionArgs_Req_DEFAULT *VerifyClientVersionReq

func NewVerifyClientVersionReq added in v2.6.0 

func NewVerifyClientVersionReq() *VerifyClientVersionReq

func (*VerifyClientVersionReq) GetVersion added in v2.6.0 

func (p *VerifyClientVersionReq) GetVersion() []byte

func (*VerifyClientVersionReq) Read added in v2.6.0 

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

func (*VerifyClientVersionReq) ReadField1 added in v2.6.0 

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

func (*VerifyClientVersionReq) String added in v2.6.0 

func (p *VerifyClientVersionReq) String() string

func (*VerifyClientVersionReq) Write added in v2.6.0 

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

type VerifyClientVersionResp added in v2.6.0 

type VerifyClientVersionResp struct {
	ErrorCode nebula0.ErrorCode `thrift:"error_code,1,required" db:"error_code" json:"error_code"`
	ErrorMsg  []byte            `thrift:"error_msg,2" db:"error_msg" json:"error_msg,omitempty"`
}

Attributes:

  • ErrorCode
  • ErrorMsg
var GraphServiceVerifyClientVersionResult_Success_DEFAULT *VerifyClientVersionResp

func NewVerifyClientVersionResp added in v2.6.0 

func NewVerifyClientVersionResp() *VerifyClientVersionResp

func (*VerifyClientVersionResp) GetErrorCode added in v2.6.0 

func (p *VerifyClientVersionResp) GetErrorCode() nebula0.ErrorCode

func (*VerifyClientVersionResp) GetErrorMsg added in v2.6.0 

func (p *VerifyClientVersionResp) GetErrorMsg() []byte

func (*VerifyClientVersionResp) IsSetErrorMsg added in v2.6.0 

func (p *VerifyClientVersionResp) IsSetErrorMsg() bool

func (*VerifyClientVersionResp) Read added in v2.6.0 

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

func (*VerifyClientVersionResp) ReadField1 added in v2.6.0 

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

func (*VerifyClientVersionResp) ReadField2 added in v2.6.0 

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

func (*VerifyClientVersionResp) String added in v2.6.0 

func (p *VerifyClientVersionResp) String() string

func (*VerifyClientVersionResp) Write added in v2.6.0 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.