graph

package
v3.3.1 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2022 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 GraphServiceExecuteJsonWithParameterResult_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,optional" db:"error_msg" json:"error_msg,omitempty"`
	SessionID             *int64            `thrift:"session_id,3,optional" db:"session_id" json:"session_id,omitempty"`
	TimeZoneOffsetSeconds *int32            `thrift:"time_zone_offset_seconds,4,optional" db:"time_zone_offset_seconds" json:"time_zone_offset_seconds,omitempty"`
	TimeZoneName          []byte            `thrift:"time_zone_name,5,optional" 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) SetErrorCode 

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

func (*AuthResponse) SetErrorMsg 

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

func (*AuthResponse) SetSessionID 

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

func (*AuthResponse) SetTimeZoneName 

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

func (*AuthResponse) SetTimeZoneOffsetSeconds 

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

func (*AuthResponse) String 

func (p *AuthResponse) String() string

func (*AuthResponse) Write 

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

type AuthResponseBuilder 

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

func NewAuthResponseBuilder 

func NewAuthResponseBuilder() *AuthResponseBuilder

func (AuthResponseBuilder) Emit 

func (p AuthResponseBuilder) Emit() *AuthResponse

func (*AuthResponseBuilder) ErrorCode 

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

func (*AuthResponseBuilder) ErrorMsg 

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

func (*AuthResponseBuilder) SessionID 

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

func (*AuthResponseBuilder) TimeZoneName 

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

func (*AuthResponseBuilder) TimeZoneOffsetSeconds 

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

type ExecutionResponse 

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

Attributes:

  • ErrorCode
  • LatencyInUs
  • Data
  • SpaceName
  • ErrorMsg
  • PlanDesc
  • Comment
var GraphServiceExecuteResult_Success_DEFAULT *ExecutionResponse
var GraphServiceExecuteWithParameterResult_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() int64

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

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

func (*ExecutionResponse) SetData 

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

func (*ExecutionResponse) SetErrorCode 

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

func (*ExecutionResponse) SetErrorMsg 

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

func (*ExecutionResponse) SetLatencyInUs 

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

func (*ExecutionResponse) SetPlanDesc 

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

func (*ExecutionResponse) SetSpaceName 

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

func (*ExecutionResponse) String 

func (p *ExecutionResponse) String() string

func (*ExecutionResponse) Write 

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

type ExecutionResponseBuilder 

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

func NewExecutionResponseBuilder 

func NewExecutionResponseBuilder() *ExecutionResponseBuilder

func (*ExecutionResponseBuilder) Comment 

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

func (*ExecutionResponseBuilder) Data 

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

func (ExecutionResponseBuilder) Emit 

func (p ExecutionResponseBuilder) Emit() *ExecutionResponse

func (*ExecutionResponseBuilder) ErrorCode 

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

func (*ExecutionResponseBuilder) ErrorMsg 

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

func (*ExecutionResponseBuilder) LatencyInUs 

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

func (*ExecutionResponseBuilder) PlanDesc 

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

func (*ExecutionResponseBuilder) SpaceName 

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

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
	//  - ParameterMap
	ExecuteWithParameter(ctx context.Context, sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value) (_r *ExecutionResponse, err error)
	// Parameters:
	//  - SessionId
	//  - Stmt
	ExecuteJson(ctx context.Context, sessionId int64, stmt []byte) (_r []byte, err error)
	// Parameters:
	//  - SessionId
	//  - Stmt
	//  - ParameterMap
	ExecuteJsonWithParameter(ctx context.Context, sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value) (_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) SetPassword 

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

func (*GraphServiceAuthenticateArgs) SetUsername 

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

func (*GraphServiceAuthenticateArgs) String 

func (p *GraphServiceAuthenticateArgs) String() string

func (*GraphServiceAuthenticateArgs) Write 

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

type GraphServiceAuthenticateArgsBuilder 

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

func NewGraphServiceAuthenticateArgsBuilder 

func NewGraphServiceAuthenticateArgsBuilder() *GraphServiceAuthenticateArgsBuilder

func (GraphServiceAuthenticateArgsBuilder) Emit 

func (p GraphServiceAuthenticateArgsBuilder) Emit() *GraphServiceAuthenticateArgs

func (*GraphServiceAuthenticateArgsBuilder) Password 

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

func (*GraphServiceAuthenticateArgsBuilder) Username 

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

type GraphServiceAuthenticateResult 

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

Attributes:

  • Success

func NewGraphServiceAuthenticateResult 

func NewGraphServiceAuthenticateResult() *GraphServiceAuthenticateResult

func (*GraphServiceAuthenticateResult) Exception 

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

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

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

func (*GraphServiceAuthenticateResult) String 

func (p *GraphServiceAuthenticateResult) String() string

func (*GraphServiceAuthenticateResult) Write 

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

type GraphServiceAuthenticateResultBuilder 

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

func NewGraphServiceAuthenticateResultBuilder 

func NewGraphServiceAuthenticateResultBuilder() *GraphServiceAuthenticateResultBuilder

func (GraphServiceAuthenticateResultBuilder) Emit 

func (p GraphServiceAuthenticateResultBuilder) Emit() *GraphServiceAuthenticateResult

func (*GraphServiceAuthenticateResultBuilder) Success 

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

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

func (p *GraphServiceChannelClient) ExecuteJsonWithParameter(ctx context.Context, sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value) (_r []byte, err error)

Parameters:

  • SessionId
  • Stmt
  • ParameterMap

func (*GraphServiceChannelClient) ExecuteWithParameter 

func (p *GraphServiceChannelClient) ExecuteWithParameter(ctx context.Context, sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value) (_r *ExecutionResponse, err error)

Parameters:

  • SessionId
  • Stmt
  • ParameterMap

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 

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

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

Parameters:

  • SessionId
  • Stmt
  • ParameterMap

func (*GraphServiceClient) ExecuteWithParameter 

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

Parameters:

  • SessionId
  • Stmt
  • ParameterMap

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 

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
	//  - ParameterMap
	ExecuteWithParameter(sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value) (_r *ExecutionResponse, err error)
	// Parameters:
	//  - SessionId
	//  - Stmt
	ExecuteJson(sessionId int64, stmt []byte) (_r []byte, err error)
	// Parameters:
	//  - SessionId
	//  - Stmt
	//  - ParameterMap
	ExecuteJsonWithParameter(sessionId int64, stmt []byte, parameterMap map[string]*nebula0.Value) (_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) SetSessionId 

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

func (*GraphServiceExecuteArgs) SetStmt 

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

func (*GraphServiceExecuteArgs) String 

func (p *GraphServiceExecuteArgs) String() string

func (*GraphServiceExecuteArgs) Write 

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

type GraphServiceExecuteArgsBuilder 

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

func NewGraphServiceExecuteArgsBuilder 

func NewGraphServiceExecuteArgsBuilder() *GraphServiceExecuteArgsBuilder

func (GraphServiceExecuteArgsBuilder) Emit 

func (p GraphServiceExecuteArgsBuilder) Emit() *GraphServiceExecuteArgs

func (*GraphServiceExecuteArgsBuilder) SessionId 

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

func (*GraphServiceExecuteArgsBuilder) Stmt 

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

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

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

func (*GraphServiceExecuteJsonArgs) SetStmt 

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

func (*GraphServiceExecuteJsonArgs) String 

func (p *GraphServiceExecuteJsonArgs) String() string

func (*GraphServiceExecuteJsonArgs) Write 

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

type GraphServiceExecuteJsonArgsBuilder 

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

func NewGraphServiceExecuteJsonArgsBuilder 

func NewGraphServiceExecuteJsonArgsBuilder() *GraphServiceExecuteJsonArgsBuilder

func (GraphServiceExecuteJsonArgsBuilder) Emit 

func (p GraphServiceExecuteJsonArgsBuilder) Emit() *GraphServiceExecuteJsonArgs

func (*GraphServiceExecuteJsonArgsBuilder) SessionId 

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

func (*GraphServiceExecuteJsonArgsBuilder) Stmt 

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

type GraphServiceExecuteJsonResult 

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

Attributes:

  • Success

func NewGraphServiceExecuteJsonResult 

func NewGraphServiceExecuteJsonResult() *GraphServiceExecuteJsonResult

func (*GraphServiceExecuteJsonResult) Exception 

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

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

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

func (*GraphServiceExecuteJsonResult) String 

func (p *GraphServiceExecuteJsonResult) String() string

func (*GraphServiceExecuteJsonResult) Write 

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

type GraphServiceExecuteJsonResultBuilder 

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

func NewGraphServiceExecuteJsonResultBuilder 

func NewGraphServiceExecuteJsonResultBuilder() *GraphServiceExecuteJsonResultBuilder

func (GraphServiceExecuteJsonResultBuilder) Emit 

func (p GraphServiceExecuteJsonResultBuilder) Emit() *GraphServiceExecuteJsonResult

func (*GraphServiceExecuteJsonResultBuilder) Success 

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

type GraphServiceExecuteJsonWithParameterArgs 

type GraphServiceExecuteJsonWithParameterArgs struct {
	thrift.IRequest
	SessionId    int64                     `thrift:"sessionId,1" db:"sessionId" json:"sessionId"`
	Stmt         []byte                    `thrift:"stmt,2" db:"stmt" json:"stmt"`
	ParameterMap map[string]*nebula0.Value `thrift:"parameterMap,3" db:"parameterMap" json:"parameterMap"`
}

Attributes:

  • SessionId
  • Stmt
  • ParameterMap

func NewGraphServiceExecuteJsonWithParameterArgs 

func NewGraphServiceExecuteJsonWithParameterArgs() *GraphServiceExecuteJsonWithParameterArgs

func (*GraphServiceExecuteJsonWithParameterArgs) GetParameterMap 

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

func (*GraphServiceExecuteJsonWithParameterArgs) GetSessionId 

func (p *GraphServiceExecuteJsonWithParameterArgs) GetSessionId() int64

func (*GraphServiceExecuteJsonWithParameterArgs) GetStmt 

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

func (*GraphServiceExecuteJsonWithParameterArgs) Read 

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

func (*GraphServiceExecuteJsonWithParameterArgs) ReadField1 

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

func (*GraphServiceExecuteJsonWithParameterArgs) ReadField2 

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

func (*GraphServiceExecuteJsonWithParameterArgs) ReadField3 

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

func (*GraphServiceExecuteJsonWithParameterArgs) SetParameterMap 

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

func (*GraphServiceExecuteJsonWithParameterArgs) SetSessionId 

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

func (*GraphServiceExecuteJsonWithParameterArgs) SetStmt 

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

func (*GraphServiceExecuteJsonWithParameterArgs) String 

func (p *GraphServiceExecuteJsonWithParameterArgs) String() string

func (*GraphServiceExecuteJsonWithParameterArgs) Write 

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

type GraphServiceExecuteJsonWithParameterArgsBuilder 

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

func NewGraphServiceExecuteJsonWithParameterArgsBuilder 

func NewGraphServiceExecuteJsonWithParameterArgsBuilder() *GraphServiceExecuteJsonWithParameterArgsBuilder

func (GraphServiceExecuteJsonWithParameterArgsBuilder) Emit 

func (p GraphServiceExecuteJsonWithParameterArgsBuilder) Emit() *GraphServiceExecuteJsonWithParameterArgs

func (*GraphServiceExecuteJsonWithParameterArgsBuilder) ParameterMap 

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

func (*GraphServiceExecuteJsonWithParameterArgsBuilder) SessionId 

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

func (*GraphServiceExecuteJsonWithParameterArgsBuilder) Stmt 

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

type GraphServiceExecuteJsonWithParameterResult 

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

Attributes:

  • Success

func NewGraphServiceExecuteJsonWithParameterResult 

func NewGraphServiceExecuteJsonWithParameterResult() *GraphServiceExecuteJsonWithParameterResult

func (*GraphServiceExecuteJsonWithParameterResult) Exception 

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

func (*GraphServiceExecuteJsonWithParameterResult) GetSuccess 

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

func (*GraphServiceExecuteJsonWithParameterResult) IsSetSuccess 

func (p *GraphServiceExecuteJsonWithParameterResult) IsSetSuccess() bool

func (*GraphServiceExecuteJsonWithParameterResult) Read 

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

func (*GraphServiceExecuteJsonWithParameterResult) ReadField0 

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

func (*GraphServiceExecuteJsonWithParameterResult) SetSuccess 

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

func (*GraphServiceExecuteJsonWithParameterResult) String 

func (p *GraphServiceExecuteJsonWithParameterResult) String() string

func (*GraphServiceExecuteJsonWithParameterResult) Write 

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

type GraphServiceExecuteJsonWithParameterResultBuilder 

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

func NewGraphServiceExecuteJsonWithParameterResultBuilder 

func NewGraphServiceExecuteJsonWithParameterResultBuilder() *GraphServiceExecuteJsonWithParameterResultBuilder

func (GraphServiceExecuteJsonWithParameterResultBuilder) Emit 

func (p GraphServiceExecuteJsonWithParameterResultBuilder) Emit() *GraphServiceExecuteJsonWithParameterResult

func (*GraphServiceExecuteJsonWithParameterResultBuilder) Success 

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

type GraphServiceExecuteResult 

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

Attributes:

  • Success

func NewGraphServiceExecuteResult 

func NewGraphServiceExecuteResult() *GraphServiceExecuteResult

func (*GraphServiceExecuteResult) Exception 

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

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

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

func (*GraphServiceExecuteResult) String 

func (p *GraphServiceExecuteResult) String() string

func (*GraphServiceExecuteResult) Write 

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

type GraphServiceExecuteResultBuilder 

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

func NewGraphServiceExecuteResultBuilder 

func NewGraphServiceExecuteResultBuilder() *GraphServiceExecuteResultBuilder

func (GraphServiceExecuteResultBuilder) Emit 

func (p GraphServiceExecuteResultBuilder) Emit() *GraphServiceExecuteResult

func (*GraphServiceExecuteResultBuilder) Success 

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

type GraphServiceExecuteWithParameterArgs 

type GraphServiceExecuteWithParameterArgs struct {
	thrift.IRequest
	SessionId    int64                     `thrift:"sessionId,1" db:"sessionId" json:"sessionId"`
	Stmt         []byte                    `thrift:"stmt,2" db:"stmt" json:"stmt"`
	ParameterMap map[string]*nebula0.Value `thrift:"parameterMap,3" db:"parameterMap" json:"parameterMap"`
}

Attributes:

  • SessionId
  • Stmt
  • ParameterMap

func NewGraphServiceExecuteWithParameterArgs 

func NewGraphServiceExecuteWithParameterArgs() *GraphServiceExecuteWithParameterArgs

func (*GraphServiceExecuteWithParameterArgs) GetParameterMap 

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

func (*GraphServiceExecuteWithParameterArgs) GetSessionId 

func (p *GraphServiceExecuteWithParameterArgs) GetSessionId() int64

func (*GraphServiceExecuteWithParameterArgs) GetStmt 

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

func (*GraphServiceExecuteWithParameterArgs) Read 

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

func (*GraphServiceExecuteWithParameterArgs) ReadField1 

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

func (*GraphServiceExecuteWithParameterArgs) ReadField2 

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

func (*GraphServiceExecuteWithParameterArgs) ReadField3 

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

func (*GraphServiceExecuteWithParameterArgs) SetParameterMap 

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

func (*GraphServiceExecuteWithParameterArgs) SetSessionId 

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

func (*GraphServiceExecuteWithParameterArgs) SetStmt 

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

func (*GraphServiceExecuteWithParameterArgs) String 

func (p *GraphServiceExecuteWithParameterArgs) String() string

func (*GraphServiceExecuteWithParameterArgs) Write 

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

type GraphServiceExecuteWithParameterArgsBuilder 

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

func NewGraphServiceExecuteWithParameterArgsBuilder 

func NewGraphServiceExecuteWithParameterArgsBuilder() *GraphServiceExecuteWithParameterArgsBuilder

func (GraphServiceExecuteWithParameterArgsBuilder) Emit 

func (p GraphServiceExecuteWithParameterArgsBuilder) Emit() *GraphServiceExecuteWithParameterArgs

func (*GraphServiceExecuteWithParameterArgsBuilder) ParameterMap 

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

func (*GraphServiceExecuteWithParameterArgsBuilder) SessionId 

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

func (*GraphServiceExecuteWithParameterArgsBuilder) Stmt 

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

type GraphServiceExecuteWithParameterResult 

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

Attributes:

  • Success

func NewGraphServiceExecuteWithParameterResult 

func NewGraphServiceExecuteWithParameterResult() *GraphServiceExecuteWithParameterResult

func (*GraphServiceExecuteWithParameterResult) Exception 

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

func (*GraphServiceExecuteWithParameterResult) GetSuccess 

func (p *GraphServiceExecuteWithParameterResult) GetSuccess() *ExecutionResponse

func (*GraphServiceExecuteWithParameterResult) IsSetSuccess 

func (p *GraphServiceExecuteWithParameterResult) IsSetSuccess() bool

func (*GraphServiceExecuteWithParameterResult) Read 

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

func (*GraphServiceExecuteWithParameterResult) ReadField0 

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

func (*GraphServiceExecuteWithParameterResult) SetSuccess 

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

func (*GraphServiceExecuteWithParameterResult) String 

func (p *GraphServiceExecuteWithParameterResult) String() string

func (*GraphServiceExecuteWithParameterResult) Write 

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

type GraphServiceExecuteWithParameterResultBuilder 

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

func NewGraphServiceExecuteWithParameterResultBuilder 

func NewGraphServiceExecuteWithParameterResultBuilder() *GraphServiceExecuteWithParameterResultBuilder

func (GraphServiceExecuteWithParameterResultBuilder) Emit 

func (p GraphServiceExecuteWithParameterResultBuilder) Emit() *GraphServiceExecuteWithParameterResult

func (*GraphServiceExecuteWithParameterResultBuilder) Success 

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

type GraphServiceProcessor 

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

func NewGraphServiceProcessor 

func NewGraphServiceProcessor(handler GraphService) *GraphServiceProcessor

func (*GraphServiceProcessor) AddToFunctionServiceMap 

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

func (*GraphServiceProcessor) AddToProcessorMap 

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

func (*GraphServiceProcessor) FunctionServiceMap 

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

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

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

func (*GraphServiceSignoutArgs) String 

func (p *GraphServiceSignoutArgs) String() string

func (*GraphServiceSignoutArgs) Write 

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

type GraphServiceSignoutArgsBuilder 

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

func NewGraphServiceSignoutArgsBuilder 

func NewGraphServiceSignoutArgsBuilder() *GraphServiceSignoutArgsBuilder

func (GraphServiceSignoutArgsBuilder) Emit 

func (p GraphServiceSignoutArgsBuilder) Emit() *GraphServiceSignoutArgs

func (*GraphServiceSignoutArgsBuilder) SessionId 

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

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

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

Parameters:

  • SessionId
  • Stmt
  • ParameterMap

func (*GraphServiceThreadsafeClient) ExecuteWithParameter 

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

Parameters:

  • SessionId
  • Stmt
  • ParameterMap

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 

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

Parameters:

  • Req

type GraphServiceVerifyClientVersionArgs 

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

Attributes:

  • Req

func NewGraphServiceVerifyClientVersionArgs 

func NewGraphServiceVerifyClientVersionArgs() *GraphServiceVerifyClientVersionArgs

func (*GraphServiceVerifyClientVersionArgs) GetReq 

func (p *GraphServiceVerifyClientVersionArgs) GetReq() *VerifyClientVersionReq

func (*GraphServiceVerifyClientVersionArgs) IsSetReq 

func (p *GraphServiceVerifyClientVersionArgs) IsSetReq() bool

func (*GraphServiceVerifyClientVersionArgs) Read 

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

func (*GraphServiceVerifyClientVersionArgs) ReadField1 

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

func (*GraphServiceVerifyClientVersionArgs) SetReq 

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

func (*GraphServiceVerifyClientVersionArgs) String 

func (p *GraphServiceVerifyClientVersionArgs) String() string

func (*GraphServiceVerifyClientVersionArgs) Write 

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

type GraphServiceVerifyClientVersionArgsBuilder 

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

func NewGraphServiceVerifyClientVersionArgsBuilder 

func NewGraphServiceVerifyClientVersionArgsBuilder() *GraphServiceVerifyClientVersionArgsBuilder

func (GraphServiceVerifyClientVersionArgsBuilder) Emit 

func (p GraphServiceVerifyClientVersionArgsBuilder) Emit() *GraphServiceVerifyClientVersionArgs

func (*GraphServiceVerifyClientVersionArgsBuilder) Req 

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

type GraphServiceVerifyClientVersionResult 

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

Attributes:

  • Success

func NewGraphServiceVerifyClientVersionResult 

func NewGraphServiceVerifyClientVersionResult() *GraphServiceVerifyClientVersionResult

func (*GraphServiceVerifyClientVersionResult) Exception 

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

func (*GraphServiceVerifyClientVersionResult) GetSuccess 

func (p *GraphServiceVerifyClientVersionResult) GetSuccess() *VerifyClientVersionResp

func (*GraphServiceVerifyClientVersionResult) IsSetSuccess 

func (p *GraphServiceVerifyClientVersionResult) IsSetSuccess() bool

func (*GraphServiceVerifyClientVersionResult) Read 

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

func (*GraphServiceVerifyClientVersionResult) ReadField0 

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

func (*GraphServiceVerifyClientVersionResult) SetSuccess 

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

func (*GraphServiceVerifyClientVersionResult) String 

func (p *GraphServiceVerifyClientVersionResult) String() string

func (*GraphServiceVerifyClientVersionResult) Write 

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

type GraphServiceVerifyClientVersionResultBuilder 

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

func NewGraphServiceVerifyClientVersionResultBuilder 

func NewGraphServiceVerifyClientVersionResultBuilder() *GraphServiceVerifyClientVersionResultBuilder

func (GraphServiceVerifyClientVersionResultBuilder) Emit 

func (p GraphServiceVerifyClientVersionResultBuilder) Emit() *GraphServiceVerifyClientVersionResult

func (*GraphServiceVerifyClientVersionResultBuilder) Success 

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

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

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

func (*Pair) SetValue 

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

func (*Pair) String 

func (p *Pair) String() string

func (*Pair) Write 

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

type PairBuilder 

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

func NewPairBuilder 

func NewPairBuilder() *PairBuilder

func (PairBuilder) Emit 

func (p PairBuilder) Emit() *Pair

func (*PairBuilder) Key 

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

func (*PairBuilder) Value 

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

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

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

func (*PlanDescription) SetNodeIndexMap 

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

func (*PlanDescription) SetOptimizeTimeInUs 

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

func (*PlanDescription) SetPlanNodeDescs 

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

func (*PlanDescription) String 

func (p *PlanDescription) String() string

func (*PlanDescription) Write 

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

type PlanDescriptionBuilder 

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

func NewPlanDescriptionBuilder 

func NewPlanDescriptionBuilder() *PlanDescriptionBuilder

func (PlanDescriptionBuilder) Emit 

func (p PlanDescriptionBuilder) Emit() *PlanDescription

func (*PlanDescriptionBuilder) Format 

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

func (*PlanDescriptionBuilder) NodeIndexMap 

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

func (*PlanDescriptionBuilder) OptimizeTimeInUs 

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

func (*PlanDescriptionBuilder) PlanNodeDescs 

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

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

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

func (*PlanNodeBranchInfo) SetIsDoBranch 

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

func (*PlanNodeBranchInfo) String 

func (p *PlanNodeBranchInfo) String() string

func (*PlanNodeBranchInfo) Write 

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

type PlanNodeBranchInfoBuilder 

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

func NewPlanNodeBranchInfoBuilder 

func NewPlanNodeBranchInfoBuilder() *PlanNodeBranchInfoBuilder

func (*PlanNodeBranchInfoBuilder) ConditionNodeID 

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

func (PlanNodeBranchInfoBuilder) Emit 

func (p PlanNodeBranchInfoBuilder) Emit() *PlanNodeBranchInfo

func (*PlanNodeBranchInfoBuilder) IsDoBranch 

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

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,optional" db:"description" json:"description,omitempty"`
	Profiles     []*ProfilingStats   `thrift:"profiles,5,optional" db:"profiles" json:"profiles,omitempty"`
	BranchInfo   *PlanNodeBranchInfo `thrift:"branch_info,6,optional" db:"branch_info" json:"branch_info,omitempty"`
	Dependencies []int64             `thrift:"dependencies,7,optional" 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) SetBranchInfo 

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

func (*PlanNodeDescription) SetDependencies 

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

func (*PlanNodeDescription) SetDescription 

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

func (*PlanNodeDescription) SetId 

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

func (*PlanNodeDescription) SetName 

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

func (*PlanNodeDescription) SetOutputVar 

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

func (*PlanNodeDescription) SetProfiles 

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

func (*PlanNodeDescription) String 

func (p *PlanNodeDescription) String() string

func (*PlanNodeDescription) Write 

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

type PlanNodeDescriptionBuilder 

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

func NewPlanNodeDescriptionBuilder 

func NewPlanNodeDescriptionBuilder() *PlanNodeDescriptionBuilder

func (*PlanNodeDescriptionBuilder) BranchInfo 

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

func (*PlanNodeDescriptionBuilder) Dependencies 

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

func (*PlanNodeDescriptionBuilder) Description 

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

func (PlanNodeDescriptionBuilder) Emit 

func (p PlanNodeDescriptionBuilder) Emit() *PlanNodeDescription

func (*PlanNodeDescriptionBuilder) Id 

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

func (*PlanNodeDescriptionBuilder) Name 

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

func (*PlanNodeDescriptionBuilder) OutputVar 

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

func (*PlanNodeDescriptionBuilder) Profiles 

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

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

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

func (*ProfilingStats) SetOtherStats 

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

func (*ProfilingStats) SetRows 

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

func (*ProfilingStats) SetTotalDurationInUs 

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

func (*ProfilingStats) String 

func (p *ProfilingStats) String() string

func (*ProfilingStats) Write 

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

type ProfilingStatsBuilder 

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

func NewProfilingStatsBuilder 

func NewProfilingStatsBuilder() *ProfilingStatsBuilder

func (ProfilingStatsBuilder) Emit 

func (p ProfilingStatsBuilder) Emit() *ProfilingStats

func (*ProfilingStatsBuilder) ExecDurationInUs 

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

func (*ProfilingStatsBuilder) OtherStats 

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

func (*ProfilingStatsBuilder) Rows 

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

func (*ProfilingStatsBuilder) TotalDurationInUs 

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

type VerifyClientVersionReq 

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

Attributes:

  • Version
var GraphServiceVerifyClientVersionArgs_Req_DEFAULT *VerifyClientVersionReq

func NewVerifyClientVersionReq 

func NewVerifyClientVersionReq() *VerifyClientVersionReq

func (*VerifyClientVersionReq) GetVersion 

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

func (*VerifyClientVersionReq) Read 

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

func (*VerifyClientVersionReq) ReadField1 

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

func (*VerifyClientVersionReq) SetVersion 

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

func (*VerifyClientVersionReq) String 

func (p *VerifyClientVersionReq) String() string

func (*VerifyClientVersionReq) Write 

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

type VerifyClientVersionReqBuilder 

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

func NewVerifyClientVersionReqBuilder 

func NewVerifyClientVersionReqBuilder() *VerifyClientVersionReqBuilder

func (VerifyClientVersionReqBuilder) Emit 

func (p VerifyClientVersionReqBuilder) Emit() *VerifyClientVersionReq

func (*VerifyClientVersionReqBuilder) Version 

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

type VerifyClientVersionResp 

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

Attributes:

  • ErrorCode
  • ErrorMsg
var GraphServiceVerifyClientVersionResult_Success_DEFAULT *VerifyClientVersionResp

func NewVerifyClientVersionResp 

func NewVerifyClientVersionResp() *VerifyClientVersionResp

func (*VerifyClientVersionResp) GetErrorCode 

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

func (*VerifyClientVersionResp) GetErrorMsg 

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

func (*VerifyClientVersionResp) IsSetErrorMsg 

func (p *VerifyClientVersionResp) IsSetErrorMsg() bool

func (*VerifyClientVersionResp) Read 

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

func (*VerifyClientVersionResp) ReadField1 

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

func (*VerifyClientVersionResp) ReadField2 

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

func (*VerifyClientVersionResp) SetErrorCode 

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

func (*VerifyClientVersionResp) SetErrorMsg 

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

func (*VerifyClientVersionResp) String 

func (p *VerifyClientVersionResp) String() string

func (*VerifyClientVersionResp) Write 

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

type VerifyClientVersionRespBuilder 

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

func NewVerifyClientVersionRespBuilder 

func NewVerifyClientVersionRespBuilder() *VerifyClientVersionRespBuilder

func (VerifyClientVersionRespBuilder) Emit 

func (p VerifyClientVersionRespBuilder) Emit() *VerifyClientVersionResp

func (*VerifyClientVersionRespBuilder) ErrorCode 

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

func (*VerifyClientVersionRespBuilder) ErrorMsg 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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