in origin/blobserver/server.go [79:116]
func New(
config Config,
stats tally.Scope,
clk clock.Clock,
addr string,
hashRing hashring.Ring,
cas *store.CAStore,
clientProvider blobclient.Provider,
clusterProvider blobclient.ClusterProvider,
pctx core.PeerContext,
backends *backend.Manager,
blobRefresher *blobrefresh.Refresher,
metaInfoGenerator *metainfogen.Generator,
writeBackManager persistedretry.Manager) (*Server, error) {
config = config.applyDefaults()
stats = stats.Tagged(map[string]string{
"module": "blobserver",
})
return &Server{
config: config,
stats: stats,
clk: clk,
addr: addr,
hashRing: hashRing,
cas: cas,
clientProvider: clientProvider,
clusterProvider: clusterProvider,
backends: backends,
blobRefresher: blobRefresher,
metaInfoGenerator: metaInfoGenerator,
uploader: newUploader(cas),
writeBackManager: writeBackManager,
pctx: pctx,
}, nil
}