-
Notifications
You must be signed in to change notification settings - Fork 7
/
server.go
82 lines (69 loc) · 2.72 KB
/
server.go
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
// MIT License. Copyright (c) 2020 CQFN
// https://github.com/cqfn/degitx/blob/master/LICENSE
// Package objectpool contains server for gRPC ObjectPool service
package objectpool
import (
"cqfn.org/degitx/internal/logging"
"gitlab.com/gitlab-org/gitaly-proto/go/gitalypb"
"golang.org/x/net/context"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
)
type server struct {
log *logging.Logger
}
// NewServer creates new ObjectPoolServiceServer
func NewServer(log *logging.Logger) gitalypb.ObjectPoolServiceServer {
return &server{
log: log,
}
}
func (server *server) CreateObjectPool(
context.Context,
*gitalypb.CreateObjectPoolRequest,
) (*gitalypb.CreateObjectPoolResponse, error) {
server.log.Info("CreateObjectPool RPC was called")
return nil, status.Errorf(codes.Unimplemented, "method CreateObjectPool not implemented")
}
func (server *server) DeleteObjectPool(
context.Context,
*gitalypb.DeleteObjectPoolRequest,
) (*gitalypb.DeleteObjectPoolResponse, error) {
server.log.Info("DeleteObjectPool RPC was called")
return nil, status.Errorf(codes.Unimplemented, "method DeleteObjectPool not implemented")
}
func (server *server) LinkRepositoryToObjectPool(
context.Context,
*gitalypb.LinkRepositoryToObjectPoolRequest,
) (*gitalypb.LinkRepositoryToObjectPoolResponse, error) {
server.log.Info("LinkRepositoryToObjectPool RPC was called")
return nil, status.Errorf(codes.Unimplemented, "method LinkRepositoryToObjectPool not implemented")
}
func (server *server) UnlinkRepositoryFromObjectPool(
context.Context,
*gitalypb.UnlinkRepositoryFromObjectPoolRequest,
) (*gitalypb.UnlinkRepositoryFromObjectPoolResponse, error) {
server.log.Info("UnlinkRepositoryFromObjectPool RPC was called")
return nil, status.Errorf(codes.Unimplemented, "method UnlinkRepositoryFromObjectPool not implemented")
}
func (server *server) ReduplicateRepository(
context.Context,
*gitalypb.ReduplicateRepositoryRequest,
) (*gitalypb.ReduplicateRepositoryResponse, error) {
server.log.Info("ReduplicateRepository RPC was called")
return nil, status.Errorf(codes.Unimplemented, "method ReduplicateRepository not implemented")
}
func (server *server) DisconnectGitAlternates(
context.Context,
*gitalypb.DisconnectGitAlternatesRequest,
) (*gitalypb.DisconnectGitAlternatesResponse, error) {
server.log.Info("DisconnectGitAlternates RPC was called")
return nil, status.Errorf(codes.Unimplemented, "method DisconnectGitAlternates not implemented")
}
func (server *server) FetchIntoObjectPool(
context.Context,
*gitalypb.FetchIntoObjectPoolRequest,
) (*gitalypb.FetchIntoObjectPoolResponse, error) {
server.log.Info("FetchIntoObjectPool RPC was called")
return nil, status.Errorf(codes.Unimplemented, "method FetchIntoObjectPool not implemented")
}