kusto

Feb 11, 2022

retracted

Changes in this version

+ type Rows struct

+ Replace bool

+ Values value.Values

Jul 23, 2024

Changes in this version

type ConnectionStringBuilder

+ ApplicationCertificateBytes []byte

+ ApplicationCertificatePassword []byte

+ ApplicationCertificatePath string

+ func (kcsb *ConnectionStringBuilder) WithAppCertificateBytes(appId string, certificateBytes []byte, password []byte, sendCertChain bool, ...) *ConnectionStringBuilder

+ func (kcsb *ConnectionStringBuilder) WithAppCertificatePath(appId string, certificatePath string, password []byte, sendCertChain bool, ...) *ConnectionStringBuilder

Dec 4, 2023

Changes in this version

+ const ResultsProgressiveEnabledValue

type QueryOption

+ func ResultsProgressiveEnabled() QueryOption

Aug 10, 2023

Changes in this version

type ConnectionStringBuilder

+ FederationTokenFilePath string

+ WorkloadAuthentication bool

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

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

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

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

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)

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

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

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

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)

Nov 2, 2021

Changes in this version

+ type TableOfContents struct

+ Id string

+ Kind string

+ Name string

+ Ordinal int64

+ PrettyName string

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