forked from Silverfish/proton-bridge
Other: Configure attachment pool size in vault
This commit is contained in:
@ -136,6 +136,7 @@ func New( //nolint:funlen
|
|||||||
liteapi.WithAppVersion(constants.AppVersion(curVersion.Original())),
|
liteapi.WithAppVersion(constants.AppVersion(curVersion.Original())),
|
||||||
liteapi.WithCookieJar(cookieJar),
|
liteapi.WithCookieJar(cookieJar),
|
||||||
liteapi.WithTransport(roundTripper),
|
liteapi.WithTransport(roundTripper),
|
||||||
|
liteapi.WithAttPoolSize(vault.SyncAttPool()),
|
||||||
liteapi.WithLogger(logrus.StandardLogger()),
|
liteapi.WithLogger(logrus.StandardLogger()),
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|||||||
@ -211,3 +211,8 @@ func (vault *Vault) SyncWorkers() int {
|
|||||||
func (vault *Vault) SyncBuffer() int {
|
func (vault *Vault) SyncBuffer() int {
|
||||||
return vault.get().Settings.SyncBuffer
|
return vault.get().Settings.SyncBuffer
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// SyncAttPool returns the size of the attachment pool.
|
||||||
|
func (vault *Vault) SyncAttPool() int {
|
||||||
|
return vault.get().Settings.SyncAttPool
|
||||||
|
}
|
||||||
|
|||||||
@ -224,4 +224,5 @@ func TestVault_Settings_SyncWorkers(t *testing.T) {
|
|||||||
|
|
||||||
require.Equal(t, runtime.NumCPU(), s.SyncWorkers())
|
require.Equal(t, runtime.NumCPU(), s.SyncWorkers())
|
||||||
require.Equal(t, runtime.NumCPU(), s.SyncBuffer())
|
require.Equal(t, runtime.NumCPU(), s.SyncBuffer())
|
||||||
|
require.Equal(t, runtime.NumCPU(), s.SyncAttPool())
|
||||||
}
|
}
|
||||||
|
|||||||
@ -47,6 +47,7 @@ type Settings struct {
|
|||||||
|
|
||||||
SyncWorkers int
|
SyncWorkers int
|
||||||
SyncBuffer int
|
SyncBuffer int
|
||||||
|
SyncAttPool int
|
||||||
}
|
}
|
||||||
|
|
||||||
func newDefaultSettings(gluonDir string) Settings {
|
func newDefaultSettings(gluonDir string) Settings {
|
||||||
@ -73,5 +74,6 @@ func newDefaultSettings(gluonDir string) Settings {
|
|||||||
|
|
||||||
SyncWorkers: runtime.NumCPU(),
|
SyncWorkers: runtime.NumCPU(),
|
||||||
SyncBuffer: runtime.NumCPU(),
|
SyncBuffer: runtime.NumCPU(),
|
||||||
|
SyncAttPool: runtime.NumCPU(),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user