lineagegraph

package
v0.16.1 Latest Latest
Warning

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

Go to latest
Published: Sep 22, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var GoUnusedProtection__ int
View Source
var TLineageGraph_Ended_DEFAULT int64
View Source
var TLineageGraph_QueryID_DEFAULT *types.TUniqueId
View Source
var TLineageGraph_TableLocation_DEFAULT string

Functions

This section is empty.

Types

type TEdgeType

type TEdgeType int64
const (
	TEdgeType_PROJECTION TEdgeType = 0
	TEdgeType_PREDICATE  TEdgeType = 1
)

func TEdgeTypeFromString

func TEdgeTypeFromString(s string) (TEdgeType, error)

func TEdgeTypePtr

func TEdgeTypePtr(v TEdgeType) *TEdgeType

func (TEdgeType) MarshalText

func (p TEdgeType) MarshalText() ([]byte, error)

func (*TEdgeType) Scan

func (p *TEdgeType) Scan(value interface{}) error

func (TEdgeType) String

func (p TEdgeType) String() string

func (*TEdgeType) UnmarshalText

func (p *TEdgeType) UnmarshalText(text []byte) error

func (*TEdgeType) Value

func (p *TEdgeType) Value() (driver.Value, error)

type TLineageGraph

type TLineageGraph struct {
	QueryText     string           `thrift:"query_text,1,required" db:"query_text" json:"query_text"`
	Hash          string           `thrift:"hash,2,required" db:"hash" json:"hash"`
	User          string           `thrift:"user,3,required" db:"user" json:"user"`
	Started       int64            `thrift:"started,4,required" db:"started" json:"started"`
	Ended         *int64           `thrift:"ended,5" db:"ended" json:"ended,omitempty"`
	Edges         []*TMultiEdge    `thrift:"edges,6" db:"edges" json:"edges"`
	Vertices      []*TVertex       `thrift:"vertices,7" db:"vertices" json:"vertices"`
	QueryID       *types.TUniqueId `thrift:"query_id,8,required" db:"query_id" json:"query_id"`
	TableLocation *string          `thrift:"table_location,9" db:"table_location" json:"table_location,omitempty"`
}

Attributes:

  • QueryText
  • Hash
  • User
  • Started
  • Ended
  • Edges
  • Vertices
  • QueryID
  • TableLocation

func NewTLineageGraph

func NewTLineageGraph() *TLineageGraph

func (*TLineageGraph) Equals

func (p *TLineageGraph) Equals(other *TLineageGraph) bool

func (*TLineageGraph) GetEdges

func (p *TLineageGraph) GetEdges() []*TMultiEdge

func (*TLineageGraph) GetEnded

func (p *TLineageGraph) GetEnded() int64

func (*TLineageGraph) GetHash

func (p *TLineageGraph) GetHash() string

func (*TLineageGraph) GetQueryID

func (p *TLineageGraph) GetQueryID() *types.TUniqueId

func (*TLineageGraph) GetQueryText

func (p *TLineageGraph) GetQueryText() string

func (*TLineageGraph) GetStarted

func (p *TLineageGraph) GetStarted() int64

func (*TLineageGraph) GetTableLocation

func (p *TLineageGraph) GetTableLocation() string

func (*TLineageGraph) GetUser

func (p *TLineageGraph) GetUser() string

func (*TLineageGraph) GetVertices

func (p *TLineageGraph) GetVertices() []*TVertex

func (*TLineageGraph) IsSetEnded

func (p *TLineageGraph) IsSetEnded() bool

func (*TLineageGraph) IsSetQueryID

func (p *TLineageGraph) IsSetQueryID() bool

func (*TLineageGraph) IsSetTableLocation

func (p *TLineageGraph) IsSetTableLocation() bool

func (*TLineageGraph) Read

func (p *TLineageGraph) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TLineageGraph) ReadField1

func (p *TLineageGraph) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TLineageGraph) ReadField2

func (p *TLineageGraph) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TLineageGraph) ReadField3

func (p *TLineageGraph) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TLineageGraph) ReadField4

func (p *TLineageGraph) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TLineageGraph) ReadField5

func (p *TLineageGraph) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TLineageGraph) ReadField6

func (p *TLineageGraph) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TLineageGraph) ReadField7

func (p *TLineageGraph) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TLineageGraph) ReadField8

func (p *TLineageGraph) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TLineageGraph) ReadField9

func (p *TLineageGraph) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TLineageGraph) String

func (p *TLineageGraph) String() string

func (*TLineageGraph) Write

func (p *TLineageGraph) Write(ctx context.Context, oprot thrift.TProtocol) error

type TMultiEdge

type TMultiEdge struct {
	Sources  []*TVertex `thrift:"sources,1" db:"sources" json:"sources"`
	Targets  []*TVertex `thrift:"targets,2" db:"targets" json:"targets"`
	Edgetype TEdgeType  `thrift:"edgetype,3" db:"edgetype" json:"edgetype"`
}

Attributes:

  • Sources
  • Targets
  • Edgetype

func NewTMultiEdge

func NewTMultiEdge() *TMultiEdge

func (*TMultiEdge) Equals

func (p *TMultiEdge) Equals(other *TMultiEdge) bool

func (*TMultiEdge) GetEdgetype

func (p *TMultiEdge) GetEdgetype() TEdgeType

func (*TMultiEdge) GetSources

func (p *TMultiEdge) GetSources() []*TVertex

func (*TMultiEdge) GetTargets

func (p *TMultiEdge) GetTargets() []*TVertex

func (*TMultiEdge) Read

func (p *TMultiEdge) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TMultiEdge) ReadField1

func (p *TMultiEdge) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TMultiEdge) ReadField2

func (p *TMultiEdge) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TMultiEdge) ReadField3

func (p *TMultiEdge) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TMultiEdge) String

func (p *TMultiEdge) String() string

func (*TMultiEdge) Write

func (p *TMultiEdge) Write(ctx context.Context, oprot thrift.TProtocol) error

type TVertex

type TVertex struct {
	ID       int64            `thrift:"id,1,required" db:"id" json:"id"`
	Label    string           `thrift:"label,2,required" db:"label" json:"label"`
	Metadata *TVertexMetadata `thrift:"metadata,3" db:"metadata" json:"metadata,omitempty"`
}

Attributes:

  • ID
  • Label
  • Metadata

func NewTVertex

func NewTVertex() *TVertex

func (*TVertex) Equals

func (p *TVertex) Equals(other *TVertex) bool

func (*TVertex) GetID

func (p *TVertex) GetID() int64

func (*TVertex) GetLabel

func (p *TVertex) GetLabel() string

func (*TVertex) GetMetadata

func (p *TVertex) GetMetadata() *TVertexMetadata

func (*TVertex) IsSetMetadata

func (p *TVertex) IsSetMetadata() bool

func (*TVertex) Read

func (p *TVertex) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TVertex) ReadField1

func (p *TVertex) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TVertex) ReadField2

func (p *TVertex) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TVertex) ReadField3

func (p *TVertex) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TVertex) String

func (p *TVertex) String() string

func (*TVertex) Write

func (p *TVertex) Write(ctx context.Context, oprot thrift.TProtocol) error

type TVertexMetadata

type TVertexMetadata struct {
	TableName       string `thrift:"table_name,1,required" db:"table_name" json:"table_name"`
	TableCreateTime int64  `thrift:"table_create_time,2,required" db:"table_create_time" json:"table_create_time"`
}

Attributes:

  • TableName
  • TableCreateTime
var TVertex_Metadata_DEFAULT *TVertexMetadata

func NewTVertexMetadata

func NewTVertexMetadata() *TVertexMetadata

func (*TVertexMetadata) Equals

func (p *TVertexMetadata) Equals(other *TVertexMetadata) bool

func (*TVertexMetadata) GetTableCreateTime

func (p *TVertexMetadata) GetTableCreateTime() int64

func (*TVertexMetadata) GetTableName

func (p *TVertexMetadata) GetTableName() string

func (*TVertexMetadata) Read

func (p *TVertexMetadata) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TVertexMetadata) ReadField1

func (p *TVertexMetadata) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TVertexMetadata) ReadField2

func (p *TVertexMetadata) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TVertexMetadata) String

func (p *TVertexMetadata) String() string

func (*TVertexMetadata) Write

func (p *TVertexMetadata) Write(ctx context.Context, oprot thrift.TProtocol) error

Jump to

Keyboard shortcuts

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