1// This file was generated by counterfeiter
2package fakes
3
4import (
5	"sync"
6
7	"github.com/cloudfoundry/bosh-utils/blobstore"
8	boshcrypto "github.com/cloudfoundry/bosh-utils/crypto"
9)
10
11type FakeDigestBlobstore struct {
12	GetStub        func(blobID string, digest boshcrypto.Digest) (fileName string, err error)
13	getMutex       sync.RWMutex
14	getArgsForCall []struct {
15		blobID string
16		digest boshcrypto.Digest
17	}
18	getReturns struct {
19		result1 string
20		result2 error
21	}
22	CleanUpStub        func(fileName string) (err error)
23	cleanUpMutex       sync.RWMutex
24	cleanUpArgsForCall []struct {
25		fileName string
26	}
27	cleanUpReturns struct {
28		result1 error
29	}
30	CreateStub        func(fileName string) (blobID string, digest boshcrypto.MultipleDigest, err error)
31	createMutex       sync.RWMutex
32	createArgsForCall []struct {
33		fileName string
34	}
35	createReturns struct {
36		result1 string
37		result2 boshcrypto.MultipleDigest
38		result3 error
39	}
40	ValidateStub        func() (err error)
41	validateMutex       sync.RWMutex
42	validateArgsForCall []struct{}
43	validateReturns     struct {
44		result1 error
45	}
46	DeleteStub        func(blobId string) (err error)
47	deleteMutex       sync.RWMutex
48	deleteArgsForCall []struct {
49		blobId string
50	}
51	deleteReturns struct {
52		result1 error
53	}
54	invocations      map[string][][]interface{}
55	invocationsMutex sync.RWMutex
56}
57
58func (fake *FakeDigestBlobstore) Get(blobID string, digest boshcrypto.Digest) (fileName string, err error) {
59	fake.getMutex.Lock()
60	fake.getArgsForCall = append(fake.getArgsForCall, struct {
61		blobID string
62		digest boshcrypto.Digest
63	}{blobID, digest})
64	fake.recordInvocation("Get", []interface{}{blobID, digest})
65	fake.getMutex.Unlock()
66	if fake.GetStub != nil {
67		return fake.GetStub(blobID, digest)
68	}
69	return fake.getReturns.result1, fake.getReturns.result2
70}
71
72func (fake *FakeDigestBlobstore) GetCallCount() int {
73	fake.getMutex.RLock()
74	defer fake.getMutex.RUnlock()
75	return len(fake.getArgsForCall)
76}
77
78func (fake *FakeDigestBlobstore) GetArgsForCall(i int) (string, boshcrypto.Digest) {
79	fake.getMutex.RLock()
80	defer fake.getMutex.RUnlock()
81	return fake.getArgsForCall[i].blobID, fake.getArgsForCall[i].digest
82}
83
84func (fake *FakeDigestBlobstore) GetReturns(result1 string, result2 error) {
85	fake.GetStub = nil
86	fake.getReturns = struct {
87		result1 string
88		result2 error
89	}{result1, result2}
90}
91
92func (fake *FakeDigestBlobstore) CleanUp(fileName string) (err error) {
93	fake.cleanUpMutex.Lock()
94	fake.cleanUpArgsForCall = append(fake.cleanUpArgsForCall, struct {
95		fileName string
96	}{fileName})
97	fake.recordInvocation("CleanUp", []interface{}{fileName})
98	fake.cleanUpMutex.Unlock()
99	if fake.CleanUpStub != nil {
100		return fake.CleanUpStub(fileName)
101	}
102	return fake.cleanUpReturns.result1
103}
104
105func (fake *FakeDigestBlobstore) CleanUpCallCount() int {
106	fake.cleanUpMutex.RLock()
107	defer fake.cleanUpMutex.RUnlock()
108	return len(fake.cleanUpArgsForCall)
109}
110
111func (fake *FakeDigestBlobstore) CleanUpArgsForCall(i int) string {
112	fake.cleanUpMutex.RLock()
113	defer fake.cleanUpMutex.RUnlock()
114	return fake.cleanUpArgsForCall[i].fileName
115}
116
117func (fake *FakeDigestBlobstore) CleanUpReturns(result1 error) {
118	fake.CleanUpStub = nil
119	fake.cleanUpReturns = struct {
120		result1 error
121	}{result1}
122}
123
124func (fake *FakeDigestBlobstore) Create(fileName string) (blobID string, digest boshcrypto.MultipleDigest, err error) {
125	fake.createMutex.Lock()
126	fake.createArgsForCall = append(fake.createArgsForCall, struct {
127		fileName string
128	}{fileName})
129	fake.recordInvocation("Create", []interface{}{fileName})
130	fake.createMutex.Unlock()
131	if fake.CreateStub != nil {
132		return fake.CreateStub(fileName)
133	}
134	return fake.createReturns.result1, fake.createReturns.result2, fake.createReturns.result3
135}
136
137func (fake *FakeDigestBlobstore) CreateCallCount() int {
138	fake.createMutex.RLock()
139	defer fake.createMutex.RUnlock()
140	return len(fake.createArgsForCall)
141}
142
143func (fake *FakeDigestBlobstore) CreateArgsForCall(i int) string {
144	fake.createMutex.RLock()
145	defer fake.createMutex.RUnlock()
146	return fake.createArgsForCall[i].fileName
147}
148
149func (fake *FakeDigestBlobstore) CreateReturns(result1 string, result2 boshcrypto.MultipleDigest, result3 error) {
150	fake.CreateStub = nil
151	fake.createReturns = struct {
152		result1 string
153		result2 boshcrypto.MultipleDigest
154		result3 error
155	}{result1, result2, result3}
156}
157
158func (fake *FakeDigestBlobstore) Validate() (err error) {
159	fake.validateMutex.Lock()
160	fake.validateArgsForCall = append(fake.validateArgsForCall, struct{}{})
161	fake.recordInvocation("Validate", []interface{}{})
162	fake.validateMutex.Unlock()
163	if fake.ValidateStub != nil {
164		return fake.ValidateStub()
165	}
166	return fake.validateReturns.result1
167}
168
169func (fake *FakeDigestBlobstore) ValidateCallCount() int {
170	fake.validateMutex.RLock()
171	defer fake.validateMutex.RUnlock()
172	return len(fake.validateArgsForCall)
173}
174
175func (fake *FakeDigestBlobstore) ValidateReturns(result1 error) {
176	fake.ValidateStub = nil
177	fake.validateReturns = struct {
178		result1 error
179	}{result1}
180}
181
182func (fake *FakeDigestBlobstore) Delete(blobId string) (err error) {
183	fake.deleteMutex.Lock()
184	fake.deleteArgsForCall = append(fake.deleteArgsForCall, struct {
185		blobId string
186	}{blobId})
187	fake.recordInvocation("Delete", []interface{}{blobId})
188	fake.deleteMutex.Unlock()
189	if fake.DeleteStub != nil {
190		return fake.DeleteStub(blobId)
191	}
192	return fake.deleteReturns.result1
193}
194
195func (fake *FakeDigestBlobstore) DeleteCallCount() int {
196	fake.deleteMutex.RLock()
197	defer fake.deleteMutex.RUnlock()
198	return len(fake.deleteArgsForCall)
199}
200
201func (fake *FakeDigestBlobstore) DeleteArgsForCall(i int) string {
202	fake.deleteMutex.RLock()
203	defer fake.deleteMutex.RUnlock()
204	return fake.deleteArgsForCall[i].blobId
205}
206
207func (fake *FakeDigestBlobstore) DeleteReturns(result1 error) {
208	fake.DeleteStub = nil
209	fake.deleteReturns = struct {
210		result1 error
211	}{result1}
212}
213
214func (fake *FakeDigestBlobstore) Invocations() map[string][][]interface{} {
215	fake.invocationsMutex.RLock()
216	defer fake.invocationsMutex.RUnlock()
217	fake.getMutex.RLock()
218	defer fake.getMutex.RUnlock()
219	fake.cleanUpMutex.RLock()
220	defer fake.cleanUpMutex.RUnlock()
221	fake.createMutex.RLock()
222	defer fake.createMutex.RUnlock()
223	fake.validateMutex.RLock()
224	defer fake.validateMutex.RUnlock()
225	fake.deleteMutex.RLock()
226	defer fake.deleteMutex.RUnlock()
227	return fake.invocations
228}
229
230func (fake *FakeDigestBlobstore) recordInvocation(key string, args []interface{}) {
231	fake.invocationsMutex.Lock()
232	defer fake.invocationsMutex.Unlock()
233	if fake.invocations == nil {
234		fake.invocations = map[string][][]interface{}{}
235	}
236	if fake.invocations[key] == nil {
237		fake.invocations[key] = [][]interface{}{}
238	}
239	fake.invocations[key] = append(fake.invocations[key], args)
240}
241
242var _ blobstore.DigestBlobstore = new(FakeDigestBlobstore)
243