azkustoingest

package
v0.0.0-...-c66332c Latest Latest
Warning

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

Go to latest
Published: Dec 4, 2019 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AuthContextProvider

type AuthContextProvider interface {
	GetAuthContext() (string, error)
}

type IngestClient

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

func New

func New(client azkustodata.Client) *IngestClient

func (IngestClient) IngestFromLocalStorage

func (ic IngestClient) IngestFromLocalStorage(path string, props map[string]string, options map[string]string) error

func (IngestClient) IngestFromStorage

func (ic IngestClient) IngestFromStorage(path string, props map[string]string, options map[string]string) error

type IngestionBlobInfo

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

func NewIngestionBlobInfo

func NewIngestionBlobInfo(source map[string]string, props map[string]string, auth string) *IngestionBlobInfo

type IngestionResourceProvider

type IngestionResourceProvider interface {
	GetIngestionQueues() ([]ResourceUri, error)
	GetStorageAccounts() ([]ResourceUri, error)
}

type IngestionResources

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

type IngestionResourcesFetcher

type IngestionResourcesFetcher interface {
	FetchIngestionResources() (*IngestionResources, error)
}

type ResourceManager

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

func NewResourceManager

func NewResourceManager(client azkustodata.KustoClient) (*ResourceManager, error)

func (*ResourceManager) FetchIngestionResources

func (rm *ResourceManager) FetchIngestionResources() error

func (*ResourceManager) GetAuthContext

func (rm *ResourceManager) GetAuthContext() (string, error)

func (*ResourceManager) GetIngestionQueues

func (rm *ResourceManager) GetIngestionQueues() ([]ResourceUri, error)

func (*ResourceManager) GetStorageAccounts

func (rm *ResourceManager) GetStorageAccounts() ([]ResourceUri, error)

type ResourceUri

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

func ParseUri

func ParseUri(uri string) ResourceUri

func (ResourceUri) String

func (ru ResourceUri) String() string

type SourceOptions

type SourceOptions struct {
}

type StorageIngestor

type StorageIngestor interface {
	IngestFromStorage(path string, options StorageSourceOptions) error
}

type StorageSourceOptions

type StorageSourceOptions struct {
}

Jump to

Keyboard shortcuts

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