pipelines

type ASN = shared.ASN

type ASNParam = shared.ASNParam

type AuditLog = shared.AuditLog

type AuditLogAction = shared.AuditLogAction

type AuditLogActor = shared.AuditLogActor

type AuditLogActorType = shared.AuditLogActorType

type AuditLogOwner = shared.AuditLogOwner

type AuditLogResource = shared.AuditLogResource

type CertificateCA = shared.CertificateCA

type CertificateRequestType = shared.CertificateRequestType

type CloudflareTunnel = shared.CloudflareTunnel

type CloudflareTunnelConfigSrc = shared.CloudflareTunnelConfigSrc

type CloudflareTunnelConnection = shared.CloudflareTunnelConnection

type CloudflareTunnelStatus = shared.CloudflareTunnelStatus

type CloudflareTunnelTunType = shared.CloudflareTunnelTunType

type Error = apierror.Error

type ErrorData = shared.ErrorData

type ErrorDataSource = shared.ErrorDataSource

type ListField struct {
	Items SourceField   `json:"items" api:"required"`
	JSON  listFieldJSON `json:"-"`
}

type ListFieldParam struct {
	Items param.Field[SourceFieldUnionParam] `json:"items" api:"required"`
}

type Member = shared.Member

type MemberPoliciesAccess = shared.MemberPoliciesAccess

type MemberPoliciesPermissionGroup = shared.MemberPoliciesPermissionGroup

type MemberPoliciesPermissionGroupsMeta = shared.MemberPoliciesPermissionGroupsMeta

type MemberPoliciesResourceGroup = shared.MemberPoliciesResourceGroup

type MemberPoliciesResourceGroupsMeta = shared.MemberPoliciesResourceGroupsMeta

type MemberPoliciesResourceGroupsScope = shared.MemberPoliciesResourceGroupsScope

type MemberPoliciesResourceGroupsScopeObject = shared.MemberPoliciesResourceGroupsScopeObject

type MemberPolicy = shared.MemberPolicy

type MemberStatus = shared.MemberStatus

type MemberUser = shared.MemberUser

type Permission = shared.Permission

type PermissionGrant = shared.PermissionGrant

type PermissionGrantParam = shared.PermissionGrantParam

type PipelineDeleteParams struct {
	// Specifies the public ID of the account.
	AccountID param.Field[string] `path:"account_id" api:"required"`
}

type PipelineDeleteV1Params struct {
	// Specifies the public ID of the account.
	AccountID param.Field[string] `path:"account_id" api:"required"`
}

type PipelineDeleteV1Response = interface{}

type PipelineDeleteV1ResponseEnvelope struct {
	Result PipelineDeleteV1Response `json:"result" api:"required"`
	// Indicates whether the API call was successful.
	Success bool                                 `json:"success" api:"required"`
	JSON    pipelineDeleteV1ResponseEnvelopeJSON `json:"-"`
}

type PipelineGetParams struct {
	// Specifies the public ID of the account.
	AccountID param.Field[string] `path:"account_id" api:"required"`
}

type PipelineGetResponseDestination struct {
	Batch       PipelineGetResponseDestinationBatch       `json:"batch" api:"required"`
	Compression PipelineGetResponseDestinationCompression `json:"compression" api:"required"`
	// Specifies the format of data to deliver.
	Format PipelineGetResponseDestinationFormat `json:"format" api:"required"`
	Path   PipelineGetResponseDestinationPath   `json:"path" api:"required"`
	// Specifies the type of destination.
	Type PipelineGetResponseDestinationType `json:"type" api:"required"`
	JSON pipelineGetResponseDestinationJSON `json:"-"`
}

type PipelineGetResponseDestinationBatch struct {
	// Specifies rough maximum size of files.
	MaxBytes int64 `json:"max_bytes" api:"required"`
	// Specifies duration to wait to aggregate batches files.
	MaxDurationS float64 `json:"max_duration_s" api:"required"`
	// Specifies rough maximum number of rows per file.
	MaxRows int64                                   `json:"max_rows" api:"required"`
	JSON    pipelineGetResponseDestinationBatchJSON `json:"-"`
}

type PipelineGetResponseDestinationCompression struct {
	// Specifies the desired compression algorithm and format.
	Type PipelineGetResponseDestinationCompressionType `json:"type" api:"required"`
	JSON pipelineGetResponseDestinationCompressionJSON `json:"-"`
}

type PipelineGetResponseDestinationCompressionType string

type PipelineGetResponseDestinationFormat string

type PipelineGetResponseDestinationPath struct {
	// Specifies the R2 Bucket to store files.
	Bucket string `json:"bucket" api:"required"`
	// Specifies the name pattern to for individual data files.
	Filename string `json:"filename"`
	// Specifies the name pattern for directory.
	Filepath string `json:"filepath"`
	// Specifies the base directory within the bucket.
	Prefix string                                 `json:"prefix"`
	JSON   pipelineGetResponseDestinationPathJSON `json:"-"`
}

type PipelineGetResponseDestinationType string

type PipelineGetResponseEnvelope struct {
	// [DEPRECATED] Describes the configuration of a pipeline. Use the new
	// streams/sinks/pipelines API instead.
	//
	// Deprecated: deprecated
	Result PipelineGetResponse `json:"result" api:"required"`
	// Indicates whether the API call was successful.
	Success bool                            `json:"success" api:"required"`
	JSON    pipelineGetResponseEnvelopeJSON `json:"-"`
}

type PipelineGetResponseSource struct {
	// Specifies the format of source data.
	Format PipelineGetResponseSourceFormat `json:"format" api:"required"`
	Type   string                          `json:"type" api:"required"`
	// Specifies whether authentication is required to send to this pipeline via HTTP.
	Authentication bool `json:"authentication"`
	// This field can have the runtime type of
	// [PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS].
	CORS interface{}                   `json:"cors"`
	JSON pipelineGetResponseSourceJSON `json:"-"`
	// contains filtered or unexported fields
}

type PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesBindingSourceFormat string

type PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS struct {
	// Specifies allowed origins to allow Cross Origin HTTP Requests.
	Origins []string                                                                       `json:"origins"`
	JSON    pipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORSJSON `json:"-"`
}

type PipelineGetResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceFormat string

type PipelineGetResponseSourceFormat string

type PipelineGetResponseSourceUnion interface {
	// contains filtered or unexported methods
}

type PipelineGetV1Params struct {
	// Specifies the public ID of the account.
	AccountID param.Field[string] `path:"account_id" api:"required"`
}

type PipelineGetV1Response struct {
	// Indicates a unique identifier for this pipeline.
	ID         string `json:"id" api:"required"`
	CreatedAt  string `json:"created_at" api:"required"`
	ModifiedAt string `json:"modified_at" api:"required"`
	// Indicates the name of the Pipeline.
	Name string `json:"name" api:"required"`
	// Specifies SQL for the Pipeline processing flow.
	Sql string `json:"sql" api:"required"`
	// Indicates the current status of the Pipeline.
	Status string `json:"status" api:"required"`
	// List of streams and sinks used by this pipeline.
	Tables []PipelineGetV1ResponseTable `json:"tables" api:"required"`
	// Indicates the reason for the failure of the Pipeline.
	FailureReason string                    `json:"failure_reason"`
	JSON          pipelineGetV1ResponseJSON `json:"-"`
}

type PipelineGetV1ResponseEnvelope struct {
	Result PipelineGetV1Response `json:"result" api:"required"`
	// Indicates whether the API call was successful.
	Success bool                              `json:"success" api:"required"`
	JSON    pipelineGetV1ResponseEnvelopeJSON `json:"-"`
}

type PipelineGetV1ResponseTable struct {
	// Unique identifier for the connection (stream or sink).
	ID string `json:"id" api:"required"`
	// Latest available version of the connection.
	Latest int64 `json:"latest" api:"required"`
	// Name of the connection.
	Name string `json:"name" api:"required"`
	// Type of the connection.
	Type PipelineGetV1ResponseTablesType `json:"type" api:"required"`
	// Current version of the connection used by this pipeline.
	Version int64                          `json:"version" api:"required"`
	JSON    pipelineGetV1ResponseTableJSON `json:"-"`
}

type PipelineGetV1ResponseTablesType string

type PipelineListParams struct {
	// Specifies the public ID of the account.
	AccountID param.Field[string] `path:"account_id" api:"required"`
	// Specifies which page to retrieve.
	Page param.Field[string] `query:"page"`
	// Specifies the number of pipelines per page.
	PerPage param.Field[string] `query:"per_page"`
	// Specifies the prefix of pipeline name to search.
	Search param.Field[string] `query:"search"`
}

type PipelineListResponse struct {
	ResultInfo PipelineListResponseResultInfo `json:"result_info" api:"required"`
	Results    []PipelineListResponseResult   `json:"results" api:"required"`
	// Indicates whether the API call was successful.
	Success bool                     `json:"success" api:"required"`
	JSON    pipelineListResponseJSON `json:"-"`
}

type PipelineListResponseResultInfo struct {
	// Indicates the number of items on current page.
	Count float64 `json:"count" api:"required"`
	// Indicates the current page number.
	Page float64 `json:"page" api:"required"`
	// Indicates the number of items per page.
	PerPage float64 `json:"per_page" api:"required"`
	// Indicates the total number of items.
	TotalCount float64                            `json:"total_count" api:"required"`
	JSON       pipelineListResponseResultInfoJSON `json:"-"`
}

type PipelineListResponseResultsDestination struct {
	Batch       PipelineListResponseResultsDestinationBatch       `json:"batch" api:"required"`
	Compression PipelineListResponseResultsDestinationCompression `json:"compression" api:"required"`
	// Specifies the format of data to deliver.
	Format PipelineListResponseResultsDestinationFormat `json:"format" api:"required"`
	Path   PipelineListResponseResultsDestinationPath   `json:"path" api:"required"`
	// Specifies the type of destination.
	Type PipelineListResponseResultsDestinationType `json:"type" api:"required"`
	JSON pipelineListResponseResultsDestinationJSON `json:"-"`
}

type PipelineListResponseResultsDestinationBatch struct {
	// Specifies rough maximum size of files.
	MaxBytes int64 `json:"max_bytes" api:"required"`
	// Specifies duration to wait to aggregate batches files.
	MaxDurationS float64 `json:"max_duration_s" api:"required"`
	// Specifies rough maximum number of rows per file.
	MaxRows int64                                           `json:"max_rows" api:"required"`
	JSON    pipelineListResponseResultsDestinationBatchJSON `json:"-"`
}

type PipelineListResponseResultsDestinationCompression struct {
	// Specifies the desired compression algorithm and format.
	Type PipelineListResponseResultsDestinationCompressionType `json:"type" api:"required"`
	JSON pipelineListResponseResultsDestinationCompressionJSON `json:"-"`
}

type PipelineListResponseResultsDestinationCompressionType string

type PipelineListResponseResultsDestinationFormat string

type PipelineListResponseResultsDestinationPath struct {
	// Specifies the R2 Bucket to store files.
	Bucket string `json:"bucket" api:"required"`
	// Specifies the name pattern to for individual data files.
	Filename string `json:"filename"`
	// Specifies the name pattern for directory.
	Filepath string `json:"filepath"`
	// Specifies the base directory within the bucket.
	Prefix string                                         `json:"prefix"`
	JSON   pipelineListResponseResultsDestinationPathJSON `json:"-"`
}

type PipelineListResponseResultsDestinationType string

type PipelineListResponseResultsSource struct {
	// Specifies the format of source data.
	Format PipelineListResponseResultsSourceFormat `json:"format" api:"required"`
	Type   string                                  `json:"type" api:"required"`
	// Specifies whether authentication is required to send to this pipeline via HTTP.
	Authentication bool `json:"authentication"`
	// This field can have the runtime type of
	// [PipelineListResponseResultsSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS].
	CORS interface{}                           `json:"cors"`
	JSON pipelineListResponseResultsSourceJSON `json:"-"`
	// contains filtered or unexported fields
}

type PipelineListResponseResultsSourceCloudflarePipelinesWorkersPipelinesBindingSourceFormat string

type PipelineListResponseResultsSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS struct {
	// Specifies allowed origins to allow Cross Origin HTTP Requests.
	Origins []string                                                                               `json:"origins"`
	JSON    pipelineListResponseResultsSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORSJSON `json:"-"`
}

type PipelineListResponseResultsSourceCloudflarePipelinesWorkersPipelinesHTTPSourceFormat string

type PipelineListResponseResultsSourceFormat string

type PipelineListResponseResultsSourceUnion interface {
	// contains filtered or unexported methods
}

type PipelineListV1Params struct {
	// Specifies the public ID of the account.
	AccountID param.Field[string]  `path:"account_id" api:"required"`
	Page      param.Field[float64] `query:"page"`
	PerPage   param.Field[float64] `query:"per_page"`
}

type PipelineListV1Response struct {
	// Indicates a unique identifier for this pipeline.
	ID         string `json:"id" api:"required"`
	CreatedAt  string `json:"created_at" api:"required"`
	ModifiedAt string `json:"modified_at" api:"required"`
	// Indicates the name of the Pipeline.
	Name string `json:"name" api:"required"`
	// Specifies SQL for the Pipeline processing flow.
	Sql string `json:"sql" api:"required"`
	// Indicates the current status of the Pipeline.
	Status string                     `json:"status" api:"required"`
	JSON   pipelineListV1ResponseJSON `json:"-"`
}

type PipelineNewParams struct {
	// Specifies the public ID of the account.
	AccountID   param.Field[string]                       `path:"account_id" api:"required"`
	Destination param.Field[PipelineNewParamsDestination] `json:"destination" api:"required"`
	// Defines the name of the pipeline.
	Name   param.Field[string]                         `json:"name" api:"required"`
	Source param.Field[[]PipelineNewParamsSourceUnion] `json:"source" api:"required"`
}

type PipelineNewParamsDestination struct {
	Batch       param.Field[PipelineNewParamsDestinationBatch]       `json:"batch" api:"required"`
	Compression param.Field[PipelineNewParamsDestinationCompression] `json:"compression" api:"required"`
	Credentials param.Field[PipelineNewParamsDestinationCredentials] `json:"credentials" api:"required"`
	// Specifies the format of data to deliver.
	Format param.Field[PipelineNewParamsDestinationFormat] `json:"format" api:"required"`
	Path   param.Field[PipelineNewParamsDestinationPath]   `json:"path" api:"required"`
	// Specifies the type of destination.
	Type param.Field[PipelineNewParamsDestinationType] `json:"type" api:"required"`
}

type PipelineNewParamsDestinationBatch struct {
	// Specifies rough maximum size of files.
	MaxBytes param.Field[int64] `json:"max_bytes"`
	// Specifies duration to wait to aggregate batches files.
	MaxDurationS param.Field[float64] `json:"max_duration_s"`
	// Specifies rough maximum number of rows per file.
	MaxRows param.Field[int64] `json:"max_rows"`
}

type PipelineNewParamsDestinationCompression struct {
	// Specifies the desired compression algorithm and format.
	Type param.Field[PipelineNewParamsDestinationCompressionType] `json:"type"`
}

type PipelineNewParamsDestinationCompressionType string

type PipelineNewParamsDestinationCredentials struct {
	// Specifies the R2 Bucket Access Key Id.
	AccessKeyID param.Field[string] `json:"access_key_id" api:"required"`
	// Specifies the R2 Endpoint.
	Endpoint param.Field[string] `json:"endpoint" api:"required"`
	// Specifies the R2 Bucket Secret Access Key.
	SecretAccessKey param.Field[string] `json:"secret_access_key" api:"required"`
}

type PipelineNewParamsDestinationFormat string

type PipelineNewParamsDestinationPath struct {
	// Specifies the R2 Bucket to store files.
	Bucket param.Field[string] `json:"bucket" api:"required"`
	// Specifies the name pattern to for individual data files.
	Filename param.Field[string] `json:"filename"`
	// Specifies the name pattern for directory.
	Filepath param.Field[string] `json:"filepath"`
	// Specifies the base directory within the bucket.
	Prefix param.Field[string] `json:"prefix"`
}

type PipelineNewParamsDestinationType string

type PipelineNewParamsSource struct {
	// Specifies the format of source data.
	Format param.Field[PipelineNewParamsSourceFormat] `json:"format" api:"required"`
	Type   param.Field[string]                        `json:"type" api:"required"`
	// Specifies whether authentication is required to send to this pipeline via HTTP.
	Authentication param.Field[bool]        `json:"authentication"`
	CORS           param.Field[interface{}] `json:"cors"`
}

type PipelineNewParamsSourceCloudflarePipelinesWorkersPipelinesBindingSourceFormat string

type PipelineNewParamsSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS struct {
	// Specifies allowed origins to allow Cross Origin HTTP Requests.
	Origins param.Field[[]string] `json:"origins"`
}

type PipelineNewParamsSourceCloudflarePipelinesWorkersPipelinesHTTPSourceFormat string

type PipelineNewParamsSourceFormat string

type PipelineNewParamsSourceUnion interface {
	// contains filtered or unexported methods
}

type PipelineNewResponseDestination struct {
	Batch       PipelineNewResponseDestinationBatch       `json:"batch" api:"required"`
	Compression PipelineNewResponseDestinationCompression `json:"compression" api:"required"`
	// Specifies the format of data to deliver.
	Format PipelineNewResponseDestinationFormat `json:"format" api:"required"`
	Path   PipelineNewResponseDestinationPath   `json:"path" api:"required"`
	// Specifies the type of destination.
	Type PipelineNewResponseDestinationType `json:"type" api:"required"`
	JSON pipelineNewResponseDestinationJSON `json:"-"`
}

type PipelineNewResponseDestinationBatch struct {
	// Specifies rough maximum size of files.
	MaxBytes int64 `json:"max_bytes" api:"required"`
	// Specifies duration to wait to aggregate batches files.
	MaxDurationS float64 `json:"max_duration_s" api:"required"`
	// Specifies rough maximum number of rows per file.
	MaxRows int64                                   `json:"max_rows" api:"required"`
	JSON    pipelineNewResponseDestinationBatchJSON `json:"-"`
}

type PipelineNewResponseDestinationCompression struct {
	// Specifies the desired compression algorithm and format.
	Type PipelineNewResponseDestinationCompressionType `json:"type" api:"required"`
	JSON pipelineNewResponseDestinationCompressionJSON `json:"-"`
}

type PipelineNewResponseDestinationCompressionType string

type PipelineNewResponseDestinationFormat string

type PipelineNewResponseDestinationPath struct {
	// Specifies the R2 Bucket to store files.
	Bucket string `json:"bucket" api:"required"`
	// Specifies the name pattern to for individual data files.
	Filename string `json:"filename"`
	// Specifies the name pattern for directory.
	Filepath string `json:"filepath"`
	// Specifies the base directory within the bucket.
	Prefix string                                 `json:"prefix"`
	JSON   pipelineNewResponseDestinationPathJSON `json:"-"`
}

type PipelineNewResponseDestinationType string

type PipelineNewResponseEnvelope struct {
	// [DEPRECATED] Describes the configuration of a pipeline. Use the new
	// streams/sinks/pipelines API instead.
	//
	// Deprecated: deprecated
	Result PipelineNewResponse `json:"result" api:"required"`
	// Indicates whether the API call was successful.
	Success bool                            `json:"success" api:"required"`
	JSON    pipelineNewResponseEnvelopeJSON `json:"-"`
}

type PipelineNewResponseSource struct {
	// Specifies the format of source data.
	Format PipelineNewResponseSourceFormat `json:"format" api:"required"`
	Type   string                          `json:"type" api:"required"`
	// Specifies whether authentication is required to send to this pipeline via HTTP.
	Authentication bool `json:"authentication"`
	// This field can have the runtime type of
	// [PipelineNewResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS].
	CORS interface{}                   `json:"cors"`
	JSON pipelineNewResponseSourceJSON `json:"-"`
	// contains filtered or unexported fields
}

type PipelineNewResponseSourceCloudflarePipelinesWorkersPipelinesBindingSourceFormat string

type PipelineNewResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS struct {
	// Specifies allowed origins to allow Cross Origin HTTP Requests.
	Origins []string                                                                       `json:"origins"`
	JSON    pipelineNewResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORSJSON `json:"-"`
}

type PipelineNewResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceFormat string

type PipelineNewResponseSourceFormat string

type PipelineNewResponseSourceUnion interface {
	// contains filtered or unexported methods
}

type PipelineNewV1Params struct {
	// Specifies the public ID of the account.
	AccountID param.Field[string] `path:"account_id" api:"required"`
	// Specifies the name of the Pipeline.
	Name param.Field[string] `json:"name" api:"required"`
	// Specifies SQL for the Pipeline processing flow.
	Sql param.Field[string] `json:"sql" api:"required"`
}

type PipelineNewV1Response struct {
	// Indicates a unique identifier for this pipeline.
	ID         string `json:"id" api:"required"`
	CreatedAt  string `json:"created_at" api:"required"`
	ModifiedAt string `json:"modified_at" api:"required"`
	// Indicates the name of the Pipeline.
	Name string `json:"name" api:"required"`
	// Specifies SQL for the Pipeline processing flow.
	Sql string `json:"sql" api:"required"`
	// Indicates the current status of the Pipeline.
	Status string                    `json:"status" api:"required"`
	JSON   pipelineNewV1ResponseJSON `json:"-"`
}

type PipelineNewV1ResponseEnvelope struct {
	Result PipelineNewV1Response `json:"result" api:"required"`
	// Indicates whether the API call was successful.
	Success bool                              `json:"success" api:"required"`
	JSON    pipelineNewV1ResponseEnvelopeJSON `json:"-"`
}

type PipelineService struct {
	Options []option.RequestOption
	Sinks   *SinkService
	Streams *StreamService
}

type PipelineUpdateParams struct {
	// Specifies the public ID of the account.
	AccountID   param.Field[string]                          `path:"account_id" api:"required"`
	Destination param.Field[PipelineUpdateParamsDestination] `json:"destination" api:"required"`
	// Defines the name of the pipeline.
	Name   param.Field[string]                            `json:"name" api:"required"`
	Source param.Field[[]PipelineUpdateParamsSourceUnion] `json:"source" api:"required"`
}

type PipelineUpdateParamsDestination struct {
	Batch       param.Field[PipelineUpdateParamsDestinationBatch]       `json:"batch" api:"required"`
	Compression param.Field[PipelineUpdateParamsDestinationCompression] `json:"compression" api:"required"`
	// Specifies the format of data to deliver.
	Format param.Field[PipelineUpdateParamsDestinationFormat] `json:"format" api:"required"`
	Path   param.Field[PipelineUpdateParamsDestinationPath]   `json:"path" api:"required"`
	// Specifies the type of destination.
	Type        param.Field[PipelineUpdateParamsDestinationType]        `json:"type" api:"required"`
	Credentials param.Field[PipelineUpdateParamsDestinationCredentials] `json:"credentials"`
}

type PipelineUpdateParamsDestinationBatch struct {
	// Specifies rough maximum size of files.
	MaxBytes param.Field[int64] `json:"max_bytes"`
	// Specifies duration to wait to aggregate batches files.
	MaxDurationS param.Field[float64] `json:"max_duration_s"`
	// Specifies rough maximum number of rows per file.
	MaxRows param.Field[int64] `json:"max_rows"`
}

type PipelineUpdateParamsDestinationCompression struct {
	// Specifies the desired compression algorithm and format.
	Type param.Field[PipelineUpdateParamsDestinationCompressionType] `json:"type"`
}

type PipelineUpdateParamsDestinationCompressionType string

type PipelineUpdateParamsDestinationCredentials struct {
	// Specifies the R2 Bucket Access Key Id.
	AccessKeyID param.Field[string] `json:"access_key_id" api:"required"`
	// Specifies the R2 Endpoint.
	Endpoint param.Field[string] `json:"endpoint" api:"required"`
	// Specifies the R2 Bucket Secret Access Key.
	SecretAccessKey param.Field[string] `json:"secret_access_key" api:"required"`
}

type PipelineUpdateParamsDestinationFormat string

type PipelineUpdateParamsDestinationPath struct {
	// Specifies the R2 Bucket to store files.
	Bucket param.Field[string] `json:"bucket" api:"required"`
	// Specifies the name pattern to for individual data files.
	Filename param.Field[string] `json:"filename"`
	// Specifies the name pattern for directory.
	Filepath param.Field[string] `json:"filepath"`
	// Specifies the base directory within the bucket.
	Prefix param.Field[string] `json:"prefix"`
}

type PipelineUpdateParamsDestinationType string

type PipelineUpdateParamsSource struct {
	// Specifies the format of source data.
	Format param.Field[PipelineUpdateParamsSourceFormat] `json:"format" api:"required"`
	Type   param.Field[string]                           `json:"type" api:"required"`
	// Specifies whether authentication is required to send to this pipeline via HTTP.
	Authentication param.Field[bool]        `json:"authentication"`
	CORS           param.Field[interface{}] `json:"cors"`
}

type PipelineUpdateParamsSourceCloudflarePipelinesWorkersPipelinesBindingSourceFormat string

type PipelineUpdateParamsSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS struct {
	// Specifies allowed origins to allow Cross Origin HTTP Requests.
	Origins param.Field[[]string] `json:"origins"`
}

type PipelineUpdateParamsSourceCloudflarePipelinesWorkersPipelinesHTTPSourceFormat string

type PipelineUpdateParamsSourceFormat string

type PipelineUpdateParamsSourceUnion interface {
	// contains filtered or unexported methods
}

type PipelineUpdateResponseDestination struct {
	Batch       PipelineUpdateResponseDestinationBatch       `json:"batch" api:"required"`
	Compression PipelineUpdateResponseDestinationCompression `json:"compression" api:"required"`
	// Specifies the format of data to deliver.
	Format PipelineUpdateResponseDestinationFormat `json:"format" api:"required"`
	Path   PipelineUpdateResponseDestinationPath   `json:"path" api:"required"`
	// Specifies the type of destination.
	Type PipelineUpdateResponseDestinationType `json:"type" api:"required"`
	JSON pipelineUpdateResponseDestinationJSON `json:"-"`
}

type PipelineUpdateResponseDestinationBatch struct {
	// Specifies rough maximum size of files.
	MaxBytes int64 `json:"max_bytes" api:"required"`
	// Specifies duration to wait to aggregate batches files.
	MaxDurationS float64 `json:"max_duration_s" api:"required"`
	// Specifies rough maximum number of rows per file.
	MaxRows int64                                      `json:"max_rows" api:"required"`
	JSON    pipelineUpdateResponseDestinationBatchJSON `json:"-"`
}

type PipelineUpdateResponseDestinationCompression struct {
	// Specifies the desired compression algorithm and format.
	Type PipelineUpdateResponseDestinationCompressionType `json:"type" api:"required"`
	JSON pipelineUpdateResponseDestinationCompressionJSON `json:"-"`
}

type PipelineUpdateResponseDestinationCompressionType string

type PipelineUpdateResponseDestinationFormat string

type PipelineUpdateResponseDestinationPath struct {
	// Specifies the R2 Bucket to store files.
	Bucket string `json:"bucket" api:"required"`
	// Specifies the name pattern to for individual data files.
	Filename string `json:"filename"`
	// Specifies the name pattern for directory.
	Filepath string `json:"filepath"`
	// Specifies the base directory within the bucket.
	Prefix string                                    `json:"prefix"`
	JSON   pipelineUpdateResponseDestinationPathJSON `json:"-"`
}

type PipelineUpdateResponseDestinationType string

type PipelineUpdateResponseEnvelope struct {
	// [DEPRECATED] Describes the configuration of a pipeline. Use the new
	// streams/sinks/pipelines API instead.
	//
	// Deprecated: deprecated
	Result PipelineUpdateResponse `json:"result" api:"required"`
	// Indicates whether the API call was successful.
	Success bool                               `json:"success" api:"required"`
	JSON    pipelineUpdateResponseEnvelopeJSON `json:"-"`
}

type PipelineUpdateResponseSource struct {
	// Specifies the format of source data.
	Format PipelineUpdateResponseSourceFormat `json:"format" api:"required"`
	Type   string                             `json:"type" api:"required"`
	// Specifies whether authentication is required to send to this pipeline via HTTP.
	Authentication bool `json:"authentication"`
	// This field can have the runtime type of
	// [PipelineUpdateResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS].
	CORS interface{}                      `json:"cors"`
	JSON pipelineUpdateResponseSourceJSON `json:"-"`
	// contains filtered or unexported fields
}

type PipelineUpdateResponseSourceCloudflarePipelinesWorkersPipelinesBindingSourceFormat string

type PipelineUpdateResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS struct {
	// Specifies allowed origins to allow Cross Origin HTTP Requests.
	Origins []string                                                                          `json:"origins"`
	JSON    pipelineUpdateResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORSJSON `json:"-"`
}

type PipelineUpdateResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceFormat string

type PipelineUpdateResponseSourceFormat string

type PipelineUpdateResponseSourceUnion interface {
	// contains filtered or unexported methods
}

type PipelineValidateSqlParams struct {
	// Specifies the public ID of the account.
	AccountID param.Field[string] `path:"account_id" api:"required"`
	// Specifies SQL to validate.
	Sql param.Field[string] `json:"sql" api:"required"`
}

type PipelineValidateSqlResponse struct {
	// Indicates tables involved in the processing.
	Tables map[string]PipelineValidateSqlResponseTable `json:"tables" api:"required"`
	// Indicates the processing flow to implement the SQL.
	Graph PipelineValidateSqlResponseGraph `json:"graph"`
	JSON  pipelineValidateSqlResponseJSON  `json:"-"`
}

type PipelineValidateSqlResponseEnvelope struct {
	Result PipelineValidateSqlResponse `json:"result" api:"required"`
	// Indicates whether the API call was successful.
	Success bool                                    `json:"success" api:"required"`
	JSON    pipelineValidateSqlResponseEnvelopeJSON `json:"-"`
}

type PipelineValidateSqlResponseGraph struct {
	Edges []PipelineValidateSqlResponseGraphEdge `json:"edges" api:"required"`
	Nodes []PipelineValidateSqlResponseGraphNode `json:"nodes" api:"required"`
	JSON  pipelineValidateSqlResponseGraphJSON   `json:"-"`
}

type PipelineValidateSqlResponseGraphEdge struct {
	DestID    int64                                    `json:"dest_id" api:"required"`
	EdgeType  string                                   `json:"edge_type" api:"required"`
	KeyType   string                                   `json:"key_type" api:"required"`
	SrcID     int64                                    `json:"src_id" api:"required"`
	ValueType string                                   `json:"value_type" api:"required"`
	JSON      pipelineValidateSqlResponseGraphEdgeJSON `json:"-"`
}

type PipelineValidateSqlResponseGraphNode struct {
	Description string                                   `json:"description" api:"required"`
	NodeID      int64                                    `json:"node_id" api:"required"`
	Operator    string                                   `json:"operator" api:"required"`
	Parallelism int64                                    `json:"parallelism" api:"required"`
	JSON        pipelineValidateSqlResponseGraphNodeJSON `json:"-"`
}

type PipelineValidateSqlResponseTable struct {
	ID      string                               `json:"id" api:"required"`
	Name    string                               `json:"name" api:"required"`
	Type    string                               `json:"type" api:"required"`
	Version float64                              `json:"version" api:"required"`
	JSON    pipelineValidateSqlResponseTableJSON `json:"-"`
}

type RatePlan = shared.RatePlan

type RatePlanID = shared.RatePlanID

type RatePlanParam = shared.RatePlanParam

type ResponseInfo = shared.ResponseInfo

type ResponseInfoSource = shared.ResponseInfoSource

type Role = shared.Role

type RoleParam = shared.RoleParam

type RolePermissions = shared.RolePermissions

type RolePermissionsParam = shared.RolePermissionsParam

type SinkDeleteParams struct {
	// Specifies the public ID of the account.
	AccountID param.Field[string] `path:"account_id" api:"required"`
}

type SinkDeleteResponse = interface{}

type SinkDeleteResponseEnvelope struct {
	Result SinkDeleteResponse `json:"result" api:"required"`
	// Indicates whether the API call was successful.
	Success bool                           `json:"success" api:"required"`
	JSON    sinkDeleteResponseEnvelopeJSON `json:"-"`
}

type SinkGetParams struct {
	// Specifies the public ID of the account.
	AccountID param.Field[string] `path:"account_id" api:"required"`
}

type SinkGetResponse struct {
	// Indicates a unique identifier for this sink.
	ID         string    `json:"id" api:"required"`
	CreatedAt  time.Time `json:"created_at" api:"required" format:"date-time"`
	ModifiedAt time.Time `json:"modified_at" api:"required" format:"date-time"`
	// Defines the name of the Sink.
	Name string `json:"name" api:"required"`
	// Specifies the type of sink.
	Type SinkGetResponseType `json:"type" api:"required"`
	// Defines the configuration of the R2 Sink.
	Config SinkGetResponseConfig `json:"config"`
	// Defines the output data format of a sink.
	Format SinkGetResponseFormat `json:"format"`
	// Defines the schema of the events in the data stream.
	Schema SinkGetResponseSchema `json:"schema"`
	JSON   sinkGetResponseJSON   `json:"-"`
}

type SinkGetResponseConfig struct {
	// Cloudflare Account ID for the bucket
	AccountID string `json:"account_id" api:"required"`
	// R2 Bucket to write to
	Bucket string `json:"bucket" api:"required"`
	// This field can have the runtime type of
	// [SinkGetResponseConfigCloudflarePipelinesR2TablePublicFileNaming].
	FileNaming interface{} `json:"file_naming"`
	// Jurisdiction this bucket is hosted in
	Jurisdiction string `json:"jurisdiction"`
	// Table namespace
	Namespace string `json:"namespace"`
	// This field can have the runtime type of
	// [SinkGetResponseConfigCloudflarePipelinesR2TablePublicPartitioning].
	Partitioning interface{} `json:"partitioning"`
	// Subpath within the bucket to write to
	Path string `json:"path"`
	// This field can have the runtime type of
	// [SinkGetResponseConfigCloudflarePipelinesR2TablePublicRollingPolicy],
	// [SinkGetResponseConfigCloudflarePipelinesR2DataCatalogTablePublicRollingPolicy].
	RollingPolicy interface{} `json:"rolling_policy"`
	// Table name
	TableName string                    `json:"table_name"`
	JSON      sinkGetResponseConfigJSON `json:"-"`
	// contains filtered or unexported fields
}

type SinkGetResponseConfigCloudflarePipelinesR2DataCatalogTablePublic struct {
	// Cloudflare Account ID
	AccountID string `json:"account_id" api:"required" format:"uri"`
	// The R2 Bucket that hosts this catalog
	Bucket string `json:"bucket" api:"required"`
	// Table name
	TableName string `json:"table_name" api:"required"`
	// Table namespace
	Namespace string `json:"namespace"`
	// Rolling policy for file sinks (when & why to close a file and open a new one).
	RollingPolicy SinkGetResponseConfigCloudflarePipelinesR2DataCatalogTablePublicRollingPolicy `json:"rolling_policy"`
	JSON          sinkGetResponseConfigCloudflarePipelinesR2DataCatalogTablePublicJSON          `json:"-"`
}

type SinkGetResponseConfigCloudflarePipelinesR2DataCatalogTablePublicRollingPolicy struct {
	// Files will be rolled after reaching this number of bytes
	FileSizeBytes int64 `json:"file_size_bytes"`
	// Number of seconds of inactivity to wait before rolling over to a new file
	InactivitySeconds int64 `json:"inactivity_seconds"`
	// Number of seconds to wait before rolling over to a new file
	IntervalSeconds int64                                                                             `json:"interval_seconds"`
	JSON            sinkGetResponseConfigCloudflarePipelinesR2DataCatalogTablePublicRollingPolicyJSON `json:"-"`
}

type SinkGetResponseConfigCloudflarePipelinesR2TablePublic struct {
	// Cloudflare Account ID for the bucket
	AccountID string `json:"account_id" api:"required"`
	// R2 Bucket to write to
	Bucket string `json:"bucket" api:"required"`
	// Controls filename prefix/suffix and strategy.
	FileNaming SinkGetResponseConfigCloudflarePipelinesR2TablePublicFileNaming `json:"file_naming"`
	// Jurisdiction this bucket is hosted in
	Jurisdiction string `json:"jurisdiction"`
	// Data-layout partitioning for sinks.
	Partitioning SinkGetResponseConfigCloudflarePipelinesR2TablePublicPartitioning `json:"partitioning"`
	// Subpath within the bucket to write to
	Path string `json:"path"`
	// Rolling policy for file sinks (when & why to close a file and open a new one).
	RollingPolicy SinkGetResponseConfigCloudflarePipelinesR2TablePublicRollingPolicy `json:"rolling_policy"`
	JSON          sinkGetResponseConfigCloudflarePipelinesR2TablePublicJSON          `json:"-"`
}

type SinkGetResponseConfigCloudflarePipelinesR2TablePublicFileNaming struct {
	// The prefix to use in file name. i.e prefix-<uuid>.parquet
	Prefix string `json:"prefix"`
	// Filename generation strategy.
	Strategy SinkGetResponseConfigCloudflarePipelinesR2TablePublicFileNamingStrategy `json:"strategy"`
	// This will overwrite the default file suffix. i.e .parquet, use with caution
	Suffix string                                                              `json:"suffix"`
	JSON   sinkGetResponseConfigCloudflarePipelinesR2TablePublicFileNamingJSON `json:"-"`
}

type SinkGetResponseConfigCloudflarePipelinesR2TablePublicFileNamingStrategy string

type SinkGetResponseConfigCloudflarePipelinesR2TablePublicPartitioning struct {
	// The pattern of the date string
	TimePattern string                                                                `json:"time_pattern"`
	JSON        sinkGetResponseConfigCloudflarePipelinesR2TablePublicPartitioningJSON `json:"-"`
}

type SinkGetResponseConfigCloudflarePipelinesR2TablePublicRollingPolicy struct {
	// Files will be rolled after reaching this number of bytes
	FileSizeBytes int64 `json:"file_size_bytes"`
	// Number of seconds of inactivity to wait before rolling over to a new file
	InactivitySeconds int64 `json:"inactivity_seconds"`
	// Number of seconds to wait before rolling over to a new file
	IntervalSeconds int64                                                                  `json:"interval_seconds"`
	JSON            sinkGetResponseConfigCloudflarePipelinesR2TablePublicRollingPolicyJSON `json:"-"`
}

type SinkGetResponseConfigUnion interface {
	// contains filtered or unexported methods
}

type SinkGetResponseEnvelope struct {
	Result SinkGetResponse `json:"result" api:"required"`
	// Indicates whether the API call was successful.
	Success bool                        `json:"success" api:"required"`
	JSON    sinkGetResponseEnvelopeJSON `json:"-"`
}

type SinkGetResponseFormat struct {
	Type SinkGetResponseFormatType `json:"type" api:"required"`
	// Specifies the compression applied to JSON sink output.
	Compression     SinkGetResponseFormatCompression     `json:"compression"`
	DecimalEncoding SinkGetResponseFormatDecimalEncoding `json:"decimal_encoding"`
	RowGroupBytes   int64                                `json:"row_group_bytes" api:"nullable"`
	TimestampFormat SinkGetResponseFormatTimestampFormat `json:"timestamp_format"`
	Unstructured    bool                                 `json:"unstructured"`
	JSON            sinkGetResponseFormatJSON            `json:"-"`
	// contains filtered or unexported fields
}

type SinkGetResponseFormatCloudflarePipelinesSinkJsonFormat struct {
	Type SinkGetResponseFormatCloudflarePipelinesSinkJsonFormatType `json:"type" api:"required"`
	// Specifies the compression applied to JSON sink output.
	Compression     SinkGetResponseFormatCloudflarePipelinesSinkJsonFormatCompression     `json:"compression"`
	DecimalEncoding SinkGetResponseFormatCloudflarePipelinesSinkJsonFormatDecimalEncoding `json:"decimal_encoding"`
	TimestampFormat SinkGetResponseFormatCloudflarePipelinesSinkJsonFormatTimestampFormat `json:"timestamp_format"`
	Unstructured    bool                                                                  `json:"unstructured"`
	JSON            sinkGetResponseFormatCloudflarePipelinesSinkJsonFormatJSON            `json:"-"`
}

type SinkGetResponseFormatCloudflarePipelinesSinkJsonFormatCompression string

type SinkGetResponseFormatCloudflarePipelinesSinkJsonFormatDecimalEncoding string

type SinkGetResponseFormatCloudflarePipelinesSinkJsonFormatTimestampFormat string

type SinkGetResponseFormatCloudflarePipelinesSinkJsonFormatType string