conn

package
v0.9.2 Latest Latest
Warning

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

Go to latest
Published: Dec 1, 2022 License: MIT Imports: 17 Imported by: 0

Documentation

Overview

Package conn holds a streaming ingest connetion.

Index

Constants

This section is empty.

Variables

View Source
var BuffPool = sync.Pool{
	New: func() interface{} {
		return &bytes.Buffer{}
	},
}

BuffPool provides a pool of *bytes.Buffer objects.

Functions

This section is empty.

Types

type Conn

type Conn struct {
	// contains filtered or unexported fields
}

Conn provides connectivity to the Kusto streaming ingestion service.

func New

func New(endpoint string, auth kusto.Authorization, client *http.Client) (*Conn, error)

New returns a new Conn object.

func (*Conn) Close added in v0.7.0

func (c *Conn) Close() error

func (*Conn) StreamIngest added in v0.6.0

func (c *Conn) StreamIngest(ctx context.Context, db, table string, payload io.Reader, format properties.DataFormat, mappingName string, clientRequestId string) error

StreamIngest ingests into database "db", table "table" what is stored in "payload" which should be encoded in "format" and have a server side data mapping reference named "mappingName". "mappingName" can be nil.

Jump to

Keyboard shortcuts

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