graph

package

Go to main page

Versions in this module

v3

v3.8.0

Apr 8, 2024

v3.7.5

Oct 9, 2024

v3.7.4

Sep 24, 2024

v3.7.3

Sep 12, 2024

v3.7.2

Jun 24, 2024

Changes in this version

type ExecutionResponse

+ var GraphServiceExecuteWithTimeoutResult_Success_DEFAULT *ExecutionResponse

type GraphService

+ ExecuteWithTimeout func(ctx context.Context, sessionId int64, stmt []byte, ...) (_r *ExecutionResponse, err error)

+ Health func(ctx context.Context) (_r *HealthResp, err error)

type GraphServiceChannelClient

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

+ func (p *GraphServiceChannelClient) Health(ctx context.Context) (_r *HealthResp, err error)

type GraphServiceClient

+ func (p *GraphServiceClient) ExecuteWithTimeout(sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value, ...) (_r *ExecutionResponse, err error)

+ func (p *GraphServiceClient) Health() (_r *HealthResp, err error)

type GraphServiceClientInterface

+ ExecuteWithTimeout func(sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value, ...) (_r *ExecutionResponse, err error)

+ Health func() (_r *HealthResp, err error)

+ type GraphServiceExecuteWithTimeoutArgs struct

+ ParameterMap map[string]*nebula0.Value

+ SessionId int64

+ Stmt []byte

+ Timeout int64

+ func NewGraphServiceExecuteWithTimeoutArgs() *GraphServiceExecuteWithTimeoutArgs

+ func (g *GraphServiceExecuteWithTimeoutArgs) SetParameterMap(parameterMap map[string]*nebula0.Value) *GraphServiceExecuteWithTimeoutArgs

+ func (g *GraphServiceExecuteWithTimeoutArgs) SetSessionId(sessionId int64) *GraphServiceExecuteWithTimeoutArgs

+ func (g *GraphServiceExecuteWithTimeoutArgs) SetStmt(stmt []byte) *GraphServiceExecuteWithTimeoutArgs

+ func (g *GraphServiceExecuteWithTimeoutArgs) SetTimeout(timeout int64) *GraphServiceExecuteWithTimeoutArgs

+ func (p *GraphServiceExecuteWithTimeoutArgs) GetParameterMap() map[string]*nebula0.Value

+ func (p *GraphServiceExecuteWithTimeoutArgs) GetSessionId() int64

+ func (p *GraphServiceExecuteWithTimeoutArgs) GetStmt() []byte

+ func (p *GraphServiceExecuteWithTimeoutArgs) GetTimeout() int64

+ func (p *GraphServiceExecuteWithTimeoutArgs) Read(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithTimeoutArgs) ReadField1(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithTimeoutArgs) ReadField2(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithTimeoutArgs) ReadField3(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithTimeoutArgs) ReadField4(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithTimeoutArgs) String() string

+ func (p *GraphServiceExecuteWithTimeoutArgs) Write(oprot thrift.Protocol) error

+ type GraphServiceExecuteWithTimeoutArgsBuilder struct

+ func NewGraphServiceExecuteWithTimeoutArgsBuilder() *GraphServiceExecuteWithTimeoutArgsBuilder

+ func (g *GraphServiceExecuteWithTimeoutArgsBuilder) ParameterMap(parameterMap map[string]*nebula0.Value) *GraphServiceExecuteWithTimeoutArgsBuilder

+ func (g *GraphServiceExecuteWithTimeoutArgsBuilder) SessionId(sessionId int64) *GraphServiceExecuteWithTimeoutArgsBuilder

+ func (g *GraphServiceExecuteWithTimeoutArgsBuilder) Stmt(stmt []byte) *GraphServiceExecuteWithTimeoutArgsBuilder

+ func (g *GraphServiceExecuteWithTimeoutArgsBuilder) Timeout(timeout int64) *GraphServiceExecuteWithTimeoutArgsBuilder

+ func (p GraphServiceExecuteWithTimeoutArgsBuilder) Emit() *GraphServiceExecuteWithTimeoutArgs

+ type GraphServiceExecuteWithTimeoutResult struct

+ Success *ExecutionResponse

+ func NewGraphServiceExecuteWithTimeoutResult() *GraphServiceExecuteWithTimeoutResult

+ func (g *GraphServiceExecuteWithTimeoutResult) SetSuccess(success *ExecutionResponse) *GraphServiceExecuteWithTimeoutResult

+ func (p *GraphServiceExecuteWithTimeoutResult) Exception() thrift.WritableException

+ func (p *GraphServiceExecuteWithTimeoutResult) GetSuccess() *ExecutionResponse

+ func (p *GraphServiceExecuteWithTimeoutResult) IsSetSuccess() bool

+ func (p *GraphServiceExecuteWithTimeoutResult) Read(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithTimeoutResult) ReadField0(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithTimeoutResult) String() string

+ func (p *GraphServiceExecuteWithTimeoutResult) Write(oprot thrift.Protocol) error

+ type GraphServiceExecuteWithTimeoutResultBuilder struct

+ func NewGraphServiceExecuteWithTimeoutResultBuilder() *GraphServiceExecuteWithTimeoutResultBuilder

+ func (g *GraphServiceExecuteWithTimeoutResultBuilder) Success(success *ExecutionResponse) *GraphServiceExecuteWithTimeoutResultBuilder

+ func (p GraphServiceExecuteWithTimeoutResultBuilder) Emit() *GraphServiceExecuteWithTimeoutResult

+ type GraphServiceHealthArgs struct

+ func NewGraphServiceHealthArgs() *GraphServiceHealthArgs

+ func (p *GraphServiceHealthArgs) Read(iprot thrift.Protocol) error

+ func (p *GraphServiceHealthArgs) String() string

+ func (p *GraphServiceHealthArgs) Write(oprot thrift.Protocol) error

+ type GraphServiceHealthArgsBuilder struct

+ func NewGraphServiceHealthArgsBuilder() *GraphServiceHealthArgsBuilder

+ func (p GraphServiceHealthArgsBuilder) Emit() *GraphServiceHealthArgs

+ type GraphServiceHealthResult struct

+ Success *HealthResp

+ func NewGraphServiceHealthResult() *GraphServiceHealthResult

+ func (g *GraphServiceHealthResult) SetSuccess(success *HealthResp) *GraphServiceHealthResult

+ func (p *GraphServiceHealthResult) Exception() thrift.WritableException

+ func (p *GraphServiceHealthResult) GetSuccess() *HealthResp

+ func (p *GraphServiceHealthResult) IsSetSuccess() bool

+ func (p *GraphServiceHealthResult) Read(iprot thrift.Protocol) error

+ func (p *GraphServiceHealthResult) ReadField0(iprot thrift.Protocol) error

+ func (p *GraphServiceHealthResult) String() string

+ func (p *GraphServiceHealthResult) Write(oprot thrift.Protocol) error

+ type GraphServiceHealthResultBuilder struct

+ func NewGraphServiceHealthResultBuilder() *GraphServiceHealthResultBuilder

+ func (g *GraphServiceHealthResultBuilder) Success(success *HealthResp) *GraphServiceHealthResultBuilder

+ func (p GraphServiceHealthResultBuilder) Emit() *GraphServiceHealthResult

type GraphServiceThreadsafeClient

+ func (p *GraphServiceThreadsafeClient) ExecuteWithTimeout(sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value, ...) (_r *ExecutionResponse, err error)

+ func (p *GraphServiceThreadsafeClient) Health() (_r *HealthResp, err error)

+ type HealthResp struct

+ ErrorCode int64

+ var GraphServiceHealthResult_Success_DEFAULT *HealthResp

+ func NewHealthResp() *HealthResp

+ func (h *HealthResp) SetErrorCode(errorCode int64) *HealthResp

+ func (p *HealthResp) GetErrorCode() int64

+ func (p *HealthResp) Read(iprot thrift.Protocol) error

+ func (p *HealthResp) ReadField1(iprot thrift.Protocol) error

+ func (p *HealthResp) String() string

+ func (p *HealthResp) Write(oprot thrift.Protocol) error

+ type HealthRespBuilder struct

+ func NewHealthRespBuilder() *HealthRespBuilder

+ func (h *HealthRespBuilder) ErrorCode(errorCode int64) *HealthRespBuilder

+ func (p HealthRespBuilder) Emit() *HealthResp

v3.7.1

May 23, 2024

v3.7.0

Jan 31, 2024

v3.6.1

Sep 15, 2023

v3.6.0

Aug 31, 2023

v3.5.0

May 18, 2023

v3.4.0

Feb 6, 2023

v3.4.0-1

Mar 3, 2023

v3.3.1

Nov 21, 2022

v3.3.0

Oct 31, 2022

v3.2.0

Jul 18, 2022

v3.1.0

Apr 25, 2022

v3.0.0

Feb 14, 2022

Changes in this version

+ var AuthResponse_ErrorMsg_DEFAULT []byte

+ var AuthResponse_SessionID_DEFAULT int64

+ var AuthResponse_TimeZoneName_DEFAULT []byte

+ var AuthResponse_TimeZoneOffsetSeconds_DEFAULT int32

+ var ExecutionResponse_Comment_DEFAULT []byte

+ var ExecutionResponse_Data_DEFAULT *nebula0.DataSet

+ var ExecutionResponse_ErrorMsg_DEFAULT []byte

+ var ExecutionResponse_SpaceName_DEFAULT []byte

+ var GoUnusedProtection__ int

+ var GraphServiceExecuteJsonResult_Success_DEFAULT []byte

+ var GraphServiceExecuteJsonWithParameterResult_Success_DEFAULT []byte

+ var PlanNodeDescription_Dependencies_DEFAULT []int64

+ var PlanNodeDescription_Description_DEFAULT []*Pair

+ var PlanNodeDescription_Profiles_DEFAULT []*ProfilingStats

+ var ProfilingStats_OtherStats_DEFAULT map[string][]byte

+ var VerifyClientVersionResp_ErrorMsg_DEFAULT []byte

+ type AuthResponse struct

+ ErrorCode nebula0.ErrorCode

+ ErrorMsg []byte

+ SessionID *int64

+ TimeZoneName []byte

+ TimeZoneOffsetSeconds *int32

+ var GraphServiceAuthenticateResult_Success_DEFAULT *AuthResponse

+ func NewAuthResponse() *AuthResponse

+ func (a *AuthResponse) SetErrorCode(errorCode nebula0.ErrorCode) *AuthResponse

+ func (a *AuthResponse) SetErrorMsg(errorMsg []byte) *AuthResponse

+ func (a *AuthResponse) SetSessionID(sessionID *int64) *AuthResponse

+ func (a *AuthResponse) SetTimeZoneName(timeZoneName []byte) *AuthResponse

+ func (a *AuthResponse) SetTimeZoneOffsetSeconds(timeZoneOffsetSeconds *int32) *AuthResponse

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

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

+ func (p *AuthResponse) GetSessionID() int64

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

+ func (p *AuthResponse) GetTimeZoneOffsetSeconds() int32

+ func (p *AuthResponse) IsSetErrorMsg() bool

+ func (p *AuthResponse) IsSetSessionID() bool

+ func (p *AuthResponse) IsSetTimeZoneName() bool

+ func (p *AuthResponse) IsSetTimeZoneOffsetSeconds() bool

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

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

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

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

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

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

+ func (p *AuthResponse) String() string

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

+ type AuthResponseBuilder struct

+ func NewAuthResponseBuilder() *AuthResponseBuilder

+ func (a *AuthResponseBuilder) ErrorCode(errorCode nebula0.ErrorCode) *AuthResponseBuilder

+ func (a *AuthResponseBuilder) ErrorMsg(errorMsg []byte) *AuthResponseBuilder

+ func (a *AuthResponseBuilder) SessionID(sessionID *int64) *AuthResponseBuilder

+ func (a *AuthResponseBuilder) TimeZoneName(timeZoneName []byte) *AuthResponseBuilder

+ func (a *AuthResponseBuilder) TimeZoneOffsetSeconds(timeZoneOffsetSeconds *int32) *AuthResponseBuilder

+ func (p AuthResponseBuilder) Emit() *AuthResponse

+ type ExecutionResponse struct

+ Comment []byte

+ Data *nebula0.DataSet

+ ErrorCode nebula0.ErrorCode

+ ErrorMsg []byte

+ LatencyInUs int64

+ PlanDesc *PlanDescription

+ SpaceName []byte

+ var GraphServiceExecuteResult_Success_DEFAULT *ExecutionResponse

+ var GraphServiceExecuteWithParameterResult_Success_DEFAULT *ExecutionResponse

+ func NewExecutionResponse() *ExecutionResponse

+ func (e *ExecutionResponse) SetComment(comment []byte) *ExecutionResponse

+ func (e *ExecutionResponse) SetData(data *nebula0.DataSet) *ExecutionResponse

+ func (e *ExecutionResponse) SetErrorCode(errorCode nebula0.ErrorCode) *ExecutionResponse

+ func (e *ExecutionResponse) SetErrorMsg(errorMsg []byte) *ExecutionResponse

+ func (e *ExecutionResponse) SetLatencyInUs(latencyInUs int64) *ExecutionResponse

+ func (e *ExecutionResponse) SetPlanDesc(planDesc *PlanDescription) *ExecutionResponse

+ func (e *ExecutionResponse) SetSpaceName(spaceName []byte) *ExecutionResponse

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

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

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

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

+ func (p *ExecutionResponse) GetLatencyInUs() int64

+ func (p *ExecutionResponse) GetPlanDesc() *PlanDescription

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

+ func (p *ExecutionResponse) IsSetComment() bool

+ func (p *ExecutionResponse) IsSetData() bool

+ func (p *ExecutionResponse) IsSetErrorMsg() bool

+ func (p *ExecutionResponse) IsSetPlanDesc() bool

+ func (p *ExecutionResponse) IsSetSpaceName() bool

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

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

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

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

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

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

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

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

+ func (p *ExecutionResponse) String() string

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

+ type ExecutionResponseBuilder struct

+ func NewExecutionResponseBuilder() *ExecutionResponseBuilder

+ func (e *ExecutionResponseBuilder) Comment(comment []byte) *ExecutionResponseBuilder

+ func (e *ExecutionResponseBuilder) Data(data *nebula0.DataSet) *ExecutionResponseBuilder

+ func (e *ExecutionResponseBuilder) ErrorCode(errorCode nebula0.ErrorCode) *ExecutionResponseBuilder

+ func (e *ExecutionResponseBuilder) ErrorMsg(errorMsg []byte) *ExecutionResponseBuilder

+ func (e *ExecutionResponseBuilder) LatencyInUs(latencyInUs int64) *ExecutionResponseBuilder

+ func (e *ExecutionResponseBuilder) PlanDesc(planDesc *PlanDescription) *ExecutionResponseBuilder

+ func (e *ExecutionResponseBuilder) SpaceName(spaceName []byte) *ExecutionResponseBuilder

+ func (p ExecutionResponseBuilder) Emit() *ExecutionResponse

+ type GraphService interface

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

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

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

+ ExecuteJsonWithParameter func(ctx context.Context, sessionId int64, stmt []byte, ...) (_r []byte, err error)

+ ExecuteWithParameter func(ctx context.Context, sessionId int64, stmt []byte, ...) (_r *ExecutionResponse, err error)

+ Signout func(ctx context.Context, sessionId int64) (err error)

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

+ type GraphServiceAuthenticateArgs struct

+ Password []byte

+ Username []byte

+ func NewGraphServiceAuthenticateArgs() *GraphServiceAuthenticateArgs

+ func (g *GraphServiceAuthenticateArgs) SetPassword(password []byte) *GraphServiceAuthenticateArgs

+ func (g *GraphServiceAuthenticateArgs) SetUsername(username []byte) *GraphServiceAuthenticateArgs

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

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

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

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

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

+ func (p *GraphServiceAuthenticateArgs) String() string

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

+ type GraphServiceAuthenticateArgsBuilder struct

+ func NewGraphServiceAuthenticateArgsBuilder() *GraphServiceAuthenticateArgsBuilder

+ func (g *GraphServiceAuthenticateArgsBuilder) Password(password []byte) *GraphServiceAuthenticateArgsBuilder

+ func (g *GraphServiceAuthenticateArgsBuilder) Username(username []byte) *GraphServiceAuthenticateArgsBuilder

+ func (p GraphServiceAuthenticateArgsBuilder) Emit() *GraphServiceAuthenticateArgs

+ type GraphServiceAuthenticateResult struct

+ Success *AuthResponse

+ func NewGraphServiceAuthenticateResult() *GraphServiceAuthenticateResult

+ func (g *GraphServiceAuthenticateResult) SetSuccess(success *AuthResponse) *GraphServiceAuthenticateResult

+ func (p *GraphServiceAuthenticateResult) Exception() thrift.WritableException

+ func (p *GraphServiceAuthenticateResult) GetSuccess() *AuthResponse

+ func (p *GraphServiceAuthenticateResult) IsSetSuccess() bool

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

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

+ func (p *GraphServiceAuthenticateResult) String() string

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

+ type GraphServiceAuthenticateResultBuilder struct

+ func NewGraphServiceAuthenticateResultBuilder() *GraphServiceAuthenticateResultBuilder

+ func (g *GraphServiceAuthenticateResultBuilder) Success(success *AuthResponse) *GraphServiceAuthenticateResultBuilder

+ func (p GraphServiceAuthenticateResultBuilder) Emit() *GraphServiceAuthenticateResult

+ type GraphServiceChannelClient struct

+ RequestChannel thrift.RequestChannel

+ func NewGraphServiceChannelClient(channel thrift.RequestChannel) *GraphServiceChannelClient

+ func (c *GraphServiceChannelClient) Close() error

+ func (c *GraphServiceChannelClient) IsOpen() bool

+ func (c *GraphServiceChannelClient) Open() error

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

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

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

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

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

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

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

+ type GraphServiceClient struct

+ CC thrift.ClientConn

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

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

+ func NewGraphServiceClientProtocol(prot thrift.Protocol) *GraphServiceClient

+ func (client *GraphServiceClient) Close() error

+ func (client *GraphServiceClient) IsOpen() bool

+ func (client *GraphServiceClient) Open() error

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

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

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

+ func (p *GraphServiceClient) ExecuteJsonWithParameter(sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value) (_r []byte, err error)

+ func (p *GraphServiceClient) ExecuteWithParameter(sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value) (_r *ExecutionResponse, err error)

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

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

+ type GraphServiceClientInterface interface

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

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

+ ExecuteJson func(sessionId int64, stmt []byte) (_r []byte, err error)

+ ExecuteJsonWithParameter func(sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value) (_r []byte, err error)

+ ExecuteWithParameter func(sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value) (_r *ExecutionResponse, err error)

+ Signout func(sessionId int64) (err error)

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

+ type GraphServiceExecuteArgs struct

+ SessionId int64

+ Stmt []byte

+ func NewGraphServiceExecuteArgs() *GraphServiceExecuteArgs

+ func (g *GraphServiceExecuteArgs) SetSessionId(sessionId int64) *GraphServiceExecuteArgs

+ func (g *GraphServiceExecuteArgs) SetStmt(stmt []byte) *GraphServiceExecuteArgs

+ func (p *GraphServiceExecuteArgs) GetSessionId() int64

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

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

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

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

+ func (p *GraphServiceExecuteArgs) String() string

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

+ type GraphServiceExecuteArgsBuilder struct

+ func NewGraphServiceExecuteArgsBuilder() *GraphServiceExecuteArgsBuilder

+ func (g *GraphServiceExecuteArgsBuilder) SessionId(sessionId int64) *GraphServiceExecuteArgsBuilder

+ func (g *GraphServiceExecuteArgsBuilder) Stmt(stmt []byte) *GraphServiceExecuteArgsBuilder

+ func (p GraphServiceExecuteArgsBuilder) Emit() *GraphServiceExecuteArgs

+ type GraphServiceExecuteJsonArgs struct

+ SessionId int64

+ Stmt []byte

+ func NewGraphServiceExecuteJsonArgs() *GraphServiceExecuteJsonArgs

+ func (g *GraphServiceExecuteJsonArgs) SetSessionId(sessionId int64) *GraphServiceExecuteJsonArgs

+ func (g *GraphServiceExecuteJsonArgs) SetStmt(stmt []byte) *GraphServiceExecuteJsonArgs

+ func (p *GraphServiceExecuteJsonArgs) GetSessionId() int64

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

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

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

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

+ func (p *GraphServiceExecuteJsonArgs) String() string

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

+ type GraphServiceExecuteJsonArgsBuilder struct

+ func NewGraphServiceExecuteJsonArgsBuilder() *GraphServiceExecuteJsonArgsBuilder

+ func (g *GraphServiceExecuteJsonArgsBuilder) SessionId(sessionId int64) *GraphServiceExecuteJsonArgsBuilder

+ func (g *GraphServiceExecuteJsonArgsBuilder) Stmt(stmt []byte) *GraphServiceExecuteJsonArgsBuilder

+ func (p GraphServiceExecuteJsonArgsBuilder) Emit() *GraphServiceExecuteJsonArgs

+ type GraphServiceExecuteJsonResult struct

+ Success []byte

+ func NewGraphServiceExecuteJsonResult() *GraphServiceExecuteJsonResult

+ func (g *GraphServiceExecuteJsonResult) SetSuccess(success []byte) *GraphServiceExecuteJsonResult

+ func (p *GraphServiceExecuteJsonResult) Exception() thrift.WritableException

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

+ func (p *GraphServiceExecuteJsonResult) IsSetSuccess() bool

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

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

+ func (p *GraphServiceExecuteJsonResult) String() string

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

+ type GraphServiceExecuteJsonResultBuilder struct

+ func NewGraphServiceExecuteJsonResultBuilder() *GraphServiceExecuteJsonResultBuilder

+ func (g *GraphServiceExecuteJsonResultBuilder) Success(success []byte) *GraphServiceExecuteJsonResultBuilder

+ func (p GraphServiceExecuteJsonResultBuilder) Emit() *GraphServiceExecuteJsonResult

+ type GraphServiceExecuteJsonWithParameterArgs struct

+ ParameterMap map[string]*nebula0.Value

+ SessionId int64

+ Stmt []byte

+ func NewGraphServiceExecuteJsonWithParameterArgs() *GraphServiceExecuteJsonWithParameterArgs

+ func (g *GraphServiceExecuteJsonWithParameterArgs) SetParameterMap(parameterMap map[string]*nebula0.Value) *GraphServiceExecuteJsonWithParameterArgs

+ func (g *GraphServiceExecuteJsonWithParameterArgs) SetSessionId(sessionId int64) *GraphServiceExecuteJsonWithParameterArgs

+ func (g *GraphServiceExecuteJsonWithParameterArgs) SetStmt(stmt []byte) *GraphServiceExecuteJsonWithParameterArgs

+ func (p *GraphServiceExecuteJsonWithParameterArgs) GetParameterMap() map[string]*nebula0.Value

+ func (p *GraphServiceExecuteJsonWithParameterArgs) GetSessionId() int64

+ func (p *GraphServiceExecuteJsonWithParameterArgs) GetStmt() []byte

+ func (p *GraphServiceExecuteJsonWithParameterArgs) Read(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteJsonWithParameterArgs) ReadField1(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteJsonWithParameterArgs) ReadField2(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteJsonWithParameterArgs) ReadField3(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteJsonWithParameterArgs) String() string

+ func (p *GraphServiceExecuteJsonWithParameterArgs) Write(oprot thrift.Protocol) error

+ type GraphServiceExecuteJsonWithParameterArgsBuilder struct

+ func NewGraphServiceExecuteJsonWithParameterArgsBuilder() *GraphServiceExecuteJsonWithParameterArgsBuilder

+ func (g *GraphServiceExecuteJsonWithParameterArgsBuilder) ParameterMap(parameterMap map[string]*nebula0.Value) *GraphServiceExecuteJsonWithParameterArgsBuilder

+ func (g *GraphServiceExecuteJsonWithParameterArgsBuilder) SessionId(sessionId int64) *GraphServiceExecuteJsonWithParameterArgsBuilder

+ func (g *GraphServiceExecuteJsonWithParameterArgsBuilder) Stmt(stmt []byte) *GraphServiceExecuteJsonWithParameterArgsBuilder

+ func (p GraphServiceExecuteJsonWithParameterArgsBuilder) Emit() *GraphServiceExecuteJsonWithParameterArgs

+ type GraphServiceExecuteJsonWithParameterResult struct

+ Success []byte

+ func NewGraphServiceExecuteJsonWithParameterResult() *GraphServiceExecuteJsonWithParameterResult

+ func (g *GraphServiceExecuteJsonWithParameterResult) SetSuccess(success []byte) *GraphServiceExecuteJsonWithParameterResult

+ func (p *GraphServiceExecuteJsonWithParameterResult) Exception() thrift.WritableException

+ func (p *GraphServiceExecuteJsonWithParameterResult) GetSuccess() []byte

+ func (p *GraphServiceExecuteJsonWithParameterResult) IsSetSuccess() bool

+ func (p *GraphServiceExecuteJsonWithParameterResult) Read(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteJsonWithParameterResult) ReadField0(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteJsonWithParameterResult) String() string

+ func (p *GraphServiceExecuteJsonWithParameterResult) Write(oprot thrift.Protocol) error

+ type GraphServiceExecuteJsonWithParameterResultBuilder struct

+ func NewGraphServiceExecuteJsonWithParameterResultBuilder() *GraphServiceExecuteJsonWithParameterResultBuilder

+ func (g *GraphServiceExecuteJsonWithParameterResultBuilder) Success(success []byte) *GraphServiceExecuteJsonWithParameterResultBuilder

+ func (p GraphServiceExecuteJsonWithParameterResultBuilder) Emit() *GraphServiceExecuteJsonWithParameterResult

+ type GraphServiceExecuteResult struct

+ Success *ExecutionResponse

+ func NewGraphServiceExecuteResult() *GraphServiceExecuteResult

+ func (g *GraphServiceExecuteResult) SetSuccess(success *ExecutionResponse) *GraphServiceExecuteResult

+ func (p *GraphServiceExecuteResult) Exception() thrift.WritableException

+ func (p *GraphServiceExecuteResult) GetSuccess() *ExecutionResponse

+ func (p *GraphServiceExecuteResult) IsSetSuccess() bool

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

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

+ func (p *GraphServiceExecuteResult) String() string

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

+ type GraphServiceExecuteResultBuilder struct

+ func NewGraphServiceExecuteResultBuilder() *GraphServiceExecuteResultBuilder

+ func (g *GraphServiceExecuteResultBuilder) Success(success *ExecutionResponse) *GraphServiceExecuteResultBuilder

+ func (p GraphServiceExecuteResultBuilder) Emit() *GraphServiceExecuteResult

+ type GraphServiceExecuteWithParameterArgs struct

+ ParameterMap map[string]*nebula0.Value

+ SessionId int64

+ Stmt []byte

+ func NewGraphServiceExecuteWithParameterArgs() *GraphServiceExecuteWithParameterArgs

+ func (g *GraphServiceExecuteWithParameterArgs) SetParameterMap(parameterMap map[string]*nebula0.Value) *GraphServiceExecuteWithParameterArgs

+ func (g *GraphServiceExecuteWithParameterArgs) SetSessionId(sessionId int64) *GraphServiceExecuteWithParameterArgs

+ func (g *GraphServiceExecuteWithParameterArgs) SetStmt(stmt []byte) *GraphServiceExecuteWithParameterArgs

+ func (p *GraphServiceExecuteWithParameterArgs) GetParameterMap() map[string]*nebula0.Value

+ func (p *GraphServiceExecuteWithParameterArgs) GetSessionId() int64

+ func (p *GraphServiceExecuteWithParameterArgs) GetStmt() []byte

+ func (p *GraphServiceExecuteWithParameterArgs) Read(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithParameterArgs) ReadField1(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithParameterArgs) ReadField2(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithParameterArgs) ReadField3(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithParameterArgs) String() string

+ func (p *GraphServiceExecuteWithParameterArgs) Write(oprot thrift.Protocol) error

+ type GraphServiceExecuteWithParameterArgsBuilder struct

+ func NewGraphServiceExecuteWithParameterArgsBuilder() *GraphServiceExecuteWithParameterArgsBuilder

+ func (g *GraphServiceExecuteWithParameterArgsBuilder) ParameterMap(parameterMap map[string]*nebula0.Value) *GraphServiceExecuteWithParameterArgsBuilder

+ func (g *GraphServiceExecuteWithParameterArgsBuilder) SessionId(sessionId int64) *GraphServiceExecuteWithParameterArgsBuilder

+ func (g *GraphServiceExecuteWithParameterArgsBuilder) Stmt(stmt []byte) *GraphServiceExecuteWithParameterArgsBuilder

+ func (p GraphServiceExecuteWithParameterArgsBuilder) Emit() *GraphServiceExecuteWithParameterArgs

+ type GraphServiceExecuteWithParameterResult struct

+ Success *ExecutionResponse

+ func NewGraphServiceExecuteWithParameterResult() *GraphServiceExecuteWithParameterResult

+ func (g *GraphServiceExecuteWithParameterResult) SetSuccess(success *ExecutionResponse) *GraphServiceExecuteWithParameterResult

+ func (p *GraphServiceExecuteWithParameterResult) Exception() thrift.WritableException

+ func (p *GraphServiceExecuteWithParameterResult) GetSuccess() *ExecutionResponse

+ func (p *GraphServiceExecuteWithParameterResult) IsSetSuccess() bool

+ func (p *GraphServiceExecuteWithParameterResult) Read(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithParameterResult) ReadField0(iprot thrift.Protocol) error

+ func (p *GraphServiceExecuteWithParameterResult) String() string

+ func (p *GraphServiceExecuteWithParameterResult) Write(oprot thrift.Protocol) error

+ type GraphServiceExecuteWithParameterResultBuilder struct

+ func NewGraphServiceExecuteWithParameterResultBuilder() *GraphServiceExecuteWithParameterResultBuilder

+ func (g *GraphServiceExecuteWithParameterResultBuilder) Success(success *ExecutionResponse) *GraphServiceExecuteWithParameterResultBuilder

+ func (p GraphServiceExecuteWithParameterResultBuilder) Emit() *GraphServiceExecuteWithParameterResult

+ type GraphServiceProcessor struct

+ func NewGraphServiceProcessor(handler GraphService) *GraphServiceProcessor

+ func (p *GraphServiceProcessor) AddToFunctionServiceMap(key, service string)

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

+ func (p *GraphServiceProcessor) FunctionServiceMap() map[string]string

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

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

+ type GraphServiceSignoutArgs struct

+ SessionId int64

+ func NewGraphServiceSignoutArgs() *GraphServiceSignoutArgs

+ func (g *GraphServiceSignoutArgs) SetSessionId(sessionId int64) *GraphServiceSignoutArgs

+ func (p *GraphServiceSignoutArgs) GetSessionId() int64

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

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

+ func (p *GraphServiceSignoutArgs) String() string

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

+ type GraphServiceSignoutArgsBuilder struct

+ func NewGraphServiceSignoutArgsBuilder() *GraphServiceSignoutArgsBuilder

+ func (g *GraphServiceSignoutArgsBuilder) SessionId(sessionId int64) *GraphServiceSignoutArgsBuilder

+ func (p GraphServiceSignoutArgsBuilder) Emit() *GraphServiceSignoutArgs

+ type GraphServiceThreadsafeClient struct

+ CC thrift.ClientConn

+ Mu sync.Mutex

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

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

+ func NewGraphServiceThreadsafeClientProtocol(prot thrift.Protocol) *GraphServiceThreadsafeClient

+ func (client *GraphServiceThreadsafeClient) Close() error

+ func (client *GraphServiceThreadsafeClient) IsOpen() bool

+ func (client *GraphServiceThreadsafeClient) Open() error

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

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

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

+ func (p *GraphServiceThreadsafeClient) ExecuteJsonWithParameter(sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value) (_r []byte, err error)

+ func (p *GraphServiceThreadsafeClient) ExecuteWithParameter(sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value) (_r *ExecutionResponse, err error)

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

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

+ type GraphServiceVerifyClientVersionArgs struct

+ Req *VerifyClientVersionReq

+ func NewGraphServiceVerifyClientVersionArgs() *GraphServiceVerifyClientVersionArgs

+ func (g *GraphServiceVerifyClientVersionArgs) SetReq(req *VerifyClientVersionReq) *GraphServiceVerifyClientVersionArgs

+ func (p *GraphServiceVerifyClientVersionArgs) GetReq() *VerifyClientVersionReq

+ func (p *GraphServiceVerifyClientVersionArgs) IsSetReq() bool

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

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

+ func (p *GraphServiceVerifyClientVersionArgs) String() string

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

+ type GraphServiceVerifyClientVersionArgsBuilder struct

+ func NewGraphServiceVerifyClientVersionArgsBuilder() *GraphServiceVerifyClientVersionArgsBuilder

+ func (g *GraphServiceVerifyClientVersionArgsBuilder) Req(req *VerifyClientVersionReq) *GraphServiceVerifyClientVersionArgsBuilder

+ func (p GraphServiceVerifyClientVersionArgsBuilder) Emit() *GraphServiceVerifyClientVersionArgs

+ type GraphServiceVerifyClientVersionResult struct

+ Success *VerifyClientVersionResp

+ func NewGraphServiceVerifyClientVersionResult() *GraphServiceVerifyClientVersionResult

+ func (g *GraphServiceVerifyClientVersionResult) SetSuccess(success *VerifyClientVersionResp) *GraphServiceVerifyClientVersionResult

+ func (p *GraphServiceVerifyClientVersionResult) Exception() thrift.WritableException

+ func (p *GraphServiceVerifyClientVersionResult) GetSuccess() *VerifyClientVersionResp

+ func (p *GraphServiceVerifyClientVersionResult) IsSetSuccess() bool

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

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

+ func (p *GraphServiceVerifyClientVersionResult) String() string

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

+ type GraphServiceVerifyClientVersionResultBuilder struct

+ func NewGraphServiceVerifyClientVersionResultBuilder() *GraphServiceVerifyClientVersionResultBuilder

+ func (g *GraphServiceVerifyClientVersionResultBuilder) Success(success *VerifyClientVersionResp) *GraphServiceVerifyClientVersionResultBuilder

+ func (p GraphServiceVerifyClientVersionResultBuilder) Emit() *GraphServiceVerifyClientVersionResult

+ type Pair struct

+ Key []byte

+ Value []byte

+ func NewPair() *Pair

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

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

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

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

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

+ func (p *Pair) SetKey(key []byte) *Pair

+ func (p *Pair) SetValue(value []byte) *Pair

+ func (p *Pair) String() string

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

+ type PairBuilder struct

+ func NewPairBuilder() *PairBuilder

+ func (p *PairBuilder) Key(key []byte) *PairBuilder

+ func (p *PairBuilder) Value(value []byte) *PairBuilder

+ func (p PairBuilder) Emit() *Pair

+ type PlanDescription struct

+ Format []byte

+ NodeIndexMap map[int64]int64

+ OptimizeTimeInUs int32

+ PlanNodeDescs []*PlanNodeDescription

+ var ExecutionResponse_PlanDesc_DEFAULT *PlanDescription

+ func NewPlanDescription() *PlanDescription

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

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

+ func (p *PlanDescription) GetOptimizeTimeInUs() int32

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

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

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

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

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

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

+ func (p *PlanDescription) SetFormat(format []byte) *PlanDescription

+ func (p *PlanDescription) SetNodeIndexMap(nodeIndexMap map[int64]int64) *PlanDescription

+ func (p *PlanDescription) SetOptimizeTimeInUs(optimizeTimeInUs int32) *PlanDescription

+ func (p *PlanDescription) SetPlanNodeDescs(planNodeDescs []*PlanNodeDescription) *PlanDescription

+ func (p *PlanDescription) String() string

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

+ type PlanDescriptionBuilder struct

+ func NewPlanDescriptionBuilder() *PlanDescriptionBuilder

+ func (p *PlanDescriptionBuilder) Format(format []byte) *PlanDescriptionBuilder

+ func (p *PlanDescriptionBuilder) NodeIndexMap(nodeIndexMap map[int64]int64) *PlanDescriptionBuilder

+ func (p *PlanDescriptionBuilder) OptimizeTimeInUs(optimizeTimeInUs int32) *PlanDescriptionBuilder

+ func (p *PlanDescriptionBuilder) PlanNodeDescs(planNodeDescs []*PlanNodeDescription) *PlanDescriptionBuilder

+ func (p PlanDescriptionBuilder) Emit() *PlanDescription

+ type PlanNodeBranchInfo struct

+ ConditionNodeID int64

+ IsDoBranch bool

+ var PlanNodeDescription_BranchInfo_DEFAULT *PlanNodeBranchInfo

+ func NewPlanNodeBranchInfo() *PlanNodeBranchInfo

+ func (p *PlanNodeBranchInfo) GetConditionNodeID() int64

+ func (p *PlanNodeBranchInfo) GetIsDoBranch() bool

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

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

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

+ func (p *PlanNodeBranchInfo) SetConditionNodeID(conditionNodeID int64) *PlanNodeBranchInfo

+ func (p *PlanNodeBranchInfo) SetIsDoBranch(isDoBranch bool) *PlanNodeBranchInfo

+ func (p *PlanNodeBranchInfo) String() string

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

+ type PlanNodeBranchInfoBuilder struct

+ func NewPlanNodeBranchInfoBuilder() *PlanNodeBranchInfoBuilder

+ func (p *PlanNodeBranchInfoBuilder) ConditionNodeID(conditionNodeID int64) *PlanNodeBranchInfoBuilder

+ func (p *PlanNodeBranchInfoBuilder) IsDoBranch(isDoBranch bool) *PlanNodeBranchInfoBuilder

+ func (p PlanNodeBranchInfoBuilder) Emit() *PlanNodeBranchInfo

+ type PlanNodeDescription struct

+ BranchInfo *PlanNodeBranchInfo

+ Dependencies []int64

+ Description []*Pair

+ Id int64

+ Name []byte

+ OutputVar []byte

+ Profiles []*ProfilingStats

+ func NewPlanNodeDescription() *PlanNodeDescription

+ func (p *PlanNodeDescription) GetBranchInfo() *PlanNodeBranchInfo

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

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

+ func (p *PlanNodeDescription) GetId() int64

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

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

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

+ func (p *PlanNodeDescription) IsSetBranchInfo() bool

+ func (p *PlanNodeDescription) IsSetDependencies() bool

+ func (p *PlanNodeDescription) IsSetDescription() bool

+ func (p *PlanNodeDescription) IsSetProfiles() bool

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

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

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

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

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

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

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

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

+ func (p *PlanNodeDescription) SetBranchInfo(branchInfo *PlanNodeBranchInfo) *PlanNodeDescription

+ func (p *PlanNodeDescription) SetDependencies(dependencies []int64) *PlanNodeDescription

+ func (p *PlanNodeDescription) SetDescription(description []*Pair) *PlanNodeDescription

+ func (p *PlanNodeDescription) SetId(id int64) *PlanNodeDescription

+ func (p *PlanNodeDescription) SetName(name []byte) *PlanNodeDescription

+ func (p *PlanNodeDescription) SetOutputVar(outputVar []byte) *PlanNodeDescription

+ func (p *PlanNodeDescription) SetProfiles(profiles []*ProfilingStats) *PlanNodeDescription

+ func (p *PlanNodeDescription) String() string

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

+ type PlanNodeDescriptionBuilder struct

+ func NewPlanNodeDescriptionBuilder() *PlanNodeDescriptionBuilder

+ func (p *PlanNodeDescriptionBuilder) BranchInfo(branchInfo *PlanNodeBranchInfo) *PlanNodeDescriptionBuilder

+ func (p *PlanNodeDescriptionBuilder) Dependencies(dependencies []int64) *PlanNodeDescriptionBuilder

+ func (p *PlanNodeDescriptionBuilder) Description(description []*Pair) *PlanNodeDescriptionBuilder

+ func (p *PlanNodeDescriptionBuilder) Id(id int64) *PlanNodeDescriptionBuilder

+ func (p *PlanNodeDescriptionBuilder) Name(name []byte) *PlanNodeDescriptionBuilder

+ func (p *PlanNodeDescriptionBuilder) OutputVar(outputVar []byte) *PlanNodeDescriptionBuilder

+ func (p *PlanNodeDescriptionBuilder) Profiles(profiles []*ProfilingStats) *PlanNodeDescriptionBuilder

+ func (p PlanNodeDescriptionBuilder) Emit() *PlanNodeDescription

+ type ProfilingStats struct

+ ExecDurationInUs int64

+ OtherStats map[string][]byte

+ Rows int64

+ TotalDurationInUs int64

+ func NewProfilingStats() *ProfilingStats

+ func (p *ProfilingStats) GetExecDurationInUs() int64

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

+ func (p *ProfilingStats) GetRows() int64

+ func (p *ProfilingStats) GetTotalDurationInUs() int64

+ func (p *ProfilingStats) IsSetOtherStats() bool

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

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

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

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

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

+ func (p *ProfilingStats) SetExecDurationInUs(execDurationInUs int64) *ProfilingStats

+ func (p *ProfilingStats) SetOtherStats(otherStats map[string][]byte) *ProfilingStats

+ func (p *ProfilingStats) SetRows(rows int64) *ProfilingStats

+ func (p *ProfilingStats) SetTotalDurationInUs(totalDurationInUs int64) *ProfilingStats

+ func (p *ProfilingStats) String() string

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

+ type ProfilingStatsBuilder struct

+ func NewProfilingStatsBuilder() *ProfilingStatsBuilder

+ func (p *ProfilingStatsBuilder) ExecDurationInUs(execDurationInUs int64) *ProfilingStatsBuilder

+ func (p *ProfilingStatsBuilder) OtherStats(otherStats map[string][]byte) *ProfilingStatsBuilder

+ func (p *ProfilingStatsBuilder) Rows(rows int64) *ProfilingStatsBuilder

+ func (p *ProfilingStatsBuilder) TotalDurationInUs(totalDurationInUs int64) *ProfilingStatsBuilder

+ func (p ProfilingStatsBuilder) Emit() *ProfilingStats

+ type VerifyClientVersionReq struct

+ Version []byte

+ var GraphServiceVerifyClientVersionArgs_Req_DEFAULT *VerifyClientVersionReq

+ func NewVerifyClientVersionReq() *VerifyClientVersionReq

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

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

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

+ func (p *VerifyClientVersionReq) String() string

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

+ func (v *VerifyClientVersionReq) SetVersion(version []byte) *VerifyClientVersionReq

+ type VerifyClientVersionReqBuilder struct

+ func NewVerifyClientVersionReqBuilder() *VerifyClientVersionReqBuilder

+ func (p VerifyClientVersionReqBuilder) Emit() *VerifyClientVersionReq

+ func (v *VerifyClientVersionReqBuilder) Version(version []byte) *VerifyClientVersionReqBuilder

+ type VerifyClientVersionResp struct

+ ErrorCode nebula0.ErrorCode

+ ErrorMsg []byte

+ var GraphServiceVerifyClientVersionResult_Success_DEFAULT *VerifyClientVersionResp

+ func NewVerifyClientVersionResp() *VerifyClientVersionResp

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

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

+ func (p *VerifyClientVersionResp) IsSetErrorMsg() bool

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

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

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

+ func (p *VerifyClientVersionResp) String() string

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

+ func (v *VerifyClientVersionResp) SetErrorCode(errorCode nebula0.ErrorCode) *VerifyClientVersionResp

+ func (v *VerifyClientVersionResp) SetErrorMsg(errorMsg []byte) *VerifyClientVersionResp

+ type VerifyClientVersionRespBuilder struct

+ func NewVerifyClientVersionRespBuilder() *VerifyClientVersionRespBuilder

+ func (p VerifyClientVersionRespBuilder) Emit() *VerifyClientVersionResp

+ func (v *VerifyClientVersionRespBuilder) ErrorCode(errorCode nebula0.ErrorCode) *VerifyClientVersionRespBuilder

+ func (v *VerifyClientVersionRespBuilder) ErrorMsg(errorMsg []byte) *VerifyClientVersionRespBuilder

Other modules containing this package

github.com/vesoft-inc/nebula-go

github.com/vesoft-inc/nebula-go/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL