sidecar

type Config struct {
	Committer *connection.ClientConfig `mapstructure:"committer"`
	Orderer   ordererdial.Config       `mapstructure:"orderer" default:"suspicion-grace-period-per-block=1s"`
	Ledger    LedgerConfig             `mapstructure:"ledger"`
	// LastCommittedBlockSetInterval is the interval at which the sidecar updates
	// the coordinator with the last committed block.
	LastCommittedBlockSetInterval time.Duration `mapstructure:"last-committed-block-set-interval" default:"5s" validate:"gt=0"` //nolint:lll,revive
	WaitingTxsLimit               int           `mapstructure:"waiting-txs-limit" default:"100000" validate:"gt=0"`
	// CheckpointHoldRetryInterval is the wait before fetching a held checkpoint block again.
	// The pause gives the snapshot hasher time to finish computing the local hash.
	CheckpointHoldRetryInterval time.Duration `mapstructure:"checkpoint-hold-retry-interval" default:"1m" validate:"gt=0"` //nolint:lll,revive
	// ChannelBufferSize is the buffer size that will be used to queue blocks, requests, and statuses.
	ChannelBufferSize int                       `mapstructure:"channel-buffer-size" default:"100" validate:"gt=0"`
	Notification      NotificationServiceConfig `mapstructure:"notification"`
	TxParsing         TxParsingConfig           `mapstructure:",squash"`
}

type LedgerConfig struct {
	Path string `mapstructure:"path" default:"./ledger/"`
	// SyncInterval controls how often the block store fsyncs to durable storage.
	// A value of N means every Nth block triggers a full sync; intermediate
	// blocks are written without fsync. A value of 0 or 1 means every block is synced.
	SyncInterval uint64 `mapstructure:"sync-interval"`
}

type NotificationServiceConfig struct {
	// MaxTimeout is an upper limit on the request's timeout to prevent resource exhaustion.
	// If a request doesn't specify a timeout, this value will be used.
	MaxTimeout time.Duration `mapstructure:"max-timeout" default:"1m" validate:"gt=0"`
	// MaxActiveTxIDs is the global limit on total active txID subscriptions across all streams.
	MaxActiveTxIDs int `mapstructure:"max-active-tx-ids" default:"100000" validate:"gt=0"`
	// MaxTxIDsPerRequest is the maximum number of txIDs allowed in a single notification request.
	MaxTxIDsPerRequest int `mapstructure:"max-tx-ids-per-request" default:"1000" validate:"gt=0"`
	// StreamWriteTimeout is the timeout for writing notifications to the stream.
	// If a client cannot consume notifications within this timeout, it will be disconnected.
	StreamWriteTimeout time.Duration `mapstructure:"stream-write-timeout" default:"30s" validate:"gt=0"`
}

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

type TxParsingConfig struct {
	// MaxWorkers is the most goroutines one block's parsing is split across. Parsing is CPU
	// bound, so more workers than the cores left over by the sidecar's other stages cannot help.
	MaxWorkers int `mapstructure:"max-workers-for-tx-parsing" default:"1" validate:"gt=0"`
	// MinBatchSize is the smallest share of a block worth giving a goroutine of its own; below
	// it, handing the share over costs more than parsing it in place.
	MinBatchSize int `mapstructure:"min-tx-parsing-batch-size" default:"256" validate:"gt=0"`
}