proxy

type ArchiveEvent struct {
	EthSendBundle   *ArchiveEventEthSendBundle   `json:"eth_sendBundle,omitempty"`
	MevSendBundle   *ArchiveEventMevSendBundle   `json:"mev_sendBundle,omitempty"`
	EthCancelBundle *ArchiveEventEthCancelBundle `json:"eth_cancelBundle,omitempty"`
}

type ArchiveEventEthCancelBundle struct {
	Params   *rpctypes.EthCancelBundleArgs `json:"params"`
	Metadata *ArchiveEventMetadata         `json:"metadata"`
}

type ArchiveEventEthSendBundle struct {
	Params   *rpctypes.EthSendBundleArgs `json:"params"`
	Metadata *ArchiveEventMetadata       `json:"metadata"`
}

type ArchiveEventMetadata struct {
	// ReceivedAt is a unix millisecond timestamp
	ReceivedAt int64 `json:"receivedAt"`
}

type ArchiveEventMevSendBundle struct {
	Params   *rpctypes.MevSendBundleArgs `json:"params"`
	Metadata *ArchiveEventMetadata       `json:"metadata"`
}

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

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

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

type ConfighubBuilder struct {
	Name           string                             `json:"name"`
	IP             string                             `json:"ip"`
	DNSName        string                             `json:"dns_name"`
	OrderflowProxy ConfighubOrderflowProxyCredentials `json:"orderflow_proxy"`
	Instance       ConfighubInstanceData              `json:"instance"`
}

type ConfighubInstanceData struct {
	TLSCert string `json:"tls_cert"`
}

type ConfighubOrderflowProxyCredentials struct {
	TLSCert            string         `json:"tls_cert,omitempty"` // for backward compatibility
	EcdsaPubkeyAddress common.Address `json:"ecdsa_pubkey_address"`
}

type FlashbotsNewOrderEventsArgs struct {
	OrderEvents []ArchiveEvent `json:"orderEvents"`
}

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

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

type ReceiverProxy struct {
	ReceiverProxyConstantConfig

	ConfigHub *BuilderConfigHub

	OrderflowSigner *signature.Signer

	UserHandler   http.Handler
	SystemHandler http.Handler
	// contains filtered or unexported fields
}

type ReceiverProxyConfig struct {
	ReceiverProxyConstantConfig

	BuilderConfigHubEndpoint string
	ArchiveEndpoint          string
	ArchiveConnections       int
	BuilderReadyEndpoint     string

	// EthRPC should support eth_blockNumber API
	EthRPC string

	MaxRequestBodySizeBytes int64

	ConnectionsPerPeer int
	MaxUserRPS         int
	ArchiveWorkerCount int
}

type ReceiverProxyConstantConfig struct {
	Log *slog.Logger
	// Name is optional field and it used to distringuish multiple proxies when running in the same process in tests
	Name                   string
	FlashbotsSignerAddress common.Address
	LocalBuilderEndpoint   string
}

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

type SenderProxy struct {
	SenderProxyConstantConfig
	ConfigHub *BuilderConfigHub
	Handler   http.Handler

	PeerUpdateForce chan struct{}
	// contains filtered or unexported fields
}

type SenderProxyConfig struct {
	SenderProxyConstantConfig
	BuilderConfigHubEndpoint string
	MaxRequestBodySizeBytes  int64
	ConnectionsPerPeer       int
}

type SenderProxyConstantConfig struct {
	Log             *slog.Logger
	OrderflowSigner *signature.Signer
}

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

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