rename channels_handler file
This commit is contained in:
parent
e0465585ce
commit
1a6b867956
@ -180,7 +180,6 @@ func populateCollections(
|
|||||||
|
|
||||||
// ictx = clues.Add(ictx, "previous_path", prevPath)
|
// ictx = clues.Add(ictx, "previous_path", prevPath)
|
||||||
// TODO: the handler should provide this implementation.
|
// TODO: the handler should provide this implementation.
|
||||||
// TODO: if we doing this messages are items for us.
|
|
||||||
items, err := collectItems(
|
items, err := collectItems(
|
||||||
ctx,
|
ctx,
|
||||||
bh.NewMessagePager(qp.ProtectedResource.ID(), ptr.Val(c.GetId())))
|
bh.NewMessagePager(qp.ProtectedResource.ID(), ptr.Val(c.GetId())))
|
||||||
|
|||||||
@ -92,16 +92,9 @@ func ProduceBackupCollections(
|
|||||||
}
|
}
|
||||||
|
|
||||||
case path.ChannelMessagesCategory:
|
case path.ChannelMessagesCategory:
|
||||||
mbpc := inject.BackupProducerConfig{
|
|
||||||
LastBackupVersion: bpc.LastBackupVersion,
|
|
||||||
Options: bpc.Options,
|
|
||||||
ProtectedResource: bpc.ProtectedResource,
|
|
||||||
Selector: bpc.Selector,
|
|
||||||
}
|
|
||||||
|
|
||||||
dbcs, err = groups.CreateCollections(
|
dbcs, err = groups.CreateCollections(
|
||||||
ctx,
|
ctx,
|
||||||
mbpc,
|
bpc,
|
||||||
groups.NewGroupBackupHandler(bpc.ProtectedResource.ID(), ac.Channels(), scope),
|
groups.NewGroupBackupHandler(bpc.ProtectedResource.ID(), ac.Channels(), scope),
|
||||||
creds.AzureTenantID,
|
creds.AzureTenantID,
|
||||||
scope,
|
scope,
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user