Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuthContextProvider ¶
type IngestClient ¶
type IngestClient struct {
// contains filtered or unexported fields
}
func New ¶
func New(client azkustodata.Client) *IngestClient
func (IngestClient) IngestFromLocalStorage ¶
func (IngestClient) IngestFromStorage ¶
type IngestionBlobInfo ¶
type IngestionBlobInfo struct {
// contains filtered or unexported fields
}
func NewIngestionBlobInfo ¶
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 { }
Click to show internal directories.
Click to hide internal directories.