Documentation ¶
Overview ¶
Package qlik_connect is a generated protocol buffer package.
It is generated from these files:
grpc_server.proto
It has these top-level messages:
ConnectionInfo SessionInfo Parameter DataInfo DataRequest DataChunk FieldAttributes FieldInfo GetDataResponse MetaInfo MetaInfoRequest
Index ¶
- Variables
- func RegisterConnectorServer(s *grpc.Server, srv ConnectorServer)
- type ConnectionInfo
- func (*ConnectionInfo) Descriptor() ([]byte, []int)
- func (m *ConnectionInfo) GetConnectionString() string
- func (m *ConnectionInfo) GetPassword() string
- func (m *ConnectionInfo) GetUser() string
- func (*ConnectionInfo) ProtoMessage()
- func (m *ConnectionInfo) Reset()
- func (m *ConnectionInfo) String() string
- type ConnectorClient
- type ConnectorServer
- type Connector_GetDataClient
- type Connector_GetDataServer
- type DataChunk
- func (*DataChunk) Descriptor() ([]byte, []int)
- func (m *DataChunk) GetDoubleBucket() []float64
- func (m *DataChunk) GetNumberCodes() []int64
- func (m *DataChunk) GetStringBucket() []string
- func (m *DataChunk) GetStringCodes() []int32
- func (*DataChunk) ProtoMessage()
- func (m *DataChunk) Reset()
- func (m *DataChunk) String() string
- type DataInfo
- type DataRequest
- func (*DataRequest) Descriptor() ([]byte, []int)
- func (m *DataRequest) GetConnection() *ConnectionInfo
- func (m *DataRequest) GetParameters() *DataInfo
- func (m *DataRequest) GetSessionInfo() *SessionInfo
- func (*DataRequest) ProtoMessage()
- func (m *DataRequest) Reset()
- func (m *DataRequest) String() string
- type FieldAttrType
- type FieldAttributes
- type FieldInfo
- func (*FieldInfo) Descriptor() ([]byte, []int)
- func (m *FieldInfo) GetFieldAttributes() *FieldAttributes
- func (m *FieldInfo) GetName() string
- func (m *FieldInfo) GetSemanticType() SemanticType
- func (m *FieldInfo) GetTags() []string
- func (*FieldInfo) ProtoMessage()
- func (m *FieldInfo) Reset()
- func (m *FieldInfo) String() string
- type GetDataResponse
- type MetaInfo
- type MetaInfoRequest
- type Parameter
- type SemanticType
- type SessionInfo
Constants ¶
This section is empty.
Variables ¶
var FieldAttrType_name = map[int32]string{
0: "UNKNOWN",
1: "TEXT",
2: "REAL",
3: "DATE",
4: "TIME",
5: "TIMESTAMP",
6: "INTERVAL",
10: "INTEGER",
11: "FIX",
12: "MONEY",
}
var FieldAttrType_value = map[string]int32{
"UNKNOWN": 0,
"TEXT": 1,
"REAL": 2,
"DATE": 3,
"TIME": 4,
"TIMESTAMP": 5,
"INTERVAL": 6,
"INTEGER": 10,
"FIX": 11,
"MONEY": 12,
}
var SemanticType_name = map[int32]string{
0: "DEFAULT",
1: "UNIX_SECONDS_SINCE_1970_UTC",
2: "ISO_8601",
}
var SemanticType_value = map[string]int32{
"DEFAULT": 0,
"UNIX_SECONDS_SINCE_1970_UTC": 1,
"ISO_8601": 2,
}
Functions ¶
func RegisterConnectorServer ¶
func RegisterConnectorServer(s *grpc.Server, srv ConnectorServer)
Types ¶
type ConnectionInfo ¶
type ConnectionInfo struct { ConnectionString string `protobuf:"bytes,1,opt,name=connectionString" json:"connectionString,omitempty"` User string `protobuf:"bytes,2,opt,name=user" json:"user,omitempty"` Password string `protobuf:"bytes,3,opt,name=password" json:"password,omitempty"` }
func (*ConnectionInfo) Descriptor ¶
func (*ConnectionInfo) Descriptor() ([]byte, []int)
func (*ConnectionInfo) GetConnectionString ¶
func (m *ConnectionInfo) GetConnectionString() string
func (*ConnectionInfo) GetPassword ¶
func (m *ConnectionInfo) GetPassword() string
func (*ConnectionInfo) GetUser ¶
func (m *ConnectionInfo) GetUser() string
func (*ConnectionInfo) ProtoMessage ¶
func (*ConnectionInfo) ProtoMessage()
func (*ConnectionInfo) Reset ¶
func (m *ConnectionInfo) Reset()
func (*ConnectionInfo) String ¶
func (m *ConnectionInfo) String() string
type ConnectorClient ¶
type ConnectorClient interface { // * The standard way to send data. // First send GetDataResponse as initial meta data. // Then send DataChunk stream. GetData(ctx context.Context, in *DataRequest, opts ...grpc.CallOption) (Connector_GetDataClient, error) GetMetaInfo(ctx context.Context, in *MetaInfoRequest, opts ...grpc.CallOption) (*MetaInfo, error) }
func NewConnectorClient ¶
func NewConnectorClient(cc *grpc.ClientConn) ConnectorClient
type ConnectorServer ¶
type ConnectorServer interface { // * The standard way to send data. // First send GetDataResponse as initial meta data. // Then send DataChunk stream. GetData(*DataRequest, Connector_GetDataServer) error GetMetaInfo(context.Context, *MetaInfoRequest) (*MetaInfo, error) }
type Connector_GetDataClient ¶
type Connector_GetDataClient interface { Recv() (*DataChunk, error) grpc.ClientStream }
type Connector_GetDataServer ¶
type Connector_GetDataServer interface { Send(*DataChunk) error grpc.ServerStream }
type DataChunk ¶
type DataChunk struct { // Value buckets StringBucket []string `protobuf:"bytes,1,rep,name=stringBucket" json:"stringBucket,omitempty"` DoubleBucket []float64 `protobuf:"fixed64,2,rep,packed,name=doubleBucket" json:"doubleBucket,omitempty"` // Code arrays StringCodes []int32 `protobuf:"zigzag32,3,rep,packed,name=stringCodes" json:"stringCodes,omitempty"` NumberCodes []int64 `protobuf:"zigzag64,4,rep,packed,name=numberCodes" json:"numberCodes,omitempty"` }
* A structure for streaming field values.
This message conatins two parts. A value bucket part and a code part.
Every transferred value have a string code and one or two numeric codes. These codes can be negative to inicate special things. -1 indicates null for example.
Otherwise they can index into the value buckets. A value with a null string and a null number is a null value in the Qlik Engine.
Number code have a special mechanism to escape an integer value inline with -2.
Each chunk starts anywhere in any row and continues for an arbitary length and may wrap to another row. A DataChunk will typically transfer many rows.
Each DataChunk must be equal or less in size to the default Grpc message size limit. This is currently 4 MB.
64 KB or slightly less is the optimal size for bandwith performance. But anything from 20 to 120 KB will give good performance if used with the hint option when writing.
Very large strings can be sent in many DataChunk messages by using the -3 escape sequence.
func (*DataChunk) Descriptor ¶
func (*DataChunk) GetDoubleBucket ¶
func (*DataChunk) GetNumberCodes ¶
func (*DataChunk) GetStringBucket ¶
func (*DataChunk) GetStringCodes ¶
func (*DataChunk) ProtoMessage ¶
func (*DataChunk) ProtoMessage()
type DataInfo ¶
type DataInfo struct { Statement string `protobuf:"bytes,1,opt,name=statement" json:"statement,omitempty"` Parameters []*Parameter `protobuf:"bytes,2,rep,name=parameters" json:"parameters,omitempty"` }
func (*DataInfo) Descriptor ¶
func (*DataInfo) GetParameters ¶
func (*DataInfo) GetStatement ¶
func (*DataInfo) ProtoMessage ¶
func (*DataInfo) ProtoMessage()
type DataRequest ¶
type DataRequest struct { Connection *ConnectionInfo `protobuf:"bytes,1,opt,name=connection" json:"connection,omitempty"` SessionInfo *SessionInfo `protobuf:"bytes,2,opt,name=sessionInfo" json:"sessionInfo,omitempty"` Parameters *DataInfo `protobuf:"bytes,3,opt,name=parameters" json:"parameters,omitempty"` }
func (*DataRequest) Descriptor ¶
func (*DataRequest) Descriptor() ([]byte, []int)
func (*DataRequest) GetConnection ¶
func (m *DataRequest) GetConnection() *ConnectionInfo
func (*DataRequest) GetParameters ¶
func (m *DataRequest) GetParameters() *DataInfo
func (*DataRequest) GetSessionInfo ¶
func (m *DataRequest) GetSessionInfo() *SessionInfo
func (*DataRequest) ProtoMessage ¶
func (*DataRequest) ProtoMessage()
func (*DataRequest) Reset ¶
func (m *DataRequest) Reset()
func (*DataRequest) String ¶
func (m *DataRequest) String() string
type FieldAttrType ¶
type FieldAttrType int32
* Direct copy of FieldAttrType in Qlik Engine. How to display the data.
const ( FieldAttrType_UNKNOWN FieldAttrType = 0 FieldAttrType_TEXT FieldAttrType = 1 FieldAttrType_REAL FieldAttrType = 2 FieldAttrType_DATE FieldAttrType = 3 FieldAttrType_TIME FieldAttrType = 4 FieldAttrType_TIMESTAMP FieldAttrType = 5 FieldAttrType_INTERVAL FieldAttrType = 6 FieldAttrType_INTEGER FieldAttrType = 10 FieldAttrType_FIX FieldAttrType = 11 FieldAttrType_MONEY FieldAttrType = 12 )
func (FieldAttrType) EnumDescriptor ¶
func (FieldAttrType) EnumDescriptor() ([]byte, []int)
func (FieldAttrType) String ¶
func (x FieldAttrType) String() string
type FieldAttributes ¶
type FieldAttributes struct {
Type FieldAttrType `protobuf:"varint,1,opt,name=Type,enum=qlik.connect.FieldAttrType" json:"Type,omitempty"`
}
* Subset of classic Qlik Engine number format
func (*FieldAttributes) Descriptor ¶
func (*FieldAttributes) Descriptor() ([]byte, []int)
func (*FieldAttributes) GetType ¶
func (m *FieldAttributes) GetType() FieldAttrType
func (*FieldAttributes) ProtoMessage ¶
func (*FieldAttributes) ProtoMessage()
func (*FieldAttributes) Reset ¶
func (m *FieldAttributes) Reset()
func (*FieldAttributes) String ¶
func (m *FieldAttributes) String() string
type FieldInfo ¶
type FieldInfo struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` SemanticType SemanticType `protobuf:"varint,2,opt,name=semanticType,enum=qlik.connect.SemanticType" json:"semanticType,omitempty"` FieldAttributes *FieldAttributes `protobuf:"bytes,3,opt,name=fieldAttributes" json:"fieldAttributes,omitempty"` Tags []string `protobuf:"bytes,4,rep,name=tags" json:"tags,omitempty"` }
func (*FieldInfo) Descriptor ¶
func (*FieldInfo) GetFieldAttributes ¶
func (m *FieldInfo) GetFieldAttributes() *FieldAttributes
func (*FieldInfo) GetSemanticType ¶
func (m *FieldInfo) GetSemanticType() SemanticType
func (*FieldInfo) ProtoMessage ¶
func (*FieldInfo) ProtoMessage()
type GetDataResponse ¶
type GetDataResponse struct { FieldInfo []*FieldInfo `protobuf:"bytes,1,rep,name=fieldInfo" json:"fieldInfo,omitempty"` TableName string `protobuf:"bytes,2,opt,name=tableName" json:"tableName,omitempty"` }
* Transferred as initial metadata with the name "x-qlik-getdata-bin".
func (*GetDataResponse) Descriptor ¶
func (*GetDataResponse) Descriptor() ([]byte, []int)
func (*GetDataResponse) GetFieldInfo ¶
func (m *GetDataResponse) GetFieldInfo() []*FieldInfo
func (*GetDataResponse) GetTableName ¶
func (m *GetDataResponse) GetTableName() string
func (*GetDataResponse) ProtoMessage ¶
func (*GetDataResponse) ProtoMessage()
func (*GetDataResponse) Reset ¶
func (m *GetDataResponse) Reset()
func (*GetDataResponse) String ¶
func (m *GetDataResponse) String() string
type MetaInfo ¶
type MetaInfo struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Version string `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"` // / Example: "1.0.0.0" or "1.23 Beta" or "Buildnumber: 1234" or "2018-Feb-06" Developer string `protobuf:"bytes,3,opt,name=developer" json:"developer,omitempty"` }
* Usefull for debugging.
func (*MetaInfo) Descriptor ¶
func (*MetaInfo) GetDeveloper ¶
func (*MetaInfo) GetVersion ¶
func (*MetaInfo) ProtoMessage ¶
func (*MetaInfo) ProtoMessage()
type MetaInfoRequest ¶
type MetaInfoRequest struct { }
func (*MetaInfoRequest) Descriptor ¶
func (*MetaInfoRequest) Descriptor() ([]byte, []int)
func (*MetaInfoRequest) ProtoMessage ¶
func (*MetaInfoRequest) ProtoMessage()
func (*MetaInfoRequest) Reset ¶
func (m *MetaInfoRequest) Reset()
func (*MetaInfoRequest) String ¶
func (m *MetaInfoRequest) String() string
type Parameter ¶
type Parameter struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` }
func (*Parameter) Descriptor ¶
func (*Parameter) ProtoMessage ¶
func (*Parameter) ProtoMessage()
type SemanticType ¶
type SemanticType int32
* How to interpret the data. If dates or times are already in the Qlik Engine format (fractional day since 1899-12-30), then the fastest way to import is to use SemanticType=DEFAULT. And transferr the date as a double and set FieldAttributes::Type = DATE. If the dates are in "days since 1904-01-01" format the best way is to add 1462 to them and send as 1899-12-30 dates.
const ( SemanticType_DEFAULT SemanticType = 0 SemanticType_UNIX_SECONDS_SINCE_1970_UTC SemanticType = 1 SemanticType_ISO_8601 SemanticType = 2 )
func (SemanticType) EnumDescriptor ¶
func (SemanticType) EnumDescriptor() ([]byte, []int)
func (SemanticType) String ¶
func (x SemanticType) String() string
type SessionInfo ¶
type SessionInfo struct { User string `protobuf:"bytes,1,opt,name=user" json:"user,omitempty"` SessionId string `protobuf:"bytes,2,opt,name=sessionId" json:"sessionId,omitempty"` DocId string `protobuf:"bytes,3,opt,name=docId" json:"docId,omitempty"` }
func (*SessionInfo) Descriptor ¶
func (*SessionInfo) Descriptor() ([]byte, []int)
func (*SessionInfo) GetDocId ¶
func (m *SessionInfo) GetDocId() string
func (*SessionInfo) GetSessionId ¶
func (m *SessionInfo) GetSessionId() string
func (*SessionInfo) GetUser ¶
func (m *SessionInfo) GetUser() string
func (*SessionInfo) ProtoMessage ¶
func (*SessionInfo) ProtoMessage()
func (*SessionInfo) Reset ¶
func (m *SessionInfo) Reset()
func (*SessionInfo) String ¶
func (m *SessionInfo) String() string