Processor (archive_lib.Archive

module Archive_rpc = Rpc

val applied_str : string

val failed_str : string

module Public_key : sig ... end

module Token_owners : sig ... end

module Token : sig ... end

module Voting_for : sig ... end

module Token_symbols : sig ... end

module Account_identifiers : sig ... end

module Zkapp_state_data : sig ... end

module Zkapp_state_data_array : sig ... end

module Zkapp_states_nullable : sig ... end

module Zkapp_states : sig ... end

module Zkapp_sequence_states : sig ... end

module Zkapp_verification_keys : sig ... end

module Zkapp_permissions : sig ... end

module Zkapp_timing_info : sig ... end

module Zkapp_uri : sig ... end

module Zkapp_updates : sig ... end

module Zkapp_balance_bounds : sig ... end

module Zkapp_nonce_bounds : sig ... end

module Zkapp_account_precondition_values : sig ... end

module Zkapp_account_precondition : sig ... end

module Zkapp_token_id_bounds : sig ... end

module Zkapp_timestamp_bounds : sig ... end

module Zkapp_length_bounds : sig ... end

module Zkapp_amount_bounds : sig ... end

module Zkapp_global_slot_bounds : sig ... end

module Timing_info : sig ... end

module Snarked_ledger_hash : sig ... end

module Zkapp_epoch_ledger : sig ... end

module Zkapp_epoch_data : sig ... end

module Zkapp_network_precondition : sig ... end

module Zkapp_events : sig ... end

module Zkapp_account_update_body : sig ... end

module Zkapp_account_update : sig ... end

module Zkapp_fee_payer_body : sig ... end

module Epoch_data : sig ... end

module User_command : sig ... end

module Internal_command : sig ... end

module Fee_transfer : sig ... end

module Coinbase : sig ... end

module Block_and_internal_command : sig ... end

module Block_and_signed_command : sig ... end

module Zkapp_account_update_failures : sig ... end

module Block_and_zkapp_command : sig ... end

module Zkapp_account : sig ... end

module Accounts_accessed : sig ... end

module Accounts_created : sig ... end

module Block : sig ... end

val retry : 
  f:
    ( unit ->
      ( 'a, [< Caqti_error.t ] as 'b ) Core._result Async_kernel__Deferred.t ) ->
  logger:Logger.t ->
  error_str:string ->
  Core_kernel__Int.t ->
  ( 'c, 'd ) Core._result Async_kernel__Deferred.t

val add_block_aux : 
  ?retries:Core_kernel__Int.t ->
  logger:Logger.t ->
  pool:
    ( (module Caqti_async.CONNECTION),
      [< Caqti_error.t Decode_rejected Encode_failed Encode_rejected Request_failed Request_rejected Response_failed Response_rejected ] as 'a )
      Caqti_async.Pool.t ->
  add_block:
    ( (module Caqti_async.CONNECTION) ->
      'b ->
      ( int, 'c ) Async_kernel__Deferred_result.t ) ->
  hash:( 'd -> Mina_base.State_hash.t ) ->
  delete_older_than:int option ->
  accounts_accessed:(int * Mina_base.Account.t) list ->
  accounts_created:(Mina_base.Account_id.t * Currency.Fee.Stable.Latest.t) list ->
  tokens_used:
    (Mina_base.Token_id.Table.key * Mina_base.Account_id.t option) list ->
  'e ->
  ( unit, 'f ) Core._result Async_kernel__Deferred.t

val add_block_aux_precomputed : 
  constraint_constants:Genesis_constants.Constraint_constants.t ->
  logger:Logger.t ->
  ?retries:Core_kernel__Int.t ->
  pool:
    ( (module Caqti_async.CONNECTION),
      [< Caqti_error.t Decode_rejected Encode_failed Encode_rejected Request_failed Request_rejected Response_failed Response_rejected ] as 'a )
      Caqti_async.Pool.t ->
  delete_older_than:int option ->
  Mina_block.Precomputed.t ->
  ( unit, 'a ) Core._result Async_kernel__Deferred.t

val add_block_aux_extensional : 
  logger:Logger.t ->
  ?retries:Core_kernel__Int.t ->
  pool:
    ( (module Caqti_async.CONNECTION),
      [< Caqti_error.t Decode_rejected Encode_failed Encode_rejected Request_failed Request_rejected Response_failed Response_rejected ] as 'a )
      Caqti_async.Pool.t ->
  delete_older_than:int option ->
  Extensional.Block.t ->
  ( unit, 'a ) Core._result Async_kernel__Deferred.t

val run : 
  ( (module Caqti_async.CONNECTION),
    [< Caqti_error.t Decode_rejected Encode_failed Encode_rejected Request_failed Request_rejected Response_failed Response_rejected ] )
    Caqti_async.Pool.t ->
  Diff.t Pipe_lib.Strict_pipe.Reader.t ->
  constraint_constants:Genesis_constants.Constraint_constants.t ->
  logger:Logger.t ->
  delete_older_than:int option ->
  unit Async.Deferred.t

val add_genesis_accounts : 
  logger:Logger.t ->
  runtime_config_opt:Runtime_config.t option ->
  ( (module Caqti_async.CONNECTION),
    [< Caqti_error.t Decode_rejected Encode_failed Encode_rejected Request_failed Request_rejected Response_failed Response_rejected ] )
    Caqti_async.Pool.t ->
  unit Async.Deferred.t

val create_metrics_server : 
  logger:Logger.t ->
  metrics_server_port:int option ->
  missing_blocks_width:int option ->
  ( (module Caqti_async.CONNECTION),
    [< Caqti_error.t Decode_rejected Encode_failed Encode_rejected Request_failed Request_rejected Response_failed Response_rejected ] )
    Caqti_async.Pool.t ->
  unit Async_kernel__Deferred.t

val setup_server : 
  metrics_server_port:int option ->
  constraint_constants:Genesis_constants.Constraint_constants.t ->
  logger:Logger.t ->
  postgres_address:Uri.t ->
  server_port:int ->
  delete_older_than:int option ->
  runtime_config_opt:Runtime_config.t option ->
  missing_blocks_width:int option ->
  unit Async.Deferred.t

module For_test : sig ... end