kusto

package

Go to main page

Versions in this module

v0

v0.99.10

Mar 14, 2023

retracted

v0.99.9

Feb 11, 2022

retracted

Changes in this version

+ type Rows struct

+ Replace bool

+ Values value.Values

v0.15.2

Apr 1, 2024

v0.15.1

Mar 4, 2024

v0.15.0

Dec 4, 2023

Changes in this version

+ const ResultsProgressiveEnabledValue

type QueryOption

+ func ResultsProgressiveEnabled() QueryOption

v0.14.2

Nov 8, 2023

v0.14.0

Aug 10, 2023

Changes in this version

type ConnectionStringBuilder

+ FederationTokenFilePath string

+ WorkloadAuthentication bool

+ func (kcsb *ConnectionStringBuilder) WithKubernetesWorkloadIdentity(appId, tokenFilePath, authorityID string) *ConnectionStringBuilder

v0.13.1

May 24, 2023

v0.13.0

May 9, 2023

Changes in this version

+ const RequestProgressiveEnabledValue

+ func CalculateTimeout(ctx context.Context, opt *queryOptions, queryType int)

type QueryOption

+ func ServerTimeout(d time.Duration) QueryOption

v0.12.1

May 1, 2023

v0.12.0

May 1, 2023

Changes in this version

type ConnectionStringBuilder

+ TokenCredential azcore.TokenCredential

+ func (kcsb *ConnectionStringBuilder) WithTokenCredential(tokenCredential azcore.TokenCredential) *ConnectionStringBuilder

type QueryOption

+ func QueryParameters(queryParameters *kql.Parameters) QueryOption

+ type Statement interface

+ GetParameters func() (map[string]string, error)

+ SupportsInlineParameters func() bool

type Stmt

+ func (s Stmt) GetParameters() (map[string]string, error)

+ func (s Stmt) SupportsInlineParameters() bool

v0.11.3

Mar 20, 2023

v0.11.2

Mar 14, 2023

v0.11.1

Mar 1, 2023

v0.11.0

Feb 14, 2023

Changes in this version

+ const ApplicationHeader

+ const ClientRequestIdHeader

+ const ClientVersionHeader

+ const NONE

+ const UserHeader

type Client

+ func (c *Client) ClientDetails() *ClientDetails

+ type ClientDetails struct

+ func NewClientDetails(applicationForTracing string, userNameForTracing string) *ClientDetails

+ func (c *ClientDetails) ApplicationForTracing() string

+ func (c *ClientDetails) ClientVersionForTracing() string

+ func (c *ClientDetails) UserNameForTracing() string

+ type Conn struct

+ func NewConn(endpoint string, auth Authorization, client *http.Client, ...) (*Conn, error)

+ func (c *Conn) Close() error

+ func (c *Conn) StreamIngest(ctx context.Context, db, table string, payload io.Reader, ...) error

type ConnectionStringBuilder

+ ApplicationForTracing string

+ UserForTracing string

+ func (kcsb *ConnectionStringBuilder) SetConnectorDetails(name, version, appName, appVersion string, sendUser bool, overrideUser string, ...)

+ type DataFormatForStreaming interface

+ CamelCase func() string

+ KnownOrDefault func() DataFormatForStreaming

type QueryOption

+ func ClientRequestID(clientRequestID string) QueryOption

+ type StringPair struct

+ Key string

+ Value string

v0.10.2

Dec 26, 2022

v0.10.1

Dec 14, 2022

v0.10.0

Dec 11, 2022

Changes in this version

+ const BEARER_TYPE

type Authorization

+ TokenProvider *TokenProvider

+ 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 TokenProvider struct

+ func (tkp *TokenProvider) AcquireToken(ctx context.Context) (string, string, error)

+ func (tkp *TokenProvider) AuthorizationRequired() bool

+ func (tkp *TokenProvider) SetHttp(http *http.Client)

v0.9.2

Dec 1, 2022

v0.9.1

Nov 20, 2022

v0.9.0

Nov 9, 2022

v0.8.1

Sep 21, 2022

Changes in this version

+ const ClientMaxRedirectCountValue

+ 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 QueryOption

+ func Application(appName string) QueryOption

+ func User(userName string) QueryOption

v0.8.0

Sep 5, 2022

Changes in this version

+ const DSAll

+ const DSDefault

+ const DSHotCache

type Client

+ func (c *Client) QueryToJson(ctx context.Context, db string, query Stmt, options ...QueryOption) (string, error)

+ type DataScope interface

type 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 TruncationMaxRecords(i int64) QueryOption

+ func TruncationMaxSize(i int64) QueryOption

+ func ValidatePermissions() QueryOption

v0.7.0

May 8, 2022

Changes in this version

type Client

+ func (c *Client) Close() error

+ func (c *Client) HttpClient() *http.Client

type Option

+ func WithHttpClient(client *http.Client) Option

v0.6.0

Apr 12, 2022

Changes in this version

type Client

+ func NewMockClient() *Client

+ type Row struct

+ Error *errors.Error

+ Replace bool

+ Values value.Values

type RowIterator

+ 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) NextRowOrError() (row *table.Row, inlineError *errors.Error, finalError error)

v0.5.2

Feb 7, 2022

v0.5.1

Feb 7, 2022

v0.5.0

Jan 23, 2022

v0.4.2

Nov 2, 2021

Changes in this version

+ type TableOfContents struct

+ Id string

+ Kind string

+ Name string

+ Ordinal int64

+ PrettyName string

v0.4.1

Oct 13, 2021

v0.4.0

Jul 13, 2021

v0.3.3

Jul 5, 2021

v0.3.2

May 3, 2021

v0.3.1

Dec 2, 2020

v0.3.0

Nov 26, 2020

v0.2.1

Sep 27, 2020

v0.2.0

Jul 1, 2020

v0.1.3

Apr 16, 2020

Changes in this version

+ type Authorization struct

+ Authorizer autorest.Authorizer

+ Config auth.AuthorizerConfig

+ func (a *Authorization) Validate(endpoint string) error

+ type Client struct

+ func New(endpoint string, auth Authorization, options ...Option) (*Client, error)

+ func (c *Client) Auth() Authorization

+ func (c *Client) Endpoint() string

+ 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)

+ 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)

+ 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 ResultsProgressiveDisable() QueryOption

+ type QueryValues map[string]interface

+ type RowIterator struct

+ RequestHeader http.Header

+ ResponseHeader http.Header

+ func (r *RowIterator) Do(f func(r *table.Row) error) error

+ func (r *RowIterator) Mock(m *MockRows) error

+ func (r *RowIterator) Next() (*table.Row, 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

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