utils

Documentation

Index

• Constants
• func CreateDateMeshFlightInfo(tick []byte, endpointURI string) *flight.FlightInfo
• func DescForCommand(cmd proto.Message) (*flight.FlightDescriptor, error)
• func GenerateArrowColumnType(domainData *datamesh.DomainData) (map[string]arrow.DataType, error)
• func GenerateArrowSchema(domainData *datamesh.DomainData) (*arrow.Schema, error)
• func GenerateBinaryDataArrowSchema() *arrow.Schema
• func PackActionResult(msg proto.Message) (*flight.Result, error)
• func ParseRegionFromEndpoint(endpoint string) (string, error)
• type DataMeshRequestContext
  • func NewDataMeshRequestContext(dd service.IDomainDataService, ds service.IDomainDataSourceService, ...) (*DataMeshRequestContext, error)
  • func (rc *DataMeshRequestContext) GetDomainData(ctx context.Context) (*datamesh.DomainData, error)
  • func (rc *DataMeshRequestContext) GetDomainDataAndSource(ctx context.Context) (*datamesh.DomainData, *datamesh.DomainDataSource, error)
  • func (rc *DataMeshRequestContext) GetDomainDataSource(ctx context.Context) (*datamesh.DomainDataSource, error)
  • func (rc *DataMeshRequestContext) GetTransferContentType() datamesh.ContentType
• type FlightRecordWriter
• type RecordWriter

Constants

const AliyunOssEndpointSuffix string = ".aliyuncs.com"

const BuiltinFlightServerEndpointURI string = "kuscia://datamesh"

Functions

func CreateDateMeshFlightInfo

func CreateDateMeshFlightInfo(tick []byte, endpointURI string) *flight.FlightInfo

func DescForCommand

func DescForCommand(cmd proto.Message) (*flight.FlightDescriptor, error)

func GenerateArrowColumnType

func GenerateArrowColumnType(domainData *datamesh.DomainData) (map[string]arrow.DataType, error)

GenerateArrowColumnType generate column from domaindata

func GenerateArrowSchema

func GenerateArrowSchema(domainData *datamesh.DomainData) (*arrow.Schema, error)

GenerateArrowSchema generate schema from domaindata

func GenerateBinaryDataArrowSchema

func GenerateBinaryDataArrowSchema() *arrow.Schema

func PackActionResult

func PackActionResult(msg proto.Message) (*flight.Result, error)

func ParseRegionFromEndpoint

func ParseRegionFromEndpoint(endpoint string) (string, error)

Types

type DataMeshRequestContext

type DataMeshRequestContext struct {
	DataSourceType string
	Query          *datamesh.CommandDomainDataQuery
	Update         *datamesh.CommandDomainDataUpdate
	SqlQuery       *datamesh.CommandDataSourceSqlQuery
	// contains filtered or unexported fields
}

func NewDataMeshRequestContext

func NewDataMeshRequestContext(dd service.IDomainDataService, ds service.IDomainDataSourceService, msg proto.Message, dsType ...string) (*DataMeshRequestContext, error)

func (*DataMeshRequestContext) GetDomainData

func (rc *DataMeshRequestContext) GetDomainData(ctx context.Context) (*datamesh.DomainData, error)

func (*DataMeshRequestContext) GetDomainDataAndSource

func (rc *DataMeshRequestContext) GetDomainDataAndSource(ctx context.Context) (*datamesh.DomainData, *datamesh.DomainDataSource, error)

func (*DataMeshRequestContext) GetDomainDataSource

func (rc *DataMeshRequestContext) GetDomainDataSource(ctx context.Context) (*datamesh.DomainDataSource, error)

func (*DataMeshRequestContext) GetTransferContentType

func (rc *DataMeshRequestContext) GetTransferContentType() datamesh.ContentType

type FlightRecordWriter

type FlightRecordWriter struct {
	FlightWriter flight.FlightService_DoGetServer
	*flight.Writer
}

type RecordWriter

type RecordWriter interface {
	Write(rec arrow.Record) error
	Close() error
}