Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncStreamWriter ¶
type AsyncStreamWriter struct {
// contains filtered or unexported fields
}
AsyncStreamWriter defines the writer interface.
func NewAsyncStreamWriter ¶
func NewAsyncStreamWriter(grpcStream qlik.Connector_GetDataServer, done chan bool) *AsyncStreamWriter
NewAsyncStreamWriter constructs a new async stream writer.
func (*AsyncStreamWriter) Close ¶
func (a *AsyncStreamWriter) Close()
Close will close the underlying stream.
func (*AsyncStreamWriter) Write ¶
func (a *AsyncStreamWriter) Write(rowBundle *qlik.DataChunk)
Write will send a datachunk on the underlying stream.
type AsyncTranslator ¶
type AsyncTranslator struct {
// contains filtered or unexported fields
}
AsyncTranslator defines the translator interface.
func NewAsyncTranslator ¶
func NewAsyncTranslator(writer *AsyncStreamWriter, fieldDescriptors []pgx.FieldDescription) *AsyncTranslator
NewAsyncTranslator constructs a new translator.
func (*AsyncTranslator) Close ¶
func (a *AsyncTranslator) Close()
Close will close the underlying channel.
func (*AsyncTranslator) GetDataResponseMetadata ¶
func (a *AsyncTranslator) GetDataResponseMetadata() *qlik.GetDataResponse
GetDataResponseMetadata returns the metadata for a specific dataset.
func (*AsyncTranslator) GetTypes ¶
func (a *AsyncTranslator) GetTypes() []*qlik.FieldInfo
GetTypes returns a list of fields and their types.
func (*AsyncTranslator) Write ¶
func (a *AsyncTranslator) Write(values [][]interface{})
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
Reader contains the pool of postegres connections.
func NewPostgresReader ¶
NewPostgresReader constructs a new reader.
func (*Reader) GetData ¶
func (r *Reader) GetData(dataRequest *qlik.DataRequest, stream qlik.Connector_GetDataServer) error
GetData will return data from the postgres database.
Source Files
Click to show internal directories.
Click to hide internal directories.