Versions in this module Expand all Collapse all v0 v0.0.3 Dec 25, 2022 v0.0.2 Dec 25, 2022 Changes in this version + const BEARER_TYPE + const ClientMaxRedirectCountValue + const DSAll + const DSDefault + const DSHotCache + const DeferPartialQueryFailuresValue + const MaterializedViewShuffleValue + const MaxMemoryConsumptionPerIteratorValue + const MaxMemoryConsumptionPerQueryPerNodeValue + const MaxOutputColumnsValue + const NoRequestTimeoutValue + const NoTruncationValue + const PushSelectionThroughAggregationValue + const QueryBinAutoAtValue + const QueryBinAutoSizeValue + const QueryConsistencyValue + const QueryCursorAfterDefaultValue + const QueryCursorBeforeOrAtDefaultValue + const QueryCursorCurrentValue + const QueryCursorDisabledValue + const QueryCursorScopedTablesValue + const QueryDatascopeValue + const QueryDateTimeScopeColumnValue + const QueryDateTimeScopeFromValue + const QueryDateTimeScopeToValue + const QueryDistributionNodesSpanValue + const QueryFanoutNodesPercentValue + const QueryFanoutThreadsPercentValue + const QueryForceRowLevelSecurityValue + const QueryLanguageValue + const QueryLogQueryParametersValue + const QueryMaxEntitiesInUnionValue + const QueryNowValue + const QueryPythonDebugValue + const QueryResultsApplyGetschemaValue + const QueryResultsCacheMaxAgeValue + const QueryResultsCachePerShardValue + const QueryResultsProgressiveRowCountValue + const QueryResultsProgressiveUpdatePeriodValue + const QueryTakeMaxRecordsValue + const RequestAppNameValue + const RequestBlockRowLevelSecurityValue + const RequestCalloutDisabledValue + const RequestDescriptionValue + const RequestExternalTableDisabledValue + const RequestImpersonationDisabledValue + const RequestReadonlyValue + const RequestRemoteEntitiesDisabledValue + const RequestSandboxedExecutionDisabledValue + const RequestUserValue + const ServerTimeoutValue + const TruncationMaxRecordsValue + const TruncationMaxSizeValue + const ValidatePermissionsValue + type Authorization struct + TokenProvider *TokenProvider + type Client struct + func New(kcsb *ConnectionStringBuilder, options ...Option) (*Client, error) + func NewMockClient() *Client + func (c *Client) Auth() Authorization + func (c *Client) Close() error + func (c *Client) Endpoint() string + func (c *Client) HttpClient() *http.Client + func (c *Client) Mgmt(ctx context.Context, db string, query Stmt, options ...MgmtOption) (*RowIterator, error) + func (c *Client) Query(ctx context.Context, db string, query Stmt, options ...QueryOption) (*RowIterator, error) + func (c *Client) QueryToJson(ctx context.Context, db string, query Stmt, options ...QueryOption) (string, error) + type CloudInfo struct + FirstPartyAuthorityURL string + KustoClientAppID string + KustoClientRedirectURI string + KustoServiceResourceID string + LoginEndpoint string + LoginMfaRequired bool + func GetMetadata(kustoUri string, httpClient *http.Client) (CloudInfo, error) + type ConnectionStringBuilder struct + AadUserID string + ApplicationCertificate string + ApplicationCertificateThumbprint string + ApplicationClientId string + ApplicationKey string + ApplicationToken string + AuthorityId string + AzCli bool + ClientOptions *azcore.ClientOptions + DataSource string + DefaultAuth bool + InteractiveLogin bool + ManagedServiceIdentity string + MsiAuthentication bool + Password string + RedirectURL string + SendCertificateChain bool + UserToken string + func NewConnectionStringBuilder(connStr string) *ConnectionStringBuilder + func (kcsb *ConnectionStringBuilder) AttachPolicyClientOptions(options *azcore.ClientOptions) *ConnectionStringBuilder + func (kcsb *ConnectionStringBuilder) WitAadUserToken(usertoken string) *ConnectionStringBuilder + func (kcsb *ConnectionStringBuilder) WithAadAppKey(appId string, appKey string, authorityID string) *ConnectionStringBuilder + func (kcsb *ConnectionStringBuilder) WithAadUserPassAuth(uname string, pswrd string, authorityID string) *ConnectionStringBuilder + func (kcsb *ConnectionStringBuilder) WithAppCertificate(appId string, certificate string, thumprint string, sendCertChain bool, ...) *ConnectionStringBuilder + func (kcsb *ConnectionStringBuilder) WithApplicationToken(appId string, appToken string) *ConnectionStringBuilder + func (kcsb *ConnectionStringBuilder) WithAzCli() *ConnectionStringBuilder + func (kcsb *ConnectionStringBuilder) WithDefaultAzureCredential() *ConnectionStringBuilder + func (kcsb *ConnectionStringBuilder) WithInteractiveLogin(authorityID string) *ConnectionStringBuilder + func (kcsb *ConnectionStringBuilder) WithSystemManagedIdentity() *ConnectionStringBuilder + func (kcsb *ConnectionStringBuilder) WithUserManagedIdentity(clientID string) *ConnectionStringBuilder + type DataScope interface + type Definitions struct + func NewDefinitions() Definitions + func (p Definitions) IsZero() bool + func (p Definitions) Must(types ParamTypes) Definitions + func (p Definitions) String() string + func (p Definitions) With(types ParamTypes) (Definitions, error) + type MgmtOption func(m *mgmtOptions) error + func AllowWrite() MgmtOption + func IngestionEndpoint() MgmtOption + type MockRows struct + func NewMockRows(columns table.Columns) (*MockRows, error) + func (m *MockRows) Error(err error) error + func (m *MockRows) Row(row value.Values) error + func (m *MockRows) Struct(p interface{}) error + type Option func(c *Client) + func WithHttpClient(client *http.Client) Option + type ParamType struct + Default interface{} + Type types.Column + type ParamTypes map[string]ParamType + type Parameters struct + func NewParameters() Parameters + func (q Parameters) IsZero() bool + func (q Parameters) Must(values QueryValues) Parameters + func (q Parameters) With(values QueryValues) (Parameters, error) + type QueryOption func(q *queryOptions) error + func Application(appName string) QueryOption + func ClientMaxRedirectCount(i int64) QueryOption + func CustomQueryOption(paramName string, i interface{}) QueryOption + func DeferPartialQueryFailures() QueryOption + func MaterializedViewShuffle(s string) QueryOption + func MaxMemoryConsumptionPerIterator(i uint64) QueryOption + func MaxMemoryConsumptionPerQueryPerNode(i uint64) QueryOption + func MaxOutputColumns(i int) QueryOption + func NoRequestTimeout() QueryOption + func NoTruncation() QueryOption + func PushSelectionThroughAggregation() QueryOption + func QueryBinAutoAt(s string) QueryOption + func QueryBinAutoSize(s string) QueryOption + func QueryConsistency(c string) QueryOption + func QueryCursorAfterDefault(s string) QueryOption + func QueryCursorBeforeOrAtDefault(s string) QueryOption + func QueryCursorCurrent(s string) QueryOption + func QueryCursorDisabled(s string) QueryOption + func QueryCursorScopedTables(l []string) QueryOption + func QueryDataScope(ds DataScope) QueryOption + func QueryDateTimeScopeColumn(s string) QueryOption + func QueryDateTimeScopeFrom(t time.Time) QueryOption + func QueryDateTimeScopeTo(t time.Time) QueryOption + func QueryDistributionNodesSpan(i int64) QueryOption + func QueryFanoutNodesPercent(i int) QueryOption + func QueryFanoutThreadsPercent(i int) QueryOption + func QueryForceRowLevelSecurity() QueryOption + func QueryLanguage(s string) QueryOption + func QueryLogQueryParameters() QueryOption + func QueryMaxEntitiesInUnion(i int64) QueryOption + func QueryNow(t time.Time) QueryOption + func QueryPythonDebug(i int) QueryOption + func QueryResultsApplyGetschema() QueryOption + func QueryResultsCacheMaxAge(d time.Duration) QueryOption + func QueryResultsCachePerShard() QueryOption + func QueryResultsProgressiveRowCount(i int64) QueryOption + func QueryResultsProgressiveUpdatePeriod(i int32) QueryOption + func QueryTakeMaxRecords(i int64) QueryOption + func RequestAppName(s string) QueryOption + func RequestBlockRowLevelSecurity() QueryOption + func RequestCalloutDisabled() QueryOption + func RequestDescription(s string) QueryOption + func RequestExternalTableDisabled() QueryOption + func RequestImpersonationDisabled() QueryOption + func RequestReadonly() QueryOption + func RequestRemoteEntitiesDisabled() QueryOption + func RequestSandboxedExecutionDisabled() QueryOption + func RequestUser(s string) QueryOption + func ResultsProgressiveDisable() QueryOption + func TruncationMaxRecords(i int64) QueryOption + func TruncationMaxSize(i int64) QueryOption + func User(userName string) QueryOption + func ValidatePermissions() QueryOption + type QueryValues map[string]interface + type Row struct + Error *errors.Error + Replace bool + Values value.Values + type RowIterator struct + RequestHeader http.Header + ResponseHeader http.Header + func (r *RowIterator) Do(f func(r *table.Row) error) error + func (r *RowIterator) DoOnRowOrError(f func(r *table.Row, e *errors.Error) error) error + func (r *RowIterator) GetExtendedProperties() (v2.DataTable, error) + func (r *RowIterator) GetNonPrimary(tableKind, tableName frames.TableKind) (v2.DataTable, error) + func (r *RowIterator) GetQueryCompletionInformation() (v2.DataTable, error) + func (r *RowIterator) Mock(m *MockRows) error + func (r *RowIterator) Next() (row *table.Row, finalError error) + func (r *RowIterator) NextRowOrError() (row *table.Row, inlineError *errors.Error, finalError error) + func (r *RowIterator) Progress() float64 + func (r *RowIterator) Progressive() bool + func (r *RowIterator) Stop() + type Stmt struct + func NewStmt(query stringConstant, options ...StmtOption) Stmt + func (s Stmt) Add(query stringConstant) Stmt + func (s Stmt) MustDefinitions(defs Definitions) Stmt + func (s Stmt) MustParameters(params Parameters) Stmt + func (s Stmt) String() string + func (s Stmt) UnsafeAdd(query string) Stmt + func (s Stmt) ValuesJSON() (string, error) + func (s Stmt) WithDefinitions(defs Definitions) (Stmt, error) + func (s Stmt) WithParameters(params Parameters) (Stmt, error) + type StmtOption func(s *Stmt) + func UnsafeStmt(options unsafe.Stmt) StmtOption + type TableOfContents struct + Id string + Kind string + Name string + Ordinal int64 + PrettyName string + type TokenProvider struct + func (tkp *TokenProvider) AcquireToken(ctx context.Context) (string, string, error) + func (tkp *TokenProvider) AuthorizationRequired() bool + func (tkp *TokenProvider) SetHttp(http *http.Client)