server

type Config struct {
	// LocalPort is the local port the main grpc server listens to.
	LocalPort int

	// LocalMetricsPort is the local port the metrics server listens to.
	LocalMetricsPort int

	// LocalProfilerPort is the local port the profile server listens to (when it is enabled).
	LocalProfilerPort int

	// PublicAddr is the public address clients make requests to.
	PublicAddr *net.TCPAddr

	// PublicName is the public facing name of the peer.
	PublicName string

	// OrgID is the organization ID of the peer, if one exists.
	OrgID ecid.ID

	// DataDir is the directory on the local machine where the state and output of all the
	// peer running on that machine are stored.
	DataDir string

	// DbDir is the local directory where this node's DB state is stored.
	DbDir string

	// BootstrapAddrs is a list of addresses for bootstrap peers.
	BootstrapAddrs []*net.TCPAddr

	// Routing defines parameters for the server's routing table.
	Routing *routing.Parameters

	// Introduce defines parameters for introductions the server performs.
	Introduce *introduce.Parameters

	// Search defines parameters for searches the server performs.
	Search *search.Parameters

	// Store defines parameters for stores the server performs.
	Store *store.Parameters

	// Replicate defines parameters for replications the server performs.
	Replicate *replicate.Parameters

	// SubscribeTo defines parameters for subscriptions to other peers.
	SubscribeTo *subscribe.ToParameters

	// SubscribeFrom defines parameters for subscriptions to other peers.
	SubscribeFrom *subscribe.FromParameters

	// ReportMetrics determines whether the server reports Prometheus metrics.
	ReportMetrics bool

	// Profile determines whether the profiler endpoint (/debug/pprof) is enabled.
	Profile bool

	// LogLevel is the log level
	LogLevel zapcore.Level
}

type Librarian struct {

	// RecentPubs is an LRU cache of recent publications librarian has received
	RecentPubs subscribe.RecentPublications
	// contains filtered or unexported fields
}

type RequestVerifier interface {
	Verify(ctx context.Context, msg proto.Message, meta *api.RequestMetadata) error
}