udf

type Data struct {

	// Types that are assignable to Val:
	//
	//	*Data_BoolVal
	//	*Data_IntVal
	//	*Data_Int64Val
	//	*Data_UintVal
	//	*Data_Uint64Val
	//	*Data_FloatVal
	//	*Data_DoubleVal
	//	*Data_StringVal
	//	*Data_BytesVal
	Val isData_Val `protobuf_oneof:"val"`
	// contains filtered or unexported fields
}

type DataType int32

type DataVector struct {
	Data   []*Data  `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Const  bool     `protobuf:"varint,2,opt,name=const,proto3" json:"const,omitempty"`
	Length int64    `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	Type   DataType `protobuf:"varint,4,opt,name=type,proto3,enum=udf.DataType" json:"type,omitempty"`
	Scale  int32    `protobuf:"varint,5,opt,name=scale,proto3" json:"scale,omitempty"`
	// contains filtered or unexported fields
}

type Data_BoolVal struct {
	BoolVal bool `protobuf:"varint,1,opt,name=boolVal,proto3,oneof"` // bool
}

type Data_BytesVal struct {
	BytesVal []byte `protobuf:"bytes,9,opt,name=bytesVal,proto3,oneof"` // binary, varbinary, blob
}

type Data_DoubleVal struct {
	DoubleVal float64 `protobuf:"fixed64,7,opt,name=doubleVal,proto3,oneof"` // float64
}

type Data_FloatVal struct {
	FloatVal float32 `protobuf:"fixed32,6,opt,name=floatVal,proto3,oneof"` // float32
}

type Data_Int64Val struct {
	Int64Val int64 `protobuf:"zigzag64,3,opt,name=int64Val,proto3,oneof"` // int64
}

type Data_IntVal struct {
	IntVal int32 `protobuf:"zigzag32,2,opt,name=intVal,proto3,oneof"` // int8, int16, int32
}

type Data_StringVal struct {
	StringVal string `protobuf:"bytes,8,opt,name=stringVal,proto3,oneof"` // char, varchar, text, json, uuid | time, date, datetime, timestamp | Decimal64, Decimal128
}

type Data_Uint64Val struct {
	Uint64Val uint64 `protobuf:"varint,5,opt,name=uint64Val,proto3,oneof"` // uint64
}

type Data_UintVal struct {
	UintVal uint32 `protobuf:"varint,4,opt,name=uintVal,proto3,oneof"` // uint8, uint16, uint32
}

type Package struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Last bool   `protobuf:"varint,2,opt,name=last,proto3" json:"last,omitempty"`
	// contains filtered or unexported fields
}

type PkgReader interface {
	Get(ctx context.Context, path string) (reader io.ReadCloser, err error)
}

type PkgUploader interface {
	Upload(ctx context.Context, localPath string, storageDir string) (storagePath string, err error)
}

type Request struct {
	Udf     *Udf              `protobuf:"bytes,1,opt,name=udf,proto3" json:"udf,omitempty"`
	Vectors []*DataVector     `protobuf:"bytes,2,rep,name=vectors,proto3" json:"vectors,omitempty"`
	Length  int64             `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	Type    RequestType       `protobuf:"varint,4,opt,name=type,proto3,enum=udf.RequestType" json:"type,omitempty"`
	Context map[string]string `` // currently just transfer, not used
	/* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RequestType int32

type Response struct {
	Vector *DataVector  `protobuf:"bytes,1,opt,name=vector,proto3" json:"vector,omitempty"`
	Type   ResponseType `protobuf:"varint,2,opt,name=type,proto3,enum=udf.ResponseType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type ResponseType int32

type Service interface {
	Language() string
	Run(ctx context.Context, request *Request, pkgReader PkgReader) (*Response, error)
}

type ServiceClient interface {
	Run(ctx context.Context, opts ...grpc.CallOption) (Service_RunClient, error)
}

type ServiceServer interface {
	Run(Service_RunServer) error
	// contains filtered or unexported methods
}

type Service_RunClient interface {
	Send(*Request) error
	Recv() (*Response, error)
	grpc.ClientStream
}

type Service_RunServer interface {
	Send(*Response) error
	Recv() (*Request, error)
	grpc.ServerStream
}

type Udf struct {
	Handler      string   `protobuf:"bytes,1,opt,name=handler,proto3" json:"handler,omitempty"`
	IsImport     bool     `protobuf:"varint,2,opt,name=isImport,proto3" json:"isImport,omitempty"`
	Body         string   `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	ImportPkg    *Package `protobuf:"bytes,4,opt,name=importPkg,proto3" json:"importPkg,omitempty"`
	RetType      DataType `protobuf:"varint,5,opt,name=retType,proto3,enum=udf.DataType" json:"retType,omitempty"`
	Language     string   `protobuf:"bytes,6,opt,name=language,proto3" json:"language,omitempty"`
	ModifiedTime string   `protobuf:"bytes,7,opt,name=modifiedTime,proto3" json:"modifiedTime,omitempty"`
	Db           string   `protobuf:"bytes,8,opt,name=db,proto3" json:"db,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedServiceServer struct {
}

type UnsafeServiceServer interface {
	// contains filtered or unexported methods
}