utils

type AWSCredentials struct {
	EndpointUrl *string
	AWS         aws.Credentials
}

type AWSCredentialsProvider interface {
	Retrieve(ctx context.Context) (AWSCredentials, error)
	GetUnderlyingProvider() aws.CredentialsProvider
	GetRegion() string
	GetEndpointURL() string
	GetTlsConfig() (*string, string)
}

type AWSSecrets struct {
	AccessKeyID     string
	SecretAccessKey string
	AwsRoleArn      string
	Region          string
	Endpoint        string
	SessionToken    string
}

type AssumeRoleBasedAWSCredentialsProvider struct {
	Provider aws.CredentialsProvider // New Credentials
	// contains filtered or unexported fields
}

type AvroFile struct {
	FilePath        string              `json:"filePath"`
	StorageLocation AvroStorageLocation `json:"storageLocation"`
	NumRecords      int64               `json:"numRecords"`
}

type AvroStorageLocation int64

type CDCStore[Items model.Items] struct {
	// contains filtered or unexported fields
}

type ClickHouseS3Credentials struct {
	Provider   AWSCredentialsProvider
	BucketPath string
}

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

type GcpServiceAccount struct {
	Type                    string `json:"type"`
	ProjectID               string `json:"project_id"`
	PrivateKeyID            string `json:"private_key_id"`
	PrivateKey              string `json:"private_key"`
	ClientEmail             string `json:"client_email"`
	ClientID                string `json:"client_id"`
	AuthURI                 string `json:"auth_uri"`
	TokenURI                string `json:"token_uri"`
	AuthProviderX509CertURL string `json:"auth_provider_x509_cert_url"`
	ClientX509CertURL       string `json:"client_x509_cert_url"`
}

type LPool[T any] struct {
	// contains filtered or unexported fields
}

type LPoolMessage[T any] struct {
	// contains filtered or unexported fields
}

type MeteredConn struct {
	net.Conn
	// contains filtered or unexported fields
}

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

type NoDeadlineConn struct{ net.Conn }

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

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

type PartitionRangeType string

type PeerAWSCredentials struct {
	Credentials    aws.Credentials
	RoleArn        *string
	ChainedRoleArn *string
	EndpointUrl    *string
	Region         string
	RootCAs        *string
	TlsHost        string
}

type RDSAuth struct {
	AwsAuthConfig *protos.AwsAuthenticationConfig
	// contains filtered or unexported fields
}

type RDSConnectionConfig struct {
	Host string
	User string
	Port uint32
}

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

type S3BucketAndPrefix struct {
	Bucket string
	Prefix string
}

type SSHTunnel struct {
	*ssh.Client
	// contains filtered or unexported fields
}

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