conn

Documentation

Overview

Package conn holds a streaming ingest connetion.

Index

• Variables
• type Conn
  • func New(endpoint string, auth kusto.Authorization, client *http.Client) (*Conn, error)
  • func (c *Conn) Close() error
  • func (c *Conn) StreamIngest(ctx context.Context, db, table string, payload io.Reader, ...) error

Variables

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

BuffPool provides a pool of *bytes.Buffer objects.

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

func (c *Conn) Close() error

func (*Conn) StreamIngest

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.