adx

Documentation

Index

• Constants
• func NewDispatcher(uploaders []Uploader) *dispatcher
• func NewUploader(kustoCli ingest.QueryClient, opts UploaderOpts) *uploader
• type IngestionMapping
• type SampleType
• type Syncer
  • func NewSyncer(kustoCli mgmt, database string, defaultMapping storage.SchemaMapping, ...) *Syncer
  • func (s *Syncer) EnsureMapping(table string) (string, error)
  • func (s *Syncer) EnsureTable(table string) error
  • func (s *Syncer) Open(ctx context.Context) error
• type Uploader
  • func NewFakeUploader(db string) Uploader
• type UploaderOpts

Constants

const ConcurrentUploads = 50

Functions

func NewDispatcher

func NewDispatcher(uploaders []Uploader) *dispatcher

func NewUploader

func NewUploader(kustoCli ingest.QueryClient, opts UploaderOpts) *uploader

Types

type IngestionMapping

type IngestionMapping struct {
	Name          string    `kusto:"Name"`
	Kind          string    `kusto:"Kind"`
	Mapping       string    `kusto:"Mapping"`
	LastUpdatedOn time.Time `kusto:"LastUpdatedOn"`
	Database      string    `kusto:"Database"`
	Table         string    `kusto:"Table"`
}

type SampleType

type SampleType int

const (
	PromMetrics SampleType = iota
	OTLPLogs
)

type Syncer

type Syncer struct {
	KustoCli mgmt
	// contains filtered or unexported fields
}

func NewSyncer

func NewSyncer(kustoCli mgmt, database string, defaultMapping storage.SchemaMapping, st SampleType) *Syncer

func (*Syncer) EnsureMapping

func (s *Syncer) EnsureMapping(table string) (string, error)

EnsureMapping creates a schema mapping for the specified table if it does not exist. It returns the name of the mapping.

func (*Syncer) EnsureTable

func (s *Syncer) EnsureTable(table string) error

func (*Syncer) Open

func (s *Syncer) Open(ctx context.Context) error

type Uploader

type Uploader interface {
	service.Component

	Database() string

	// UploadQueue returns a channel that can be used to upload files to kusto.
	UploadQueue() chan *cluster.Batch

	// Mgmt executes a management query against the database.
	Mgmt(ctx context.Context, query kusto.Statement, options ...kusto.MgmtOption) (*kusto.RowIterator, error)
}

func NewFakeUploader

func NewFakeUploader(db string) Uploader

type UploaderOpts

type UploaderOpts struct {
	StorageDir        string
	Database          string
	ConcurrentUploads int
	Dimensions        []string
	DefaultMapping    storage.SchemaMapping
	SampleType        SampleType
}