/
pbm.go
77 lines (71 loc) · 2.13 KB
/
pbm.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
package fake
import (
"context"
"github.com/percona/percona-backup-mongodb/pbm"
pbmLog "github.com/percona/percona-backup-mongodb/pbm/log"
"github.com/percona/percona-backup-mongodb/pbm/storage"
"go.mongodb.org/mongo-driver/bson/primitive"
"go.mongodb.org/mongo-driver/mongo"
"sigs.k8s.io/controller-runtime/pkg/client"
api "github.com/percona/percona-server-mongodb-operator/pkg/apis/psmdb/v1"
"github.com/percona/percona-server-mongodb-operator/pkg/psmdb/backup"
)
type fakePBM struct {
}
func NewPBM(_ context.Context, _ client.Client, _ *api.PerconaServerMongoDB) (backup.PBM, error) {
return new(fakePBM), nil
}
func (p *fakePBM) Conn() *mongo.Client {
return nil
}
func (p *fakePBM) GetPITRChunkContains(ctx context.Context, unixTS int64) (*pbm.OplogChunk, error) {
return nil, nil
}
func (p *fakePBM) GetLatestTimelinePITR() (pbm.Timeline, error) {
return pbm.Timeline{}, nil
}
func (p *fakePBM) PITRGetChunksSlice(rs string, from, to primitive.Timestamp) ([]pbm.OplogChunk, error) {
return nil, nil
}
func (p *fakePBM) Logger() *pbmLog.Logger {
return nil
}
func (p *fakePBM) GetStorage(l *pbmLog.Event) (storage.Storage, error) {
return nil, nil
}
func (p *fakePBM) ResyncStorage(l *pbmLog.Event) error {
return nil
}
func (p *fakePBM) SendCmd(cmd pbm.Cmd) error {
return nil
}
func (p *fakePBM) Close(ctx context.Context) error {
return nil
}
func (p *fakePBM) HasLocks(predicates ...backup.LockHeaderPredicate) (bool, error) {
return false, nil
}
func (p *fakePBM) GetRestoreMeta(name string) (*pbm.RestoreMeta, error) {
return nil, nil
}
func (p *fakePBM) GetBackupMeta(name string) (*pbm.BackupMeta, error) {
return nil, nil
}
func (p *fakePBM) DeleteBackup(name string, l *pbmLog.Event) error {
return nil
}
func (p *fakePBM) SetConfig(ctx context.Context, k8sclient client.Client, cluster *api.PerconaServerMongoDB, stg api.BackupStorageSpec) error {
return nil
}
func (p *fakePBM) SetConfigVar(key, val string) error {
return nil
}
func (p *fakePBM) GetConfigVar(key string) (any, error) {
return nil, nil
}
func (p *fakePBM) DeleteConfigVar(key string) error {
return nil
}
func (p *fakePBM) Node() (string, error) {
return "", nil
}