func()

in tools/mc2bq/pkg/export/v1.go [47:58]

• 12 lines of code
• 1 McCabe index (conditional complexity)

func (mc *MCv1) GroupSource(ctx context.Context, pal mcutil.ProjectAndLocation) mcutil.ObjectSource {
	it := mc.client.ListGroups(ctx, &migrationcenterpb.ListGroupsRequest{
		Parent:   pal.String(),
		PageSize: 1000,
	})
	r := newObjectReader[*migrationcenterpb.Group](it, "group", mc.schema.GroupTable)
	src := newMigrationCenterLoadSource(r)
	return &struct {
		bigquery.LoadSource
		*objectReader[*migrationcenterpb.Group]
	}{src, r}
}