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