metadata: add image delete events during garbage collection
Signed-off-by: Derek McGowan <derek@mcg.dev>
This commit is contained in:
		@@ -325,6 +325,8 @@ func (m *DB) publishEvents(events []namespacedEvent) {
 | 
				
			|||||||
			ctx := namespaces.WithNamespace(ctx, ne.namespace)
 | 
								ctx := namespaces.WithNamespace(ctx, ne.namespace)
 | 
				
			||||||
			var topic string
 | 
								var topic string
 | 
				
			||||||
			switch ne.event.(type) {
 | 
								switch ne.event.(type) {
 | 
				
			||||||
 | 
								case *eventstypes.ImageDelete:
 | 
				
			||||||
 | 
									topic = "/images/delete"
 | 
				
			||||||
			case *eventstypes.SnapshotRemove:
 | 
								case *eventstypes.SnapshotRemove:
 | 
				
			||||||
				topic = "/snapshot/remove"
 | 
									topic = "/snapshot/remove"
 | 
				
			||||||
			default:
 | 
								default:
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -711,7 +711,9 @@ func (c *gcContext) remove(ctx context.Context, tx *bolt.Tx, node gc.Node) (inte
 | 
				
			|||||||
	case ResourceImage:
 | 
						case ResourceImage:
 | 
				
			||||||
		ibkt := nsbkt.Bucket(bucketKeyObjectImages)
 | 
							ibkt := nsbkt.Bucket(bucketKeyObjectImages)
 | 
				
			||||||
		if ibkt != nil {
 | 
							if ibkt != nil {
 | 
				
			||||||
			return nil, ibkt.DeleteBucket([]byte(node.Key))
 | 
								return &eventstypes.ImageDelete{
 | 
				
			||||||
 | 
									Name: node.Key,
 | 
				
			||||||
 | 
								}, ibkt.DeleteBucket([]byte(node.Key))
 | 
				
			||||||
		}
 | 
							}
 | 
				
			||||||
	case ResourceLease:
 | 
						case ResourceLease:
 | 
				
			||||||
		lbkt := nsbkt.Bucket(bucketKeyObjectLeases)
 | 
							lbkt := nsbkt.Bucket(bucketKeyObjectLeases)
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user