conn

Documentation

Overview

Package conn holds a streaming ingest connetion.

Index

• Variables
• type Conn
  • func New(endpoint string, auth kusto.Authorization) (*Conn, error)
  • func (c *Conn) Write(ctx context.Context, db, table string, payload *bytes.Buffer, ...) 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) (*Conn, error)

New returns a new Conn object.

func (*Conn) Write

func (c *Conn) Write(ctx context.Context, db, table string, payload *bytes.Buffer, format properties.DataFormat, mappingName string) error

Write writes 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 if the format doesn't require it.