api

func ChorusHandlers(
	credsSvc objstore.CredsService,
	proxyClient rpc.Proxy,
	agentClient *rpc.AgentClient,
	appInfo *dom.AppInfo,
) pb.ChorusServer

func DiffHandlers(
	credsSvc objstore.CredsService,
	queueSvc tasks.QueueService,
	checkSvc *handler.ConsistencyCheckSvc,
) pb.DiffServer

func ErrorInterceptor() grpc.UnaryServerInterceptor

func ErrorStreamInterceptor() grpc.StreamServerInterceptor

func GRPCGateway(ctx context.Context, conf *Config, register RegisterHandlersFunc) (start func(context.Context) error, stop func(context.Context) error, err error)

func NewGrpcServer(port int, register RegisterServicesFunc, tracer otel_trace.TracerProvider, logConf *log.Config, version dom.AppInfo) (start func(context.Context) error, stop func(context.Context) error, err error)

func PolicyHandlers(
	credsSvc objstore.CredsService,
	clients objstore.Clients,
	queueSvc tasks.QueueService,
	policySvc policy.Service,
	versionSvc meta.VersionService,
	objectListStateStore *store.MigrationObjectListStateStore,
	bucketListStateStore *store.MigrationBucketListStateStore,
	agentClient *rpc.AgentClient,
	notificationSvc *notifications.Service,
	replicationStatusLocker *store.ReplicationStatusLocker,
	userLocker *store.UserLocker,
) pb.PolicyServer