1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
package info
import (
"context"
"errors"
"gitlab.com/gitlab-org/gitaly/internal/helper"
"gitlab.com/gitlab-org/gitaly/internal/praefect/config"
"gitlab.com/gitlab-org/gitaly/internal/praefect/datastore"
"gitlab.com/gitlab-org/gitaly/internal/praefect/nodes"
"gitlab.com/gitlab-org/gitaly/proto/go/gitalypb"
)
type GenerationStore interface {
GetOutdatedRepositories(ctx context.Context, virtualStorage string) (map[string]map[string]int, error)
}
// Server is a InfoService server
type Server struct {
gitalypb.UnimplementedPraefectInfoServiceServer
nodeMgr nodes.Manager
conf config.Config
gs GenerationStore
queue datastore.ReplicationEventQueue
}
// NewServer creates a new instance of a grpc InfoServiceServer
func NewServer(nodeMgr nodes.Manager, conf config.Config, queue datastore.ReplicationEventQueue, gs GenerationStore) gitalypb.PraefectInfoServiceServer {
return &Server{
nodeMgr: nodeMgr,
conf: conf,
gs: gs,
queue: queue,
}
}
func (s *Server) EnableWrites(ctx context.Context, req *gitalypb.EnableWritesRequest) (*gitalypb.EnableWritesResponse, error) {
if err := s.nodeMgr.EnableWrites(ctx, req.GetVirtualStorage()); err != nil {
if errors.Is(err, nodes.ErrVirtualStorageNotExist) {
return nil, helper.ErrInvalidArgument(err)
}
return nil, helper.ErrInternal(err)
}
return &gitalypb.EnableWritesResponse{}, nil
}
|
