Add defaults for third-party stubs A-D (#9952)

This commit is contained in:
Alex Waygood
2023-03-27 16:49:58 +01:00
committed by GitHub
parent ce5f02fcdc
commit b9fedd20ce
186 changed files with 1829 additions and 1760 deletions

View File

@@ -21,108 +21,121 @@ class NullHandler(logging.Handler):
log: Any
perflog: Any
def set_file_logger(name, filepath, level: Any = ..., format_string: Incomplete | None = ...): ...
def set_stream_logger(name, level: Any = ..., format_string: Incomplete | None = ...): ...
def connect_sqs(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_s3(aws_access_key_id: str | None = ..., aws_secret_access_key: str | None = ..., **kwargs) -> S3Connection: ...
def connect_gs(gs_access_key_id: Incomplete | None = ..., gs_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_ec2(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_elb(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_autoscale(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_cloudwatch(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_sdb(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_fps(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_mturk(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_cloudfront(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_vpc(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_rds(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_rds2(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_emr(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_sns(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_iam(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_route53(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def set_file_logger(name, filepath, level: Any = 20, format_string: Incomplete | None = None): ...
def set_stream_logger(name, level: Any = 10, format_string: Incomplete | None = None): ...
def connect_sqs(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_s3(aws_access_key_id: str | None = None, aws_secret_access_key: str | None = None, **kwargs) -> S3Connection: ...
def connect_gs(gs_access_key_id: Incomplete | None = None, gs_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_ec2(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_elb(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_autoscale(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_cloudwatch(
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_sdb(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_fps(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_mturk(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_cloudfront(
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_vpc(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_rds(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_rds2(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_emr(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_sns(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_iam(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_route53(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_cloudformation(
aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_euca(
host: Incomplete | None = ...,
aws_access_key_id: Incomplete | None = ...,
aws_secret_access_key: Incomplete | None = ...,
port: int = ...,
path: str = ...,
is_secure: bool = ...,
host: Incomplete | None = None,
aws_access_key_id: Incomplete | None = None,
aws_secret_access_key: Incomplete | None = None,
port: int = 8773,
path: str = "/services/Eucalyptus",
is_secure: bool = False,
**kwargs,
): ...
def connect_glacier(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_glacier(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_ec2_endpoint(
url, aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs
url, aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_walrus(
host: Incomplete | None = ...,
aws_access_key_id: Incomplete | None = ...,
aws_secret_access_key: Incomplete | None = ...,
port: int = ...,
path: str = ...,
is_secure: bool = ...,
host: Incomplete | None = None,
aws_access_key_id: Incomplete | None = None,
aws_secret_access_key: Incomplete | None = None,
port: int = 8773,
path: str = "/services/Walrus",
is_secure: bool = False,
**kwargs,
): ...
def connect_ses(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_sts(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_ses(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_sts(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_ia(
ia_access_key_id: Incomplete | None = ..., ia_secret_access_key: Incomplete | None = ..., is_secure: bool = ..., **kwargs
ia_access_key_id: Incomplete | None = None, ia_secret_access_key: Incomplete | None = None, is_secure: bool = False, **kwargs
): ...
def connect_dynamodb(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_swf(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_cloudsearch(
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_dynamodb(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_swf(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_cloudsearch(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_cloudsearch2(
aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., sign_request: bool = ..., **kwargs
aws_access_key_id: Incomplete | None = None,
aws_secret_access_key: Incomplete | None = None,
sign_request: bool = False,
**kwargs,
): ...
def connect_cloudsearchdomain(
aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_beanstalk(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_beanstalk(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_elastictranscoder(
aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_opsworks(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_redshift(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_support(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_cloudtrail(
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_opsworks(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_redshift(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_support(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_cloudtrail(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_directconnect(
aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_kinesis(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_logs(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_kinesis(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_logs(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_route53domains(
aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_cognito_identity(
aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_cognito_sync(
aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_kms(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_awslambda(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_codedeploy(
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_kms(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_awslambda(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_codedeploy(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_configservice(
aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_cloudhsm(aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs): ...
def connect_cloudhsm(aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs): ...
def connect_ec2containerservice(
aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def connect_machinelearning(
aws_access_key_id: Incomplete | None = ..., aws_secret_access_key: Incomplete | None = ..., **kwargs
aws_access_key_id: Incomplete | None = None, aws_secret_access_key: Incomplete | None = None, **kwargs
): ...
def storage_uri(
uri_str,
default_scheme: str = ...,
debug: int = ...,
validate: bool = ...,
default_scheme: str = "file",
debug: int = 0,
validate: bool = True,
bucket_storage_uri_class: Any = ...,
suppress_consec_slashes: bool = ...,
is_latest: bool = ...,
suppress_consec_slashes: bool = True,
is_latest: bool = False,
): ...
def storage_uri_for_key(key): ...

View File

@@ -47,7 +47,7 @@ class HmacAuthV4Handler(AuthHandler, HmacKeys):
service_name: Any
region_name: Any
def __init__(
self, host, config, provider, service_name: Incomplete | None = ..., region_name: Incomplete | None = ...
self, host, config, provider, service_name: Incomplete | None = None, region_name: Incomplete | None = None
) -> None: ...
def headers_to_sign(self, http_request): ...
def host_header(self, host, http_request): ...
@@ -81,7 +81,7 @@ class S3HmacAuthV4Handler(HmacAuthV4Handler, AuthHandler):
def mangle_path_and_params(self, req): ...
def payload(self, http_request): ...
def add_auth(self, req, **kwargs): ...
def presign(self, req, expires, iso_date: Incomplete | None = ...): ...
def presign(self, req, expires, iso_date: Incomplete | None = None): ...
class STSAnonHandler(AuthHandler):
capability: Any
@@ -107,6 +107,6 @@ class POSTPathQSV2AuthHandler(QuerySignatureV2AuthHandler, AuthHandler):
capability: Any
def add_auth(self, req, **kwargs): ...
def get_auth_handler(host, config, provider, requested_capability: Incomplete | None = ...): ...
def get_auth_handler(host, config, provider, requested_capability: Incomplete | None = None): ...
def detect_potential_sigv4(func): ...
def detect_potential_s3sigv4(func): ...

View File

@@ -42,7 +42,7 @@ class HTTPRequest:
class HTTPResponse(http.client.HTTPResponse):
def __init__(self, *args, **kwargs) -> None: ...
def read(self, amt: Incomplete | None = ...): ...
def read(self, amt: Incomplete | None = None): ...
class AWSAuthConnection:
suppress_consec_slashes: Any
@@ -67,22 +67,22 @@ class AWSAuthConnection:
def __init__(
self,
host,
aws_access_key_id: Incomplete | None = ...,
aws_secret_access_key: Incomplete | None = ...,
is_secure: bool = ...,
port: Incomplete | None = ...,
proxy: Incomplete | None = ...,
proxy_port: Incomplete | None = ...,
proxy_user: Incomplete | None = ...,
proxy_pass: Incomplete | None = ...,
debug: int = ...,
https_connection_factory: Incomplete | None = ...,
path: str = ...,
provider: str = ...,
security_token: Incomplete | None = ...,
suppress_consec_slashes: bool = ...,
validate_certs: bool = ...,
profile_name: Incomplete | None = ...,
aws_access_key_id: Incomplete | None = None,
aws_secret_access_key: Incomplete | None = None,
is_secure: bool = True,
port: Incomplete | None = None,
proxy: Incomplete | None = None,
proxy_port: Incomplete | None = None,
proxy_user: Incomplete | None = None,
proxy_pass: Incomplete | None = None,
debug: int = 0,
https_connection_factory: Incomplete | None = None,
path: str = "/",
provider: str = "aws",
security_token: Incomplete | None = None,
suppress_consec_slashes: bool = True,
validate_certs: bool = True,
profile_name: Incomplete | None = None,
) -> None: ...
auth_region_name: Any
@property
@@ -101,8 +101,8 @@ class AWSAuthConnection:
def secret_key(self): ...
@property
def profile_name(self): ...
def get_path(self, path: str = ...): ...
def server_name(self, port: Incomplete | None = ...): ...
def get_path(self, path: str = "/"): ...
def server_name(self, port: Incomplete | None = None): ...
proxy: Any
proxy_port: Any
proxy_user: Any
@@ -114,8 +114,8 @@ class AWSAuthConnection:
def skip_proxy(self, host): ...
def new_http_connection(self, host, port, is_secure): ...
def put_http_connection(self, host, port, is_secure, connection): ...
def proxy_ssl(self, host: Incomplete | None = ..., port: Incomplete | None = ...): ...
def prefix_proxy_to_path(self, path, host: Incomplete | None = ...): ...
def proxy_ssl(self, host: Incomplete | None = None, port: Incomplete | None = None): ...
def prefix_proxy_to_path(self, path, host: Incomplete | None = None): ...
def get_proxy_auth_header(self): ...
def get_proxy_url_with_auth(self): ...
def set_host_header(self, request): ...
@@ -125,23 +125,23 @@ class AWSAuthConnection:
method,
path,
auth_path,
params: Incomplete | None = ...,
headers: Incomplete | None = ...,
data: str = ...,
host: Incomplete | None = ...,
params: Incomplete | None = None,
headers: Incomplete | None = None,
data: str = "",
host: Incomplete | None = None,
): ...
def make_request(
self,
method,
path,
headers: Incomplete | None = ...,
data: str = ...,
host: Incomplete | None = ...,
auth_path: Incomplete | None = ...,
sender: Incomplete | None = ...,
override_num_retries: Incomplete | None = ...,
params: Incomplete | None = ...,
retry_handler: Incomplete | None = ...,
headers: Incomplete | None = None,
data: str = "",
host: Incomplete | None = None,
auth_path: Incomplete | None = None,
sender: Incomplete | None = None,
override_num_retries: Incomplete | None = None,
params: Incomplete | None = None,
retry_handler: Incomplete | None = None,
): ...
def close(self): ...
@@ -150,29 +150,29 @@ class AWSQueryConnection(AWSAuthConnection):
ResponseError: Any
def __init__(
self,
aws_access_key_id: Incomplete | None = ...,
aws_secret_access_key: Incomplete | None = ...,
is_secure: bool = ...,
port: Incomplete | None = ...,
proxy: Incomplete | None = ...,
proxy_port: Incomplete | None = ...,
proxy_user: Incomplete | None = ...,
proxy_pass: Incomplete | None = ...,
host: Incomplete | None = ...,
debug: int = ...,
https_connection_factory: Incomplete | None = ...,
path: str = ...,
security_token: Incomplete | None = ...,
validate_certs: bool = ...,
profile_name: Incomplete | None = ...,
provider: str = ...,
aws_access_key_id: Incomplete | None = None,
aws_secret_access_key: Incomplete | None = None,
is_secure: bool = True,
port: Incomplete | None = None,
proxy: Incomplete | None = None,
proxy_port: Incomplete | None = None,
proxy_user: Incomplete | None = None,
proxy_pass: Incomplete | None = None,
host: Incomplete | None = None,
debug: int = 0,
https_connection_factory: Incomplete | None = None,
path: str = "/",
security_token: Incomplete | None = None,
validate_certs: bool = True,
profile_name: Incomplete | None = None,
provider: str = "aws",
) -> None: ...
def get_utf8_value(self, value): ...
def make_request( # type: ignore[override]
self, action, params: Incomplete | None = ..., path: str = ..., verb: str = ..., *args, **kwargs
self, action, params: Incomplete | None = None, path: str = "/", verb: str = "GET", *args, **kwargs
): ...
def build_list_params(self, params, items, label): ...
def build_complex_list_params(self, params, items, label, names): ...
def get_list(self, action, params, markers, path: str = ..., parent: Incomplete | None = ..., verb: str = ...): ...
def get_object(self, action, params, cls, path: str = ..., parent: Incomplete | None = ..., verb: str = ...): ...
def get_status(self, action, params, path: str = ..., parent: Incomplete | None = ..., verb: str = ...): ...
def get_list(self, action, params, markers, path: str = "/", parent: Incomplete | None = None, verb: str = "GET"): ...
def get_object(self, action, params, cls, path: str = "/", parent: Incomplete | None = None, verb: str = "GET"): ...
def get_status(self, action, params, path: str = "/", parent: Incomplete | None = None, verb: str = "GET"): ...

View File

@@ -20,7 +20,7 @@ class BotoServerError(StandardError):
error_code: Any
message: str
box_usage: Any
def __init__(self, status, reason, body: Incomplete | None = ..., *args) -> None: ...
def __init__(self, status, reason, body: Incomplete | None = None, *args) -> None: ...
def __getattr__(self, name: str): ...
def __setattr__(self, name: str, value) -> None: ...
def startElement(self, name, attrs, connection): ...
@@ -32,13 +32,13 @@ class ConsoleOutput:
timestamp: Any
comment: Any
output: Any
def __init__(self, parent: Incomplete | None = ...) -> None: ...
def __init__(self, parent: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
class StorageCreateError(BotoServerError):
bucket: Any
def __init__(self, status, reason, body: Incomplete | None = ...) -> None: ...
def __init__(self, status, reason, body: Incomplete | None = None) -> None: ...
def endElement(self, name, value, connection): ...
class S3CreateError(StorageCreateError): ...
@@ -50,7 +50,7 @@ class GSCopyError(StorageCopyError): ...
class SQSError(BotoServerError):
detail: Any
type: Any
def __init__(self, status, reason, body: Incomplete | None = ...) -> None: ...
def __init__(self, status, reason, body: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
@@ -60,7 +60,7 @@ class SQSDecodeError(BotoClientError):
class StorageResponseError(BotoServerError):
resource: Any
def __init__(self, status, reason, body: Incomplete | None = ...) -> None: ...
def __init__(self, status, reason, body: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
@@ -69,7 +69,7 @@ class GSResponseError(StorageResponseError): ...
class EC2ResponseError(BotoServerError):
errors: Any
def __init__(self, status, reason, body: Incomplete | None = ...) -> None: ...
def __init__(self, status, reason, body: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
request_id: Any
def endElement(self, name, value, connection): ...
@@ -80,7 +80,7 @@ class JSONResponseError(BotoServerError):
body: Any
error_message: Any
error_code: Any
def __init__(self, status, reason, body: Incomplete | None = ..., *args) -> None: ...
def __init__(self, status, reason, body: Incomplete | None = None, *args) -> None: ...
class DynamoDBResponseError(JSONResponseError): ...
class SWFResponseError(JSONResponseError): ...
@@ -90,7 +90,7 @@ class _EC2Error:
connection: Any
error_code: Any
error_message: Any
def __init__(self, connection: Incomplete | None = ...) -> None: ...
def __init__(self, connection: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
@@ -141,7 +141,7 @@ class TooManyRecordsException(Exception):
class PleaseRetryException(Exception):
message: Any
response: Any
def __init__(self, message, response: Incomplete | None = ...) -> None: ...
def __init__(self, message, response: Incomplete | None = None) -> None: ...
class InvalidInstanceMetadataError(Exception):
MSG: str

View File

@@ -17,16 +17,16 @@ class KMSConnection(AWSQueryConnection):
self,
key_id: str,
grantee_principal: str,
retiring_principal: str | None = ...,
operations: list[str] | None = ...,
constraints: dict[str, dict[str, str]] | None = ...,
grant_tokens: list[str] | None = ...,
retiring_principal: str | None = None,
operations: list[str] | None = None,
constraints: dict[str, dict[str, str]] | None = None,
grant_tokens: list[str] | None = None,
) -> dict[str, Any] | None: ...
def create_key(
self, policy: str | None = ..., description: str | None = ..., key_usage: str | None = ...
self, policy: str | None = None, description: str | None = None, key_usage: str | None = None
) -> dict[str, Any] | None: ...
def decrypt(
self, ciphertext_blob: bytes, encryption_context: Mapping[str, Any] | None = ..., grant_tokens: list[str] | None = ...
self, ciphertext_blob: bytes, encryption_context: Mapping[str, Any] | None = None, grant_tokens: list[str] | None = None
) -> dict[str, Any] | None: ...
def delete_alias(self, alias_name: str) -> dict[str, Any] | None: ...
def describe_key(self, key_id: str) -> dict[str, Any] | None: ...
@@ -38,40 +38,40 @@ class KMSConnection(AWSQueryConnection):
self,
key_id: str,
plaintext: bytes,
encryption_context: Mapping[str, Any] | None = ...,
grant_tokens: list[str] | None = ...,
encryption_context: Mapping[str, Any] | None = None,
grant_tokens: list[str] | None = None,
) -> dict[str, Any] | None: ...
def generate_data_key(
self,
key_id: str,
encryption_context: Mapping[str, Any] | None = ...,
number_of_bytes: int | None = ...,
key_spec: str | None = ...,
grant_tokens: list[str] | None = ...,
encryption_context: Mapping[str, Any] | None = None,
number_of_bytes: int | None = None,
key_spec: str | None = None,
grant_tokens: list[str] | None = None,
) -> dict[str, Any] | None: ...
def generate_data_key_without_plaintext(
self,
key_id: str,
encryption_context: Mapping[str, Any] | None = ...,
key_spec: str | None = ...,
number_of_bytes: int | None = ...,
grant_tokens: list[str] | None = ...,
encryption_context: Mapping[str, Any] | None = None,
key_spec: str | None = None,
number_of_bytes: int | None = None,
grant_tokens: list[str] | None = None,
) -> dict[str, Any] | None: ...
def generate_random(self, number_of_bytes: int | None = ...) -> dict[str, Any] | None: ...
def generate_random(self, number_of_bytes: int | None = None) -> dict[str, Any] | None: ...
def get_key_policy(self, key_id: str, policy_name: str) -> dict[str, Any] | None: ...
def get_key_rotation_status(self, key_id: str) -> dict[str, Any] | None: ...
def list_aliases(self, limit: int | None = ..., marker: str | None = ...) -> dict[str, Any] | None: ...
def list_grants(self, key_id: str, limit: int | None = ..., marker: str | None = ...) -> dict[str, Any] | None: ...
def list_key_policies(self, key_id: str, limit: int | None = ..., marker: str | None = ...) -> dict[str, Any] | None: ...
def list_keys(self, limit: int | None = ..., marker: str | None = ...) -> dict[str, Any] | None: ...
def list_aliases(self, limit: int | None = None, marker: str | None = None) -> dict[str, Any] | None: ...
def list_grants(self, key_id: str, limit: int | None = None, marker: str | None = None) -> dict[str, Any] | None: ...
def list_key_policies(self, key_id: str, limit: int | None = None, marker: str | None = None) -> dict[str, Any] | None: ...
def list_keys(self, limit: int | None = None, marker: str | None = None) -> dict[str, Any] | None: ...
def put_key_policy(self, key_id: str, policy_name: str, policy: str) -> dict[str, Any] | None: ...
def re_encrypt(
self,
ciphertext_blob: bytes,
destination_key_id: str,
source_encryption_context: Mapping[str, Any] | None = ...,
destination_encryption_context: Mapping[str, Any] | None = ...,
grant_tokens: list[str] | None = ...,
source_encryption_context: Mapping[str, Any] | None = None,
destination_encryption_context: Mapping[str, Any] | None = None,
grant_tokens: list[str] | None = None,
) -> dict[str, Any] | None: ...
def retire_grant(self, grant_token: str) -> dict[str, Any] | None: ...
def revoke_grant(self, key_id: str, grant_id: str) -> dict[str, Any] | None: ...

View File

@@ -6,5 +6,5 @@ class Plugin:
@classmethod
def is_capable(cls, requested_capability): ...
def get_plugin(cls, requested_capability: Incomplete | None = ...): ...
def get_plugin(cls, requested_capability: Incomplete | None = None): ...
def load_plugins(config): ...

View File

@@ -4,7 +4,7 @@ from typing import Any
def load_endpoint_json(path): ...
def merge_endpoints(defaults, additions): ...
def load_regions(): ...
def get_regions(service_name, region_cls: Incomplete | None = ..., connection_cls: Incomplete | None = ...): ...
def get_regions(service_name, region_cls: Incomplete | None = None, connection_cls: Incomplete | None = None): ...
class RegionInfo:
connection: Any
@@ -13,10 +13,10 @@ class RegionInfo:
connection_cls: Any
def __init__(
self,
connection: Incomplete | None = ...,
name: Incomplete | None = ...,
endpoint: Incomplete | None = ...,
connection_cls: Incomplete | None = ...,
connection: Incomplete | None = None,
name: Incomplete | None = None,
endpoint: Incomplete | None = None,
connection_cls: Incomplete | None = None,
) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...

View File

@@ -10,7 +10,7 @@ class Policy:
parent: Any
namespace: Any
acl: ACL
def __init__(self, parent: Incomplete | None = ...) -> None: ...
def __init__(self, parent: Incomplete | None = None) -> None: ...
owner: User
def startElement(self, name: str, attrs: dict[str, Any], connection: S3Connection) -> None | User | ACL: ...
def endElement(self, name: str, value: Any, connection: S3Connection) -> None: ...
@@ -19,10 +19,10 @@ class Policy:
class ACL:
policy: Policy
grants: list[Grant]
def __init__(self, policy: Policy | None = ...) -> None: ...
def __init__(self, policy: Policy | None = None) -> None: ...
def add_grant(self, grant: Grant) -> None: ...
def add_email_grant(self, permission: str, email_address: str) -> None: ...
def add_user_grant(self, permission: str, user_id: str, display_name: str | None = ...) -> None: ...
def add_user_grant(self, permission: str, user_id: str, display_name: str | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name: str, value: Any, connection: S3Connection) -> None: ...
def to_xml(self) -> str: ...
@@ -37,12 +37,12 @@ class Grant:
type: str
def __init__(
self,
permission: str | None = ...,
type: str | None = ...,
id: str | None = ...,
display_name: str | None = ...,
uri: str | None = ...,
email_address: str | None = ...,
permission: str | None = None,
type: str | None = None,
id: str | None = None,
display_name: str | None = None,
uri: str | None = None,
email_address: str | None = None,
) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name: str, value: Any, connection: S3Connection) -> None: ...

View File

@@ -21,170 +21,172 @@ class Bucket:
name: str
connection: S3Connection
key_class: type[Key]
def __init__(self, connection: S3Connection | None = ..., name: str | None = ..., key_class: type[Key] = ...) -> None: ...
def __init__(self, connection: S3Connection | None = None, name: str | None = None, key_class: type[Key] = ...) -> None: ...
def __iter__(self): ...
def __contains__(self, key_name) -> bool: ...
def startElement(self, name, attrs, connection): ...
creation_date: Any
def endElement(self, name, value, connection): ...
def set_key_class(self, key_class): ...
def lookup(self, key_name, headers: dict[str, str] | None = ...): ...
def lookup(self, key_name, headers: dict[str, str] | None = None): ...
def get_key(
self,
key_name,
headers: dict[str, str] | None = ...,
version_id: Incomplete | None = ...,
response_headers: dict[str, str] | None = ...,
validate: bool = ...,
headers: dict[str, str] | None = None,
version_id: Incomplete | None = None,
response_headers: dict[str, str] | None = None,
validate: bool = True,
) -> Key: ...
def list(
self,
prefix: str = ...,
delimiter: str = ...,
marker: str = ...,
headers: dict[str, str] | None = ...,
encoding_type: Incomplete | None = ...,
prefix: str = "",
delimiter: str = "",
marker: str = "",
headers: dict[str, str] | None = None,
encoding_type: Incomplete | None = None,
) -> BucketListResultSet: ...
def list_versions(
self,
prefix: str = ...,
delimiter: str = ...,
key_marker: str = ...,
version_id_marker: str = ...,
headers: dict[str, str] | None = ...,
encoding_type: str | None = ...,
prefix: str = "",
delimiter: str = "",
key_marker: str = "",
version_id_marker: str = "",
headers: dict[str, str] | None = None,
encoding_type: str | None = None,
) -> BucketListResultSet: ...
def list_multipart_uploads(
self,
key_marker: str = ...,
upload_id_marker: str = ...,
headers: dict[str, str] | None = ...,
encoding_type: Incomplete | None = ...,
key_marker: str = "",
upload_id_marker: str = "",
headers: dict[str, str] | None = None,
encoding_type: Incomplete | None = None,
): ...
def validate_kwarg_names(self, kwargs, names): ...
def get_all_keys(self, headers: dict[str, str] | None = ..., **params): ...
def get_all_versions(self, headers: dict[str, str] | None = ..., **params): ...
def get_all_keys(self, headers: dict[str, str] | None = None, **params): ...
def get_all_versions(self, headers: dict[str, str] | None = None, **params): ...
def validate_get_all_versions_params(self, params): ...
def get_all_multipart_uploads(self, headers: dict[str, str] | None = ..., **params): ...
def new_key(self, key_name: Incomplete | None = ...): ...
def get_all_multipart_uploads(self, headers: dict[str, str] | None = None, **params): ...
def new_key(self, key_name: Incomplete | None = None): ...
def generate_url(
self,
expires_in,
method: str = ...,
headers: dict[str, str] | None = ...,
force_http: bool = ...,
response_headers: dict[str, str] | None = ...,
expires_in_absolute: bool = ...,
method: str = "GET",
headers: dict[str, str] | None = None,
force_http: bool = False,
response_headers: dict[str, str] | None = None,
expires_in_absolute: bool = False,
): ...
def delete_keys(
self, keys, quiet: bool = False, mfa_token: Incomplete | None = None, headers: dict[str, str] | None = None
): ...
def delete_keys(self, keys, quiet: bool = ..., mfa_token: Incomplete | None = ..., headers: dict[str, str] | None = ...): ...
def delete_key(
self,
key_name,
headers: dict[str, str] | None = ...,
version_id: Incomplete | None = ...,
mfa_token: Incomplete | None = ...,
headers: dict[str, str] | None = None,
version_id: Incomplete | None = None,
mfa_token: Incomplete | None = None,
): ...
def copy_key(
self,
new_key_name,
src_bucket_name,
src_key_name,
metadata: Incomplete | None = ...,
src_version_id: Incomplete | None = ...,
storage_class: str = ...,
preserve_acl: bool = ...,
encrypt_key: bool = ...,
headers: dict[str, str] | None = ...,
query_args: Incomplete | None = ...,
metadata: Incomplete | None = None,
src_version_id: Incomplete | None = None,
storage_class: str = "STANDARD",
preserve_acl: bool = False,
encrypt_key: bool = False,
headers: dict[str, str] | None = None,
query_args: Incomplete | None = None,
): ...
def set_canned_acl(
self, acl_str, key_name: str = ..., headers: dict[str, str] | None = ..., version_id: Incomplete | None = ...
self, acl_str, key_name: str = "", headers: dict[str, str] | None = None, version_id: Incomplete | None = None
): ...
def get_xml_acl(self, key_name: str = ..., headers: dict[str, str] | None = ..., version_id: Incomplete | None = ...): ...
def get_xml_acl(self, key_name: str = "", headers: dict[str, str] | None = None, version_id: Incomplete | None = None): ...
def set_xml_acl(
self,
acl_str,
key_name: str = ...,
headers: dict[str, str] | None = ...,
version_id: Incomplete | None = ...,
query_args: str = ...,
key_name: str = "",
headers: dict[str, str] | None = None,
version_id: Incomplete | None = None,
query_args: str = "acl",
): ...
def set_acl(
self, acl_or_str, key_name: str = ..., headers: dict[str, str] | None = ..., version_id: Incomplete | None = ...
self, acl_or_str, key_name: str = "", headers: dict[str, str] | None = None, version_id: Incomplete | None = None
): ...
def get_acl(self, key_name: str = ..., headers: dict[str, str] | None = ..., version_id: Incomplete | None = ...): ...
def get_acl(self, key_name: str = "", headers: dict[str, str] | None = None, version_id: Incomplete | None = None): ...
def set_subresource(
self, subresource, value, key_name: str = ..., headers: dict[str, str] | None = ..., version_id: Incomplete | None = ...
self, subresource, value, key_name: str = "", headers: dict[str, str] | None = None, version_id: Incomplete | None = None
): ...
def get_subresource(
self, subresource, key_name: str = ..., headers: dict[str, str] | None = ..., version_id: Incomplete | None = ...
self, subresource, key_name: str = "", headers: dict[str, str] | None = None, version_id: Incomplete | None = None
): ...
def make_public(self, recursive: bool = ..., headers: dict[str, str] | None = ...): ...
def add_email_grant(self, permission, email_address, recursive: bool = ..., headers: dict[str, str] | None = ...): ...
def make_public(self, recursive: bool = False, headers: dict[str, str] | None = None): ...
def add_email_grant(self, permission, email_address, recursive: bool = False, headers: dict[str, str] | None = None): ...
def add_user_grant(
self,
permission,
user_id,
recursive: bool = ...,
headers: dict[str, str] | None = ...,
display_name: Incomplete | None = ...,
recursive: bool = False,
headers: dict[str, str] | None = None,
display_name: Incomplete | None = None,
): ...
def list_grants(self, headers: dict[str, str] | None = ...): ...
def list_grants(self, headers: dict[str, str] | None = None): ...
def get_location(self): ...
def set_xml_logging(self, logging_str, headers: dict[str, str] | None = ...): ...
def set_xml_logging(self, logging_str, headers: dict[str, str] | None = None): ...
def enable_logging(
self, target_bucket, target_prefix: str = ..., grants: Incomplete | None = ..., headers: dict[str, str] | None = ...
self, target_bucket, target_prefix: str = "", grants: Incomplete | None = None, headers: dict[str, str] | None = None
): ...
def disable_logging(self, headers: dict[str, str] | None = ...): ...
def get_logging_status(self, headers: dict[str, str] | None = ...): ...
def set_as_logging_target(self, headers: dict[str, str] | None = ...): ...
def get_request_payment(self, headers: dict[str, str] | None = ...): ...
def set_request_payment(self, payer: str = ..., headers: dict[str, str] | None = ...): ...
def disable_logging(self, headers: dict[str, str] | None = None): ...
def get_logging_status(self, headers: dict[str, str] | None = None): ...
def set_as_logging_target(self, headers: dict[str, str] | None = None): ...
def get_request_payment(self, headers: dict[str, str] | None = None): ...
def set_request_payment(self, payer: str = "BucketOwner", headers: dict[str, str] | None = None): ...
def configure_versioning(
self, versioning, mfa_delete: bool = ..., mfa_token: Incomplete | None = ..., headers: dict[str, str] | None = ...
self, versioning, mfa_delete: bool = False, mfa_token: Incomplete | None = None, headers: dict[str, str] | None = None
): ...
def get_versioning_status(self, headers: dict[str, str] | None = ...): ...
def configure_lifecycle(self, lifecycle_config, headers: dict[str, str] | None = ...): ...
def get_lifecycle_config(self, headers: dict[str, str] | None = ...): ...
def delete_lifecycle_configuration(self, headers: dict[str, str] | None = ...): ...
def get_versioning_status(self, headers: dict[str, str] | None = None): ...
def configure_lifecycle(self, lifecycle_config, headers: dict[str, str] | None = None): ...
def get_lifecycle_config(self, headers: dict[str, str] | None = None): ...
def delete_lifecycle_configuration(self, headers: dict[str, str] | None = None): ...
def configure_website(
self,
suffix: Incomplete | None = ...,
error_key: Incomplete | None = ...,
redirect_all_requests_to: Incomplete | None = ...,
routing_rules: Incomplete | None = ...,
headers: dict[str, str] | None = ...,
suffix: Incomplete | None = None,
error_key: Incomplete | None = None,
redirect_all_requests_to: Incomplete | None = None,
routing_rules: Incomplete | None = None,
headers: dict[str, str] | None = None,
): ...
def set_website_configuration(self, config, headers: dict[str, str] | None = ...): ...
def set_website_configuration_xml(self, xml, headers: dict[str, str] | None = ...): ...
def get_website_configuration(self, headers: dict[str, str] | None = ...): ...
def get_website_configuration_obj(self, headers: dict[str, str] | None = ...): ...
def get_website_configuration_with_xml(self, headers: dict[str, str] | None = ...): ...
def get_website_configuration_xml(self, headers: dict[str, str] | None = ...): ...
def delete_website_configuration(self, headers: dict[str, str] | None = ...): ...
def set_website_configuration(self, config, headers: dict[str, str] | None = None): ...
def set_website_configuration_xml(self, xml, headers: dict[str, str] | None = None): ...
def get_website_configuration(self, headers: dict[str, str] | None = None): ...
def get_website_configuration_obj(self, headers: dict[str, str] | None = None): ...
def get_website_configuration_with_xml(self, headers: dict[str, str] | None = None): ...
def get_website_configuration_xml(self, headers: dict[str, str] | None = None): ...
def delete_website_configuration(self, headers: dict[str, str] | None = None): ...
def get_website_endpoint(self): ...
def get_policy(self, headers: dict[str, str] | None = ...): ...
def set_policy(self, policy, headers: dict[str, str] | None = ...): ...
def delete_policy(self, headers: dict[str, str] | None = ...): ...
def set_cors_xml(self, cors_xml, headers: dict[str, str] | None = ...): ...
def set_cors(self, cors_config, headers: dict[str, str] | None = ...): ...
def get_cors_xml(self, headers: dict[str, str] | None = ...): ...
def get_cors(self, headers: dict[str, str] | None = ...): ...
def delete_cors(self, headers: dict[str, str] | None = ...): ...
def get_policy(self, headers: dict[str, str] | None = None): ...
def set_policy(self, policy, headers: dict[str, str] | None = None): ...
def delete_policy(self, headers: dict[str, str] | None = None): ...
def set_cors_xml(self, cors_xml, headers: dict[str, str] | None = None): ...
def set_cors(self, cors_config, headers: dict[str, str] | None = None): ...
def get_cors_xml(self, headers: dict[str, str] | None = None): ...
def get_cors(self, headers: dict[str, str] | None = None): ...
def delete_cors(self, headers: dict[str, str] | None = None): ...
def initiate_multipart_upload(
self,
key_name,
headers: dict[str, str] | None = ...,
reduced_redundancy: bool = ...,
metadata: Incomplete | None = ...,
encrypt_key: bool = ...,
policy: Incomplete | None = ...,
headers: dict[str, str] | None = None,
reduced_redundancy: bool = False,
metadata: Incomplete | None = None,
encrypt_key: bool = False,
policy: Incomplete | None = None,
): ...
def complete_multipart_upload(self, key_name, upload_id, xml_body, headers: dict[str, str] | None = ...): ...
def cancel_multipart_upload(self, key_name, upload_id, headers: dict[str, str] | None = ...): ...
def delete(self, headers: dict[str, str] | None = ...): ...
def complete_multipart_upload(self, key_name, upload_id, xml_body, headers: dict[str, str] | None = None): ...
def cancel_multipart_upload(self, key_name, upload_id, headers: dict[str, str] | None = None): ...
def delete(self, headers: dict[str, str] | None = None): ...
def get_tags(self): ...
def get_xml_tags(self): ...
def set_xml_tags(self, tag_str, headers: dict[str, str] | None = ..., query_args: str = ...): ...
def set_tags(self, tags, headers: dict[str, str] | None = ...): ...
def delete_tags(self, headers: dict[str, str] | None = ...): ...
def set_xml_tags(self, tag_str, headers: dict[str, str] | None = None, query_args: str = "tagging"): ...
def set_tags(self, tags, headers: dict[str, str] | None = None): ...
def delete_tags(self, headers: dict[str, str] | None = None): ...

View File

@@ -6,11 +6,11 @@ from .key import Key
def bucket_lister(
bucket,
prefix: str = ...,
delimiter: str = ...,
marker: str = ...,
headers: Incomplete | None = ...,
encoding_type: Incomplete | None = ...,
prefix: str = "",
delimiter: str = "",
marker: str = "",
headers: Incomplete | None = None,
encoding_type: Incomplete | None = None,
): ...
class BucketListResultSet(Iterable[Key]):
@@ -22,23 +22,23 @@ class BucketListResultSet(Iterable[Key]):
encoding_type: Any
def __init__(
self,
bucket: Incomplete | None = ...,
prefix: str = ...,
delimiter: str = ...,
marker: str = ...,
headers: Incomplete | None = ...,
encoding_type: Incomplete | None = ...,
bucket: Incomplete | None = None,
prefix: str = "",
delimiter: str = "",
marker: str = "",
headers: Incomplete | None = None,
encoding_type: Incomplete | None = None,
) -> None: ...
def __iter__(self) -> Iterator[Key]: ...
def versioned_bucket_lister(
bucket,
prefix: str = ...,
delimiter: str = ...,
key_marker: str = ...,
version_id_marker: str = ...,
headers: Incomplete | None = ...,
encoding_type: Incomplete | None = ...,
prefix: str = "",
delimiter: str = "",
key_marker: str = "",
version_id_marker: str = "",
headers: Incomplete | None = None,
encoding_type: Incomplete | None = None,
): ...
class VersionedBucketListResultSet:
@@ -51,22 +51,22 @@ class VersionedBucketListResultSet:
encoding_type: Any
def __init__(
self,
bucket: Incomplete | None = ...,
prefix: str = ...,
delimiter: str = ...,
key_marker: str = ...,
version_id_marker: str = ...,
headers: Incomplete | None = ...,
encoding_type: Incomplete | None = ...,
bucket: Incomplete | None = None,
prefix: str = "",
delimiter: str = "",
key_marker: str = "",
version_id_marker: str = "",
headers: Incomplete | None = None,
encoding_type: Incomplete | None = None,
) -> None: ...
def __iter__(self) -> Iterator[Key]: ...
def multipart_upload_lister(
bucket,
key_marker: str = ...,
upload_id_marker: str = ...,
headers: Incomplete | None = ...,
encoding_type: Incomplete | None = ...,
key_marker: str = "",
upload_id_marker: str = "",
headers: Incomplete | None = None,
encoding_type: Incomplete | None = None,
): ...
class MultiPartUploadListResultSet:
@@ -77,10 +77,10 @@ class MultiPartUploadListResultSet:
encoding_type: Any
def __init__(
self,
bucket: Incomplete | None = ...,
key_marker: str = ...,
upload_id_marker: str = ...,
headers: Incomplete | None = ...,
encoding_type: Incomplete | None = ...,
bucket: Incomplete | None = None,
key_marker: str = "",
upload_id_marker: str = "",
headers: Incomplete | None = None,
encoding_type: Incomplete | None = None,
) -> None: ...
def __iter__(self): ...

View File

@@ -6,7 +6,7 @@ class BucketLogging:
prefix: Any
grants: Any
def __init__(
self, target: Incomplete | None = ..., prefix: Incomplete | None = ..., grants: Incomplete | None = ...
self, target: Incomplete | None = None, prefix: Incomplete | None = None, grants: Incomplete | None = None
) -> None: ...
def add_grant(self, grant): ...
def startElement(self, name, attrs, connection): ...

View File

@@ -11,10 +11,10 @@ def assert_case_insensitive(f): ...
class _CallingFormat:
def get_bucket_server(self, server, bucket): ...
def build_url_base(self, connection, protocol, server, bucket, key: str = ...): ...
def build_url_base(self, connection, protocol, server, bucket, key: str = ""): ...
def build_host(self, server, bucket): ...
def build_auth_path(self, bucket, key: str = ...): ...
def build_path_base(self, bucket, key: str = ...): ...
def build_auth_path(self, bucket, key: str = ""): ...
def build_path_base(self, bucket, key: str = ""): ...
class SubdomainCallingFormat(_CallingFormat):
def get_bucket_server(self, server, bucket): ...
@@ -24,10 +24,10 @@ class VHostCallingFormat(_CallingFormat):
class OrdinaryCallingFormat(_CallingFormat):
def get_bucket_server(self, server, bucket): ...
def build_path_base(self, bucket, key: str = ...): ...
def build_path_base(self, bucket, key: str = ""): ...
class ProtocolIndependentOrdinaryCallingFormat(OrdinaryCallingFormat):
def build_url_base(self, connection, protocol, server, bucket, key: str = ...): ...
def build_url_base(self, connection, protocol, server, bucket, key: str = ""): ...
class Location:
DEFAULT: str
@@ -53,26 +53,26 @@ class S3Connection(AWSAuthConnection):
anon: Any
def __init__(
self,
aws_access_key_id: Incomplete | None = ...,
aws_secret_access_key: Incomplete | None = ...,
is_secure: bool = ...,
port: Incomplete | None = ...,
proxy: Incomplete | None = ...,
proxy_port: Incomplete | None = ...,
proxy_user: Incomplete | None = ...,
proxy_pass: Incomplete | None = ...,
aws_access_key_id: Incomplete | None = None,
aws_secret_access_key: Incomplete | None = None,
is_secure: bool = True,
port: Incomplete | None = None,
proxy: Incomplete | None = None,
proxy_port: Incomplete | None = None,
proxy_user: Incomplete | None = None,
proxy_pass: Incomplete | None = None,
host: Any = ...,
debug: int = ...,
https_connection_factory: Incomplete | None = ...,
calling_format: Any = ...,
path: str = ...,
provider: str = ...,
debug: int = 0,
https_connection_factory: Incomplete | None = None,
calling_format: Any = "boto.s3.connection.SubdomainCallingFormat",
path: str = "/",
provider: str = "aws",
bucket_class: type[Bucket] = ...,
security_token: Incomplete | None = ...,
suppress_consec_slashes: bool = ...,
anon: bool = ...,
validate_certs: Incomplete | None = ...,
profile_name: Incomplete | None = ...,
security_token: Incomplete | None = None,
suppress_consec_slashes: bool = True,
anon: bool = False,
validate_certs: Incomplete | None = None,
profile_name: Incomplete | None = None,
) -> None: ...
def __iter__(self): ...
def __contains__(self, bucket_name): ...
@@ -82,61 +82,61 @@ class S3Connection(AWSAuthConnection):
self,
bucket_name,
key,
expires_in: int = ...,
acl: Incomplete | None = ...,
success_action_redirect: Incomplete | None = ...,
max_content_length: Incomplete | None = ...,
http_method: str = ...,
fields: Incomplete | None = ...,
conditions: Incomplete | None = ...,
storage_class: str = ...,
server_side_encryption: Incomplete | None = ...,
expires_in: int = 6000,
acl: Incomplete | None = None,
success_action_redirect: Incomplete | None = None,
max_content_length: Incomplete | None = None,
http_method: str = "http",
fields: Incomplete | None = None,
conditions: Incomplete | None = None,
storage_class: str = "STANDARD",
server_side_encryption: Incomplete | None = None,
): ...
def generate_url_sigv4(
self,
expires_in,
method,
bucket: str = ...,
key: str = ...,
headers: dict[str, str] | None = ...,
force_http: bool = ...,
response_headers: dict[str, str] | None = ...,
version_id: Incomplete | None = ...,
iso_date: Incomplete | None = ...,
bucket: str = "",
key: str = "",
headers: dict[str, str] | None = None,
force_http: bool = False,
response_headers: dict[str, str] | None = None,
version_id: Incomplete | None = None,
iso_date: Incomplete | None = None,
): ...
def generate_url(
self,
expires_in,
method,
bucket: str = ...,
key: str = ...,
headers: dict[str, str] | None = ...,
query_auth: bool = ...,
force_http: bool = ...,
response_headers: dict[str, str] | None = ...,
expires_in_absolute: bool = ...,
version_id: Incomplete | None = ...,
bucket: str = "",
key: str = "",
headers: dict[str, str] | None = None,
query_auth: bool = True,
force_http: bool = False,
response_headers: dict[str, str] | None = None,
expires_in_absolute: bool = False,
version_id: Incomplete | None = None,
): ...
def get_all_buckets(self, headers: dict[str, str] | None = ...): ...
def get_canonical_user_id(self, headers: dict[str, str] | None = ...): ...
def get_bucket(self, bucket_name: str, validate: bool = ..., headers: dict[str, str] | None = ...) -> Bucket: ...
def head_bucket(self, bucket_name, headers: dict[str, str] | None = ...): ...
def lookup(self, bucket_name, validate: bool = ..., headers: dict[str, str] | None = ...): ...
def get_all_buckets(self, headers: dict[str, str] | None = None): ...
def get_canonical_user_id(self, headers: dict[str, str] | None = None): ...
def get_bucket(self, bucket_name: str, validate: bool = True, headers: dict[str, str] | None = None) -> Bucket: ...
def head_bucket(self, bucket_name, headers: dict[str, str] | None = None): ...
def lookup(self, bucket_name, validate: bool = True, headers: dict[str, str] | None = None): ...
def create_bucket(
self, bucket_name, headers: dict[str, str] | None = ..., location: Any = ..., policy: Incomplete | None = ...
self, bucket_name, headers: dict[str, str] | None = None, location: Any = "", policy: Incomplete | None = None
): ...
def delete_bucket(self, bucket, headers: dict[str, str] | None = ...): ...
def delete_bucket(self, bucket, headers: dict[str, str] | None = None): ...
def make_request( # type: ignore[override]
self,
method,
bucket: str = ...,
key: str = ...,
headers: Incomplete | None = ...,
data: str = ...,
query_args: Incomplete | None = ...,
sender: Incomplete | None = ...,
override_num_retries: Incomplete | None = ...,
retry_handler: Incomplete | None = ...,
bucket: str = "",
key: str = "",
headers: Incomplete | None = None,
data: str = "",
query_args: Incomplete | None = None,
sender: Incomplete | None = None,
override_num_retries: Incomplete | None = None,
retry_handler: Incomplete | None = None,
*args,
**kwargs,
): ...

View File

@@ -10,12 +10,12 @@ class CORSRule:
expose_header: Any
def __init__(
self,
allowed_method: Incomplete | None = ...,
allowed_origin: Incomplete | None = ...,
id: Incomplete | None = ...,
allowed_header: Incomplete | None = ...,
max_age_seconds: Incomplete | None = ...,
expose_header: Incomplete | None = ...,
allowed_method: Incomplete | None = None,
allowed_origin: Incomplete | None = None,
id: Incomplete | None = None,
allowed_header: Incomplete | None = None,
max_age_seconds: Incomplete | None = None,
expose_header: Incomplete | None = None,
) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
@@ -29,8 +29,8 @@ class CORSConfiguration(list[CORSRule]):
self,
allowed_method,
allowed_origin,
id: Incomplete | None = ...,
allowed_header: Incomplete | None = ...,
max_age_seconds: Incomplete | None = ...,
expose_header: Incomplete | None = ...,
id: Incomplete | None = None,
allowed_header: Incomplete | None = None,
max_age_seconds: Incomplete | None = None,
expose_header: Incomplete | None = None,
): ...

View File

@@ -8,6 +8,6 @@ class DeleteMarker:
is_latest: bool
last_modified: Any
owner: Any
def __init__(self, bucket: Incomplete | None = ..., name: Incomplete | None = ...) -> None: ...
def __init__(self, bucket: Incomplete | None = None, name: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...

View File

@@ -32,7 +32,7 @@ class Key:
ongoing_restore: Any
expiry_date: Any
local_hashes: Any
def __init__(self, bucket: Incomplete | None = ..., name: Incomplete | None = ...) -> None: ...
def __init__(self, bucket: Incomplete | None = None, name: Incomplete | None = None) -> None: ...
def __iter__(self): ...
@property
def provider(self): ...
@@ -42,194 +42,194 @@ class Key:
storage_class: Any
def get_md5_from_hexdigest(self, md5_hexdigest): ...
def handle_encryption_headers(self, resp): ...
def handle_version_headers(self, resp, force: bool = ...): ...
def handle_version_headers(self, resp, force: bool = False): ...
def handle_restore_headers(self, response): ...
def handle_addl_headers(self, headers): ...
def open_read(
self,
headers: dict[str, str] | None = ...,
query_args: str = ...,
override_num_retries: Incomplete | None = ...,
response_headers: dict[str, str] | None = ...,
headers: dict[str, str] | None = None,
query_args: str = "",
override_num_retries: Incomplete | None = None,
response_headers: dict[str, str] | None = None,
): ...
def open_write(self, headers: dict[str, str] | None = ..., override_num_retries: Incomplete | None = ...): ...
def open_write(self, headers: dict[str, str] | None = None, override_num_retries: Incomplete | None = None): ...
def open(
self,
mode: str = ...,
headers: dict[str, str] | None = ...,
query_args: Incomplete | None = ...,
override_num_retries: Incomplete | None = ...,
mode: str = "r",
headers: dict[str, str] | None = None,
query_args: Incomplete | None = None,
override_num_retries: Incomplete | None = None,
): ...
closed: bool
def close(self, fast: bool = ...): ...
def close(self, fast: bool = False): ...
def next(self): ...
__next__: Any
def read(self, size: int = ...): ...
def change_storage_class(self, new_storage_class, dst_bucket: Incomplete | None = ..., validate_dst_bucket: bool = ...): ...
def read(self, size: int = 0): ...
def change_storage_class(self, new_storage_class, dst_bucket: Incomplete | None = None, validate_dst_bucket: bool = True): ...
def copy(
self,
dst_bucket,
dst_key,
metadata: Incomplete | None = ...,
reduced_redundancy: bool = ...,
preserve_acl: bool = ...,
encrypt_key: bool = ...,
validate_dst_bucket: bool = ...,
metadata: Incomplete | None = None,
reduced_redundancy: bool = False,
preserve_acl: bool = False,
encrypt_key: bool = False,
validate_dst_bucket: bool = True,
): ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
def exists(self, headers: dict[str, str] | None = ...): ...
def delete(self, headers: dict[str, str] | None = ...): ...
def exists(self, headers: dict[str, str] | None = None): ...
def delete(self, headers: dict[str, str] | None = None): ...
def get_metadata(self, name): ...
def set_metadata(self, name, value): ...
def update_metadata(self, d): ...
def set_acl(self, acl_str, headers: dict[str, str] | None = ...): ...
def get_acl(self, headers: dict[str, str] | None = ...): ...
def get_xml_acl(self, headers: dict[str, str] | None = ...): ...
def set_xml_acl(self, acl_str, headers: dict[str, str] | None = ...): ...
def set_canned_acl(self, acl_str, headers: dict[str, str] | None = ...): ...
def set_acl(self, acl_str, headers: dict[str, str] | None = None): ...
def get_acl(self, headers: dict[str, str] | None = None): ...
def get_xml_acl(self, headers: dict[str, str] | None = None): ...
def set_xml_acl(self, acl_str, headers: dict[str, str] | None = None): ...
def set_canned_acl(self, acl_str, headers: dict[str, str] | None = None): ...
def get_redirect(self): ...
def set_redirect(self, redirect_location, headers: dict[str, str] | None = ...): ...
def make_public(self, headers: dict[str, str] | None = ...): ...
def set_redirect(self, redirect_location, headers: dict[str, str] | None = None): ...
def make_public(self, headers: dict[str, str] | None = None): ...
def generate_url(
self,
expires_in,
method: str = ...,
headers: dict[str, str] | None = ...,
query_auth: bool = ...,
force_http: bool = ...,
response_headers: dict[str, str] | None = ...,
expires_in_absolute: bool = ...,
version_id: Incomplete | None = ...,
policy: Incomplete | None = ...,
reduced_redundancy: bool = ...,
encrypt_key: bool = ...,
method: str = "GET",
headers: dict[str, str] | None = None,
query_auth: bool = True,
force_http: bool = False,
response_headers: dict[str, str] | None = None,
expires_in_absolute: bool = False,
version_id: Incomplete | None = None,
policy: Incomplete | None = None,
reduced_redundancy: bool = False,
encrypt_key: bool = False,
): ...
def send_file(
self,
fp,
headers: dict[str, str] | None = ...,
cb: Callable[[int, int], object] | None = ...,
num_cb: int = ...,
query_args: Incomplete | None = ...,
chunked_transfer: bool = ...,
size: Incomplete | None = ...,
headers: dict[str, str] | None = None,
cb: Callable[[int, int], object] | None = None,
num_cb: int = 10,
query_args: Incomplete | None = None,
chunked_transfer: bool = False,
size: Incomplete | None = None,
): ...
def should_retry(self, response, chunked_transfer: bool = ...): ...
def compute_md5(self, fp, size: Incomplete | None = ...): ...
def should_retry(self, response, chunked_transfer: bool = False): ...
def compute_md5(self, fp, size: Incomplete | None = None): ...
def set_contents_from_stream(
self,
fp,
headers: dict[str, str] | None = ...,
replace: bool = ...,
cb: Callable[[int, int], object] | None = ...,
num_cb: int = ...,
policy: Incomplete | None = ...,
reduced_redundancy: bool = ...,
query_args: Incomplete | None = ...,
size: Incomplete | None = ...,
headers: dict[str, str] | None = None,
replace: bool = True,
cb: Callable[[int, int], object] | None = None,
num_cb: int = 10,
policy: Incomplete | None = None,
reduced_redundancy: bool = False,
query_args: Incomplete | None = None,
size: Incomplete | None = None,
): ...
def set_contents_from_file(
self,
fp,
headers: dict[str, str] | None = ...,
replace: bool = ...,
cb: Callable[[int, int], object] | None = ...,
num_cb: int = ...,
policy: Incomplete | None = ...,
md5: Incomplete | None = ...,
reduced_redundancy: bool = ...,
query_args: Incomplete | None = ...,
encrypt_key: bool = ...,
size: Incomplete | None = ...,
rewind: bool = ...,
headers: dict[str, str] | None = None,
replace: bool = True,
cb: Callable[[int, int], object] | None = None,
num_cb: int = 10,
policy: Incomplete | None = None,
md5: Incomplete | None = None,
reduced_redundancy: bool = False,
query_args: Incomplete | None = None,
encrypt_key: bool = False,
size: Incomplete | None = None,
rewind: bool = False,
): ...
def set_contents_from_filename(
self,
filename,
headers: dict[str, str] | None = ...,
replace: bool = ...,
cb: Callable[[int, int], object] | None = ...,
num_cb: int = ...,
policy: Incomplete | None = ...,
md5: Incomplete | None = ...,
reduced_redundancy: bool = ...,
encrypt_key: bool = ...,
headers: dict[str, str] | None = None,
replace: bool = True,
cb: Callable[[int, int], object] | None = None,
num_cb: int = 10,
policy: Incomplete | None = None,
md5: Incomplete | None = None,
reduced_redundancy: bool = False,
encrypt_key: bool = False,
): ...
def set_contents_from_string(
self,
string_data: str | bytes,
headers: dict[str, str] | None = ...,
replace: bool = ...,
cb: Callable[[int, int], object] | None = ...,
num_cb: int = ...,
policy: Incomplete | None = ...,
md5: Incomplete | None = ...,
reduced_redundancy: bool = ...,
encrypt_key: bool = ...,
headers: dict[str, str] | None = None,
replace: bool = True,
cb: Callable[[int, int], object] | None = None,
num_cb: int = 10,
policy: Incomplete | None = None,
md5: Incomplete | None = None,
reduced_redundancy: bool = False,
encrypt_key: bool = False,
) -> None: ...
def get_file(
self,
fp,
headers: dict[str, str] | None = ...,
cb: Callable[[int, int], object] | None = ...,
num_cb: int = ...,
torrent: bool = ...,
version_id: Incomplete | None = ...,
override_num_retries: Incomplete | None = ...,
response_headers: dict[str, str] | None = ...,
headers: dict[str, str] | None = None,
cb: Callable[[int, int], object] | None = None,
num_cb: int = 10,
torrent: bool = False,
version_id: Incomplete | None = None,
override_num_retries: Incomplete | None = None,
response_headers: dict[str, str] | None = None,
): ...
def get_torrent_file(
self, fp, headers: dict[str, str] | None = ..., cb: Callable[[int, int], object] | None = ..., num_cb: int = ...
self, fp, headers: dict[str, str] | None = None, cb: Callable[[int, int], object] | None = None, num_cb: int = 10
): ...
def get_contents_to_file(
self,
fp,
headers: dict[str, str] | None = ...,
cb: Callable[[int, int], object] | None = ...,
num_cb: int = ...,
torrent: bool = ...,
version_id: Incomplete | None = ...,
res_download_handler: Incomplete | None = ...,
response_headers: dict[str, str] | None = ...,
headers: dict[str, str] | None = None,
cb: Callable[[int, int], object] | None = None,
num_cb: int = 10,
torrent: bool = False,
version_id: Incomplete | None = None,
res_download_handler: Incomplete | None = None,
response_headers: dict[str, str] | None = None,
): ...
def get_contents_to_filename(
self,
filename,
headers: dict[str, str] | None = ...,
cb: Callable[[int, int], object] | None = ...,
num_cb: int = ...,
torrent: bool = ...,
version_id: Incomplete | None = ...,
res_download_handler: Incomplete | None = ...,
response_headers: dict[str, str] | None = ...,
headers: dict[str, str] | None = None,
cb: Callable[[int, int], object] | None = None,
num_cb: int = 10,
torrent: bool = False,
version_id: Incomplete | None = None,
res_download_handler: Incomplete | None = None,
response_headers: dict[str, str] | None = None,
): ...
@overload
def get_contents_as_string(
self,
headers: dict[str, str] | None = ...,
cb: Callable[[int, int], object] | None = ...,
num_cb: int = ...,
torrent: bool = ...,
version_id: Incomplete | None = ...,
response_headers: dict[str, str] | None = ...,
encoding: None = ...,
headers: dict[str, str] | None = None,
cb: Callable[[int, int], object] | None = None,
num_cb: int = 10,
torrent: bool = False,
version_id: Incomplete | None = None,
response_headers: dict[str, str] | None = None,
encoding: None = None,
) -> bytes: ...
@overload
def get_contents_as_string(
self,
headers: dict[str, str] | None = ...,
cb: Callable[[int, int], object] | None = ...,
num_cb: int = ...,
torrent: bool = ...,
version_id: Incomplete | None = ...,
response_headers: dict[str, str] | None = ...,
headers: dict[str, str] | None = None,
cb: Callable[[int, int], object] | None = None,
num_cb: int = 10,
torrent: bool = False,
version_id: Incomplete | None = None,
response_headers: dict[str, str] | None = None,
*,
encoding: str,
) -> str: ...
def add_email_grant(self, permission, email_address, headers: dict[str, str] | None = ...): ...
def add_email_grant(self, permission, email_address, headers: dict[str, str] | None = None): ...
def add_user_grant(
self, permission, user_id, headers: dict[str, str] | None = ..., display_name: Incomplete | None = ...
self, permission, user_id, headers: dict[str, str] | None = None, display_name: Incomplete | None = None
): ...
def set_remote_metadata(self, metadata_plus, metadata_minus, preserve_acl, headers: dict[str, str] | None = ...): ...
def restore(self, days, headers: dict[str, str] | None = ...): ...
def set_remote_metadata(self, metadata_plus, metadata_minus, preserve_acl, headers: dict[str, str] | None = None): ...
def restore(self, days, headers: dict[str, str] | None = None): ...

View File

@@ -12,7 +12,7 @@ class KeyFile:
name: Any
def __init__(self, key) -> None: ...
def tell(self): ...
def seek(self, pos, whence: Any = ...): ...
def seek(self, pos, whence: Any = 0): ...
def read(self, size): ...
def close(self): ...
def isatty(self): ...

View File

@@ -9,11 +9,11 @@ class Rule:
transition: Any
def __init__(
self,
id: Incomplete | None = ...,
prefix: Incomplete | None = ...,
status: Incomplete | None = ...,
expiration: Incomplete | None = ...,
transition: Incomplete | None = ...,
id: Incomplete | None = None,
prefix: Incomplete | None = None,
status: Incomplete | None = None,
expiration: Incomplete | None = None,
transition: Incomplete | None = None,
) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
@@ -22,7 +22,7 @@ class Rule:
class Expiration:
days: Any
date: Any
def __init__(self, days: Incomplete | None = ..., date: Incomplete | None = ...) -> None: ...
def __init__(self, days: Incomplete | None = None, date: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
def to_xml(self): ...
@@ -32,7 +32,7 @@ class Transition:
date: Any
storage_class: Any
def __init__(
self, days: Incomplete | None = ..., date: Incomplete | None = ..., storage_class: Incomplete | None = ...
self, days: Incomplete | None = None, date: Incomplete | None = None, storage_class: Incomplete | None = None
) -> None: ...
def to_xml(self): ...
@@ -47,7 +47,7 @@ class Transitions(list[Transition]):
def endElement(self, name, value, connection): ...
def to_xml(self): ...
def add_transition(
self, days: Incomplete | None = ..., date: Incomplete | None = ..., storage_class: Incomplete | None = ...
self, days: Incomplete | None = None, date: Incomplete | None = None, storage_class: Incomplete | None = None
): ...
@property
def days(self): ...
@@ -62,9 +62,9 @@ class Lifecycle(list[Rule]):
def to_xml(self): ...
def add_rule(
self,
id: Incomplete | None = ...,
prefix: str = ...,
status: str = ...,
expiration: Incomplete | None = ...,
transition: Incomplete | None = ...,
id: Incomplete | None = None,
prefix: str = "",
status: str = "Enabled",
expiration: Incomplete | None = None,
transition: Incomplete | None = None,
): ...

View File

@@ -8,10 +8,10 @@ class Deleted:
delete_marker_version_id: Any
def __init__(
self,
key: Incomplete | None = ...,
version_id: Incomplete | None = ...,
delete_marker: bool = ...,
delete_marker_version_id: Incomplete | None = ...,
key: Incomplete | None = None,
version_id: Incomplete | None = None,
delete_marker: bool = False,
delete_marker_version_id: Incomplete | None = None,
) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
@@ -23,10 +23,10 @@ class Error:
message: Any
def __init__(
self,
key: Incomplete | None = ...,
version_id: Incomplete | None = ...,
code: Incomplete | None = ...,
message: Incomplete | None = ...,
key: Incomplete | None = None,
version_id: Incomplete | None = None,
code: Incomplete | None = None,
message: Incomplete | None = None,
) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
@@ -35,6 +35,6 @@ class MultiDeleteResult:
bucket: Any
deleted: Any
errors: Any
def __init__(self, bucket: Incomplete | None = ...) -> None: ...
def __init__(self, bucket: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...

View File

@@ -9,7 +9,7 @@ class CompleteMultiPartUpload:
etag: Any
version_id: Any
encrypted: Any
def __init__(self, bucket: Incomplete | None = ...) -> None: ...
def __init__(self, bucket: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
@@ -19,11 +19,11 @@ class Part:
last_modified: Any
etag: Any
size: Any
def __init__(self, bucket: Incomplete | None = ...) -> None: ...
def __init__(self, bucket: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
def part_lister(mpupload, part_number_marker: Incomplete | None = ...): ...
def part_lister(mpupload, part_number_marker: Incomplete | None = None): ...
class MultiPartUpload:
bucket: Any
@@ -38,37 +38,37 @@ class MultiPartUpload:
next_part_number_marker: Any
max_parts: Any
is_truncated: bool
def __init__(self, bucket: Incomplete | None = ...) -> None: ...
def __init__(self, bucket: Incomplete | None = None) -> None: ...
def __iter__(self): ...
def to_xml(self): ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
def get_all_parts(
self,
max_parts: Incomplete | None = ...,
part_number_marker: Incomplete | None = ...,
encoding_type: Incomplete | None = ...,
max_parts: Incomplete | None = None,
part_number_marker: Incomplete | None = None,
encoding_type: Incomplete | None = None,
): ...
def upload_part_from_file(
self,
fp,
part_num,
headers: Incomplete | None = ...,
replace: bool = ...,
cb: Incomplete | None = ...,
num_cb: int = ...,
md5: Incomplete | None = ...,
size: Incomplete | None = ...,
headers: Incomplete | None = None,
replace: bool = True,
cb: Incomplete | None = None,
num_cb: int = 10,
md5: Incomplete | None = None,
size: Incomplete | None = None,
): ...
def copy_part_from_key(
self,
src_bucket_name,
src_key_name,
part_num,
start: Incomplete | None = ...,
end: Incomplete | None = ...,
src_version_id: Incomplete | None = ...,
headers: Incomplete | None = ...,
start: Incomplete | None = None,
end: Incomplete | None = None,
src_version_id: Incomplete | None = None,
headers: Incomplete | None = None,
): ...
def complete_upload(self): ...
def cancel_upload(self): ...

View File

@@ -4,7 +4,7 @@ from typing import Any
class Prefix:
bucket: Any
name: Any
def __init__(self, bucket: Incomplete | None = ..., name: Incomplete | None = ...) -> None: ...
def __init__(self, bucket: Incomplete | None = None, name: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
@property

View File

@@ -4,7 +4,7 @@ from typing import Any
class Tag:
key: Any
value: Any
def __init__(self, key: Incomplete | None = ..., value: Incomplete | None = ...) -> None: ...
def __init__(self, key: Incomplete | None = None, value: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
def to_xml(self): ...

View File

@@ -5,7 +5,7 @@ class User:
type: Any
id: Any
display_name: Any
def __init__(self, parent: Incomplete | None = ..., id: str = ..., display_name: str = ...) -> None: ...
def __init__(self, parent: Incomplete | None = None, id: str = "", display_name: str = "") -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
def to_xml(self, element_name: str = ...): ...
def to_xml(self, element_name: str = "Owner"): ...

View File

@@ -10,10 +10,10 @@ class WebsiteConfiguration:
routing_rules: Any
def __init__(
self,
suffix: Incomplete | None = ...,
error_key: Incomplete | None = ...,
redirect_all_requests_to: Incomplete | None = ...,
routing_rules: Incomplete | None = ...,
suffix: Incomplete | None = None,
error_key: Incomplete | None = None,
redirect_all_requests_to: Incomplete | None = None,
routing_rules: Incomplete | None = None,
) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
@@ -22,7 +22,7 @@ class WebsiteConfiguration:
class _XMLKeyValue:
translator: Any
container: Any
def __init__(self, translator, container: Incomplete | None = ...) -> None: ...
def __init__(self, translator, container: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
def to_xml(self): ...
@@ -31,7 +31,7 @@ class RedirectLocation(_XMLKeyValue):
TRANSLATOR: Any
hostname: Any
protocol: Any
def __init__(self, hostname: Incomplete | None = ..., protocol: Incomplete | None = ...) -> None: ...
def __init__(self, hostname: Incomplete | None = None, protocol: Incomplete | None = None) -> None: ...
def to_xml(self): ...
class RoutingRules(list[RoutingRule]):
@@ -43,26 +43,26 @@ class RoutingRules(list[RoutingRule]):
class RoutingRule:
condition: Any
redirect: Any
def __init__(self, condition: Incomplete | None = ..., redirect: Incomplete | None = ...) -> None: ...
def __init__(self, condition: Incomplete | None = None, redirect: Incomplete | None = None) -> None: ...
def startElement(self, name, attrs, connection): ...
def endElement(self, name, value, connection): ...
def to_xml(self): ...
@classmethod
def when(cls, key_prefix: Incomplete | None = ..., http_error_code: Incomplete | None = ...): ...
def when(cls, key_prefix: Incomplete | None = None, http_error_code: Incomplete | None = None): ...
def then_redirect(
self,
hostname: Incomplete | None = ...,
protocol: Incomplete | None = ...,
replace_key: Incomplete | None = ...,
replace_key_prefix: Incomplete | None = ...,
http_redirect_code: Incomplete | None = ...,
hostname: Incomplete | None = None,
protocol: Incomplete | None = None,
replace_key: Incomplete | None = None,
replace_key_prefix: Incomplete | None = None,
http_redirect_code: Incomplete | None = None,
): ...
class Condition(_XMLKeyValue):
TRANSLATOR: Any
key_prefix: Any
http_error_code: Any
def __init__(self, key_prefix: Incomplete | None = ..., http_error_code: Incomplete | None = ...) -> None: ...
def __init__(self, key_prefix: Incomplete | None = None, http_error_code: Incomplete | None = None) -> None: ...
def to_xml(self): ...
class Redirect(_XMLKeyValue):
@@ -74,10 +74,10 @@ class Redirect(_XMLKeyValue):
http_redirect_code: Any
def __init__(
self,
hostname: Incomplete | None = ...,
protocol: Incomplete | None = ...,
replace_key: Incomplete | None = ...,
replace_key_prefix: Incomplete | None = ...,
http_redirect_code: Incomplete | None = ...,
hostname: Incomplete | None = None,
protocol: Incomplete | None = None,
replace_key: Incomplete | None = None,
replace_key_prefix: Incomplete | None = None,
http_redirect_code: Incomplete | None = None,
) -> None: ...
def to_xml(self): ...

View File

@@ -24,25 +24,33 @@ qsa_of_interest: list[str]
def unquote_v(nv: str) -> str | tuple[str, str]: ...
def canonical_string(
method: str, path: str, headers: Mapping[str, str | None], expires: int | None = ..., provider: _Provider | None = ...
method: str, path: str, headers: Mapping[str, str | None], expires: int | None = None, provider: _Provider | None = None
) -> str: ...
def merge_meta(
headers: Mapping[str, str], metadata: Mapping[str, str], provider: _Provider | None = ...
headers: Mapping[str, str], metadata: Mapping[str, str], provider: _Provider | None = None
) -> Mapping[str, str]: ...
def get_aws_metadata(headers: Mapping[str, str], provider: _Provider | None = ...) -> Mapping[str, str]: ...
def retry_url(url: str, retry_on_404: bool = ..., num_retries: int = ..., timeout: int | None = ...) -> str: ...
def get_aws_metadata(headers: Mapping[str, str], provider: _Provider | None = None) -> Mapping[str, str]: ...
def retry_url(url: str, retry_on_404: bool = True, num_retries: int = 10, timeout: int | None = None) -> str: ...
class LazyLoadMetadata(dict[_KT, _VT]):
def __init__(self, url: str, num_retries: int, timeout: int | None = ...) -> None: ...
def __init__(self, url: str, num_retries: int, timeout: int | None = None) -> None: ...
def get_instance_metadata(
version: str = ..., url: str = ..., data: str = ..., timeout: int | None = ..., num_retries: int = ...
version: str = "latest",
url: str = "http://169.254.169.254",
data: str = "meta-data/",
timeout: int | None = None,
num_retries: int = 5,
) -> LazyLoadMetadata[Any, Any] | None: ...
def get_instance_identity(
version: str = ..., url: str = ..., timeout: int | None = ..., num_retries: int = ...
version: str = "latest", url: str = "http://169.254.169.254", timeout: int | None = None, num_retries: int = 5
) -> Mapping[str, Any] | None: ...
def get_instance_userdata(
version: str = ..., sep: str | None = ..., url: str = ..., timeout: int | None = ..., num_retries: int = ...
version: str = "latest",
sep: str | None = None,
url: str = "http://169.254.169.254",
timeout: int | None = None,
num_retries: int = 5,
) -> Mapping[str, str]: ...
ISO8601: str
@@ -51,12 +59,12 @@ RFC1123: str
LOCALE_LOCK: _LockType
def setlocale(name: str | tuple[str, str]) -> AbstractContextManager[str]: ...
def get_ts(ts: time.struct_time | None = ...) -> str: ...
def get_ts(ts: time.struct_time | None = None) -> str: ...
def parse_ts(ts: str) -> datetime.datetime: ...
def find_class(module_name: str, class_name: str | None = ...) -> type[Any] | None: ...
def find_class(module_name: str, class_name: str | None = None) -> type[Any] | None: ...
def update_dme(username: str, password: str, dme_id: str, ip_address: str) -> str: ...
def fetch_file(
uri: str, file: IO[str] | None = ..., username: str | None = ..., password: str | None = ...
uri: str, file: IO[str] | None = None, username: str | None = None, password: str | None = None
) -> IO[str] | None: ...
class ShellCommand:
@@ -66,10 +74,10 @@ class ShellCommand:
wait: bool
fail_fast: bool
def __init__(
self, command: subprocess._CMD, wait: bool = ..., fail_fast: bool = ..., cwd: StrOrBytesPath | None = ...
self, command: subprocess._CMD, wait: bool = True, fail_fast: bool = False, cwd: StrOrBytesPath | None = None
) -> None: ...
process: subprocess.Popen[Any]
def run(self, cwd: subprocess._CMD | None = ...) -> int | None: ...
def run(self, cwd: subprocess._CMD | None = None) -> int | None: ...
def setReadOnly(self, value) -> None: ...
def getStatus(self) -> int | None: ...
status: int | None
@@ -102,34 +110,36 @@ _Str: TypeAlias = str
class Password:
hashfunc: Callable[[bytes], _Hash]
str: _Str | None
def __init__(self, str: _Str | None = ..., hashfunc: Callable[[bytes], _Hash] | None = ...) -> None: ...
def __init__(self, str: _Str | None = None, hashfunc: Callable[[bytes], _Hash] | None = None) -> None: ...
def set(self, value: bytes | _Str) -> None: ...
def __eq__(self, other: _Str | bytes | None) -> bool: ... # type: ignore[override]
def __len__(self) -> int: ...
def notify(
subject: str,
body: str | None = ...,
html_body: Sequence[str] | str | None = ...,
to_string: str | None = ...,
attachments: Iterable[Message] | None = ...,
append_instance_id: bool = ...,
body: str | None = None,
html_body: Sequence[str] | str | None = None,
to_string: str | None = None,
attachments: Iterable[Message] | None = None,
append_instance_id: bool = True,
) -> None: ...
def get_utf8_value(value: str) -> bytes: ...
def mklist(value: Any) -> list[Any]: ...
def pythonize_name(name: str) -> str: ...
def write_mime_multipart(
content: list[tuple[str, str]], compress: bool = ..., deftype: str = ..., delimiter: str = ...
content: list[tuple[str, str]], compress: bool = False, deftype: str = "text/plain", delimiter: str = ":"
) -> str: ...
def guess_mime_type(content: str, deftype: str) -> str: ...
def compute_md5(fp: IO[Any], buf_size: int = ..., size: int | None = ...) -> tuple[str, str, int]: ...
def compute_hash(fp: IO[Any], buf_size: int = ..., size: int | None = ..., hash_algorithm: Any = ...) -> tuple[str, str, int]: ...
def compute_md5(fp: IO[Any], buf_size: int = 8192, size: int | None = None) -> tuple[str, str, int]: ...
def compute_hash(
fp: IO[Any], buf_size: int = 8192, size: int | None = None, hash_algorithm: Any = ...
) -> tuple[str, str, int]: ...
def find_matching_headers(name: str, headers: Mapping[str, str | None]) -> list[str]: ...
def merge_headers_by_name(name: str, headers: Mapping[str, str | None]) -> str: ...
class RequestHook:
def handle_request_data(
self, request: boto.connection.HTTPRequest, response: boto.connection.HTTPResponse, error: bool = ...
self, request: boto.connection.HTTPRequest, response: boto.connection.HTTPResponse, error: bool = False
) -> Any: ...
def host_is_ipv6(hostname: str) -> bool: ...