# sig/multiwoven/integrations/config.rbs

class Multiwoven::Integrations::Config
  def initialize: () -> void
end


# sig/multiwoven/integrations/core/base_connector.rbs

class Multiwoven::Integrations::Core::BaseConnector
  def auth_headers: () -> untyped
  def check_connection: () -> untyped
  def connector_spec: () -> untyped
  def discover: () -> untyped
  def failure_status: () -> untyped
  def meta_data: () -> untyped
  def read_json: () -> untyped
  def relative_path: () -> untyped
  def success_status: () -> untyped
end


# sig/multiwoven/integrations/core/destination_connector.rbs

class Multiwoven::Integrations::Core::DestinationConnector < Multiwoven::Integrations::Core::BaseConnector
  def tracking_message: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/core/http_client.rbs

class Multiwoven::Integrations::Core::HttpClient
  def build_request: () -> untyped
  def request: () -> untyped
end


# sig/multiwoven/integrations/core/query_builder.rbs

class Multiwoven::Integrations::Core::QueryBuilder
  def self.perform: () -> untyped
end


# sig/multiwoven/integrations/core/source_connector.rbs

class Multiwoven::Integrations::Core::SourceConnector < Multiwoven::Integrations::Core::BaseConnector
  def batched_query: () -> untyped
  def create_connection: () -> untyped
  def query: () -> untyped
  def read: () -> untyped
end


# sig/multiwoven/integrations/destination/ais_data_store/client.rbs

class Multiwoven::Integrations::Destination::AISDataStore::Client < Multiwoven::Integrations::Destination::AISDataStore::DestinationConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def group_by_table: () -> untyped
  def query: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/airtable/client.rbs

class Multiwoven::Integrations::Destination::Airtable::Client < Multiwoven::Integrations::Destination::Airtable::DestinationConnector
  def base_id_exists?: () -> untyped
  def build_catalog_from_schema: () -> untyped
  def check_connection: () -> untyped
  def create_payload: () -> untyped
  def create_stream: () -> untyped
  def discover: () -> untyped
  def extract_bases: () -> untyped
  def extract_body: () -> untyped
  def load_catalog: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/databricks_lakehouse/client.rbs

class Multiwoven::Integrations::Destination::DatabricksLakehouse::Client < Multiwoven::Integrations::Destination::DatabricksLakehouse::DestinationConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def generate_body: () -> untyped
  def group_by_table: () -> untyped
  def tracking_message: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/facebook_custom_audience/client.rbs

class Multiwoven::Integrations::Destination::FacebookCustomAudience::Client < Multiwoven::Integrations::Destination::FacebookCustomAudience::DestinationConnector
  def ad_account_exists?: () -> untyped
  def check_connection: () -> untyped
  def create_payload: () -> untyped
  def discover: () -> untyped
  def extract_data: () -> untyped
  def extract_schema_and_data: () -> untyped
  def generate_url: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/google_sheets/client.rbs

class Multiwoven::Integrations::Destination::GoogleSheets::Client < Multiwoven::Integrations::Destination::GoogleSheets::DestinationConnector
  def authorize_client: () -> untyped
  def build_catalog_from_spreadsheets: () -> untyped
  def check_connection: () -> untyped
  def clear_all_records: () -> untyped
  def clear_sheet_data: () -> untyped
  def column_index_to_letter: () -> untyped
  def control_message: () -> untyped
  def delete_extra_sheets: () -> untyped
  def discover: () -> untyped
  def extract_sheet_properties: () -> untyped
  def extract_spreadsheet_id: () -> untyped
  def fetch_column_names: () -> untyped
  def fetch_google_spread_sheets: () -> untyped
  def generate_header_range: () -> untyped
  def generate_json_schema: () -> untyped
  def generate_properties_schema: () -> untyped
  def load_catalog: () -> untyped
  def prepare_chunk_values: () -> untyped
  def process_record_chunks: () -> untyped
  def process_sheet_for_catalog: () -> untyped
  def setup_write_environment: () -> untyped
  def spread_sheet_value: () -> untyped
  def update_sheet_values: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/http/client.rbs

class Multiwoven::Integrations::Destination::Http::Client < Multiwoven::Integrations::Destination::Http::DestinationConnector
  def check_connection: () -> untyped
  def create_payload: () -> untyped
  def discover: () -> untyped
  def extract_body: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/hubspot/client.rbs

class Multiwoven::Integrations::Destination::Hubspot::Client < Multiwoven::Integrations::Destination::Hubspot::DestinationConnector
  def authenticate_client: () -> untyped
  def build_args: () -> untyped
  def check_connection: () -> untyped
  def discover: () -> untyped
  def failure_status: () -> untyped
  def initialize_client: () -> untyped
  def load_catalog: () -> untyped
  def log_debug: () -> untyped
  def process_records: () -> untyped
  def send_data_to_hubspot: () -> untyped
  def success_status: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/iterable/client.rbs

class Multiwoven::Integrations::Destination::Iterable::Client < Multiwoven::Integrations::Destination::Iterable::DestinationConnector
  def check_connection: () -> untyped
  def discover: () -> untyped
  def initialize_attribute: () -> untyped
  def initialize_client: () -> untyped
  def initialize_params: () -> untyped
  def load_catalog: () -> untyped
  def process_records: () -> untyped
  def process_stream: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/klaviyo/client.rbs

class Multiwoven::Integrations::Destination::Klaviyo::Client < Multiwoven::Integrations::Destination::Klaviyo::DestinationConnector
  def auth_headers: () -> untyped
  def check_connection: () -> untyped
  def discover: () -> untyped
  def extract_message: () -> untyped
  def parse_response: () -> untyped
  def success?: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/mailchimp/client.rbs

class Multiwoven::Integrations::Destination::Mailchimp::Client < Multiwoven::Integrations::Destination::Mailchimp::DestinationConnector
  def authenticate_client: () -> untyped
  def check_connection: () -> untyped
  def discover: () -> untyped
  def initialize_client: () -> untyped
  def load_catalog: () -> untyped
  def log_debug: () -> untyped
  def process_records: () -> untyped
  def send_to_mailchimp: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/maria_db/client.rbs

class Multiwoven::Integrations::Destination::MariaDB::Client < Multiwoven::Integrations::Destination::MariaDB::DestinationConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def group_by_table: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/microsoft_excel/client.rbs

class Multiwoven::Integrations::Destination::MicrosoftExcel::Client < Multiwoven::Integrations::Destination::MicrosoftExcel::DestinationConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def get_all_sheets: () -> untyped
  def get_file: () -> untyped
  def get_file_data: () -> untyped
  def get_table: () -> untyped
  def group_by_table: () -> untyped
  def process_write_request: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/microsoft_sql/client.rbs

class Multiwoven::Integrations::Destination::MicrosoftSql::Client < Multiwoven::Integrations::Destination::MicrosoftSql::DestinationConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def group_by_table: () -> untyped
  def query: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/oracle_db/client.rbs

class Multiwoven::Integrations::Destination::Oracle::Client < Multiwoven::Integrations::Destination::Oracle::DestinationConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def group_by_table: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/postgresql/client.rbs

class Multiwoven::Integrations::Destination::Postgresql::Client < Multiwoven::Integrations::Destination::Postgresql::DestinationConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def group_by_table: () -> untyped
  def query: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/salesforce_consumer_goods_cloud/client.rbs

class Multiwoven::Integrations::Destination::SalesforceConsumerGoodsCloud::Client < Multiwoven::Integrations::Destination::SalesforceConsumerGoodsCloud::DestinationConnector
  def authenticate_client: () -> untyped
  def check_connection: () -> untyped
  def discover: () -> untyped
  def failure_status: () -> untyped
  def initialize: () -> void
  def initialize_client: () -> untyped
  def load_catalog: () -> untyped
  def log_debug: () -> untyped
  def process_records: () -> untyped
  def send_data_to_salesforce: () -> untyped
  def success_status: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/salesforce_crm/client.rbs

class Multiwoven::Integrations::Destination::SalesforceCrm::Client < Multiwoven::Integrations::Destination::SalesforceCrm::DestinationConnector
  def authenticate_client: () -> untyped
  def build_args: () -> untyped
  def check_connection: () -> untyped
  def discover: () -> untyped
  def failure_status: () -> untyped
  def initialize_client: () -> untyped
  def load_catalog: () -> untyped
  def log_debug: () -> untyped
  def process_record: () -> untyped
  def process_records: () -> untyped
  def send_data_to_salesforce: () -> untyped
  def success_status: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/sftp/client.rbs

class Multiwoven::Integrations::Destination::Sftp::Client < Multiwoven::Integrations::Destination::Sftp::DestinationConnector
  def check_connection: () -> untyped
  def clear_all_records: () -> untyped
  def control_message: () -> untyped
  def discover: () -> untyped
  def generate_csv_content: () -> untyped
  def generate_file_path: () -> untyped
  def generate_local_file_name: () -> untyped
  def test_file_operations: () -> untyped
  def tracking_message: () -> untyped
  def with_sftp_client: () -> untyped
  def write: () -> untyped
  def write_compressed_data: () -> untyped
  def write_uncompressed_data: () -> untyped
end


# sig/multiwoven/integrations/destination/slack/client.rbs

class Multiwoven::Integrations::Destination::Slack::Client < Multiwoven::Integrations::Destination::Slack::DestinationConnector
  def build_args: () -> untyped
  def check_connection: () -> untyped
  def configure_slack: () -> untyped
  def discover: () -> untyped
  def failure_status: () -> untyped
  def load_catalog: () -> untyped
  def process_record: () -> untyped
  def process_records: () -> untyped
  def send_data_to_slack: () -> untyped
  def slack_code_block: () -> untyped
  def success_status: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/stripe/client.rbs

class Multiwoven::Integrations::Destination::Stripe::Client < Multiwoven::Integrations::Destination::Stripe::DestinationConnector
  def authenticate_client: () -> untyped
  def check_connection: () -> untyped
  def discover: () -> untyped
  def initialize_client: () -> untyped
  def load_catalog: () -> untyped
  def log_debug: () -> untyped
  def process_records: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/destination/zendesk/client.rbs

class Multiwoven::Integrations::Destination::Zendesk::Client < Multiwoven::Integrations::Destination::Zendesk::DestinationConnector
  def authenticate_client: () -> untyped
  def check_connection: () -> untyped
  def discover: () -> untyped
  def initialize_client: () -> untyped
  def load_catalog: () -> untyped
  def pluralize_stream_name: () -> untyped
  def prepare_record_data: () -> untyped
  def process_records: () -> untyped
  def write: () -> untyped
end


# sig/multiwoven/integrations/protocol/protocol.rbs

class Multiwoven::Integrations::Protocol::Catalog < Multiwoven::Integrations::Protocol::ProtocolModel
  def to_multiwoven_message: () -> untyped
end


# sig/multiwoven/integrations/protocol/protocol.rbs

class Multiwoven::Integrations::Protocol::ConnectionStatus < Multiwoven::Integrations::Protocol::ProtocolModel
  def to_multiwoven_message: () -> untyped
end


# sig/multiwoven/integrations/protocol/protocol.rbs

class Multiwoven::Integrations::Protocol::ConnectorSpecification < Multiwoven::Integrations::Protocol::ProtocolModel
  def to_multiwoven_message: () -> untyped
end


# sig/multiwoven/integrations/protocol/protocol.rbs

class Multiwoven::Integrations::Protocol::ControlMessage < Multiwoven::Integrations::Protocol::ProtocolModel
  def to_multiwoven_message: () -> untyped
end


# sig/multiwoven/integrations/protocol/protocol.rbs

class Multiwoven::Integrations::Protocol::LogMessage < Multiwoven::Integrations::Protocol::ProtocolModel
  def to_multiwoven_message: () -> untyped
end


# sig/multiwoven/integrations/protocol/protocol.rbs

class Multiwoven::Integrations::Protocol::ProtocolModel < Multiwoven::Integrations::Protocol::Dry::Struct
  def from_json: () -> untyped
end


# sig/multiwoven/integrations/protocol/protocol.rbs

class Multiwoven::Integrations::Protocol::RecordMessage < Multiwoven::Integrations::Protocol::ProtocolModel
  def to_multiwoven_message: () -> untyped
end


# sig/multiwoven/integrations/protocol/protocol.rbs

class Multiwoven::Integrations::Protocol::Stream < Multiwoven::Integrations::Protocol::ProtocolModel
  def rate_limit_unit_seconds: () -> untyped
end


# sig/multiwoven/integrations/protocol/protocol.rbs

class Multiwoven::Integrations::Protocol::TrackingMessage < Multiwoven::Integrations::Protocol::ProtocolModel
  def to_multiwoven_message: () -> untyped
end


# sig/multiwoven/integrations/service.rbs

class Multiwoven::Integrations::Service
  def build_connectors: () -> untyped
  def config: () -> untyped
  def connector_class: () -> untyped
  def connectors: () -> untyped
  def default_logger: () -> untyped
  def exception_reporter: () -> untyped
  def initialize: () -> void
  def logger: () -> untyped
end


# sig/multiwoven/integrations/source/amazon_s3/client.rbs

class Multiwoven::Integrations::Source::AmazonS3::Client < Multiwoven::Integrations::Source::AmazonS3::SourceConnector
  def build_discover_columns: () -> untyped
  def build_path: () -> untyped
  def check_connection: () -> untyped
  def column_schema_helper: () -> untyped
  def create_connection: () -> untyped
  def discover: () -> untyped
  def get_auth_data: () -> untyped
  def get_results: () -> untyped
  def hash_array_values: () -> untyped
  def query: () -> untyped
  def read: () -> untyped
end


# sig/multiwoven/integrations/source/aws_athena/client.rbs

class Multiwoven::Integrations::Source::AwsAthena::Client < Multiwoven::Integrations::Source::AwsAthena::SourceConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def group_by_table: () -> untyped
  def query: () -> untyped
  def query_execution: () -> untyped
  def read: () -> untyped
  def transform_results: () -> untyped
end


# sig/multiwoven/integrations/source/aws_sagemaker_model/client.rbs

class Multiwoven::Integrations::Source::AwsSagemakerModel::Client < Multiwoven::Integrations::Source::AwsSagemakerModel::SourceConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def discover: () -> untyped
  def process_response: () -> untyped
  def read: () -> untyped
  def run_model: () -> untyped
end


# sig/multiwoven/integrations/source/bigquery/client.rbs

class Multiwoven::Integrations::Source::Bigquery::Client < Multiwoven::Integrations::Source::Bigquery::SourceConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def group_by_table: () -> untyped
  def query: () -> untyped
  def read: () -> untyped
end


# sig/multiwoven/integrations/source/clickhouse/client.rbs

class Multiwoven::Integrations::Source::Clickhouse::Client < Multiwoven::Integrations::Source::Clickhouse::SourceConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def group_by_table: () -> untyped
  def query: () -> untyped
  def query_execution: () -> untyped
  def read: () -> untyped
end


# sig/multiwoven/integrations/source/databricks/client.rbs

class Multiwoven::Integrations::Source::Databricks::Client < Multiwoven::Integrations::Source::Databricks::SourceConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def generate_drvconnect: () -> untyped
  def group_by_table: () -> untyped
  def query: () -> untyped
  def read: () -> untyped
end


# sig/multiwoven/integrations/source/databrics_model/client.rbs

class Multiwoven::Integrations::Source::DatabricksModel::Client < Multiwoven::Integrations::Source::DatabricksModel::SourceConnector
  def build_url: () -> untyped
  def check_connection: () -> untyped
  def discover: () -> untyped
  def process_response: () -> untyped
  def read: () -> untyped
  def run_model: () -> untyped
  def send_request: () -> untyped
end


# sig/multiwoven/integrations/source/http_model/client.rbs

class Multiwoven::Integrations::Source::HttpModel::Client < Multiwoven::Integrations::Source::HttpModel::SourceConnector
  def check_connection: () -> untyped
  def discover: () -> untyped
  def process_response: () -> untyped
  def read: () -> untyped
  def run_model: () -> untyped
  def send_request: () -> untyped
end


# sig/multiwoven/integrations/source/maria_db/client.rbs

class Multiwoven::Integrations::Source::MariaDB::Client < Multiwoven::Integrations::Source::MariaDB::SourceConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def group_by_table: () -> untyped
  def query: () -> untyped
  def query_execution: () -> untyped
  def read: () -> untyped
end


# sig/multiwoven/integrations/source/oracle_db/client.rbs

class Multiwoven::Integrations::Source::Oracle::Client < Multiwoven::Integrations::Source::Oracle::SourceConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def group_by_table: () -> untyped
  def query: () -> untyped
  def read: () -> untyped
  def reformat_query: () -> untyped
end


# sig/multiwoven/integrations/source/postgresql/client.rbs

class Multiwoven::Integrations::Source::Postgresql::Client < Multiwoven::Integrations::Source::Postgresql::SourceConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def group_by_table: () -> untyped
  def query: () -> untyped
  def read: () -> untyped
end


# sig/multiwoven/integrations/source/redshift/client.rbs

class Multiwoven::Integrations::Source::Redshift::Client < Multiwoven::Integrations::Source::Redshift::SourceConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def group_by_table: () -> untyped
  def query: () -> untyped
  def read: () -> untyped
end


# sig/multiwoven/integrations/source/salesforce_consumer_goods_cloud/client.rbs

class Multiwoven::Integrations::Source::SalesforceConsumerGoodsCloud::Client < Multiwoven::Integrations::Source::SalesforceConsumerGoodsCloud::SourceConnector
  def authenticate_client: () -> untyped
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def discover: () -> untyped
  def failure_status: () -> untyped
  def flatten_nested_hash: () -> untyped
  def initialize_client: () -> untyped
  def load_catalog: () -> untyped
  def log_debug: () -> untyped
  def query: () -> untyped
  def read: () -> untyped
  def success_status: () -> untyped
  def tracking_message: () -> untyped
end


# sig/multiwoven/integrations/source/snowflake/client.rbs

class Multiwoven::Integrations::Source::Snowflake::Client < Multiwoven::Integrations::Source::Snowflake::SourceConnector
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def create_streams: () -> untyped
  def discover: () -> untyped
  def generate_drvconnect: () -> untyped
  def group_by_table: () -> untyped
  def query: () -> untyped
  def read: () -> untyped
end


# sig/multiwoven/integrations/source/google_vertex_model/client.rbs

class Multiwoven::Integrations::Source::VertexModel::Client < Multiwoven::Integrations::Source::VertexModel::SourceConnector
  def build_url: () -> untyped
  def check_connection: () -> untyped
  def create_connection: () -> untyped
  def discover: () -> untyped
  def process_response: () -> untyped
  def read: () -> untyped
  def run_model: () -> untyped
end


# sig/multiwoven/integrations/core/fullrefresher.rbs

module Multiwoven::Integrations::Core::Fullrefresher
  def write: () -> untyped
end


# sig/multiwoven/integrations/core/rate_limiter.rbs

module Multiwoven::Integrations::Core::RateLimiter
  def write: () -> untyped
end


# sig/multiwoven/integrations/core/utils.rbs

module Multiwoven::Integrations::Core::Utils
  def build_catalog: () -> untyped
  def build_stream: () -> untyped
  def convert_to_json_schema: () -> untyped
  def create_log_message: () -> untyped
  def extract_data: () -> untyped
  def handle_exception: () -> untyped
  def hash_to_string: () -> untyped
  def keys_to_symbols: () -> untyped
  def log_request_response: () -> untyped
  def logger: () -> untyped
  def map_type_to_json_schema: () -> untyped
  def report_exception: () -> untyped
  def success?: () -> untyped
end


# sig/multiwoven/integrations/destination/airtable/schema_helper.rbs

module Multiwoven::Integrations::Destination::Airtable::SchemaHelper
  def adjust_array_with_any: () -> untyped
  def adjust_complex_type: () -> untyped
  def build_schema: () -> untyped
  def clean_name: () -> untyped
  def deep_copy: () -> untyped
  def determine_schema: () -> untyped
  def get_json_schema: () -> untyped
  def process_field: () -> untyped
  def simple_type_schema: () -> untyped
end


# sig/multiwoven/integrations/destination/salesforce_consumer_goods_cloud/schema_helper.rbs

module Multiwoven::Integrations::Destination::SalesforceConsumerGoodsCloud::SchemaHelper
  def create_json_schema_for_object: () -> untyped
  def salesforce_field_to_json_schema_type: () -> untyped
end


# sig/multiwoven/integrations/source/salesforce_consumer_goods_cloud/schema_helper.rbs

module Multiwoven::Integrations::Source::SalesforceConsumerGoodsCloud::SchemaHelper
  def create_json_schema_for_object: () -> untyped
  def salesforce_field_to_json_schema_type: () -> untyped
end