var (
    // ContextOAuth2 takes a oauth2.TokenSource as authentication for the request.
    ContextOAuth2 = contextKey("token")

    // ContextBasicAuth takes BasicAuth as authentication for the request.
    ContextBasicAuth = contextKey("basic")

    // ContextAccessToken takes a string oauth2 access token as authentication for the request.
    ContextAccessToken = contextKey("accesstoken")

    // ContextAPIKey takes an APIKey as authentication for the request
    ContextAPIKey = contextKey("apikey")
)

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

type APIKey struct {
    Key    string
    Prefix string
}

type APIResponse struct {
    *http.Response `json:"-"`
    Message        string `json:"message,omitempty"`
    // Operation is the name of the swagger operation.
    Operation string `json:"operation,omitempty"`
    // RequestURL is the request URL. This value is always available, even if the
    // embedded *http.Response is nil.
    RequestURL string `json:"url,omitempty"`
    // Method is the HTTP method used for the request.  This value is always
    // available, even if the embedded *http.Response is nil.
    Method string `json:"method,omitempty"`
    // Payload holds the contents of the response body (which may be nil or empty).
    // This is provided here as the raw response.Body() reader will have already
    // been drained.
    Payload []byte `json:"-"`
}

type AddDocumentsRequest struct {
    // Array of JSON documents
    Data []interface{} `json:"data"`
}

type AddDocumentsResponse struct {
    // information about the added documents
    Data []DocumentStatus `json:"data,omitempty"`
}

type ApiKey struct {
    // ISO-8601 date
    CreatedAt string `json:"created_at,omitempty"`
    // descriptive label
    Name string `json:"name"`
    // string of 64 alphanumeric characters
    Key string `json:"key"`
    // ISO-8601 date
    LastAccessTime string `json:"last_access_time,omitempty"`
}

type ApiKeysApiService Service

type AwsAccessKey struct {
    // AWS access key ID
    AwsAccessKeyId string `json:"aws_access_key_id"`
    // AWS secret access key
    AwsSecretAccessKey string `json:"aws_secret_access_key"`
}

type AwsExternalIdIntegration struct {
    // ARN of rockset-role created in your account
    AwsRoleArn     string `json:"aws_role_arn"`
    AwsExternalId  string `json:"aws_external_id,omitempty"`
    RocksetIamUser string `json:"rockset_iam_user,omitempty"`
}

type AwsKeyIntegration struct {
    // AWS access key ID
    AwsAccessKeyId string `json:"aws_access_key_id"`
    // AWS secret access key
    AwsSecretAccessKey string `json:"aws_secret_access_key"`
}

type AwsRole struct {
    // ARN of rockset-role created in your account
    AwsRoleArn string `json:"aws_role_arn"`
}

type BasicAuth struct {
    UserName string `json:"userName,omitempty"`
    Password string `json:"password,omitempty"`
}

type Collection struct {
    // ISO-8601 date
    CreatedAt string `json:"created_at,omitempty"`
    // email of user who created the collection
    CreatedBy string `json:"created_by,omitempty"`
    // unique identifer for collection, can contain alphanumeric or dash characters
    Name string `json:"name,omitempty"`
    // text describing the collection
    Description string `json:"description,omitempty"`
    // name of the workspace that the collection is in
    Workspace string `json:"workspace,omitempty"`
    // current status of collection, one of: CREATED, READY, DELETED
    Status string `json:"status,omitempty"`
    // list of sources from which collection ingests
    Sources []Source `json:"sources,omitempty"`
    // metrics about the collection
    Stats *CollectionStats `json:"stats,omitempty"`
    // number of seconds after which data is purged based on event time
    RetentionSecs int64 `json:"retention_secs,omitempty"`
    // list of mappings applied on all documents in a collection
    FieldMappings []FieldMappingV2 `json:"field_mappings,omitempty"`
}

type CollectionStats struct {
    // number of documents in the collection
    DocCount int64 `json:"doc_count,omitempty"`
    // number of documents purged from the collection
    PurgedDocCount int64 `json:"purged_doc_count,omitempty"`
    // number between 0 and 1 that indicates progress of collection creation
    FillProgress float64 `json:"fill_progress,omitempty"`
    // milliseconds since Unix epoch Jan 1, 1970
    LastQueriedMs int64 `json:"last_queried_ms,omitempty"`
    // milliseconds since Unix epoch Jan 1, 1970
    LastUpdatedMs int64 `json:"last_updated_ms,omitempty"`
    // total collection size in bytes
    TotalSize int64 `json:"total_size,omitempty"`
    // total collection index size in bytes
    TotalIndexSize int64 `json:"total_index_size,omitempty"`
    // total collection row index size in bytes
    RowIndexSize int64 `json:"row_index_size,omitempty"`
    // total collection column index size in bytes
    ColumnIndexSize int64 `json:"column_index_size,omitempty"`
    // total collection inverted index size in bytes
    InvertedIndexSize int64 `json:"inverted_index_size,omitempty"`
    // total collection range index size in bytes
    RangeIndexSize int64 `json:"range_index_size,omitempty"`
    // total size of bytes purged in bytes
    PurgedDocSize int64 `json:"purged_doc_size,omitempty"`
    // total number of bytes inserted into the collection
    BytesInserted int64 `json:"bytes_inserted,omitempty"`
    // total number of bytes overwritten in writing into the collection
    BytesOverwritten int64 `json:"bytes_overwritten,omitempty"`
}

type CollectionsApiService Service

type CommitMark struct {
}

type CommitMarkPositions struct {
}

type Configuration struct {
    BasePath      string            `json:"basePath,omitempty"`
    Host          string            `json:"host,omitempty"`
    Scheme        string            `json:"scheme,omitempty"`
    DefaultHeader map[string]string `json:"defaultHeader,omitempty"`
    UserAgent     string            `json:"userAgent,omitempty"`
    HTTPClient    *http.Client
    Version       string
}

type CreateApiKeyRequest struct {
    // descriptive label
    Name string `json:"name"`
}

type CreateApiKeyResponse struct {
    // the API key that was created
    Data *ApiKey `json:"data,omitempty"`
}

type CreateCollectionRequest struct {
    // unique identifer for collection, can contain alphanumeric or dash characters
    Name string `json:"name"`
    // text describing the collection
    Description string `json:"description,omitempty"`
    // list of sources from which to ingest data
    Sources []Source `json:"sources,omitempty"`
    // number of seconds after which data is purged, based on event time
    RetentionSecs int64 `json:"retention_secs,omitempty"`
    // configuration for event data
    EventTimeInfo *EventTimeInfo `json:"event_time_info,omitempty"`
    // list of mappings
    FieldMappings []FieldMappingV2 `json:"field_mappings,omitempty"`
}

type CreateCollectionResponse struct {
    // collection that was created
    Data *Collection `json:"data,omitempty"`
}

type CreateIntegrationRequest struct {
    // descriptive label
    Name string `json:"name"`
    // longer explanation for the integration
    Description string `json:"description,omitempty"`
    // Amazon S3 details, must have one of aws_access_key or aws_role
    S3  *S3Integration `json:"s3,omitempty"`
    // Amazon Kinesis details, must have one of aws_access_key or aws_role
    Kinesis *KinesisIntegration `json:"kinesis,omitempty"`
    // Amazon DynamoDB details, must have one of aws_access_key or aws_role
    Dynamodb *DynamodbIntegration `json:"dynamodb,omitempty"`
    // Amazon Redshift details
    Redshift *RedshiftIntegration `json:"redshift,omitempty"`
    // GCS details
    Gcs     *GcsIntegration     `json:"gcs,omitempty"`
    Segment *SegmentIntegration `json:"segment,omitempty"`
    Kafka   *KafkaIntegration   `json:"kafka,omitempty"`
    // MongoDb details
    Mongodb *MongoDbIntegration `json:"mongodb,omitempty"`
}

type CreateIntegrationResponse struct {
    // integration object that was created
    Data *Integration `json:"data,omitempty"`
}

type CreateQueryLambdaRequest struct {
    // Query Lambda name
    Name string `json:"name"`
    // optional description
    Description string `json:"description,omitempty"`
    // Query Lambda SQL query
    Sql *QueryLambdaSql `json:"sql"`
}

type CreateQueryLambdaResponse struct {
    // Query Lambda data
    Data *QueryLambda `json:"data,omitempty"`
}

type CreateQueryLambdaTagRequest struct {
    // name of Query Lambda tag
    TagName string `json:"tag_name,omitempty"`
    // hash identifying a Query Lambda tag
    Version string `json:"version,omitempty"`
}

type CreateSavedQueryRequest struct {
    // query name
    Name string `json:"name"`
    // optional version tag
    VersionTag string `json:"version_tag,omitempty"`
    // SQL text of this query
    QuerySql string `json:"query_sql"`
    // parameters associated with this query
    Parameters []SavedQueryParameter `json:"parameters,omitempty"`
}

type CreateSavedQueryResponse struct {
    // saved query data
    Data *SavedQuery `json:"data,omitempty"`
}

type CreateUserRequest struct {
    // user email, must be unique
    Email string `json:"email"`
    // List of roles for a given user
    Roles []string `json:"roles,omitempty"`
}

type CreateUserResponse struct {
    // user that was created
    Data *User `json:"data,omitempty"`
}

type CreateWorkspaceRequest struct {
    // descriptive label and unique identifier
    Name string `json:"name"`
    // longer explanation for the workspace
    Description string `json:"description,omitempty"`
}

type CreateWorkspaceResponse struct {
    // the workspace that was created
    Data *Workspace `json:"data,omitempty"`
}

type CsvParams struct {
    // If the first line in every object specifies the column names
    FirstLineAsColumnNames bool `json:"firstLineAsColumnNames,omitempty"`
    // a single character that is the column separator
    Separator string `json:"separator,omitempty"`
    // can be one of: UTF-8, ISO_8859_1, UTF-16
    Encoding string `json:"encoding,omitempty"`
    // names of columns
    ColumnNames []string `json:"columnNames,omitempty"`
    // names of columns
    ColumnTypes []string `json:"columnTypes,omitempty"`
    // character within which a cell value is enclosed,null character if no such character, default is '\"'
    QuoteChar string `json:"quoteChar,omitempty"`
    // escape character removes any special meaning from the following character,default is '\\'
    EscapeChar string `json:"escapeChar,omitempty"`
}

type DeleteApiKeyResponse struct {
    // the API key that was deleted
    Data *ApiKey `json:"data,omitempty"`
}

type DeleteCollectionResponse struct {
    // collection that was deleted
    Data *Collection `json:"data,omitempty"`
}

type DeleteDocumentsRequest struct {
    // array of document IDs
    Data []DeleteDocumentsRequestData `json:"data"`
}

type DeleteDocumentsRequestData struct {
    // unique document ID
    Id string `json:"_id"`
}

type DeleteDocumentsResponse struct {
    // information about deleted documents
    Data []DocumentStatus `json:"data,omitempty"`
}

type DeleteIntegrationResponse struct {
    // integration object that was deleted
    Data *Integration `json:"data,omitempty"`
}

type DeleteQueryLambdaResponse struct {
    // Query Lambda details
    Data *QueryLambda `json:"data,omitempty"`
}

type DeleteSavedQueryResponse struct {
    // saved query details
    Data *SavedQuery `json:"data,omitempty"`
}

type DeleteUserResponse struct {
    // user object that was deleted
    Data *User `json:"data,omitempty"`
}

type DeleteWorkspaceResponse struct {
    // the workspace that was deleted
    Data *Workspace `json:"data,omitempty"`
}

type DocumentStatus struct {
    // collection name
    Collection string `json:"_collection,omitempty"`
    // error message, if any
    Error_ *ErrorModel `json:"error,omitempty"`
    // unique document ID
    Id  string `json:"_id,omitempty"`
    // status, one of ADDED, REPLACED, DELETED, ERROR
    Status string `json:"status,omitempty"`
    // unique id used to represent each patch request
    PatchId string `json:"patch_id,omitempty"`
}

type DocumentsApiService Service

type DynamodbIntegration struct {
    // credentials for an AWS access key integration
    AwsAccessKey *AwsAccessKey `json:"aws_access_key,omitempty"`
    // role used for external id type authentication
    AwsRole *AwsRole `json:"aws_role,omitempty"`
}

type ErrorModel struct {
    // descriptive message about the error
    Message string `json:"message,omitempty"`
    // category of the error
    Type_ string `json:"type,omitempty"`
    // Line where the error happened (if applicable)
    Line int32 `json:"line,omitempty"`
    // Column where the error happened (if applicable)
    Column int32 `json:"column,omitempty"`
    // Internal trace ID to help with debugging
    TraceId string `json:"trace_id,omitempty"`
    // ID of the error
    ErrorId string `json:"error_id,omitempty"`
}

type ErrorModelContext struct {
    // additional error message
    Lineinfo string `json:"lineinfo,omitempty"`
}

type EventTimeInfo struct {
    // name of the field containing event time
    Field string `json:"field"`
    // format of time field, can be one of: milliseconds_since_epoch, seconds_since_epoch
    Format string `json:"format,omitempty"`
    // default time zone, in standard IANA format
    TimeZone string `json:"time_zone,omitempty"`
}

type ExecuteOpts struct {
    Body optional.Interface
}

type ExecuteQueryLambdaRequest struct {
    // list of named parameters
    Parameters []QueryParameter `json:"parameters,omitempty"`
    // Row limit to use if no limit specified in the SQL query text
    DefaultRowLimit int32 `json:"default_row_limit,omitempty"`
    // Whether to generate warnings
    GenerateWarnings bool `json:"generate_warnings,omitempty"`
}

type ExecuteSavedQueryParameter struct {
    // name of the field
    Name string `json:"name"`
    // literal value of the field
    Value *interface{} `json:"value"`
}

type ExecuteSavedQueryRequest struct {
    // workspace of this saved query
    Workspace string `json:"workspace,omitempty"`
    // query name
    Name string `json:"name,omitempty"`
    // query version
    Version string `json:"version,omitempty"`
    // list of named parameters
    Parameters []ExecuteSavedQueryParameter `json:"parameters,omitempty"`
    // Row limit to use if no limit specified in the query
    DefaultRowLimit int32 `json:"default_row_limit,omitempty"`
    // Whether to generate warnings
    GenerateWarnings bool `json:"generate_warnings,omitempty"`
}

type Execute_4Opts struct {
    Body optional.Interface
}

type FieldMapping struct {
}

type FieldMappingV2 struct {
    // A user specified string that is a name for this mapping
    Name string `json:"name,omitempty"`
    // A boolean that determines whether to drop all fields in this document. If set, input and output fields should not be set
    IsDropAllFields bool `json:"is_drop_all_fields,omitempty"`
    // A List of InputField for this mapping
    InputFields []InputField `json:"input_fields,omitempty"`
    // An OutputField for this mapping
    OutputField *OutputField `json:"output_field,omitempty"`
}

type FieldMask struct {
    InputPath []string       `json:"input_path"`
    Mask      *FieldMaskMask `json:"mask,omitempty"`
}

type FieldMaskMask struct {
    Name string       `json:"name"`
    Args *interface{} `json:"args,omitempty"`
}

type FormatParams struct {
    // source data is in json format
    Json bool       `json:"json,omitempty"`
    Csv  *CsvParams `json:"csv,omitempty"`
    Xml  *XmlParams `json:"xml,omitempty"`
}

type GcpServiceAccount struct {
    // Contents of JSON Service Account key file
    ServiceAccountKeyFileJson string `json:"service_account_key_file_json"`
}

type GcsIntegration struct {
    // credentials for an AWS key integration
    GcpServiceAccount *GcpServiceAccount `json:"gcp_service_account,omitempty"`
}

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

type GetCollectionResponse struct {
    // collection that was requested
    Data *Collection `json:"data,omitempty"`
}

type GetIntegrationResponse struct {
    // integration object
    Data *Integration `json:"data,omitempty"`
}

type GetQueryLambdaResponse struct {
    // Query Lambda details
    Data *QueryLambda `json:"data,omitempty"`
}

type GetSavedQueryResponse struct {
    // saved query details
    Data *SavedQuery `json:"data,omitempty"`
}

type GetWorkspaceResponse struct {
    // the workspace that was requested
    Data *Workspace `json:"data,omitempty"`
}

type InputField struct {
    // The name of a field, parsed as a SQL qualified name
    FieldName string `json:"field_name,omitempty"`
    // Define the behaviour if fieldName is missing or is null
    IfMissing string `json:"if_missing,omitempty"`
    // If true, then drop fieldName from the document
    IsDrop bool `json:"is_drop,omitempty"`
    // Sql parameter name
    Param string `json:"param,omitempty"`
}

type Integration struct {
    // descriptive label and unique identifier
    Name string `json:"name"`
    // longer explanation for the integration
    Description string `json:"description,omitempty"`
    // list of collections that use the integration
    Collections []Collection `json:"collections,omitempty"`
    // email of user who created the integration
    CreatedBy string `json:"created_by"`
    // ISO-8601 date
    CreatedAt string `json:"created_at,omitempty"`
    // Amazon S3 details, must have one of aws_access_key or aws_role
    S3  *S3Integration `json:"s3,omitempty"`
    // Amazon Kinesis details, must have one of aws_access_key or aws_role
    Kinesis *KinesisIntegration `json:"kinesis,omitempty"`
    // Amazon DynamoDB details, must have one of aws_access_key or aws_role
    Dynamodb *DynamodbIntegration `json:"dynamodb,omitempty"`
    // Amazon Redshift details
    Redshift *RedshiftIntegration `json:"redshift,omitempty"`
    // GCS details
    Gcs *GcsIntegration `json:"gcs,omitempty"`
    // Segment details
    Segment *SegmentIntegration `json:"segment,omitempty"`
    // Kafka details
    Kafka *KafkaIntegration `json:"kafka,omitempty"`
    // MongoDb details
    Mongodb *MongoDbIntegration `json:"mongodb,omitempty"`
}

type IntegrationsApiService Service

type KafkaIntegration struct {
    // Kafka topics to tail
    KafkaTopicNames []string `json:"kafka_topic_names"`
    // The status of the Kafka source by topic
    SourceStatusByTopic map[string]StatusKafka `json:"source_status_by_topic,omitempty"`
    // The format of the Kafka topics being tailed
    KafkaDataFormat string `json:"kafka_data_format"`
    // segment connection string
    ConnectionString string `json:"connection_string,omitempty"`
}

type KinesisIntegration struct {
    // credentials for an AWS access key integration
    AwsAccessKey *AwsAccessKey `json:"aws_access_key,omitempty"`
    // details of an AWS cross-account role integration
    AwsRole *AwsRole `json:"aws_role,omitempty"`
}

type ListApiKeysResponse struct {
    // list of API key objects
    Data []ApiKey `json:"data,omitempty"`
}

type ListCollectionsResponse struct {
    // list of all collections
    Data []Collection `json:"data,omitempty"`
}

type ListIntegrationsResponse struct {
    // list of integration objects
    Data []Integration `json:"data,omitempty"`
}

type ListQueryLambdaTagsResponse struct {
    // list of all tags associated with a Query Lambda
    Data []QueryLambdaTag `json:"data,omitempty"`
}

type ListQueryLambdaVersionsResponse struct {
    // list of all versions for a particular Query Lambda
    Data []QueryLambdaVersion `json:"data,omitempty"`
}

type ListQueryLambdasResponse struct {
    // list of all Query Lambdas
    Data []QueryLambda `json:"data,omitempty"`
}

type ListSavedQueriesResponse struct {
    // list of all saved queries
    Data []SavedQuery `json:"data,omitempty"`
}

type ListUsersResponse struct {
    // list of users
    Data []User `json:"data,omitempty"`
}

type ListWorkspacesResponse struct {
    // list of workspaces
    Data []Workspace `json:"data,omitempty"`
}

type MongoDbIntegration struct {
    // MongoDB connection URI string
    ConnectionUri string `json:"connection_uri"`
}

type OperatorStats struct {
    // The id of the worker this operator ran on
    Worker string `json:"worker,omitempty"`
    // The id of the fragment this operator belonged to
    Fragment int64 `json:"fragment,omitempty"`
    // The id of the task this operator belonged to
    Task string `json:"task,omitempty"`
    // The id of this operator in the task
    OperatorId int64 `json:"operator_id,omitempty"`
    // The class name of this operator
    OperatorName string `json:"operator_name,omitempty"`
    // Microseconds since UNIX epoch of the first time data was received from any of this operator's inputs
    StartTimeUs int64 `json:"start_time_us,omitempty"`
    // Microseconds since UNIX epoch of the last time data was sent to any of this operator's outputs
    EndTimeUs int64 `json:"end_time_us,omitempty"`
    // Maximum memory used by this operator during execution
    MaxMemory int64 `json:"max_memory,omitempty"`
    // Total bytes received across all inputs
    InputBytes int64 `json:"input_bytes,omitempty"`
    // Total rows received across all inputs
    InputRows int64 `json:"input_rows,omitempty"`
    // Total bytes sent across all outputs
    OutputBytes int64 `json:"output_bytes,omitempty"`
    // Total rows sent across all outputs
    OutputRows int64 `json:"output_rows,omitempty"`
    // Total time in microseconds spent doing useful work
    ProcessingTimeUs int64 `json:"processing_time_us,omitempty"`
}

type OrgMembership struct {
    Organization *Organization `json:"organization"`
    Roles        []string      `json:"roles"`
    InviteState  string        `json:"invite_state"`
    InvitedBy    string        `json:"invited_by"`
    // ISO-8601 date
    ExpiresAt string `json:"expires_at"`
    // ISO-8601 date
    CreatedAt string `json:"created_at"`
}

type Organization struct {
    // unique identifier for the organization
    Id  string `json:"id,omitempty"`
    // ISO-8601 date
    CreatedAt string `json:"created_at,omitempty"`
    // name of the organization
    DisplayName string `json:"display_name,omitempty"`
    // name of the company
    CompanyName string `json:"company_name,omitempty"`
    // organization's unique external ID within Rockset
    ExternalId  string `json:"external_id,omitempty"`
    RocksetUser string `json:"rockset_user,omitempty"`
    // org state
    State string `json:"state,omitempty"`
    // number of dedicated pods
    NumDedicatedPods int32 `json:"num_dedicated_pods,omitempty"`
}

type OrganizationResponse struct {
    // Organization object
    Data *Organization `json:"data,omitempty"`
}

type OrganizationsApiService Service

type OutputField struct {
    // The name of a field, parsed as a SQL qualified name
    FieldName string `json:"field_name,omitempty"`
    // The name of a sql function
    Value *SqlExpression `json:"value,omitempty"`
    // Error in Mapping execution: 'skip' or 'fail'
    OnError string `json:"on_error,omitempty"`
}

type PatchDocument struct {
    // Unique id of the document which is being patched
    Id  string `json:"_id"`
    // List of patch operations
    Patch []PatchOperation `json:"patch"`
}

type PatchDocumentsRequest struct {
    // List of JSON Patch Documents
    Data []PatchDocument `json:"data"`
}

type PatchDocumentsResponse struct {
    Data []DocumentStatus `json:"data"`
}

type PatchOperation struct {
    // Operation to be performed in this patch
    Op  string `json:"op"`
    // JSON-Pointer referencing a location in the target document where theoperation is performed
    Path string `json:"path"`
    // Value used in the patch operation. Required for add, replace and test operations
    Value *interface{} `json:"value,omitempty"`
    // JSON-Pointer referencing a location in the target document.Required for copy and move operations
    From string `json:"from,omitempty"`
}

type QueriesApiService Service

type QueryError struct {
    // The type of error
    Type_ string `json:"type,omitempty"`
    // A message associated with the error, containing more information about it
    Message string `json:"message,omitempty"`
    // The HTTP status code associated with this error, had it been sent as the response status code
    StatusCode int32 `json:"status_code,omitempty"`
}

type QueryFieldType struct {
    // name of the field
    Name string `json:"name"`
    // data type of the field
    Type_ string `json:"type"`
}

type QueryLambda struct {
    // workspace of this Query Lambda
    Workspace string `json:"workspace,omitempty"`
    // user that created this Query Lambda
    LastUpdatedBy string `json:"last_updated_by,omitempty"`
    // ISO-8601 date of when Query Lambda was last updated
    LastUpdated string `json:"last_updated,omitempty"`
    // Query Lambda name
    Name string `json:"name,omitempty"`
    // number of Query Lambda versions
    VersionCount int32 `json:"version_count,omitempty"`
    // collections queried by underlying SQL query
    Collections []string `json:"collections,omitempty"`
    // Query Lambda version details for most recently created version
    LatestVersion *QueryLambdaVersion `json:"latest_version,omitempty"`
}

type QueryLambdaSql struct {
    // SQL text
    Query string `json:"query"`
    // default parameters for this Query Lambda
    DefaultParameters []QueryParameter `json:"default_parameters,omitempty"`
}

type QueryLambdaStats struct {
    // ISO-8601 date
    LastExecuted string `json:"last_executed,omitempty"`
    // user who last executed Query Lambda
    LastExecutedBy string `json:"last_executed_by,omitempty"`
    // ISO-8601 date of last execution failure
    LastExecutionError string `json:"last_execution_error,omitempty"`
    // error message associated with last failed execution
    LastExecutionErrorMessage string `json:"last_execution_error_message,omitempty"`
}

type QueryLambdaTag struct {
    // name of Query Lambda tag
    TagName string `json:"tag_name,omitempty"`
    // query lambda version
    Version *QueryLambdaVersion `json:"version,omitempty"`
}

type QueryLambdaTagResponse struct {
    // updated Query Lambda tag
    Data *QueryLambdaTag `json:"data,omitempty"`
}

type QueryLambdaVersion struct {
    // workspace of this Query Lambda
    Workspace string `json:"workspace,omitempty"`
    // user that created this Query Lambda
    CreatedBy string `json:"created_by,omitempty"`
    // ISO-8601 date of when Query Lambda was created
    CreatedAt string `json:"created_at,omitempty"`
    // Query Lambda name
    Name string `json:"name,omitempty"`
    // Query Lambda version
    Version string `json:"version,omitempty"`
    // optional description
    Description string `json:"description,omitempty"`
    // Query Lambda SQL query
    Sql *QueryLambdaSql `json:"sql,omitempty"`
    // collections queried by underlying SQL query
    Collections []string `json:"collections,omitempty"`
    // status of this Query Lambda
    State string `json:"state,omitempty"`
    // stats related to this Query Lambda
    Stats *QueryLambdaStats `json:"stats,omitempty"`
}

type QueryLambdaVersionResponse struct {
    // Query Lambda version details
    Data *QueryLambdaVersion `json:"data,omitempty"`
}

type QueryLambdasApiService Service

type QueryParameter struct {
    // name of the field
    Name string `json:"name"`
    // data type of the field
    Type_ string `json:"type"`
    // literal value of the field
    Value string `json:"value"`
}

type QueryRequest struct {
    // details about the query
    Sql *QueryRequestSql `json:"sql,omitempty"`
}

type QueryRequestSql struct {
    // list of named parameters
    Parameters []QueryParameter `json:"parameters,omitempty"`
    // SQL query as a string
    Query string `json:"query"`
    // Row limit to use if no limit specified in the query
    DefaultRowLimit int32 `json:"default_row_limit,omitempty"`
    // Whether to generate warnings
    GenerateWarnings bool `json:"generate_warnings,omitempty"`
    // Whether to generate a performance profile for this query
    ProfilingEnabled bool `json:"profiling_enabled,omitempty"`
}

type QueryResponse struct {
    // unique id for this query
    QueryId string `json:"query_id,omitempty"`
    // list of collections queried by the query
    Collections []string `json:"collections,omitempty"`
    // list of objects returned by the query
    Results []interface{} `json:"results,omitempty"`
    // meta information about the query
    Stats *QueryResponseStats `json:"stats,omitempty"`
    // warnings received from the query
    Warnings []string `json:"warnings,omitempty"`
    // errors encountered while streaming the query
    QueryErrors []QueryError `json:"query_errors,omitempty"`
    // meta information about each column in the result set
    ColumnFields []QueryFieldType `json:"column_fields,omitempty"`
}

type QueryResponseStats struct {
    // query time in milliseconds
    ElapsedTimeMs int64 `json:"elapsed_time_ms,omitempty"`
}

type RedshiftIntegration struct {
    // AWS access key credentials
    AwsAccessKey *AwsAccessKey `json:"aws_access_key,omitempty"`
    // Username associated with Redshift cluster
    Username string `json:"username"`
    // Password associated with Redshift cluster
    Password string `json:"password"`
    // Redshift Cluster host
    Host string `json:"host"`
    // Redshift Cluster port
    Port int32 `json:"port"`
    // unload S3 bucket path
    S3BucketPath string `json:"s3_bucket_path"`
}

type Resource struct {
    // ISO-8601 date
    CreatedAt string `json:"created_at,omitempty"`
    // email of user who created the collection
    CreatedBy string `json:"created_by,omitempty"`
    // unique identifer for collection, can contain alphanumeric or dash characters
    Name string `json:"name,omitempty"`
    // text describing the collection
    Description string `json:"description,omitempty"`
    // current status of collection, one of: CREATED, READY, DELETED, PAUSED, RESUMING
    Status string `json:"status,omitempty"`
    // list of sources from which collection ingests
    Sources []Source `json:"sources,omitempty"`
    // metrics about the collection
    Stats *ResourceStats `json:"stats,omitempty"`
    // number of seconds after which data is purged based on event time
    RetentionSecs int64 `json:"retention_secs,omitempty"`
    // list of mappings applied on all documents in a collection
    FieldMappings []FieldMappingV2 `json:"field_mappings,omitempty"`
}

type ResourceStats struct {
    // number of documents in the collection
    DocCount int64 `json:"doc_count,omitempty"`
    // total collection size in bytes
    TotalSize int64 `json:"total_size,omitempty"`
    // number between 0 and 1 that indicates progress of collection creation
    FillProgress float64 `json:"fill_progress,omitempty"`
    // milliseconds since Unix epoch Jan 1, 1970
    LastUpdatedMs int64 `json:"last_updated_ms,omitempty"`
    // milliseconds since Unix epoch Jan 1, 1970
    LastQueriedMs int64 `json:"last_queried_ms,omitempty"`
}

type Response struct {
    Metadata map[string][]interface{} `json:"metadata,omitempty"`
    Status   int32                    `json:"status,omitempty"`
    Entity   *interface{}             `json:"entity,omitempty"`
}

type S3Integration struct {
    // credentials for an AWS access key integration
    AwsAccessKey *AwsAccessKey `json:"aws_access_key,omitempty"`
    // details of an AWS cross-account role integration
    AwsRole *AwsRole `json:"aws_role,omitempty"`
}

type SavedQuery struct {
    // workspace of this saved query
    Workspace string `json:"workspace,omitempty"`
    // user that created this query
    CreatedBy string `json:"created_by,omitempty"`
    // ISO-8601 date of when saved query was created
    CreatedAt string `json:"created_at,omitempty"`
    // query name
    Name string `json:"name,omitempty"`
    // query version
    Version int32 `json:"version,omitempty"`
    // optional version tag
    VersionTag string `json:"version_tag,omitempty"`
    // SQL text of this query
    QuerySql string `json:"query_sql,omitempty"`
    // collections queried by this query
    Collections []string `json:"collections,omitempty"`
    // parameters associated with this query
    Parameters []SavedQueryParameter `json:"parameters,omitempty"`
    // status of this query
    State string `json:"state,omitempty"`
    // stats related to this query
    Stats *SavedQueryStats `json:"stats,omitempty"`
}

type SavedQueryParameter struct {
    // name of the field
    Name string `json:"name"`
    // data type of the field
    Type_ string `json:"type"`
    // default value of the field
    DefaultValue *interface{} `json:"default_value"`
}

type SavedQueryStats struct {
    // ISO-8601 date
    LastExecuted string `json:"last_executed,omitempty"`
    // user who last executed saved query
    LastExecutedBy string `json:"last_executed_by,omitempty"`
    // ISO-8601 date of last execution failure
    LastExecutionError string `json:"last_execution_error,omitempty"`
    // error message associated with last failed query execution
    LastExecutionErrorMessage string `json:"last_execution_error_message,omitempty"`
}

type SegmentIntegration struct {
    // segment connection string
    ConnectionString string `json:"connection_string,omitempty"`
}

type Service struct {
    Client *APIClient
}

type Source struct {
    // name of integration to use
    IntegrationName string `json:"integration_name"`
    // configuration for ingestion from S3
    S3  *SourceS3 `json:"s3,omitempty"`
    // configuration for ingestion from kinesis stream
    Kinesis *SourceKinesis `json:"kinesis,omitempty"`
    // configuration for ingestion from GCS
    Gcs *SourceGcs `json:"gcs,omitempty"`
    // configuration for ingestion from Redshift
    Redshift *SourceRedshift `json:"redshift,omitempty"`
    // configuration for ingestion from  a dynamodb table
    Dynamodb *SourceDynamoDb `json:"dynamodb,omitempty"`
    // file upload details
    FileUpload *SourceFileUpload `json:"file_upload,omitempty"`
    // kafka collection identifier
    Kafka *SourceKafka `json:"kafka,omitempty"`
    // MongoDB collection details
    Mongodb *SourceMongoDb `json:"mongodb,omitempty"`
    // the ingest status of this source
    Status *Status `json:"status,omitempty"`
    // format parameters for data from this source
    FormatParams *FormatParams `json:"format_params,omitempty"`
}

type SourceDynamoDb struct {
    // AWS region name of DynamoDB table, by default us-west-2 is used
    AwsRegion string `json:"aws_region,omitempty"`
    // name of DynamoDB table containing data
    TableName string `json:"table_name"`
    // DynamoDB source status
    Status *StatusDynamoDb `json:"status,omitempty"`
    // Max RCU usage for scan
    Rcu int64 `json:"rcu,omitempty"`
}

type SourceFileUpload struct {
    // name of the file
    FileName string `json:"file_name"`
    // size of the file in bytes
    FileSize int64 `json:"file_size"`
    // time of file upload
    FileUploadTime string `json:"file_upload_time"`
}

type SourceGcs struct {
    // name of GCS bucket you want to ingest from
    Bucket string `json:"bucket,omitempty"`
    // Prefix that selects keys to ingest.
    Prefix string `json:"prefix,omitempty"`
}

type SourceKafka struct {
    // The Kafka topic to be tailed
    KafkaTopicName string `json:"kafka_topic_name"`
    // Kafka source status
    Status *StatusKafka `json:"status,omitempty"`
}

type SourceKinesis struct {
    // name of kinesis stream
    StreamName string `json:"stream_name"`
    // AWS region name of Kinesis stream, by default us-west-2 is used
    AwsRegion string `json:"aws_region,omitempty"`
}

type SourceMongoDb struct {
    // MongoDB database name containing this collection
    DatabaseName string `json:"database_name"`
    // MongoDB collection name
    CollectionName string `json:"collection_name"`
    // MongoDB source status
    Status *StatusMongoDb `json:"status,omitempty"`
}

type SourceRedshift struct {
    // name of the database in Redshift Cluster
    Database string `json:"database"`
    // schema which contains the Redshift table
    Schema string `json:"schema"`
    // name of Redshift table containing data
    TableName string `json:"table_name"`
    // field in Redshift source table to monitor for updates
    IncrementalField string `json:"incremental_field,omitempty"`
}

type SourceS3 struct {
    // Prefix that selects keys to ingest.
    Prefix string `json:"prefix,omitempty"`
    // Pattern that selects keys to ingest.
    Pattern string `json:"pattern,omitempty"`
    // address of S3 bucket containing data
    Bucket string `json:"bucket"`
}

type SqlExpression struct {
    // The name of a sql function
    Sql string `json:"sql,omitempty"`
}

type Status struct {
    // Status of the Source's ingestion, one of: INITIALIZING, WATCHING, PROCESSING, COMPLETED, ERROR
    State string `json:"state,omitempty"`
    // ISO-8601 date when state was triggered
    Since string `json:"since,omitempty"`
    // state message
    Message string `json:"message,omitempty"`
    // ISO-8601 date when source was last processed
    LastProcessedAt string `json:"last_processed_at,omitempty"`
    // last source item processed by ingester
    LastProcessedItem string `json:"last_processed_item,omitempty"`
    // Total items processed of source
    TotalProcessedItems int64 `json:"total_processed_items,omitempty"`
    // ISO-8601 date when last error occurred
    LastErrorAt string `json:"last_error_at,omitempty"`
    // last source item that errored
    LastErrorItem string `json:"last_error_item,omitempty"`
    // reason for the last error
    LastErrorReason string `json:"last_error_reason,omitempty"`
    // Total items that errored
    TotalErrorItems int64 `json:"total_error_items,omitempty"`
}

type StatusDynamoDb struct {
    // DynamoDB scan start time
    ScanStartTime string `json:"scan_start_time,omitempty"`
    // DynamoDb scan end time
    ScanEndTime string `json:"scan_end_time,omitempty"`
    // Number of records inserted using scan
    ScanRecordsProcessed int64 `json:"scan_records_processed,omitempty"`
    // Number of records in DynamoDB table at time of scan
    ScanTotalRecords int64 `json:"scan_total_records,omitempty"`
    // state of current ingest for this table
    State string `json:"state,omitempty"`
    // ISO-8601 date when source was last processed
    StreamLastProcessedAt string `json:"stream_last_processed_at,omitempty"`
}

type StatusKafka struct {
    // State of the Kafka source
    State string `json:"state,omitempty"`
    // Time at which the last document was consumed from Kafka
    LastConsumedTime string `json:"last_consumed_time,omitempty"`
    // Number of documents consumed by this Kafka topic
    NumDocumentsProcessed int64 `json:"num_documents_processed,omitempty"`
}

type StatusKafkaPartition struct {
    // The number of this partition
    PartitionNumber int32 `json:"partition_number,omitempty"`
    // Number of documents consumed by this partition
    NumDocumentsProcessed int64 `json:"num_documents_processed,omitempty"`
}

type StatusMongoDb struct {
    // MongoDB scan start time
    ScanStartTime string `json:"scan_start_time,omitempty"`
    // MongoDB scan end time
    ScanEndTime string `json:"scan_end_time,omitempty"`
    // Number of records inserted using scan
    ScanRecordsProcessed int64 `json:"scan_records_processed,omitempty"`
    // Number of records in MongoDB table at time of scan
    ScanTotalRecords int64 `json:"scan_total_records,omitempty"`
    // state of current ingest for this table
    State string `json:"state,omitempty"`
    // ISO-8601 date when new insert from source was last processed
    StreamLastInsertProcessedAt string `json:"stream_last_insert_processed_at,omitempty"`
    // ISO-8601 date when update from source was last processed
    StreamLastUpdateProcessedAt string `json:"stream_last_update_processed_at,omitempty"`
    // ISO-8601 date when delete from source was last processed
    StreamLastDeleteProcessedAt string `json:"stream_last_delete_processed_at,omitempty"`
    // Number of new records inserted using stream
    StreamRecordsInserted int64 `json:"stream_records_inserted,omitempty"`
    // Number of new records updated using stream
    StreamRecordsUpdated int64 `json:"stream_records_updated,omitempty"`
    // Number of new records deleted using stream
    StreamRecordsDeleted int64 `json:"stream_records_deleted,omitempty"`
}

type UpdateOpts struct {
    Create optional.Bool
}

type UpdateQueryLambdaRequest struct {
    // optional description
    Description string `json:"description,omitempty"`
    // Query Lambda SQL query
    Sql *QueryLambdaSql `json:"sql,omitempty"`
}

type UpdateQueryLambdaResponse struct {
    // Query Lambda data
    Data *QueryLambda `json:"data,omitempty"`
}

type UpdateSavedQueryRequest struct {
    // optional version tag
    VersionTag string `json:"version_tag,omitempty"`
    // SQL text of this query
    QuerySql string `json:"query_sql"`
    // parameters associated with this query
    Parameters []SavedQueryParameter `json:"parameters,omitempty"`
}

type UpdateSavedQueryResponse struct {
    // saved query data
    Data *SavedQuery `json:"data,omitempty"`
}

type User struct {
    // ISO-8601 date
    CreatedAt string `json:"created_at,omitempty"`
    // user email
    Email string `json:"email"`
    // user first name
    FirstName string `json:"first_name,omitempty"`
    // user last name
    LastName string `json:"last_name,omitempty"`
    // List of roles for a given user
    Roles []string `json:"roles,omitempty"`
    // state of user - NEW / ACTIVE
    State          string          `json:"state,omitempty"`
    Org            string          `json:"org,omitempty"`
    InviteState    string          `json:"invite_state,omitempty"`
    Orgs           []Organization  `json:"orgs,omitempty"`
    OrgMemberships []OrgMembership `json:"org_memberships,omitempty"`
}

type UsersApiService Service

type ValidateOpts struct {
    Parameters optional.Bool
}

type ValidateQueryResponse struct {
    // list of collection specified in query
    Name []string `json:"name"`
    // list of collection specified in query
    Collections []string `json:"collections"`
    // list of parameters specified in query
    Parameters []string `json:"parameters"`
}

type Workspace struct {
    // ISO-8601 date of when workspace was created
    CreatedAt string `json:"created_at,omitempty"`
    // email of user who created the workspace
    CreatedBy string `json:"created_by,omitempty"`
    // descriptive label and unique identifier
    Name string `json:"name,omitempty"`
    // longer explanation for the workspace
    Description string `json:"description,omitempty"`
    // number of collections that are immediate children of workspace
    CollectionCount int64 `json:"collection_count,omitempty"`
}

type WorkspacesApiService Service

type XmlParams struct {
    // tag until which xml is ignored
    RootTag string `json:"root_tag,omitempty"`
    // encoding in which data source is encoded
    Encoding string `json:"encoding,omitempty"`
    // tags with which documents are identified
    DocTag string `json:"doc_tag,omitempty"`
    // tag used for the value when there are attributes in the element having no child
    ValueTag string `json:"value_tag,omitempty"`
    // tag to differentiate between attributes and elements
    AttributePrefix string `json:"attribute_prefix,omitempty"`
}